| /systemd-251/src/libsystemd/sd-bus/ |
| D | bus-container.c | 23 assert(b->input_fd < 0); in bus_container_connect_socket()
42 b->input_fd = socket(b->sockaddr.sa.sa_family, SOCK_STREAM|SOCK_CLOEXEC|SOCK_NONBLOCK, 0); in bus_container_connect_socket()
43 if (b->input_fd < 0) in bus_container_connect_socket()
46 b->input_fd = fd_move_above_stdio(b->input_fd); in bus_container_connect_socket()
48 b->output_fd = b->input_fd; in bus_container_connect_socket()
62 r = connect(b->input_fd, &b->sockaddr.sa, b->sockaddr_size); in bus_container_connect_socket()
|
| D | bus-socket.c | 548 k = readv(b->input_fd, &iov, 1); in bus_socket_read_auth()
559 k = recvmsg_safe(b->input_fd, &mh, MSG_DONTWAIT|MSG_CMSG_CLOEXEC); in bus_socket_read_auth()
562 k = readv(b->input_fd, &iov, 1); in bus_socket_read_auth()
611 (void) fd_inc_rcvbuf(b->input_fd, SNDBUF_SIZE); in bus_socket_setup()
627 b->ucred_valid = getpeercred(b->input_fd, &b->ucred) >= 0; in bus_get_peercred()
630 r = getpeersec(b->input_fd, &b->label); in bus_get_peercred()
635 r = getpeergroups(b->input_fd, &b->groups); in bus_get_peercred()
688 if (sd_is_socket(b->input_fd, AF_UNIX, 0, 0) <= 0) in bus_socket_start_auth()
691 if (b->output_fd != b->input_fd) in bus_socket_start_auth()
886 assert(b->input_fd < 0); in bus_socket_connect()
[all …]
|
| D | sd-bus.c | 134 if (b->input_fd != b->output_fd) in bus_close_io_fds()
136 b->output_fd = b->input_fd = safe_close(b->input_fd); in bus_close_io_fds()
242 .input_fd = -1, in sd_bus_new()
274 _public_ int sd_bus_set_fd(sd_bus *bus, int input_fd, int output_fd) { in sd_bus_set_fd() argument
278 assert_return(input_fd >= 0, -EBADF); in sd_bus_set_fd()
282 bus->input_fd = input_fd; in sd_bus_set_fd()
1151 assert(b->input_fd >= 0); in bus_start_fd()
1156 (void) fd_get_path(b->input_fd, &pi); in bus_start_fd()
1160 b->input_fd, b->output_fd, in bus_start_fd()
1164 r = fd_nonblock(b->input_fd, true); in bus_start_fd()
[all …]
|
| D | bus-internal.h | 187 int input_fd, output_fd; member
|
| /systemd-251/src/shared/ |
| D | ptyfwd.c | 31 int input_fd; member
102 if (f->input_fd >= 0) { in pty_forward_disconnect()
104 (void) tcsetattr(f->input_fd, TCSANOW, &f->saved_stdin_attr); in pty_forward_disconnect()
106 (void) fd_nonblock(f->input_fd, false); in pty_forward_disconnect()
108 f->input_fd = safe_close(f->input_fd); in pty_forward_disconnect()
211 … k = read(f->input_fd, f->in_buffer + f->in_buffer_full, LINE_MAX - f->in_buffer_full); in shovel()
365 assert(fd == f->input_fd); in on_stdin_event()
420 .input_fd = -1, in pty_forward_new()
443 f->input_fd = fd_reopen(STDIN_FILENO, O_RDONLY|O_CLOEXEC|O_NOCTTY|O_NONBLOCK); in pty_forward_new()
444 if (f->input_fd < 0) { in pty_forward_new()
[all …]
|
| /systemd-251/src/import/ |
| D | export-raw.c | 37 int input_fd; member
71 safe_close(e->input_fd); in raw_export_unref()
95 .input_fd = -1, in raw_export_new()
148 r = btrfs_reflink(e->input_fd, e->output_fd); in raw_export_process()
159 l = sendfile(e->output_fd, e->input_fd, NULL, COPY_BUFFER_SIZE); in raw_export_process()
186 l = read(e->input_fd, input, sizeof(input)); in raw_export_process()
225 (void) copy_times(e->input_fd, e->output_fd, COPY_CRTIME); in raw_export_process()
226 (void) copy_xattr(e->input_fd, e->output_fd, 0); in raw_export_process()
310 e->input_fd = TAKE_FD(tfd); in raw_export_start()
312 e->input_fd = TAKE_FD(sfd); in raw_export_start()
|
| D | import-raw.c | 44 int input_fd; member
109 .input_fd = -1, in raw_import_new()
237 (void) copy_times(i->input_fd, i->output_fd, COPY_CRTIME); in raw_import_finish()
238 (void) copy_xattr(i->input_fd, i->output_fd, 0); in raw_import_finish()
319 assert(i->input_fd >= 0); in raw_import_try_reflink()
331 p = lseek(i->input_fd, 0, SEEK_CUR); in raw_import_try_reflink()
339 r = btrfs_reflink(i->input_fd, i->output_fd); in raw_import_try_reflink()
404 l = read(i->input_fd, i->buffer + i->buffer_size, sizeof(i->buffer) - i->buffer_size); in raw_import_process()
499 if (i->input_fd >= 0) in raw_import_start()
529 i->input_fd = fd; in raw_import_start()
|
| D | import-tar.c | 45 int input_fd; member
111 .input_fd = -1, in tar_import_new()
270 l = read(i->input_fd, i->buffer + i->buffer_size, sizeof(i->buffer) - i->buffer_size); in tar_import_process()
351 if (i->input_fd >= 0) in tar_import_start()
379 i->input_fd = fd; in tar_import_start()
|
| /systemd-251/src/coredump/ |
| D | coredump.c | 335 int input_fd, in save_external_coredump() argument
449 r = copy_bytes(input_fd, fd, max_size, 0); in save_external_coredump()
486 … r = compress_stream(input_fd, fd_compressed, max_size, &partial_uncompressed_size); in save_external_coredump()
769 int input_fd) { in submit_coredump() argument
784 assert(input_fd >= 0); in submit_coredump()
790 r = save_external_coredump(context, input_fd, in submit_coredump()
960 _cleanup_close_ int input_fd = -1; in process_socket() local
1019 assert(input_fd < 0); in process_socket()
1020 input_fd = *(int*) CMSG_DATA(found); in process_socket()
1035 assert(input_fd >= 0); in process_socket()
[all …]
|
| /systemd-251/src/systemd/ |
| D | sd-bus.h | 147 int sd_bus_set_fd(sd_bus *bus, int input_fd, int output_fd);
|