goto cleanup;
}
- retval = reader_pipe_init_with_writer(&reader, wr, server, params.monitor, params.is_dumping);
+ retval = reader_pipe_init(&reader, params.enabled_buffers, server, params.monitor, params.is_dumping);
if (retval != 0)
goto cleanup;
return 0;
}
-int reader_pipe_init_with_writer(struct reader_pipe **reader, struct writer *writer, struct logger *server,
- bool monitor, bool is_dumping)
-{
- assert(reader);
- assert(writer);
- assert(writer->buf_ptr);
- assert(server);
-
- __attribute__((cleanup(reader_free_ptr))) struct reader_pipe *ret = reader_pipe_alloc(server, monitor, is_dumping);
- if (!ret)
- return -ENOMEM;
-
- log_storage_reader *const lsr = log_storage_new_reader(writer->buf_ptr->log_storage_ptr,
- is_dumping, monitor, reader_pipe_notify_losing_log, ret);
- if (!lsr)
- return -ENOMEM;
- ret->log_storage_reader_ptrs[0] = lsr;
-
- init_fd_entity(&ret->common.fd_entity_sink, dispatch_event_reader, ret);
- init_fd_entity(&ret->common.fd_entity_source, dispatch_event_reader, ret);
-
- *reader = ret;
- ret = NULL;
- return 0;
-}
-
int reader_pipe_print_out_single_log(struct reader_pipe *reader, const dlogutil_entry_s *dlogutil_entry)
{
assert(reader);
int reader_pipe_init(struct reader_pipe **reader, int enabled_buffers, struct logger *server,
bool monitor, bool is_dumping);
-int reader_pipe_init_with_writer(struct reader_pipe **reader, struct writer *writer, struct logger *server,
- bool monitor, bool is_dumping);
int reader_pipe_print_out_single_log(struct reader_pipe *reader, const dlogutil_entry_s *dlogutil_entry);