struct pakfire_log_file* file;
// Buffer
- struct pakfire_log_buffer* buffer;
+ pakfire_log_buffer* buffer;
// Streams
struct pakfire_log_stream* stdout;
free(line);
}
-static void pakfire_log_buffer_free(struct pakfire_log_buffer* buffer) {
+static void pakfire_log_buffer_free(pakfire_log_buffer* buffer) {
struct pakfire_log_line* line = NULL;
// Free all entries
free(buffer);
}
-int pakfire_log_buffer_create(struct pakfire_log_buffer** buffer, pakfire_ctx* ctx, size_t max_length) {
- struct pakfire_log_buffer* b = NULL;
+int pakfire_log_buffer_create(pakfire_log_buffer** buffer, pakfire_ctx* ctx, size_t max_length) {
+ pakfire_log_buffer* b = NULL;
// Allocate a new object
b = calloc(1, sizeof(*b));
return 0;
}
-struct pakfire_log_buffer* pakfire_log_buffer_ref(struct pakfire_log_buffer* buffer) {
+pakfire_log_buffer* pakfire_log_buffer_ref(pakfire_log_buffer* buffer) {
++buffer->nrefs;
return buffer;
}
-struct pakfire_log_buffer* pakfire_log_buffer_unref(struct pakfire_log_buffer* buffer) {
+pakfire_log_buffer* pakfire_log_buffer_unref(pakfire_log_buffer* buffer) {
if (--buffer->nrefs > 0)
return buffer;
return NULL;
}
-static int pakfire_log_buffer_drop(struct pakfire_log_buffer* self) {
+static int pakfire_log_buffer_drop(pakfire_log_buffer* self) {
struct timeval timestamp = {};
int priority = 0;
char* line = NULL;
return 0;
}
-int pakfire_log_buffer_enqueue(struct pakfire_log_buffer* buffer, int priority, const char* line, ssize_t length) {
+int pakfire_log_buffer_enqueue(pakfire_log_buffer* buffer, int priority, const char* line, ssize_t length) {
struct pakfire_log_line* l = NULL;
int r;
return r;
}
-int pakfire_log_buffer_dequeue(struct pakfire_log_buffer* buffer,
+int pakfire_log_buffer_dequeue(pakfire_log_buffer* buffer,
struct timeval* timestamp, int* priority, char** line, size_t* length) {
struct pakfire_log_line* l = NULL;
return 0;
}
-int pakfire_log_buffer_dump(struct pakfire_log_buffer* buffer, char** result, size_t* length) {
+int pakfire_log_buffer_dump(pakfire_log_buffer* buffer, char** result, size_t* length) {
struct pakfire_log_line* line = NULL;
char* s = NULL;
size_t l = 0;
Ring buffer for log messages
*/
-struct pakfire_log_buffer;
+typedef struct pakfire_log_buffer pakfire_log_buffer;
-int pakfire_log_buffer_create(struct pakfire_log_buffer** buffer, pakfire_ctx* ctx, size_t size);
-struct pakfire_log_buffer* pakfire_log_buffer_ref(struct pakfire_log_buffer* buffer);
-struct pakfire_log_buffer* pakfire_log_buffer_unref(struct pakfire_log_buffer* buffer);
+int pakfire_log_buffer_create(pakfire_log_buffer** buffer, pakfire_ctx* ctx, size_t size);
+pakfire_log_buffer* pakfire_log_buffer_ref(pakfire_log_buffer* buffer);
+pakfire_log_buffer* pakfire_log_buffer_unref(pakfire_log_buffer* buffer);
-int pakfire_log_buffer_enqueue(struct pakfire_log_buffer* buffer, int priority, const char* line, ssize_t length);
-int pakfire_log_buffer_dequeue(struct pakfire_log_buffer* buffer,
+int pakfire_log_buffer_enqueue(pakfire_log_buffer* buffer, int priority, const char* line, ssize_t length);
+int pakfire_log_buffer_dequeue(pakfire_log_buffer* buffer,
struct timeval* timestamp, int* priority, char** line, size_t* length);
-int pakfire_log_buffer_dump(struct pakfire_log_buffer* buffer, char** result, size_t* length);
+int pakfire_log_buffer_dump(pakfire_log_buffer* buffer, char** result, size_t* length);
#endif /* PAKFIRE_LOG_BUFFER_H */
#include "../testsuite.h"
static int test_simple(const struct test* t) {
- struct pakfire_log_buffer* buffer = NULL;
+ pakfire_log_buffer* buffer = NULL;
struct timeval timestamp = {};
char* line = NULL;
size_t length = 0;
}
static int test_wrong_usage(const struct test* t) {
- struct pakfire_log_buffer* buffer = NULL;
+ pakfire_log_buffer* buffer = NULL;
struct timeval timestamp = {};
int priority = -1;
char* line = NULL;
}
static int test_full(const struct test* t) {
- struct pakfire_log_buffer* buffer = NULL;
+ pakfire_log_buffer* buffer = NULL;
struct timeval timestamp = {};
char* line = NULL;
size_t length = 0;