diff --git a/rtmp/rtmp.go b/rtmp/rtmp.go index 4bcd085b..671836a0 100644 --- a/rtmp/rtmp.go +++ b/rtmp/rtmp.go @@ -341,9 +341,9 @@ func rtmpWrite(r *C.RTMP, data []byte) int { pkt.m_packetType = C.uint8_t(*indxBytePtr(buf, 0)) buf = incBytePtr(buf, 1) - pkt.m_nBodySize = C.uint32_t(C.AMF_DecodeInt24((*C.char)(buf))) + pkt.m_nBodySize = C.uint32_t(afmDecodeInt24((*byte)(buf))) buf = incBytePtr(buf, 3) - pkt.m_nTimeStamp = C.uint32_t(C.AMF_DecodeInt24((*C.char)(buf))) + pkt.m_nTimeStamp = C.uint32_t(afmDecodeInt24((*byte)(buf))) buf = incBytePtr(buf, 3) pkt.m_nTimeStamp |= C.uint32_t(*indxBytePtr(buf, 0)) << 24 buf = incBytePtr(buf, 4) @@ -410,9 +410,12 @@ func rtmpWrite(r *C.RTMP, data []byte) int { // afmDecodeInt24 decodes data into an unsigned int func afmDecodeInt24(data *byte) uint32 { - dataPtr := unsafe.Pointer(data) - - return (uint32)(*data)<<16 | *(*uint32)(incBytePtr(dataPtr, 1))<<8 | *(*uint32)(incBytePtr(dataPtr, 2)) + // TODO Understand logic and simplify + c := (*uint8)(unsafe.Pointer(data)) + dst := uint32(int32(*c) << 16) + dst |= uint32(int32(*((*uint8)(unsafe.Pointer(uintptr(unsafe.Pointer(c)) + (uintptr)(int32(1))*unsafe.Sizeof(*c))))) << 8) + dst |= uint32(int32(*((*uint8)(unsafe.Pointer(uintptr(unsafe.Pointer(c)) + (uintptr)(int32(2))*unsafe.Sizeof(*c)))))) + return dst } func afmEncodeString(output *byte, outend *byte, bv *C.AVal) *byte {