const char *filename;
int r;
+ assert(s);
+ assert(w);
+
switch (s->split_mode) {
case JOURNAL_WRITE_SPLIT_NONE:
filename = s->output;
const void *key;
int r;
+ assert(s);
+ assert(writer);
+
switch (s->split_mode) {
case JOURNAL_WRITE_SPLIT_NONE:
key = "one and only";
/* This takes ownership of name, but only on success. */
+ assert(s);
assert(fd >= 0);
assert(source);
}
int journal_remote_add_raw_socket(RemoteServer *s, int fd) {
- int r;
_unused_ _cleanup_close_ int fd_ = fd;
char name[STRLEN("raw-socket-") + DECIMAL_STR_MAX(int) + 1];
+ int r;
+ assert(s);
assert(fd >= 0);
r = sd_event_add_io(s->events, &s->listen_event,
if (r < 0)
return r;
- fd_ = -EBADF;
+ TAKE_FD(fd_);
s->active++;
return 0;
}
void journal_remote_server_destroy(RemoteServer *s) {
size_t i;
+ if (!s)
+ return;
+
#if HAVE_MICROHTTPD
hashmap_free_with_destructor(s->daemons, MHDDaemonWrapper_free);
#endif
* 0 if data is currently exhausted, negative on error.
*/
+ assert(s);
assert(fd >= 0 && fd < (ssize_t) MALLOC_ELEMENTSOF(s->sources));
source = s->sources[fd];
assert(source->importer.fd == fd);
static int dispatch_raw_source_until_block(sd_event_source *event,
void *userdata) {
- RemoteSource *source = userdata;
+ RemoteSource *source = ASSERT_PTR(userdata);
int r;
+ assert(event);
+
/* Make sure event stays around even if source is destroyed */
sd_event_source_ref(event);
int fd,
uint32_t revents,
void *userdata) {
- RemoteSource *source = userdata;
+ RemoteSource *source = ASSERT_PTR(userdata);
int r;
assert(source->event);
static int dispatch_blocking_source_event(sd_event_source *event,
void *userdata) {
- RemoteSource *source = userdata;
+ RemoteSource *source = ASSERT_PTR(userdata);
return journal_remote_handle_raw_source(event, source->importer.fd, EPOLLIN, journal_remote_server_global);
}
_cleanup_close_ int fd2 = -EBADF;
int r;
+ assert(addr);
+ assert(hostname);
+
log_debug("Accepting new %s connection on fd:%d", type, fd);
fd2 = accept4(fd, &addr->sockaddr.sa, &addr->size, SOCK_NONBLOCK|SOCK_CLOEXEC);
if (fd2 < 0) {
uint32_t revents,
void *userdata) {
- RemoteServer *s = userdata;
+ RemoteServer *s = ASSERT_PTR(userdata);
int fd2;
SocketAddress addr = {
.size = sizeof(union sockaddr_union),