houxiao
2016-12-29 633e76c1d533c3d9c257b92df7ebdfd36c9fd8a0
RtspFace/PL_RTSPServer.cpp
@@ -1,5 +1,6 @@
#include "PL_RTSPServer.h"
#include "MaterialBuffer.h"
#include "logger.h"
#include <liveMedia.hh>
#include <BasicUsageEnvironment.hh>
@@ -112,7 +113,7 @@
      *FrameBuffer = pBuffer;
      *FrameSize = newBufferSize;
      printf("send frame size=%u\n", in.buffSize);
      LOG(DEBUG) << "send frame size=" << in.buffSize;
   }
   
   virtual char ReleaseFrame()
@@ -124,7 +125,7 @@
         int ret = pthread_mutex_unlock(in.frame_mutex);
         if(ret != 0)
         {
            printf("pthread_mutex_unlock frame_mutex: %s/n", strerror(ret));
            LOG(WARN) << "pthread_mutex_unlock frame_mutex: " << strerror(ret);
            return 0;
         }
      }
@@ -142,7 +143,7 @@
         int ret = pthread_mutex_lock(in.frame_mutex);
         if(ret != 0)
         {
            printf("pthread_mutex_lock frame_mutex: %s/n", strerror(ret));
            LOG(WARN) << "pthread_mutex_lock frame_mutex: " << strerror(ret);
            return;
         }
      }
@@ -196,7 +197,7 @@
   int ret = pthread_create(&(in->live_daemon_thid), NULL, live_daemon_thd, in);
   if(ret != 0)
   {
      printf("pthread_create: %s/n", strerror(ret));
      LOG(ERROR) << "pthread_create: " << strerror(ret);
      return false;
   }
@@ -214,19 +215,21 @@
{
   RTSPServer_Internal* in = (RTSPServer_Internal*)internal;
   if (pm.buffer == nullptr || pm.buffSize <= 0)
   if (pm.buffer == nullptr)
      return false;
   
   if (pm.type != PipeMaterial::PMT_FRAME)
   {
      printf("PL_RTSPServer::pay only support PMT_FRAME\n");
      LOG(ERROR) << "PL_RTSPServer::pay only support PMT_FRAME";
      return false;
   }
   
   if (in->buffSize > 0)
      printf("PL_RTSPServer::pay may lost data size=%u\n", in->buffSize);
      LOG(WARN) << "PL_RTSPServer::pay may lost data size=" << in->buffSize;
   
   MB_Frame* frame = (MB_Frame*)pm.buffer;
   if (frame->buffer == nullptr)
      return false;
   memcpy(in->buffer, frame->buffer, frame->buffSize);
   in->buffSize = frame->buffSize;
   
@@ -241,6 +244,7 @@
{
   RTSPServer_Internal* in = (RTSPServer_Internal*)internal;
   pm.type = PipeMaterial::PMT_NONE;
   pm.buffer = nullptr;
   pm.buffSize = 0;
   pm.former = this;