public
Description: Darwin Streaming Server
Clone URL: git://github.com/lstoll/dss.git
Reverting all printf testing - it works, now can add custom statements
lstoll (author)
Mon Mar 31 01:59:51 -0700 2008
commit  4f7a709b7249c72fa5174a84407f7d361ff25b9f
tree    e0499939818dc125dd435a697f6fde624f246b90
parent  2cfa57faf7deac6ee6208f00812f271ed09745d3
...
613
614
615
616
 
617
618
619
620
 
621
622
623
624
625
 
626
627
628
...
631
632
633
634
 
635
636
637
...
655
656
657
658
 
659
660
661
...
686
687
688
689
 
690
691
692
...
894
895
896
897
 
898
899
900
...
961
962
963
964
 
965
966
967
...
1002
1003
1004
1005
 
1006
1007
1008
...
1078
1079
1080
1081
 
1082
1083
1084
...
1355
1356
1357
1358
 
1359
1360
1361
...
1588
1589
1590
1591
 
1592
1593
1594
...
1630
1631
1632
1633
 
1634
1635
1636
...
1659
1660
1661
1662
 
1663
1664
1665
...
1880
1881
1882
1883
 
1884
1885
1886
...
1923
1924
1925
1926
 
1927
1928
1929
...
2058
2059
2060
2061
 
2062
2063
2064
...
2082
2083
2084
2085
 
2086
2087
2088
...
2107
2108
2109
2110
 
2111
2112
2113
2114
2115
2116
2117
 
2118
2119
2120
2121
 
2122
2123
2124
...
2133
2134
2135
2136
 
2137
2138
2139
...
2149
2150
2151
2152
 
2153
2154
2155
2156
2157
2158
2159
 
2160
2161
2162
...
613
614
615
 
616
617
618
619
 
620
621
622
623
624
 
625
626
627
628
...
631
632
633
 
634
635
636
637
...
655
656
657
 
658
659
660
661
...
686
687
688
 
689
690
691
692
...
894
895
896
 
897
898
899
900
...
961
962
963
 
964
965
966
967
...
1002
1003
1004
 
1005
1006
1007
1008
...
1078
1079
1080
 
1081
1082
1083
1084
...
1355
1356
1357
 
1358
1359
1360
1361
...
1588
1589
1590
 
1591
1592
1593
1594
...
1630
1631
1632
 
1633
1634
1635
1636
...
1659
1660
1661
 
1662
1663
1664
1665
...
1880
1881
1882
 
1883
1884
1885
1886
...
1923
1924
1925
 
1926
1927
1928
1929
...
2058
2059
2060
 
2061
2062
2063
2064
...
2082
2083
2084
 
2085
2086
2087
2088
...
2107
2108
2109
 
2110
2111
2112
2113
2114
2115
2116
 
2117
2118
2119
2120
 
2121
2122
2123
2124
...
2133
2134
2135
 
2136
2137
2138
2139
...
2149
2150
2151
 
2152
2153
2154
2155
2156
2157
2158
 
2159
2160
2161
2162
0
@@ -613,16 +613,16 @@ QTSS_Error ProcessRTPData(QTSS_IncomingData_Params* inParams)
0
     if (!sBroadcastPushEnabled)
0
         return QTSS_NoErr;
0
         
0
- qtss_printf("QTSSReflectorModule:ProcessRTPData inRTSPSession=%lu inClientSession=%lu\n",inParams->inRTSPSession, inParams->inClientSession);
0
+ //qtss_printf("QTSSReflectorModule:ProcessRTPData inRTSPSession=%lu inClientSession=%lu\n",inParams->inRTSPSession, inParams->inClientSession);
0
     ReflectorSession* theSession = NULL;
0
     UInt32 theLen = sizeof(theSession);
0
     QTSS_Error theErr = QTSS_GetValue(inParams->inRTSPSession, sRTSPBroadcastSessionAttr, 0, &theSession, &theLen);
0
- qtss_printf("QTSSReflectorModule.cpp:ProcessRTPData sClientBroadcastSessionAttr=%lu theSession=%lu err=%ld \n",sClientBroadcastSessionAttr, theSession,theErr);
0
+ //qtss_printf("QTSSReflectorModule.cpp:ProcessRTPData sClientBroadcastSessionAttr=%lu theSession=%lu err=%ld \n",sClientBroadcastSessionAttr, theSession,theErr);
0
     if (theSession == NULL || theErr != QTSS_NoErr)
0
         return QTSS_NoErr;
0
     
0
     // it is a broadcaster session
0
- qtss_printf("QTSSReflectorModule.cpp:is broadcaster session\n");
0
+ //qtss_printf("QTSSReflectorModule.cpp:is broadcaster session\n");
0
 
0
     SourceInfo* theSoureInfo = theSession->GetSourceInfo();
0
     Assert(theSoureInfo != NULL);
0
@@ -631,7 +631,7 @@ QTSS_Error ProcessRTPData(QTSS_IncomingData_Params* inParams)
0
             
0
 
0
     UInt32 numStreams = theSession->GetNumStreams();
0
- qtss_printf("QTSSReflectorModule.cpp:ProcessRTPData numStreams=%lu\n",numStreams);
0
+ //qtss_printf("QTSSReflectorModule.cpp:ProcessRTPData numStreams=%lu\n",numStreams);
0
 
0
 {
0
 /*
0
@@ -655,7 +655,7 @@ QTSS_Error ProcessRTPData(QTSS_IncomingData_Params* inParams)
0
     char* rtpPacket = &packetData[4];
0
     
0
     //UInt32 packetLen = inParams->inPacketLen;
0
- qtss_printf("QTSSReflectorModule.cpp:ProcessRTPData channel=%u theSoureInfo=%lu packetLen=%lu packetDatalen=%u\n",(UInt16) packetChannel,theSoureInfo,inParams->inPacketLen,packetDataLen);
0
+ //qtss_printf("QTSSReflectorModule.cpp:ProcessRTPData channel=%u theSoureInfo=%lu packetLen=%lu packetDatalen=%u\n",(UInt16) packetChannel,theSoureInfo,inParams->inPacketLen,packetDataLen);
0
 
0
     if (1)
0
     {
0
@@ -686,7 +686,7 @@ QTSS_Error ProcessRTPData(QTSS_IncomingData_Params* inParams)
0
 QTSS_Error ProcessRTSPRequest(QTSS_StandardRTSP_Params* inParams)
0
 {
0
     QTSS_RTSPMethod* theMethod = NULL;
0
- qtss_printf("QTSSReflectorModule:ProcessRTSPRequest inClientSession=%lu\n", (UInt32) inParams->inClientSession);
0
+ //qtss_printf("QTSSReflectorModule:ProcessRTSPRequest inClientSession=%lu\n", (UInt32) inParams->inClientSession);
0
     UInt32 theLen = 0;
0
     if ((QTSS_GetValuePtr(inParams->inRTSPRequest, qtssRTSPReqMethod, 0,
0
             (void**)&theMethod, &theLen) != QTSS_NoErr) || (theLen != sizeof(QTSS_RTSPMethod)))
0
@@ -894,7 +894,7 @@ QTSS_Error DoAnnounce(QTSS_StandardRTSP_Params* inParams)
0
     
0
     //
0
     // Eventually, we should really require access control before we do this.
0
- qtss_printf("QTSSReflectorModule:DoAnnounce\n");
0
+ //qtss_printf("QTSSReflectorModule:DoAnnounce\n");
0
     //
0
     // Get the full path to this file
0
     char* theFullPathStr = NULL;
0
@@ -961,7 +961,7 @@ QTSS_Error DoAnnounce(QTSS_StandardRTSP_Params* inParams)
0
     theLen = sizeof(theRequestBody);
0
     theErr = QTSS_GetValue(inParams->inRTSPRequest, sRequestBodyAttr, 0, &theRequestBody, &theLen);
0
 
0
- qtss_printf("QTSSReflectorModule:DoAnnounce theRequestBody =%s\n",theRequestBody);
0
+ //qtss_printf("QTSSReflectorModule:DoAnnounce theRequestBody =%s\n",theRequestBody);
0
     if (theErr != QTSS_NoErr)
0
     {
0
         //
0
@@ -1002,7 +1002,7 @@ QTSS_Error DoAnnounce(QTSS_StandardRTSP_Params* inParams)
0
         // Update our offset in the buffer
0
         theBufferOffset += theLen;
0
         (void)QTSS_SetValue(inParams->inRTSPRequest, sBufferOffsetAttr, 0, &theBufferOffset, sizeof(theBufferOffset));
0
- qtss_printf("QTSSReflectorModule:DoAnnounce Request some more data \n");
0
+ //qtss_printf("QTSSReflectorModule:DoAnnounce Request some more data \n");
0
         //
0
         // The entire content body hasn't arrived yet. Request a read event and wait for it.
0
         // Our DoAnnounce function will get called again when there is more data.
0
@@ -1078,7 +1078,7 @@ QTSS_Error DoAnnounce(QTSS_StandardRTSP_Params* inParams)
0
     }
0
     
0
 
0
- qtss_printf("QTSSReflectorModule:DoAnnounce SendResponse OK=200\n");
0
+ //qtss_printf("QTSSReflectorModule:DoAnnounce SendResponse OK=200\n");
0
     
0
     return QTSS_SendStandardRTSPResponse(inParams->inRTSPRequest, inParams->inClientSession, 0);
0
 }
0
@@ -1355,7 +1355,7 @@ ReflectorSession* FindOrCreateSession(StrPtrLen* inPath, QTSS_StandardRTSP_Param
0
             return NULL;
0
         }
0
         
0
- qtss_printf("Created reflector session = %lu theInfo=%lu \n", (UInt32) theSession,(UInt32)theInfo);
0
+ //qtss_printf("Created reflector session = %lu theInfo=%lu \n", (UInt32) theSession,(UInt32)theInfo);
0
         //put the session's ID into the session map.
0
         theErr = sSessionMap->Register(theSession->GetRef());
0
         Assert(theErr == QTSS_NoErr);
0
@@ -1588,7 +1588,7 @@ QTSS_Error AddRTPStream(ReflectorSession* theSession,QTSS_StandardRTSP_Params* i
0
 QTSS_Error DoSetup(QTSS_StandardRTSP_Params* inParams)
0
 {
0
     ReflectorSession* theSession = NULL;
0
- qtss_printf("QTSSReflectorModule.cpp:DoSetup \n");
0
+ //qtss_printf("QTSSReflectorModule.cpp:DoSetup \n");
0
 
0
     // See if this is a push from a Broadcaster
0
     UInt32 theLen = 0;
0
@@ -1630,7 +1630,7 @@ QTSS_Error DoSetup(QTSS_StandardRTSP_Params* inParams)
0
             // This is an incoming data session. Set the Reflector Session in the ClientSession
0
             theErr = QTSS_SetValue(inParams->inClientSession, sClientBroadcastSessionAttr, 0, &theSession, sizeof(theSession));
0
             Assert(theErr == QTSS_NoErr);
0
- qtss_printf("QTSSReflectorModule.cpp:SETsession sClientBroadcastSessionAttr=%lu theSession=%lu err=%ld \n",(UInt32)sClientBroadcastSessionAttr, (UInt32) theSession,theErr);
0
+ //qtss_printf("QTSSReflectorModule.cpp:SETsession sClientBroadcastSessionAttr=%lu theSession=%lu err=%ld \n",(UInt32)sClientBroadcastSessionAttr, (UInt32) theSession,theErr);
0
             (void) QTSS_SetValue(inParams->inClientSession, qtssCliSesTimeoutMsec, 0, &sBroadcasterSessionTimeoutMilliSecs, sizeof(sBroadcasterSessionTimeoutMilliSecs));
0
        }
0
     }
0
@@ -1659,7 +1659,7 @@ QTSS_Error DoSetup(QTSS_StandardRTSP_Params* inParams)
0
     // RTP Stream.
0
     if (isPush)
0
     {
0
- qtss_printf("QTSSReflectorModule.cpp:DoSetup is push setup\n");
0
+ //qtss_printf("QTSSReflectorModule.cpp:DoSetup is push setup\n");
0
 
0
         // Get info about this trackID
0
         SourceInfo::StreamInfo* theStreamInfo = theSession->GetSourceInfo()->GetStreamInfoByTrackID(theTrackID);
0
@@ -1880,7 +1880,7 @@ QTSS_Error DoPlay(QTSS_StandardRTSP_Params* inParams, ReflectorSession* inSessio
0
             
0
             
0
     
0
- qtss_printf("QTSSReflectorModule:SET for att err=%ld id=%ld\n",theErr,inParams->inRTSPSession);
0
+ //qtss_printf("QTSSReflectorModule:SET for att err=%ld id=%ld\n",theErr,inParams->inRTSPSession);
0
             
0
         // this code needs to be cleaned up
0
         // Check and see if the full path to this file matches an existing ReflectorSession
0
@@ -1923,7 +1923,7 @@ QTSS_Error DoPlay(QTSS_StandardRTSP_Params* inParams, ReflectorSession* inSessio
0
         
0
     
0
         KeepSession(inParams->inRTSPRequest,true);
0
- qtss_printf("QTSSReflectorModule.cpp:DoPlay (PUSH) inRTSPSession=%lu inClientSession=%lu\n",(UInt32)inParams->inRTSPSession,(UInt32)inParams->inClientSession);
0
+ //qtss_printf("QTSSReflectorModule.cpp:DoPlay (PUSH) inRTSPSession=%lu inClientSession=%lu\n",(UInt32)inParams->inRTSPSession,(UInt32)inParams->inClientSession);
0
     }
0
     else// it is NOT a broadcaster session
0
     {
0
@@ -2058,7 +2058,7 @@ QTSS_Error DestroySession(QTSS_ClientSessionClosing_Params* inParams)
0
     
0
     UInt32 theLen = sizeof(theSession);
0
     QTSS_Error theErr = QTSS_GetValue(inParams->inClientSession, sClientBroadcastSessionAttr, 0, &theSession, &theLen);
0
- qtss_printf("QTSSReflectorModule.cpp:DestroySession sClientBroadcastSessionAttr=%lu theSession=%lu err=%ld \n",(UInt32)sClientBroadcastSessionAttr, (UInt32)theSession,theErr);
0
+ //qtss_printf("QTSSReflectorModule.cpp:DestroySession sClientBroadcastSessionAttr=%lu theSession=%lu err=%ld \n",(UInt32)sClientBroadcastSessionAttr, (UInt32)theSession,theErr);
0
     if (theSession != NULL) // it is a broadcaster session
0
     {
0
         ReflectorSession* deletedSession = NULL;
0
@@ -2082,7 +2082,7 @@ QTSS_Error DestroySession(QTSS_ClientSessionClosing_Params* inParams)
0
         (void) QTSS_GetValue(inParams->inClientSession, sKillClientsEnabledAttr, 0, &killClients, &theLen);
0
 
0
 
0
- qtss_printf("QTSSReflectorModule.cpp:DestroySession broadcaster theSession=%lu\n", (UInt32) theSession);
0
+ //qtss_printf("QTSSReflectorModule.cpp:DestroySession broadcaster theSession=%lu\n", (UInt32) theSession);
0
         theSession->RemoveSessionFromOutput(inParams->inClientSession);
0
         RemoveOutput(NULL, theSession, killClients);
0
     }
0
@@ -2107,18 +2107,18 @@ QTSS_Error DestroySession(QTSS_ClientSessionClosing_Params* inParams)
0
 
0
 void RemoveOutput(ReflectorOutput* inOutput, ReflectorSession* inSession, Bool16 killClients)
0
 {
0
- qtss_printf("QTSSReflectorModule.cpp:RemoveOutput\n");
0
+ //qtss_printf("QTSSReflectorModule.cpp:RemoveOutput\n");
0
     // This function removes the output from the ReflectorSession, then
0
     Assert(inSession);
0
     if (inSession != NULL)
0
     {
0
         if (inOutput != NULL)
0
         { inSession->RemoveOutput(inOutput,true);
0
- qtss_printf("QTSSReflectorModule.cpp:RemoveOutput it is a client session\n");
0
+ //qtss_printf("QTSSReflectorModule.cpp:RemoveOutput it is a client session\n");
0
         }
0
         else
0
         { // it is a Broadcaster session
0
- qtss_printf("QTSSReflectorModule.cpp:RemoveOutput it is a broadcaster session\n");
0
+ //qtss_printf("QTSSReflectorModule.cpp:RemoveOutput it is a broadcaster session\n");
0
             SourceInfo* theInfo = inSession->GetSourceInfo();
0
             Assert(theInfo);
0
             
0
@@ -2133,7 +2133,7 @@ void RemoveOutput(ReflectorOutput* inOutput, ReflectorSession* inSession, Bool16
0
             }
0
         }
0
     
0
- qtss_printf("QTSSReflectorModule.cpp:RemoveOutput refcount =%lu\n", inSession->GetRef()->GetRefCount() );
0
+ //qtss_printf("QTSSReflectorModule.cpp:RemoveOutput refcount =%lu\n", inSession->GetRef()->GetRefCount() );
0
 
0
         //check if the ReflectorSession should be deleted
0
         //(it should if its ref count has dropped to 0)
0
@@ -2149,14 +2149,14 @@ void RemoveOutput(ReflectorOutput* inOutput, ReflectorSession* inSession, Bool16
0
             }
0
             else if (theSessionRef->GetRefCount() == 1)
0
             {
0
- qtss_printf("QTSSReflector.cpp:RemoveOutput Delete SESSION=%lu\n",(UInt32)inSession);
0
+ //qtss_printf("QTSSReflector.cpp:RemoveOutput Delete SESSION=%lu\n",(UInt32)inSession);
0
                 sSessionMap->Release(theSessionRef);
0
                 sSessionMap->UnRegister(theSessionRef); // the last session so get rid of the ref
0
                 delete inSession;
0
             }
0
             else
0
             {
0
- qtss_printf("QTSSReflector.cpp:RemoveOutput Release SESSION=%lu\n",(UInt32)inSession);
0
+ //qtss_printf("QTSSReflector.cpp:RemoveOutput Release SESSION=%lu\n",(UInt32)inSession);
0
                 sSessionMap->Release(theSessionRef); // one of the sessions on the ref is ending just decrement the count
0
             }
0
                 
...
683
684
685
686
 
687
688
689
...
683
684
685
 
686
687
688
689
0
@@ -683,7 +683,7 @@ Bool16 RTPSessionOutput::PacketShouldBeThinned(QTSS_RTPStreamObject inStream, St
0
     if (*curQualityLevel > 0 && ((*lastChangeTime + 30000) < timeNow) ) // 30 seconds between reductions
0
     { *curQualityLevel -= 1; // reduce quality value. If we quality doesn't change then we may have hit some steady state which we can't get out of without thinning or increasing the quality
0
         *lastChangeTime =timeNow;
0
- qtss_printf("RTPSessionOutput set quality to %lu\n",*curQualityLevel);
0
+ //qtss_printf("RTPSessionOutput set quality to %lu\n",*curQualityLevel);
0
     }
0
 
0
     //Check to see if we need to drop to audio only
...
70
71
72
73
 
74
75
76
...
128
129
130
131
 
132
133
134
...
139
140
141
142
 
143
144
145
...
223
224
225
226
 
227
228
229
...
235
236
237
238
 
239
240
241
...
258
259
260
261
 
262
263
264
...
70
71
72
 
73
74
75
76
...
128
129
130
 
131
132
133
134
...
139
140
141
 
142
143
144
145
...
223
224
225
 
226
227
228
229
...
235
236
237
 
238
239
240
241
...
258
259
260
 
261
262
263
264
0
@@ -70,7 +70,7 @@ FileDeleter::FileDeleter(StrPtrLen* inSDPPath)
0
 
0
 FileDeleter::~FileDeleter()
0
 {
0
- qtss_printf("FileDeleter::~FileDeleter delete = %s \n",fFilePath.Ptr);
0
+ //qtss_printf("FileDeleter::~FileDeleter delete = %s \n",fFilePath.Ptr);
0
     ::unlink(fFilePath.Ptr);
0
     delete fFilePath.Ptr;
0
     fFilePath.Ptr = NULL;
0
@@ -128,7 +128,7 @@ ReflectorSession::~ReflectorSession()
0
         UInt32 refCount = fStreamArray[x]->GetRef()->GetRefCount();
0
         Bool16 unregisterNow = (refCount == 1) ? true : false;
0
         
0
- qtss_printf("ReflectorSession::~ReflectorSession stream index=%lu refcount=%lu\n",x,refCount);
0
+ //qtss_printf("ReflectorSession::~ReflectorSession stream index=%lu refcount=%lu\n",x,refCount);
0
         //decrement the ref count
0
         
0
         if (refCount > 0) // Refcount may be 0 if there was some error setting up the stream
0
@@ -139,7 +139,7 @@ ReflectorSession::~ReflectorSession()
0
         { // Delete this stream if the refcount has dropped to 0
0
             if (unregisterNow)
0
                 sStreamMap->UnRegister(fStreamArray[x]->GetRef()); // Refcount may be 0 if there was some error setting up the stream
0
- qtss_printf("delete stream index=%lu refcount=%lu\n",x,refCount);
0
+ //qtss_printf("delete stream index=%lu refcount=%lu\n",x,refCount);
0
             delete fStreamArray[x];
0
             fStreamArray[x] = NULL;
0
         }
0
@@ -223,7 +223,7 @@ QTSS_Error ReflectorSession::SetupReflectorSession(SourceInfo* inInfo, QTSS_Stan
0
                 
0
             // If the port was 0, update it to reflect what the actual RTP port is.
0
             fSourceInfo->GetStreamInfo(x)->fPort = fStreamArray[x]->GetStreamInfo()->fPort;
0
- qtss_printf("ReflectorSession::SetupReflectorSession fSourceInfo->GetStreamInfo(x)->fPort= %u\n",fSourceInfo->GetStreamInfo(x)->fPort);
0
+ //qtss_printf("ReflectorSession::SetupReflectorSession fSourceInfo->GetStreamInfo(x)->fPort= %u\n",fSourceInfo->GetStreamInfo(x)->fPort);
0
             
0
             ReflectorStream::GenerateSourceID(fSourceInfo->GetStreamInfo(x), &theStreamID[0]);
0
 
0
@@ -235,7 +235,7 @@ QTSS_Error ReflectorSession::SetupReflectorSession(SourceInfo* inInfo, QTSS_Stan
0
             Assert(debug == fStreamArray[x]->GetRef());
0
 
0
             //UInt32 refCount = fStreamArray[x]->GetRef()->GetRefCount();
0
- qtss_printf("stream index=%lu refcount=%lu\n",x,refCount);
0
+ //qtss_printf("stream index=%lu refcount=%lu\n",x,refCount);
0
         
0
         }
0
         else
0
@@ -258,7 +258,7 @@ void ReflectorSession::AddBroadcasterClientSession(QTSS_StandardRTSP_Params* inP
0
     for (UInt32 x = 0; x < fSourceInfo->GetNumStreams(); x++)
0
     {
0
         if (fStreamArray[x] != NULL)
0
- { qtss_printf("AddBroadcasterSession=%lu\n",inParams->inClientSession);
0
+ { //qtss_printf("AddBroadcasterSession=%lu\n",inParams->inClientSession);
0
             ((ReflectorSocket*)fStreamArray[x]->GetSocketPair()->GetSocketA())->AddBroadcasterSession(inParams->inClientSession);
0
             ((ReflectorSocket*)fStreamArray[x]->GetSocketPair()->GetSocketB())->AddBroadcasterSession(inParams->inClientSession);
0
         }
...
224
225
226
227
 
228
229
230
...
490
491
492
493
 
494
495
496
 
497
498
499
...
503
504
505
506
 
507
508
509
 
510
511
512
...
1092
1093
1094
1095
 
1096
1097
1098
...
1324
1325
1326
1327
 
1328
1329
1330
...
1333
1334
1335
1336
 
1337
1338
1339
1340
 
1341
1342
1343
1344
1345
1346
1347
 
1348
1349
1350
...
1375
1376
1377
1378
 
1379
1380
1381
...
1411
1412
1413
1414
 
1415
1416
1417
...
224
225
226
 
227
228
229
230
...
490
491
492
 
493
494
495
 
496
497
498
499
...
503
504
505
 
506
507
508
 
509
510
511
512
...
1092
1093
1094
 
1095
1096
1097
1098
...
1324
1325
1326
 
1327
1328
1329
1330
...
1333
1334
1335
 
1336
1337
1338
1339
 
1340
1341
1342
1343
1344
1345
1346
 
1347
1348
1349
1350
...
1375
1376
1377
 
1378
1379
1380
1381
...
1411
1412
1413
 
1414
1415
1416
1417
0
@@ -224,7 +224,7 @@ ReflectorStream::~ReflectorStream()
0
         sSocketPool.ReleaseUDPSocketPair(fSockets);
0
     }
0
         
0
- qtss_printf("Deleting stream %x\n", this);
0
+ //qtss_printf("Deleting stream %x\n", this);
0
 
0
     //delete every client Bucket
0
     for (UInt32 y = 0; y < fNumBuckets; y++)
0
@@ -490,10 +490,10 @@ void ReflectorStream::PushPacket(char *packet, UInt32 packetLen, Bool16 isRTCP)
0
     {
0
         ReflectorPacket* thePacket = NULL;
0
         if (isRTCP)
0
- { qtss_printf("ReflectorStream::PushPacket RTCP packetlen = %lu\n",packetLen);
0
+ { //qtss_printf("ReflectorStream::PushPacket RTCP packetlen = %lu\n",packetLen);
0
             thePacket = ((ReflectorSocket*)fSockets->GetSocketB())->GetPacket();
0
             if (thePacket == NULL)
0
- { qtss_printf("ReflectorStream::PushPacket RTCP GetPacket() is NULL\n");
0
+ { //qtss_printf("ReflectorStream::PushPacket RTCP GetPacket() is NULL\n");
0
                 return;
0
             }
0
             
0
@@ -503,10 +503,10 @@ void ReflectorStream::PushPacket(char *packet, UInt32 packetLen, Bool16 isRTCP)
0
             ((ReflectorSocket*)fSockets->GetSocketB())->Signal(Task::kIdleEvent);
0
         }
0
         else
0
- { qtss_printf("ReflectorStream::PushPacket RTP packetlen = %lu\n",packetLen);
0
+ { //qtss_printf("ReflectorStream::PushPacket RTP packetlen = %lu\n",packetLen);
0
             thePacket = ((ReflectorSocket*)fSockets->GetSocketA())->GetPacket();
0
             if (thePacket == NULL)
0
- { qtss_printf("ReflectorStream::PushPacket GetPacket() is NULL\n");
0
+ { //qtss_printf("ReflectorStream::PushPacket GetPacket() is NULL\n");
0
                 return;
0
             }
0
     
0
@@ -1092,7 +1092,7 @@ OSQueueElem* ReflectorSender::SendPacketsToOutput(ReflectorOutput* theOutput,
0
             else
0
                 theOutput->fLastIntervalMilliSec *= 2; // scale upwards over time
0
 
0
- qtss_printf ( "Blocked ReflectorSender::SendPacketsToOutput timeToSendPacket=%qd fLastIntervalMilliSec=%qd fNextTimeToRun=%qd \n", timeToSendPacket, theOutput->fLastIntervalMilliSec, fNextTimeToRun);
0
+ //qtss_printf ( "Blocked ReflectorSender::SendPacketsToOutput timeToSendPacket=%qd fLastIntervalMilliSec=%qd fNextTimeToRun=%qd \n", timeToSendPacket, theOutput->fLastIntervalMilliSec, fNextTimeToRun);
0
            
0
            break;
0
         }
0
@@ -1324,7 +1324,7 @@ void ReflectorSocket::FilterInvalidSSRCs(ReflectorPacket* thePacket,Bool16 isRTC
0
         if (0 == fValidSSRC)
0
         { fValidSSRC = thePacket->GetSSRC(isRTCP); // SSRC of 0 is allowed
0
             fLastValidSSRCTime = currentTime;
0
- qtss_printf("socket=%lu FIRST PACKET fValidSSRC=%lu \n", (long unsigned) this,fValidSSRC);
0
+ //qtss_printf("socket=%lu FIRST PACKET fValidSSRC=%lu \n", (long unsigned) this,fValidSSRC);
0
             break;
0
         }
0
     
0
@@ -1333,18 +1333,18 @@ void ReflectorSocket::FilterInvalidSSRCs(ReflectorPacket* thePacket,Bool16 isRTC
0
         {
0
             if (packetSSRC == fValidSSRC)
0
             { fLastValidSSRCTime = currentTime;
0
- qtss_printf("socket=%lu good packet\n", (long unsigned) this );
0
+ //qtss_printf("socket=%lu good packet\n", (long unsigned) this );
0
                 break;
0
             }
0
             
0
- qtss_printf("socket=%lu bad packet packetSSRC= %lu fValidSSRC=%lu \n", (long unsigned) this,packetSSRC,fValidSSRC);
0
+ //qtss_printf("socket=%lu bad packet packetSSRC= %lu fValidSSRC=%lu \n", (long unsigned) this,packetSSRC,fValidSSRC);
0
             thePacket->fPacketPtr.Len = 0; // ignore this packet wrong SSRC
0
         }
0
         
0
         // this executes whenever an invalid SSRC is found -- maybe the original stream ended and a new one is now active
0
         if ( (fLastValidSSRCTime + fTimeoutSecs) < currentTime) // fValidSSRC timed out --no packets with this SSRC seen for awhile
0
         { fValidSSRC = 0; // reset the valid SSRC with the next packet's SSRC
0
- qtss_printf("RESET fValidSSRC\n");
0
+ //qtss_printf("RESET fValidSSRC\n");
0
         }
0
 
0
     }while (false);
0
@@ -1375,7 +1375,7 @@ Bool16 ReflectorSocket::ProcessPacket(const SInt64& inMilliseconds,ReflectorPack
0
             fFreeQueue.EnQueue(&thePacket->fQueueElem);
0
             this->RequestEvent(EV_RE);
0
             done = true;
0
- qtss_printf("ReflectorSocket::ProcessPacket no more packets on this socket!\n");
0
+ //qtss_printf("ReflectorSocket::ProcessPacket no more packets on this socket!\n");
0
             break;//no more packets on this socket!
0
         }
0
         
0
@@ -1411,7 +1411,7 @@ Bool16 ReflectorSocket::ProcessPacket(const SInt64& inMilliseconds,ReflectorPack
0
         if (theSender == NULL)
0
         {
0
             //UInt16* theSeqNumberP = (UInt16*)thePacket->fPacketPtr.Ptr;
0
- qtss_printf("ReflectorSocket::ProcessPacket no sender found for packet! sequence number=%d\n",ntohs(theSeqNumberP[1]));
0
+ //qtss_printf("ReflectorSocket::ProcessPacket no sender found for packet! sequence number=%d\n",ntohs(theSeqNumberP[1]));
0
             fFreeQueue.EnQueue(&thePacket->fQueueElem); // don't process the packet
0
             done = true;
0
             break;

Comments

    No one has commented yet.