From e4cd61b66301cc6405a678a14f2b14dbb124ec86 Mon Sep 17 00:00:00 2001
From: saxon <saxon.milton@gmail.com>
Date: Tue, 7 Aug 2018 14:19:11 +0930
Subject: [PATCH] Started commenting functions to indicate name and location of
 C versions

---
 rtmp/rtmp.go | 40 ++++++++++++++++++++++++++++++++++------
 1 file changed, 34 insertions(+), 6 deletions(-)

diff --git a/rtmp/rtmp.go b/rtmp/rtmp.go
index 4e3a42d1..07bbd3c3 100644
--- a/rtmp/rtmp.go
+++ b/rtmp/rtmp.go
@@ -423,6 +423,8 @@ func (s *session) Write(data []byte) (int, error) {
 	return len(data), nil
 }
 
+// int RTMP_IsConnected(RTMP *r);
+// rtmp.c +363
 func C_RTMP_IsConnected(r *C.RTMP) int32 {
 	if r.m_sb.sb_socket != -1 {
 		return 1
@@ -437,7 +439,7 @@ func startSession(rtmp *C.RTMP, u string, timeout uint32) (*C.RTMP, error) {
 	C_RTMP_Init(rtmp)
 	//C.RTMP_Init(rtmp)
 	rtmp.Link.timeout = connect_timeout
-	if C_RTMP_SetupUrl(rtmp, u) == 0 {
+	if C_RTMP_SetupURL(rtmp, u) == 0 {
 		// if C.RTMP_SetupURL(rtmp, C.CString(u)) == 0 {
 		//C.RTMP_Close(rtmp)
 		//C.RTMP_Free(rtmp)
@@ -465,12 +467,17 @@ func startSession(rtmp *C.RTMP, u string, timeout uint32) (*C.RTMP, error) {
 
 	return rtmp, nil
 }
+
+// RTMP* RTMP_IsConnected();
+// rtmp.c +317
 func C_RTMP_Alloc() *C.RTMP {
 	var r C.RTMP
 	//return (*C.RTMP)(C.malloc(C.size_t(unsafe.Sizeof(r))))
 	return (*C.RTMP)(allocate(unsafe.Sizeof(r)))
 }
 
+// void RTMP_Init(RTMP *r);
+// rtmp.c +329
 func C_RTMP_Init(r *C.RTMP) {
 	r.m_sb.sb_socket = -1
 	r.m_inChunkSize = RTMP_DEFAULT_CHUNKSIZE
@@ -485,7 +492,9 @@ func C_RTMP_Init(r *C.RTMP) {
 	r.Link.swfAge = 30
 }
 
-func C_RTMP_SetupUrl(r *C.RTMP, u string) int32 {
+// int RTMP_SetupURL(RTMP *r, char* url);
+// rtmp.c +757
+func C_RTMP_SetupURL(r *C.RTMP, u string) int32 {
 	url := goStrToCStr(u)
 
 	var ret, len int32
@@ -554,6 +563,8 @@ func C_RTMP_SetupUrl(r *C.RTMP, u string) int32 {
 	return 1
 }
 
+// void SocksSetup(RTMP *r, AVal* sockshost);
+// rtmp.c +410
 func C_SocksSetup(r *C.RTMP, sockshost *C.AVal) {
 	if sockshost.av_len != 0 {
 		socksport := strchr((*byte)(unsafe.Pointer(sockshost.av_val)), ':')
@@ -664,14 +675,20 @@ func closeInternal(r *C.RTMP, reconnect int32) {
 }
 */
 
+// void RTMP_EnableWrite(RTMP *r);
+// rtmp.c +351
 func C_RTMP_EnableWrite(r *C.RTMP) {
 	r.Link.protocol |= RTMP_FEATURE_WRITE
 }
 
+// void RTMP_SetBufferMS(RTMP *r, int size);
+// rtmp.c +381
 func C_RTMP_SetBufferMS(r *C.RTMP, size int32) {
 	r.m_nBufferMS = C.int(size)
 }
 
+// int RTMP_Connect(RTMP *r, RTMPPacket* cp);
+// rtmp.c +1032
 func C_RTMP_Connect(r *C.RTMP, cp *C.RTMPPacket) int {
 	// TODO: port this
 	var service C.sockaddr_in
@@ -708,7 +725,8 @@ func C_RTMP_Connect(r *C.RTMP, cp *C.RTMPPacket) int {
 	//return int(C.RTMP_Connect1(r, cp))
 }
 
-//
+// int RTMP_Connect0(RTMP *r, struct sockaddr* service);
+// rtmp.c +906
 func C_RTMP_Connect0(r *C.RTMP, service *C.sockaddr) int {
 	on := 1
 	r.m_sb.sb_timedout = 0
@@ -752,6 +770,8 @@ func C_RTMP_Connect0(r *C.RTMP, service *C.sockaddr) int {
 	return 1
 }
 
+// int RTMP_Connect1(RTMP* r, RTMPPacket* cp);
+// rtmp.c +978
 func C_RTMP_Connect1(r *C.RTMP, cp *C.RTMPPacket) int {
 	if debugMode {
 		log.Println("... connected, handshaking...")
@@ -772,6 +792,8 @@ func C_RTMP_Connect1(r *C.RTMP, cp *C.RTMPPacket) int {
 	return 1
 }
 
+// int HandShake(RTMP* r, int FP9HandShake);
+// rtmp.c +3744
 func C_HandShake(r *C.RTMP, FP9HandShake int32) int {
 	var bMatch int
 	//uptime := uint32(0)
@@ -845,6 +867,8 @@ func C_HandShake(r *C.RTMP, FP9HandShake int32) int {
 	return 1
 }
 
+// int ReadN(RTMP* r, char* buffer, int n);
+// rtmp.c +1390
 func C_ReadN(r *C.RTMP, buffer *byte, n int) int {
 	nOriginalSize := n
 	var avail int
@@ -860,7 +884,7 @@ func C_ReadN(r *C.RTMP, buffer *byte, n int) int {
 
 		avail = int(r.m_sb.sb_size)
 		if avail == 0 {
-			if C_RTMP_SockBuffFill(&r.m_sb) < 1 {
+			if C_RTMPSockBuf_Fill(&r.m_sb) < 1 {
 				// if C.RTMPSockBuf_Fill(&r.m_sb) < 1 {
 				if r.m_sb.sb_timedout == 0 {
 					return 0
@@ -904,7 +928,9 @@ func C_ReadN(r *C.RTMP, buffer *byte, n int) int {
 	return nOriginalSize - n
 }
 
-func C_RTMP_SockBuffFill(sb *C.RTMPSockBuf) int {
+// int RTMPSockBuf_Fill(RTMPSockBuf* sb);
+// rtmp.c +4253
+func C_RTMPSockBuf_Fill(sb *C.RTMPSockBuf) int {
 	var nBytes int
 
 	if sb.sb_size == 0 {
@@ -923,13 +949,15 @@ func C_RTMP_SockBuffFill(sb *C.RTMPSockBuf) int {
 		if nBytes != -1 {
 			sb.sb_size += C.int(nBytes)
 		} else {
-			log.Println("C_RTMP_SockBuffFill: recv error!")
+			log.Println("C_RTMPSockBuf_Fill: recv error!")
 		}
 		break
 	}
 	return nBytes
 }
 
+// int SendBytesReceived(RTMP* r);
+// rtmp.c +2080
 func C_SendBytesReceived(r *C.RTMP) int {
 	var packet C.RTMPPacket
 	var pbuf [256]byte