server_common/a8
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
azw 2023-05-13 03:09:45 +00:00
parent 17eb6a687c
commit b08e735f3c
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
a8/fifobuffer.cc
View File

@ -17,6 +17,7 @@ namespace a8
} }
buf_ = (char*)malloc(buf_len); buf_ = (char*)malloc(buf_len);
buf_len_ = buf_len; buf_len_ = buf_len;
capacity_ = buf_len;
} }
FifoBuffer::~FifoBuffer() FifoBuffer::~FifoBuffer()
@ -40,7 +41,11 @@ namespace a8
if (p != buf_ + head_) { if (p != buf_ + head_) {
abort(); abort();
} }
BufHead* buf_head = (BufHead*)(p - sizeof(BufHead));
head_ += sizeof(BufHead) + buf_head->len;
if (head_ >= buf_len_) {
head_ = 0;
}
} else { } else {
free(p); free(p);
} }

1
a8/fifobuffer.h
View File

@ -21,6 +21,7 @@ namespace a8
unsigned int buf_len_ = 0; unsigned int buf_len_ = 0;
std::atomic<unsigned int> head_ = 0; std::atomic<unsigned int> head_ = 0;
std::atomic<unsigned int> tail_ = 0; std::atomic<unsigned int> tail_ = 0;
std::atomic<unsigned int> capacity_ = 0;
}; };