|
|
@@ -1559,11 +1559,13 @@ static const size_t SRFrameHeaderOverhead = 32;
|
|
|
|
|
|
case NSStreamEventHasBytesAvailable: {
|
|
|
SRFastLog(@"NSStreamEventHasBytesAvailable %@", aStream);
|
|
|
- const NSUInteger bufferSize = 2048;
|
|
|
- uint8_t buffer[bufferSize];
|
|
|
+
|
|
|
+ #define FSRWEB_SOCKET_BUFFER_SIZE 2048
|
|
|
+ uint8_t buffer[FSRWEB_SOCKET_BUFFER_SIZE];
|
|
|
+
|
|
|
|
|
|
while (_inputStream.hasBytesAvailable) {
|
|
|
- NSInteger bytes_read = [_inputStream read:buffer maxLength:bufferSize];
|
|
|
+ NSInteger bytes_read = [_inputStream read:buffer maxLength:FSRWEB_SOCKET_BUFFER_SIZE];
|
|
|
|
|
|
if (bytes_read > 0) {
|
|
|
[_readBuffer appendBytes:buffer length:bytes_read];
|
|
|
@@ -1571,7 +1573,7 @@ static const size_t SRFrameHeaderOverhead = 32;
|
|
|
[self _failWithError:_inputStream.streamError];
|
|
|
}
|
|
|
|
|
|
- if (bytes_read != bufferSize) {
|
|
|
+ if (bytes_read != FSRWEB_SOCKET_BUFFER_SIZE) {
|
|
|
break;
|
|
|
}
|
|
|
};
|