hydrar/mistserver
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Improved RTMP protocol verbosity.

Browse source
This commit is contained in:
Thulinma 2013-03-16 16:29:03 +01:00
parent c3143cfe01
commit b2916bad35
1 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/connectors/conn_rtmp.cpp
View file

@ -205,8 +205,13 @@ void Connector_RTMP::parseChunk(Socket::Buffer & inbuffer){
switch (next.msg_type_id){ switch (next.msg_type_id){
case 0: //does not exist case 0: //does not exist
#if DEBUG >= 2 #if DEBUG >= 2
fprintf(stderr, "UNKN: Received a zero-type message. This is an error.\n"); fprintf(stderr, "UNKN: Received a zero-type message. Possible data corruption? Aborting!\n");
#endif #endif
while (inbuffer.size()){
inbuffer.get().clear();
}
SS.close();
Socket.close();
break; //happens when connection breaks unexpectedly break; //happens when connection breaks unexpectedly
case 1: //set chunk size case 1: //set chunk size
RTMPStream::chunk_rec_max = ntohl(*(int*)next.data.c_str()); RTMPStream::chunk_rec_max = ntohl(*(int*)next.data.c_str());
@ -460,6 +465,10 @@ void Connector_RTMP::parseAMFCommand(AMF::Object & amfdata, int messagetype, int
} }
return; return;
} }
if ((amfdata.getContentP(0)->StrValue() == "FCPublish") || (amfdata.getContentP(0)->StrValue() == "releaseStream")){
// ignored
return;
}
if ((amfdata.getContentP(0)->StrValue() == "getStreamLength") || (amfdata.getContentP(0)->StrValue() == "getMovLen")){ if ((amfdata.getContentP(0)->StrValue() == "getStreamLength") || (amfdata.getContentP(0)->StrValue() == "getMovLen")){
//send a _result reply //send a _result reply
AMF::Object amfreply("container", AMF::AMF0_DDV_CONTAINER); AMF::Object amfreply("container", AMF::AMF0_DDV_CONTAINER);
@ -584,7 +593,7 @@ void Connector_RTMP::parseAMFCommand(AMF::Object & amfdata, int messagetype, int
} //seek } //seek
#if DEBUG >= 2 #if DEBUG >= 2
fprintf(stderr, "AMF0 command not processed! :(\n"); fprintf(stderr, "AMF0 command not processed!\n%s\n", amfdata.Print().c_str());
#endif #endif
} //parseAMFCommand } //parseAMFCommand