Cross Reference: /systemd/src/journal-remote/journal-remote.c

Lines Matching defs:source
308                              int fd, char *name, RemoteSource **source) {
315         assert(source);
322                 return log_warning_errno(r, "Failed to get writer for source %s: %m",
335         *source = s->sources[fd];
340         RemoteSource *source;
345         source = s->sources[fd];
346         if (source) {
348                 source_free(source);
358         RemoteSource *source = NULL;
373         r = get_source_for_fd(s, fd, name, &source);
375                 log_error_errno(r, "Failed to create source for fd:%d (%s): %m",
381         r = sd_event_add_io(s->events, &source->event,
383                             dispatch_raw_source_event, source);
385                 /* Add additional source for buffer processing. It will be
387                 r = sd_event_add_defer(s->events, &source->buffer_event,
388                                        dispatch_raw_source_until_block, source);
390                         sd_event_source_set_enabled(source->buffer_event, SD_EVENT_OFF);
393                 r = sd_event_add_defer(s->events, &source->event,
394                                        dispatch_blocking_source_event, source);
396                         sd_event_source_set_enabled(source->event, SD_EVENT_ON);
399                 log_error_errno(r, "Failed to register event source for fd:%d: %m",
404         r = sd_event_source_set_description(source->event, name);
406                 log_error_errno(r, "Failed to set source name for fd:%d: %m", fd);
456         RemoteSource *source;
466                 return log_warning_errno(r, "Failed to get writer for source %s: %m",
469         source = source_new(fd, true, hostname, writer);
470         if (!source) {
475         log_debug("Added RemoteSource as connection metadata %p", source);
477         *connection_cls = source;
501                 RemoteSource *source) {
507         assert(source);
515                 r = push_data(source, upload_data, *upload_data_size);
524                 r = process_source(source, arg_compress, arg_seal);
546         remaining = source_non_empty(source);
729                 log_error_errno(r, "Failed to set source name: %m");
962                         log_debug("Using standard input as source.");
1034         RemoteSource *source;
1042         source = s->sources[fd];
1043         assert(source->fd == fd);
1045         r = process_source(source, arg_compress, arg_seal);
1046         if (source->state == STATE_EOF) {
1049                 log_debug("EOF reached with source fd:%d (%s)",
1050                           source->fd, source->name);
1052                 remaining = source_non_empty(source);
1055                 remove_source(s, source->fd);
1073         RemoteSource *source = userdata;
1076         /* Make sure event stays around even if source is destroyed */
1079         r = handle_raw_source(event, source->fd, EPOLLIN, server);
1093         RemoteSource *source = userdata;
1096         assert(source->event);
1097         assert(source->buffer_event);
1103                 sd_event_source_set_enabled(source->buffer_event, SD_EVENT_ON);
1110         RemoteSource *source = userdata;
1112         return handle_raw_source(event, source->fd, EPOLLIN, server);