OutPacketBuffer::maxSize & MAX_PACKET_SIZE & maxRTCPPacketSize (live555)

重要结构体

OutPacketBuffer:RTP输出的Buffer
BufferedPacket :RTP输入的Buffer

OutPacketBuffer::maxSize

live555\liveMedia\include\MediaSink.hh
// A data structure that a sink may use for an output packet:
class OutPacketBuffer 
{
public:
    OutPacketBuffer(unsigned preferredPacketSize, 
                    unsigned maxPacketSize,
                    unsigned maxBufferSize = 0);

    // if "maxBufferSize" is >0, use it - instead of "maxSize" to compute the buffer size
    ~OutPacketBuffer();

    static unsigned maxSize;
    ...
}

OutPacketBuffer中的静态变量maxSize用于定义输出buffer的最大值,即OutPacketBuffer的最大值。
默认值为:

live555\liveMedia\MediaSink.cpp
unsigned OutPacketBuffer::maxSize = 60000; // by default

也可自己进行手动设置,使用方法:

// Increase the maximum size of video frames that we can 'proxy' without truncation.
// (Such frames are unreasonably large; the back-end servers should really not be sending frames this large!)
OutPacketBuffer::maxSize = (1024*1024); // bytes

 // Begin by setting up our usage environment:
  TaskScheduler* scheduler = BasicTaskScheduler::createNew();
  env = BasicUsageEnvironment::createNew(*scheduler);

RTP输出,判断是否超过上限:

live555\liveMedia\include\MultiFramedRTPSink.hh
class MultiFramedRTPSink: public RTPSink {
...
private:
  OutPacketBuffer* fOutBuf;
...
}

live555\liveMedia\MultiFramedRTPSink.cpp
void MultiFramedRTPSink::afterGettingFrame1(unsigned       frameSize, 
                                            unsigned       numTruncatedBytes,
                                            struct timeval presentationTime,
                                            unsigned       durationInMicroseconds) 
{
    if (fIsFirstPacket) 
    {
        // Record the fact that we're starting to play now:
        gettimeofday(&fNextSendTime, NULL);
    }

    fMostRecentPresentationTime = presentationTime;
    if (fInitialPresentationTime.tv_sec == 0 && fInitialPresentationTime.tv_usec == 0) 
    {
        fInitialPresentationTime = presentationTime;
    }    

    if (numTruncatedBytes > 0) 
    {
        unsigned const bufferSize = fOutBuf->totalBytesAvailable();

        envir() << "MultiFramedRTPSink::afterGettingFrame1(): The input frame data was too large for our buffer size ("
                << bufferSize << ").  "
                << numTruncatedBytes 
                << " bytes of trailing data was dropped!  Correct this by increasing \"OutPacketBuffer::maxSize\" to at least "
                << OutPacketBuffer::maxSize + numTruncatedBytes 
                << ", *before* creating this 'RTPSink'.  (Current value is "
                << OutPacketBuffer::maxSize 
                << ".)\n";
    }
...
}

MAX_PACKET_SIZE

MAX_PACKET_SIZE用于定义输入Buffer的上限值,即BufferedPacket的最大值.

live555\liveMedia\MultiFramedRTPSource.cpp
#define MAX_PACKET_SIZE 65536

BufferedPacket::BufferedPacket()
               : fPacketSize(MAX_PACKET_SIZE),
                 fBuf(new unsigned char[MAX_PACKET_SIZE]),
                 fNextPacket(NULL) 
{

}

在哪里判断输入数据的大小是否超过MAX_PACKET_SIZE呢?
void MultiFramedRTPSource::networkReadHandler1()

具体代码:

void MultiFramedRTPSource::networkReadHandler1() 
{
    BufferedPacket* bPacket = fPacketReadInProgress;
    if (bPacket == NULL) 
    {
        // Normal case: Get a free BufferedPacket descriptor to hold the new network packet:
        bPacket = fReorderingBuffer->getFreePacket(this);
    }

    // Read the network packet, and perform sanity checks on the RTP header:
    Boolean readSuccess = False;
    do 
    {
        struct sockaddr_in fromAddress;
        Boolean packetReadWasIncomplete = fPacketReadInProgress != NULL;
        if (!bPacket->fillInData(fRTPInterface, fromAddress, packetReadWasIncomplete)) 
        {
            if (bPacket->bytesAvailable() == 0) 
            {   // should not happen??
                envir() << "MultiFramedRTPSource internal error: Hit limit when reading incoming packet over TCP\n";
                NsLogNotifyA_Add_file(0, 0, 
                    "Live555: MultiFramedRTPSource internal error: Hit limit when reading incoming packet over TCP");
            }

            fPacketReadInProgress = NULL;

            break;
        }
        ...
    } while (0);
    if (!readSuccess) fReorderingBuffer->freePacket(bPacket);
    doGetNextFrame1();
    // If we didn't get proper data this time, we'll get another chance
}

maxRTCPPacketSize

用于定义RTCP数据包的最大值。

live555\liveMedia\RTCP.cpp
static unsigned const maxRTCPPacketSize = 2048;

在哪里判断RTCP数据包是否超过maxRTCPPacketSize呢?

live555\liveMedia\RTCP.cpp
void RTCPInstance::incomingReportHandler1() 
{
    do 
    {
        if (fNumBytesAlreadyRead >= maxRTCPPacketSize) 
        {
            envir() << "RTCPInstance error: Hit limit when reading incoming packet over TCP. Increase \"maxRTCPPacketSize:\""
                    << maxRTCPPacketSize    << "; fNumBytesAlreadyRead:"
                    << fNumBytesAlreadyRead << " >= maxRTCPPacketSize. \n";

            break;
        }
        ...
    } while (0);
}

问题1: Hit limit when reading incoming packet over TCP

长时间拉取拉取RTSP流,有时会报以下错误:

RTCPInstance error: 
Hit limit when reading incoming packet over TCP. 
Increase "maxRTCPPacketSize"

可考虑提高maxRTCPPacketSize的值,比如:

static unsigned const maxRTCPPacketSize = (512 * 1024);

References:

http://blog.csdn.net/uyuanuyuan/article/details/17919177
http://blog.csdn.net/commshare/article/details/18705339

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 213,558评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,002评论 3 387
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 159,036评论 0 349
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,024评论 1 285
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,144评论 6 385
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,255评论 1 292
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,295评论 3 412
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,068评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,478评论 1 305
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,789评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,965评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,649评论 4 336
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,267评论 3 318
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,982评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,223评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,800评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,847评论 2 351

推荐阅读更多精彩内容