File tree Expand file tree Collapse file tree 1 file changed +9
-8
lines changed Expand file tree Collapse file tree 1 file changed +9
-8
lines changed Original file line number Diff line number Diff line change @@ -13,11 +13,19 @@ func ReadTlvStream(
13
13
onFrame func ([]byte ) bool ,
14
14
ignoreError func (error ) bool ,
15
15
) error {
16
- recvBuf := make ([]byte , ndn .MaxNDNPacketSize * 32 )
16
+ recvBuf := make ([]byte , ndn .MaxNDNPacketSize * 8 )
17
17
recvOff := 0
18
18
tlvOff := 0
19
19
20
20
for {
21
+ // If less than one packet space remains in buffer, shift to beginning
22
+ if len (recvBuf )- recvOff < ndn .MaxNDNPacketSize {
23
+ copy (recvBuf , recvBuf [tlvOff :recvOff ])
24
+ recvOff -= tlvOff
25
+ tlvOff = 0
26
+ }
27
+
28
+ // Read multiple packets at once
21
29
readSize , err := reader .Read (recvBuf [recvOff :])
22
30
recvOff += readSize
23
31
if err != nil {
@@ -63,12 +71,5 @@ func ReadTlvStream(
63
71
break
64
72
}
65
73
}
66
-
67
- // If less than one packet space remains in buffer, shift to beginning
68
- if recvOff - tlvOff < ndn .MaxNDNPacketSize {
69
- copy (recvBuf , recvBuf [tlvOff :recvOff ])
70
- recvOff -= tlvOff
71
- tlvOff = 0
72
- }
73
74
}
74
75
}
You can’t perform that action at this time.
0 commit comments