fd 272 daemons/execd/remoted_tls.c int fd; fd 279 daemons/execd/remoted_tls.c fd = socket(addr->ai_family, addr->ai_socktype, addr->ai_protocol); fd 280 daemons/execd/remoted_tls.c if (fd < 0) { fd 288 daemons/execd/remoted_tls.c rc = setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval)); fd 292 daemons/execd/remoted_tls.c close(fd); fd 298 daemons/execd/remoted_tls.c rc = setsockopt(fd, IPPROTO_IPV6, IPV6_V6ONLY, &optval, sizeof(optval)); fd 302 daemons/execd/remoted_tls.c close(fd); fd 307 daemons/execd/remoted_tls.c if (bind(fd, addr->ai_addr, addr->ai_addrlen) != 0) { fd 310 daemons/execd/remoted_tls.c close(fd); fd 314 daemons/execd/remoted_tls.c if (listen(fd, 10) == -1) { fd 317 daemons/execd/remoted_tls.c close(fd); fd 320 daemons/execd/remoted_tls.c return fd; fd 161 daemons/fenced/cts-fence-helper.c rc = st->cmds->connect(st, crm_system_name, &pollfd.fd); fd 324 daemons/fenced/cts-fence-helper.c rc = st->cmds->connect(st, crm_system_name, &pollfd.fd); fd 352 daemons/fenced/cts-fence-helper.c rc = st->cmds->connect(st, crm_system_name, &pollfd.fd); fd 140 daemons/pacemakerd/pcmkd_corosync.c int fd = -1, retries = 0, rv; fd 159 daemons/pacemakerd/pcmkd_corosync.c rc = corosync_cfg_fd_get(cfg_handle, &fd); fd 167 daemons/pacemakerd/pcmkd_corosync.c if (!(rv = crm_ipc_is_authentic_process(fd, (uid_t) 0,(gid_t) 0, &found_pid, fd 199 daemons/pacemakerd/pcmkd_corosync.c mainloop_add_fd("corosync-cfg", G_PRIORITY_DEFAULT, fd, &cfg_handle, &cfg_fd_callbacks); fd 232 daemons/pacemakerd/pcmkd_corosync.c int fd = -1; fd 238 daemons/pacemakerd/pcmkd_corosync.c if (cpg_fd_get(local_handle, &fd) != CS_OK) { fd 270 daemons/pacemakerd/pcmkd_corosync.c int fd = -1; fd 299 daemons/pacemakerd/pcmkd_corosync.c rc = cmap_fd_get(local_handle, &fd); fd 308 daemons/pacemakerd/pcmkd_corosync.c if (!(rv = crm_ipc_is_authentic_process(fd, (uid_t) 0,(gid_t) 0, &found_pid, fd 38 include/crm/common/io_internal.h int pcmk__write_sync(int fd, const char *contents); fd 39 include/crm/common/io_internal.h int pcmk__set_nonblocking(int fd); fd 92 include/crm/common/ipc_internal.h int pcmk__ipc_fd(crm_ipc_t *ipc, int *fd); fd 160 include/crm/common/mainloop.h mainloop_io_t *mainloop_add_fd(const char *name, int priority, int fd, void *userdata, fd 33 include/crm/common/xml_io_internal.h int pcmk__xml2fd(int fd, xmlNode *cur); fd 34 include/crm/common/xml_io_internal.h int pcmk__xml_write_fd(const xmlNode *xml, const char *filename, int fd); fd 191 include/crm/lrmd.h int (*connect) (lrmd_t *lrmd, const char *client_name, int *fd); fd 923 lib/cib/cib_file.c int rc, fd; fd 959 lib/cib/cib_file.c fd = mkstemp(tmp_cib); fd 960 lib/cib/cib_file.c if (fd < 0) { fd 968 lib/cib/cib_file.c if (fchmod(fd, S_IRUSR | S_IWUSR) < 0) { fd 974 lib/cib/cib_file.c if (cib_do_chown && (fchown(fd, cib_file_owner, cib_file_group) < 0)) { fd 982 lib/cib/cib_file.c if (pcmk__xml_write_fd(cib_root, tmp_cib, fd) != pcmk_rc_ok) { fd 995 lib/cib/cib_file.c fd = mkstemp(tmp_digest); fd 996 lib/cib/cib_file.c if (fd < 0) { fd 1001 lib/cib/cib_file.c if (cib_do_chown && (fchown(fd, cib_file_owner, cib_file_group) < 0)) { fd 1005 lib/cib/cib_file.c close(fd); fd 1008 lib/cib/cib_file.c rc = pcmk__write_sync(fd, digest); fd 1013 lib/cib/cib_file.c close(fd); fd 1016 lib/cib/cib_file.c close(fd); fd 22 lib/cib/fuzzers/cib_file_fuzzer.c int fd = 0; fd 110 lib/cluster/corosync.c int fd = -1; fd 144 lib/cluster/corosync.c rc = cmap_fd_get(cmap_handle, &fd); fd 152 lib/cluster/corosync.c if (!(rv = crm_ipc_is_authentic_process(fd, (uid_t) 0,(gid_t) 0, &found_pid, fd 352 lib/cluster/corosync.c int fd = 0; fd 397 lib/cluster/corosync.c rc = quorum_fd_get(pcmk_quorum_handle, &fd); fd 405 lib/cluster/corosync.c if (!(rv = crm_ipc_is_authentic_process(fd, (uid_t) 0,(gid_t) 0, &found_pid, fd 440 lib/cluster/corosync.c mainloop_add_fd("quorum", G_PRIORITY_HIGH, fd, dispatch, &quorum_fd_callbacks); fd 565 lib/cluster/corosync.c int fd = -1; fd 587 lib/cluster/corosync.c rc = cmap_fd_get(cmap_handle, &fd); fd 595 lib/cluster/corosync.c if (!(rv = crm_ipc_is_authentic_process(fd, (uid_t) 0,(gid_t) 0, &found_pid, fd 678 lib/cluster/corosync.c int fd = -1; fd 691 lib/cluster/corosync.c rc = cmap_fd_get(handle, &fd); fd 699 lib/cluster/corosync.c if (!(rv = crm_ipc_is_authentic_process(fd, (uid_t) 0,(gid_t) 0, &found_pid, fd 739 lib/cluster/corosync.c int fd = -1; fd 770 lib/cluster/corosync.c cs_rc = cmap_fd_get(cmap_handle, &fd); fd 779 lib/cluster/corosync.c rc = crm_ipc_is_authentic_process(fd, (uid_t) 0, (gid_t) 0, fd 113 lib/cluster/cpg.c int fd = -1; fd 135 lib/cluster/cpg.c rc = cpg_fd_get(local_handle, &fd); fd 143 lib/cluster/cpg.c rv = crm_ipc_is_authentic_process(fd, (uid_t) 0, (gid_t) 0, &found_pid, fd 784 lib/cluster/cpg.c int fd = -1; fd 829 lib/cluster/cpg.c rc = cpg_fd_get(handle, &fd); fd 837 lib/cluster/cpg.c if (!(rv = crm_ipc_is_authentic_process(fd, (uid_t) 0,(gid_t) 0, &found_pid, fd 869 lib/cluster/cpg.c mainloop_add_fd("corosync-cpg", G_PRIORITY_MEDIUM, fd, cluster, &cpg_fd_callbacks); fd 394 lib/common/io.c int fd; fd 403 lib/common/io.c fd = dirfd(directory); fd 404 lib/common/io.c if (fd < 0) { fd 409 lib/common/io.c if (fsync(fd) < 0) { fd 490 lib/common/io.c pcmk__write_sync(int fd, const char *contents) fd 493 lib/common/io.c FILE *fp = fdopen(fd, "w"); fd 520 lib/common/io.c pcmk__set_nonblocking(int fd) fd 522 lib/common/io.c int flag = fcntl(fd, F_GETFL); fd 527 lib/common/io.c if (fcntl(fd, F_SETFL, flag | O_NONBLOCK) < 0) { fd 398 lib/common/ipc_client.c rc = pcmk__ipc_fd(api->ipc, &(pollfd.fd)); fd 874 lib/common/ipc_client.c client->pfd.fd = -1; fd 909 lib/common/ipc_client.c rc = qb_ipcc_fd_get(ipc->ipc, &ipc->pfd.fd); fd 922 lib/common/ipc_client.c rc = is_ipc_provider_expected(ipc->ipc, ipc->pfd.fd, cl_uid, cl_gid, fd 1001 lib/common/ipc_client.c pcmk__ipc_fd(crm_ipc_t *ipc, int *fd) fd 1003 lib/common/ipc_client.c if ((ipc == NULL) || (fd == NULL)) { fd 1006 lib/common/ipc_client.c if ((ipc->ipc == NULL) || (ipc->pfd.fd < 0)) { fd 1009 lib/common/ipc_client.c *fd = ipc->pfd.fd; fd 1016 lib/common/ipc_client.c int fd = -1; fd 1018 lib/common/ipc_client.c if (pcmk__ipc_fd(client, &fd) != pcmk_rc_ok) { fd 1024 lib/common/ipc_client.c return fd; fd 1040 lib/common/ipc_client.c } else if (client->pfd.fd < 0) { fd 1047 lib/common/ipc_client.c client->pfd.fd = -EINVAL; fd 1553 lib/common/ipc_client.c int fd; fd 1564 lib/common/ipc_client.c &(pollfd.fd)); fd 1593 lib/common/ipc_client.c qb_rc = qb_ipcc_fd_get(c, &fd); fd 1601 lib/common/ipc_client.c auth_rc = is_ipc_provider_expected(c, fd, refuid, refgid, fd 293 lib/common/logging.c enable_logfile(int fd) fd 295 lib/common/logging.c qb_log_ctl(fd, QB_LOG_CONF_ENABLED, QB_TRUE); fd 297 lib/common/logging.c qb_log_ctl(fd, QB_LOG_CONF_FILE_SYNC, 1); // Turn on synchronous writes fd 302 lib/common/logging.c qb_log_ctl(fd, QB_LOG_CONF_MAX_LINE_LEN, 800); fd 309 lib/common/logging.c disable_logfile(int fd) fd 311 lib/common/logging.c qb_log_ctl(fd, QB_LOG_CONF_ENABLED, QB_FALSE); fd 338 lib/common/logging.c int fd = 0; fd 384 lib/common/logging.c fd = qb_log_file_open(filename); fd 385 lib/common/logging.c if (fd < 0) { fd 387 lib/common/logging.c filename, strerror(-fd)); fd 388 lib/common/logging.c return -fd; // == +errno fd 392 lib/common/logging.c default_fd = fd; fd 401 lib/common/logging.c enable_logfile(fd); fd 445 lib/common/mainloop.c gint fd = g_io_channel_unix_get_fd(gio); fd 447 lib/common/mainloop.c crm_trace("%p.%d %d", data, fd, condition); fd 453 lib/common/mainloop.c return (adaptor->fn(fd, condition, adaptor->data) == 0); fd 508 lib/common/mainloop.c gio_poll_dispatch_update(enum qb_loop_priority p, int32_t fd, int32_t evts, fd 515 lib/common/mainloop.c res = qb_array_index(gio_map, fd, (void **)&adaptor); fd 517 lib/common/mainloop.c crm_err("Array lookup failed for fd=%d: %d", fd, res); fd 521 lib/common/mainloop.c crm_trace("Adding fd=%d to mainloop as adaptor %p", fd, adaptor); fd 524 lib/common/mainloop.c crm_err("Adaptor for descriptor %d is still in-use", fd); fd 528 lib/common/mainloop.c crm_err("Adaptor for descriptor %d is not in-use", fd); fd 533 lib/common/mainloop.c channel = g_io_channel_unix_new(fd); fd 535 lib/common/mainloop.c crm_err("No memory left to add fd=%d", fd); fd 576 lib/common/mainloop.c gio_poll_dispatch_add(enum qb_loop_priority p, int32_t fd, int32_t evts, fd 579 lib/common/mainloop.c return gio_poll_dispatch_update(p, fd, evts, data, fn, QB_TRUE); fd 583 lib/common/mainloop.c gio_poll_dispatch_mod(enum qb_loop_priority p, int32_t fd, int32_t evts, fd 586 lib/common/mainloop.c return gio_poll_dispatch_update(p, fd, evts, data, fn, QB_FALSE); fd 590 lib/common/mainloop.c gio_poll_dispatch_del(int32_t fd) fd 594 lib/common/mainloop.c crm_trace("Looking for fd=%d", fd); fd 595 lib/common/mainloop.c if (qb_array_index(gio_map, fd, (void **)&adaptor) == 0) { fd 692 lib/common/mainloop.c int fd; fd 719 lib/common/mainloop.c pcmk__assert(client->fd == g_io_channel_unix_get_fd(gio)); fd 866 lib/common/mainloop.c int fd = -1; fd 878 lib/common/mainloop.c rc = pcmk__ipc_fd(ipc, &fd); fd 886 lib/common/mainloop.c *source = mainloop_add_fd(ipc_name, priority, fd, userdata, NULL); fd 956 lib/common/mainloop.c mainloop_add_fd(const char *name, int priority, int fd, void *userdata, fd 961 lib/common/mainloop.c if (fd >= 0) { fd 974 lib/common/mainloop.c client->fd = fd; fd 975 lib/common/mainloop.c client->channel = g_io_channel_unix_new(fd); fd 991 lib/common/mainloop.c crm_trace("Added connection %d for %s[%p].%d", client->source, client->name, client, fd); fd 109 lib/common/pid.c int fd; fd 117 lib/common/pid.c fd = open(filename, O_RDONLY); fd 118 lib/common/pid.c if (fd < 0) { fd 122 lib/common/pid.c if ((fstat(fd, &sbuf) >= 0) && (sbuf.st_size < LOCKSTRLEN)) { fd 128 lib/common/pid.c if (read(fd, buf, sizeof(buf)) < 1) { fd 151 lib/common/pid.c close(fd); fd 213 lib/common/pid.c int fd = 0; fd 223 lib/common/pid.c fd = open(filename, O_CREAT | O_WRONLY | O_EXCL, 0644); fd 224 lib/common/pid.c if (fd < 0) { fd 229 lib/common/pid.c rc = write(fd, buf, LOCKSTRLEN); fd 230 lib/common/pid.c close(fd); fd 38 lib/common/procfs.c int fd, local_pid; fd 59 lib/common/procfs.c fd = open(procpath, O_RDONLY); fd 60 lib/common/procfs.c if (fd < 0 ) { fd 63 lib/common/procfs.c if (fstat(fd, &statbuf) < 0) { fd 64 lib/common/procfs.c close(fd); fd 67 lib/common/procfs.c close(fd); fd 409 lib/common/remote.c fds.fd = sock; fd 30 lib/common/unittest.c int fd; fd 33 lib/common/unittest.c fd = mkstemp(xmllint_input); fd 34 lib/common/unittest.c if (fd < 0) { fd 38 lib/common/unittest.c rc = pcmk__xml2fd(fd, xml); fd 44 lib/common/unittest.c close(fd); fd 117 lib/common/unittest.c int fd; fd 122 lib/common/unittest.c fd = mkstemp(out_path); fd 123 lib/common/unittest.c if (fd < 0) { fd 130 lib/common/unittest.c close(fd); fd 134 lib/common/unittest.c if (pcmk__write_sync(fd, contents) != pcmk_rc_ok) { fd 138 lib/common/unittest.c close(fd); fd 576 lib/common/xml_io.c pcmk__xml_write_fd(const xmlNode *xml, const char *filename, int fd) fd 580 lib/common/xml_io.c CRM_CHECK((xml != NULL) && (fd > 0), return EINVAL); fd 581 lib/common/xml_io.c stream = fdopen(fd, "w"); fd 624 lib/common/xml_io.c pcmk__xml2fd(int fd, xmlNode *cur) fd 628 lib/common/xml_io.c xmlOutputBuffer *fd_out = xmlOutputBufferCreateFd(fd, NULL); fd 640 lib/common/xml_io.c fsync(fd); fd 1117 lib/lrmd/lrmd_client.c lrmd_ipc_connect(lrmd_t * lrmd, int *fd) fd 1129 lib/lrmd/lrmd_client.c if (fd) { fd 1135 lib/lrmd/lrmd_client.c rc = pcmk__ipc_fd(native->ipc, fd); fd 1625 lib/lrmd/lrmd_client.c lrmd_tls_connect(lrmd_t * lrmd, int *fd) fd 1677 lib/lrmd/lrmd_client.c if (fd) { fd 1678 lib/lrmd/lrmd_client.c *fd = native->sock; fd 1686 lib/lrmd/lrmd_client.c lrmd_api_connect(lrmd_t * lrmd, const char *name, int *fd) fd 1693 lib/lrmd/lrmd_client.c rc = lrmd_ipc_connect(lrmd, fd); fd 1696 lib/lrmd/lrmd_client.c rc = lrmd_tls_connect(lrmd, fd); fd 155 lib/services/dbus.c int fd = dbus_watch_get_unix_fd(watch); fd 157 lib/services/dbus.c mainloop_io_t *client = mainloop_add_fd("dbus", G_PRIORITY_DEFAULT, fd, fd 160 lib/services/dbus.c crm_trace("Added DBus watch for file descriptor %d", fd); fd 78 lib/services/services_linux.c int fd; fd 82 lib/services/services_linux.c fd = signalfd(-1, &(data->mask), SFD_NONBLOCK); fd 83 lib/services/services_linux.c if (fd < 0) { fd 87 lib/services/services_linux.c return fd; fd 92 lib/services/services_linux.c sigchld_close(int fd) fd 94 lib/services/services_linux.c if (fd > 0) { fd 95 lib/services/services_linux.c close(fd); fd 101 lib/services/services_linux.c sigchld_received(int fd, int pid, struct sigchld_data_s *data) fd 106 lib/services/services_linux.c if (fd < 0) { fd 109 lib/services/services_linux.c s = read(fd, &fdsi, sizeof(struct signalfd_siginfo)); fd 223 lib/services/services_linux.c sigchld_close(int fd) fd 230 lib/services/services_linux.c sigchld_received(int fd, int pid, struct sigchld_data_s *data) fd 234 lib/services/services_linux.c if (fd < 0) { fd 239 lib/services/services_linux.c while (read(fd, &ch, 1) == 1) /*omit*/; fd 288 lib/services/services_linux.c svc_read_output(int fd, svc_action_t * op, bool is_stderr) fd 297 lib/services/services_linux.c if (fd < 0) { fd 320 lib/services/services_linux.c rc = read(fd, buf, buf_read_len); fd 602 lib/services/services_linux.c int fd; fd 606 lib/services/services_linux.c fd = op->opaque->stderr_fd; fd 609 lib/services/services_linux.c fd = op->opaque->stdout_fd; fd 615 lib/services/services_linux.c svc_read_output(fd, op, is_stderr); fd 617 lib/services/services_linux.c close(fd); fd 1058 lib/services/services_linux.c fds[0].fd = op->opaque->stdout_fd; fd 1062 lib/services/services_linux.c fds[1].fd = op->opaque->stderr_fd; fd 1066 lib/services/services_linux.c fds[2].fd = sigchld_open(data); fd 1086 lib/services/services_linux.c && sigchld_received(fds[2].fd, op->pid, data)) { fd 1133 lib/services/services_linux.c sigchld_close(fds[2].fd);