return pakfire_buffer_resize(self, self->length);
}
-int pakfire_buffer_append(struct pakfire_buffer* self, const char* data, size_t length) {
+int pakfire_buffer_push(struct pakfire_buffer* self, const char* data, size_t length) {
int r;
// Check inputs
return 0;
}
-int pakfire_buffer_append_from_fd(struct pakfire_buffer* self, int fd) {
+int pakfire_buffer_push_from_fd(struct pakfire_buffer* self, int fd) {
ssize_t bytes_read = 0;
int r;
return 0;
}
-int pakfire_buffer_consume(struct pakfire_buffer* self, size_t length) {
+int pakfire_buffer_pop(struct pakfire_buffer* self, size_t length) {
// Check if we actually have enough data
if (self->used < length)
return -EINVAL;
void pakfire_buffer_free(struct pakfire_buffer* buffer);
-int pakfire_buffer_append(struct pakfire_buffer* self, const char* data, size_t length);
-int pakfire_buffer_append_from_fd(struct pakfire_buffer* self, int fd);
+int pakfire_buffer_push(struct pakfire_buffer* self, const char* data, size_t length);
+int pakfire_buffer_push_from_fd(struct pakfire_buffer* self, int fd);
-int pakfire_buffer_consume(struct pakfire_buffer* self, size_t length);
+int pakfire_buffer_pop(struct pakfire_buffer* self, size_t length);
size_t pakfire_buffer_find_line(struct pakfire_buffer* self);
return r;
// Consume the data
- pakfire_buffer_consume(&stream->buffer, length);
+ pakfire_buffer_pop(&stream->buffer, length);
}
return 0;
if (events & EPOLLIN) {
// Fill the buffer
- r = pakfire_buffer_append_from_fd(&stream->buffer, fd);
+ r = pakfire_buffer_push_from_fd(&stream->buffer, fd);
if (r < 0)
return r;
struct pakfire_log_stream* self = data;
int r;
- // Append the data to the buffer
- r = pakfire_buffer_append(&self->buffer, buffer, length);
+ // Push the data into the buffer
+ r = pakfire_buffer_push(&self->buffer, buffer, length);
if (r < 0)
return r;