|
|
@ -61,7 +61,7 @@ response(?AgUndef, DoneCnt, _MessageId, _ChunkIdx, _ChunkSize, _ChunkBuffer, Dat |
|
|
|
ByteSize = erlang:byte_size(LeftBuffer), |
|
|
|
ChunkSize = Length - ?AgHeaderSize, |
|
|
|
|
|
|
|
io:format("IMY***********get ret ~p ~n", [{Length, ChunkX, IsFirst, MessageId, _MessageLength, ChunkSize, ByteSize}]), |
|
|
|
?AgDebug("IMY***********response/7 Length:~p ChunkX:~p IsFirst:~p MessageId:~p _MessageLength:~p ChunkSize:~pn> ByteSize:~p", [{Length, ChunkX, IsFirst, MessageId, _MessageLength, ChunkSize, ByteSize}]), |
|
|
|
|
|
|
|
if |
|
|
|
ByteSize == ChunkSize -> |
|
|
@ -230,7 +230,7 @@ response(?AgCBody, DoneCnt, MessageId, ChunkIdx, ChunkSize, ChunkBuffer, DataBuf |
|
|
|
response(?AgUndef, #recvState{chunkCnt = ChunkCnt, msgBuffer = MsgBuffer} = RecvState, DataBuffer) -> |
|
|
|
case DataBuffer of |
|
|
|
<<Length:32/integer-little-unsigned, ChunkX:31/integer-little-unsigned, IsFirst:1/integer-little-unsigned, MessageId:64/integer-little-unsigned, _MessageLength:64/integer-little-unsigned, LeftBuffer/binary>> -> |
|
|
|
?AgDebug('IM**************', "response 1: ChunkX:~p IsFirst:~p MessageId:~p Length:~p _MessageLength:~p", [ChunkX, IsFirst, MessageId, Length, _MessageLength]), |
|
|
|
?AgDebug('IM**************response/3', "response 1: ChunkX:~p IsFirst:~p MessageId:~p Length:~p _MessageLength:~p", [ChunkX, IsFirst, MessageId, Length, _MessageLength]), |
|
|
|
|
|
|
|
ByteSize = erlang:byte_size(LeftBuffer), |
|
|
|
ChunkSize = Length - ?AgHeaderSize, |
|
|
|