xuxiuxi

2017-05-11 109ffe9a777658936a38d0c146579a67c60a0d17

 RtspFace/PL_RTSPServer.cpp

@@ -1,4 +1,6 @@
#include "PL_RTSPServer.h"

#include "MaterialBuffer.h"

#include "logger.h"



#include <liveMedia.hh>

#include <BasicUsageEnvironment.hh>

@@ -111,7 +113,7 @@
      *FrameBuffer = pBuffer;

      *FrameSize = newBufferSize;



      printf("send frame size=%u\n", in.buffSize);

      LOG_DEBUG << "send frame size=" << in.buffSize << std::endl;

   }

   

   virtual char ReleaseFrame()

@@ -123,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) << std::endl;

            return 0;

         }

      }

@@ -141,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) << std::endl;

            return;

         }

      }

@@ -195,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) << std::endl;

      return false;

   }



@@ -213,14 +215,23 @@
{

   RTSPServer_Internal* in = (RTSPServer_Internal*)internal;



   if (pm.buffer == nullptr || pm.buffSize <= 0)

   if (pm.buffer == nullptr)

      return false;

   

   if (in->buffSize > 0)

      printf("PL_RTSPServer::pay may lost data size=%u\n", in->buffSize);

   if (pm.type != PipeMaterial::PMT_FRAME)

   {

      LOG_ERROR << "PL_RTSPServer::pay only support PMT_FRAME" << std::endl;

      return false;

   }

   

   memcpy(in->buffer, pm.buffer, pm.buffSize);

   in->buffSize = pm.buffSize;

   if (in->buffSize > 0)

      LOG_WARN << "PL_RTSPServer::pay may lost data size=" << in->buffSize << std::endl;

	
   MB_Frame* frame = (MB_Frame*)pm.buffer;

   if (frame->buffer == nullptr)

      return false;

   memcpy(in->buffer, frame->buffer, frame->buffSize);

   in->buffSize = frame->buffSize;

   

   if (in->encoderStub == nullptr)

      return false;

@@ -233,6 +244,7 @@
{

   RTSPServer_Internal* in = (RTSPServer_Internal*)internal;



   pm.type = PipeMaterial::PMT_NONE;

   pm.buffer = nullptr;

   pm.buffSize = 0;

   pm.former = this;