cpp/firebuf
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Error on full buffer

Browse Source
This commit is contained in:
flamingcow
2019-05-09 19:19:15 -07:00
parent 49766e29f4
commit 4d9486e281
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
stream_buffer.cc
View File

@@ -7,6 +7,10 @@ StreamBuffer::StreamBuffer(int sock, size_t size)
sock_(sock) {} sock_(sock) {}
bool StreamBuffer::Refill() { bool StreamBuffer::Refill() {
if (WriteMaxLen() == 0) {
LOG(ERROR) << "buffer full";
return false;
}
auto read_len = read(sock_, WritePtr(), WriteMaxLen()); auto read_len = read(sock_, WritePtr(), WriteMaxLen());
if (read_len == -1) { if (read_len == -1) {
if (errno == EINTR) { if (errno == EINTR) {