|
@@ -156,7 +156,6 @@ Error PacketPeerStream::_poll_buffer() const {
|
|
Error err = peer->get_partial_data(&temp_buffer[0], ring_buffer.space_left(), read);
|
|
Error err = peer->get_partial_data(&temp_buffer[0], ring_buffer.space_left(), read);
|
|
if (err)
|
|
if (err)
|
|
return err;
|
|
return err;
|
|
-
|
|
|
|
if (read==0)
|
|
if (read==0)
|
|
return OK;
|
|
return OK;
|
|
|
|
|
|
@@ -202,7 +201,7 @@ Error PacketPeerStream::get_packet(const uint8_t **r_buffer,int &r_buffer_size)
|
|
uint8_t lbuf[4];
|
|
uint8_t lbuf[4];
|
|
ring_buffer.copy(lbuf,0,4);
|
|
ring_buffer.copy(lbuf,0,4);
|
|
remaining-=4;
|
|
remaining-=4;
|
|
- uint32_t len = decode_uint32(lbuf);
|
|
|
|
|
|
+ uint32_t len = decode_uint32(lbuf);
|
|
ERR_FAIL_COND_V(remaining<(int)len,ERR_UNAVAILABLE);
|
|
ERR_FAIL_COND_V(remaining<(int)len,ERR_UNAVAILABLE);
|
|
|
|
|
|
ring_buffer.read(lbuf,4); //get rid of first 4 bytes
|
|
ring_buffer.read(lbuf,4); //get rid of first 4 bytes
|