C# 视频监控系列（8）：服务器端——预览和可被客户端连接

核心提示： HikVisionDlg.cpp 的StreamDirectReadCallback方法int __cdecl StreamDirectReadCallback(ULONG channelNum,void *DataBuf,DWORD Length,int frameType,void

HikVisionDlg.cpp 的StreamDirectReadCallback方法

int __cdecl StreamDirectReadCallback(ULONG channelNum,void *DataBuf,DWORD Length,int frameType,void *context)
{


　　　 int i,status=0;
　　　 CString ctip;
　　　 int nframetype =0;

　　　 // if cap images we need clean the queue here
//　　　 if (!bCapture)
//　　　　　　　 return 0;

　　　　 // no errors
　　　　 if(frameType > 0) {
　　　　　　　　 if(frameType == PktSysHeader){　　　　
　　　　　　　　　　　　 // store the file header　　　　　　　　　　　　
　　　　　　　　　　　　 memcpy(FileHeader[channelNum], DataBuf, Length);
　　　　　　　　　　　　 FileHeaderLen = Length;
　　　　　　　　　　　　 TRACE("channel %d get the file header !n",channelNum);
　　　　　　　　　　　
　　　　　　　　 }

　　　　　　　　 if(frameType == PktIFrames || frameType ==PktSubIFrames){
　　　　　　　　　　　　 status = 1;
　　　　　　　　 }
　　　　　　　　 else{
　　　　　　　　　　　　 status = 0;
　　　　　　　　 }
　　　　　　　　　　　
　　　　　　　　 if(frameType == PktMotionDetection){
//　　　　　　　　　　　　 m_VideoWin.DrawVect(channelNum, (char *)DataBuf, Length);
　　　　　　　　　　　　 return 0;
　　　　　　　　 }
　　　　　　　　 if(frameType == PktOrigImage){
　　　　　　　　　　　　 return 0;
　　　　　　　　 }


　　　　 }

　　　　 if(Length == 0){
　　　　　　　　 TRACE("no data ?n");
　　　　　　　　 return 0;
　　　　 }

//　　　　 if(frameType == PktIFrames){
//　　　　　　　　 int iii=1;
//　　　　 }

　　　 ULONG currentTime = timeGetTime();

　　　 gChannelTotalLength[channelNum] += Length;
　　　 gCurrentFileLen[channelNum] += Length;

　　　 if(currentTime > StartTime+1000){

　　　　　　　 CString str,str2;
　　　　　　　 str.Format("%d", (gChannelTotalLength[dcurrentwin] *8/(currentTime - StartTime)));
　　　　　　　 for(i=0;i<g_nChannelTotal;i++)
　　　　　　　　　　　 gChannelTotalLength[i] = 0;
　　　　　　　　 StartTime= currentTime;
　　　　　　　 CHKVisionDlg *pMain = (CHKVisionDlg *)AfxGetMainWnd();
　　　　　　　　 pMain->GetDlgItem(IDC_BPS)->SetWindowText((LPCTSTR)str);
　　　 }

//　　　 if (m_sframe && channelNum ==0)
//　　　 {
　//　　　　　　　　　 if((frameType == PktSFrames && nframetype ==4 )||(frameType == PktSysHeader))
//　　　　　　　　 {
//　　　　　　　　　　　 MP4_ServerWriteData(channelNum,(unsigned char *)DataBuf, Length,frameType,status);　　　
//　　　　　　　　 }
//　　　 }
　　　
//　　　 MP4_ServerWriteData(channelNum,(unsigned char *)DataBuf, Length,frameType,status);　　　
　　　
　　　 if(frameType ==PktAudioFrames)
　　　 {
　　　　　　　 _write(gFileHandleQcif[channelNum],DataBuf,Length);
　　　　　　　 MP4_ServerWriteDataEx(channelNum,(unsigned char *)DataBuf, Length,frameType,status,1);
　　　　　　　 _write(gFileHandle[channelNum], DataBuf, Length);
　　　　　　　 MP4_ServerWriteDataEx(channelNum,(unsigned char *)DataBuf, Length,frameType,status,0);
　　　　　　　
　　　 }else if (frameType ==PktSubIFrames || frameType ==PktSubPFrames || frameType == PktSubBBPFrames || frameType == PktSubSysHeader)
　　　 {
　　　　　　　
　　　　　　　 _write(gFileHandleQcif[channelNum],DataBuf,Length);
　　　　　　　 MP4_ServerWriteDataEx(channelNum,(unsigned char *)DataBuf, Length,frameType,status,1);　　　
　　　 }else
　　　 {
　　　　　　　 _write(gFileHandle[channelNum], DataBuf, Length);
　　　　　　　 MP4_ServerWriteDataEx(channelNum,(unsigned char *)DataBuf, Length,frameType,status,0);
　　　 }

　　　 return 0;
}