| Server IP : 62.60.133.156 / Your IP : 216.73.217.51 Web Server : LiteSpeed System : Linux linux24.centraldnserver.com 4.18.0-553.141.2.lve.el8.x86_64 #1 SMP Wed Jul 8 16:10:02 UTC 2026 x86_64 User : mimradmin ( 1166) PHP Version : 7.4.33 Disable Function : show_source, system, shell_exec, passthru, exec, popen, proc_open MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/php71/usr/include/php/ext/swoole/include/ |
Upload File : |
/*
+----------------------------------------------------------------------+
| Swoole |
+----------------------------------------------------------------------+
| This source file is subject to version 2.0 of the Apache license, |
| that is bundled with this package in the file LICENSE, and is |
| available through the world-wide-web at the following url: |
| http://www.apache.org/licenses/LICENSE-2.0.html |
| If you did not receive a copy of the Apache2.0 license and are unable|
| to obtain it through the world-wide-web, please send a note to |
| license@php.net so we can mail you a copy immediately. |
+----------------------------------------------------------------------+
| Author: Tianfeng Han <mikan.tenny@gmail.com> |
+----------------------------------------------------------------------+
*/
#pragma once
#include <queue>
namespace swoole {
struct BufferChunk {
enum Type {
TYPE_DATA,
TYPE_SENDFILE,
TYPE_CLOSE,
};
Type type;
uint32_t length;
uint32_t offset;
union {
char *ptr;
void *object;
struct {
uint32_t val1;
uint32_t val2;
} data;
} value;
uint32_t size;
void (*destroy)(BufferChunk *chunk);
};
class Buffer {
private:
// 0: donot use chunk
uint32_t chunk_size;
uint32_t total_length = 0;
std::queue<BufferChunk *> queue_;
public:
Buffer(uint32_t chunk_size);
~Buffer();
BufferChunk *alloc(BufferChunk::Type type, uint32_t size);
BufferChunk *front() {
return queue_.front();
}
void pop();
void append(const void *data, uint32_t size);
uint32_t length() {
return total_length;
}
size_t count() {
return queue_.size();
}
static bool empty(Buffer *buffer) {
return buffer == nullptr || buffer->queue_.empty();
}
};
} // namespace swoole