diff --git a/rtmp/rtmp_c/librtmp/rtmp.c b/rtmp/rtmp_c/librtmp/rtmp.c index 81532de0..ff21240a 100644 --- a/rtmp/rtmp_c/librtmp/rtmp.c +++ b/rtmp/rtmp_c/librtmp/rtmp.c @@ -109,10 +109,10 @@ typedef enum { } RTMPTCmd; static int DumpMetaData(AMFObject *obj); -static int HandShake(RTMP *r, int FP9HandShake); +int HandShake(RTMP *r, int FP9HandShake); int SocksNegotiate(RTMP *r); -static int SendConnectPacket(RTMP *r, RTMPPacket *cp); +int SendConnectPacket(RTMP *r, RTMPPacket *cp); static int SendCheckBW(RTMP *r); static int SendCheckBWResult(RTMP *r, double txn); int SendDeleteStream(RTMP *r, double dStreamId); @@ -946,6 +946,7 @@ RTMP_Connect0(RTMP *r, struct sockaddr * service) if (setsockopt (r->m_sb.sb_socket, SOL_SOCKET, SO_RCVTIMEO, (char *)&tv, sizeof(tv))) { + printf("int here\n"); fflush(stdout); RTMP_Log(RTMP_LOGERROR, "%s, Setting socket timeout to %ds failed!", __FUNCTION__, r->Link.timeout); } @@ -1574,7 +1575,7 @@ SAVC(secureTokenResponse); SAVC(type); SAVC(nonprivate); -static int +int SendConnectPacket(RTMP *r, RTMPPacket *cp) { RTMPPacket packet; @@ -3739,7 +3740,7 @@ RTMP_ReadPacket(RTMP *r, RTMPPacket *packet) } #ifndef CRYPTO -static int +int HandShake(RTMP *r, int FP9HandShake) { int i; diff --git a/rtmp/rtmp_c/librtmp/rtmp.h b/rtmp/rtmp_c/librtmp/rtmp.h index 56fd4f52..374223d4 100644 --- a/rtmp/rtmp_c/librtmp/rtmp.h +++ b/rtmp/rtmp_c/librtmp/rtmp.h @@ -297,6 +297,10 @@ extern "C" int SendFCUnpublish(RTMP *r); + int HandShake(RTMP *r, int FP9HandShake); + + int SendConnectPacket(RTMP *r, RTMPPacket *cp); + int SendDeleteStream(RTMP *r, double dStreamId); int RTMP_SetOpt(RTMP *r, const AVal *opt, AVal *arg);