fd 313 cib/main.c int (*ccm_api_activate) (const oc_ev_t * token, int *fd) = fd 85 crmd/heartbeat.c int (*ccm_api_activate) (const oc_ev_t * token, int *fd) = fd 141 fencing/test.c rc = st->cmds->connect(st, crm_system_name, &pollfd.fd); fd 288 fencing/test.c rc = st->cmds->connect(st, crm_system_name, &pollfd.fd); fd 312 fencing/test.c rc = st->cmds->connect(st, crm_system_name, &pollfd.fd); fd 44 include/crm/common/internal.h int crm_write_sync(int fd, const char *contents); fd 45 include/crm/common/internal.h int crm_set_nonblocking(int fd); fd 94 include/crm/common/mainloop.h mainloop_io_t *mainloop_add_fd(const char *name, int priority, int fd, void *userdata, fd 160 include/crm/common/xml.h int write_xml_fd(xmlNode * xml_node, const char *filename, int fd, gboolean compress); fd 287 include/crm/lrmd.h int (*connect) (lrmd_t * lrmd, const char *client_name, int *fd); fd 220 include/portability.h int fd; /**< as Unix file descriptor */ fd 350 lib/cib/cib_file.c int rc, fd; fd 390 lib/cib/cib_file.c fd = mkstemp(tmp_cib); fd 391 lib/cib/cib_file.c if (fd < 0) { fd 399 lib/cib/cib_file.c if (fchmod(fd, S_IRUSR | S_IWUSR) < 0) { fd 405 lib/cib/cib_file.c if (cib_do_chown && (fchown(fd, cib_file_owner, cib_file_group) < 0)) { fd 413 lib/cib/cib_file.c if (write_xml_fd(cib_root, tmp_cib, fd, FALSE) <= 0) { fd 426 lib/cib/cib_file.c fd = mkstemp(tmp_digest); fd 427 lib/cib/cib_file.c if (fd < 0) { fd 432 lib/cib/cib_file.c if (cib_do_chown && (fchown(fd, cib_file_owner, cib_file_group) < 0)) { fd 436 lib/cib/cib_file.c close(fd); fd 439 lib/cib/cib_file.c if (crm_write_sync(fd, digest) < 0) { fd 442 lib/cib/cib_file.c close(fd); fd 445 lib/cib/cib_file.c close(fd); fd 253 lib/cluster/corosync.c int fd = 0; fd 293 lib/cluster/corosync.c rc = quorum_fd_get(pcmk_quorum_handle, &fd); fd 299 lib/cluster/corosync.c mainloop_add_fd("quorum", G_PRIORITY_HIGH, fd, dispatch, &quorum_fd_callbacks); fd 439 lib/cluster/cpg.c int fd = 0; fd 487 lib/cluster/cpg.c rc = cpg_fd_get(handle, &fd); fd 495 lib/cluster/cpg.c mainloop_add_fd("corosync-cpg", G_PRIORITY_MEDIUM, fd, cluster, &cpg_fd_callbacks); fd 438 lib/cluster/legacy.c int rc = -1, fd = -1; fd 466 lib/cluster/legacy.c fd = cman_get_fd(pcmk_cman_handle); fd 468 lib/cluster/legacy.c mainloop_add_fd("cman", G_PRIORITY_MEDIUM, fd, dispatch, &cman_fd_callbacks); fd 360 lib/common/io.c int fd; fd 369 lib/common/io.c fd = dirfd(directory); fd 370 lib/common/io.c if (fd < 0) { fd 375 lib/common/io.c if (fsync(fd) < 0) { fd 441 lib/common/io.c crm_write_sync(int fd, const char *contents) fd 444 lib/common/io.c FILE *fp = fdopen(fd, "w"); fd 471 lib/common/io.c crm_set_nonblocking(int fd) fd 473 lib/common/io.c int flag = fcntl(fd, F_GETFL); fd 478 lib/common/io.c if (fcntl(fd, F_SETFL, flag | O_NONBLOCK) < 0) { fd 858 lib/common/ipc.c client->pfd.fd = -1; fd 883 lib/common/ipc.c client->pfd.fd = crm_ipc_get_fd(client); fd 884 lib/common/ipc.c if (client->pfd.fd < 0) { fd 944 lib/common/ipc.c int fd = 0; fd 946 lib/common/ipc.c if (client && client->ipc && (qb_ipcc_fd_get(client->ipc, &fd) == 0)) { fd 947 lib/common/ipc.c return fd; fd 968 lib/common/ipc.c } else if (client->pfd.fd < 0) { fd 975 lib/common/ipc.c client->pfd.fd = -EINVAL; fd 234 lib/common/logging.c int fd = 0, rc = 0; fd 324 lib/common/logging.c fd = qb_log_file_open(filename); fd 326 lib/common/logging.c if (fd < 0) { fd 332 lib/common/logging.c default_fd = fd; fd 340 lib/common/logging.c qb_log_ctl(fd, QB_LOG_CONF_ENABLED, QB_TRUE); fd 434 lib/common/mainloop.c gint fd = g_io_channel_unix_get_fd(gio); fd 436 lib/common/mainloop.c crm_trace("%p.%d %d", data, fd, condition); fd 442 lib/common/mainloop.c return (adaptor->fn(fd, condition, adaptor->data) == 0); fd 460 lib/common/mainloop.c gio_poll_dispatch_update(enum qb_loop_priority p, int32_t fd, int32_t evts, fd 467 lib/common/mainloop.c res = qb_array_index(gio_map, fd, (void **)&adaptor); fd 469 lib/common/mainloop.c crm_err("Array lookup failed for fd=%d: %d", fd, res); fd 473 lib/common/mainloop.c crm_trace("Adding fd=%d to mainloop as adaptor %p", fd, adaptor); fd 476 lib/common/mainloop.c crm_err("Adaptor for descriptor %d is still in-use", fd); fd 480 lib/common/mainloop.c crm_err("Adaptor for descriptor %d is not in-use", fd); fd 485 lib/common/mainloop.c channel = g_io_channel_unix_new(fd); fd 487 lib/common/mainloop.c crm_err("No memory left to add fd=%d", fd); fd 528 lib/common/mainloop.c gio_poll_dispatch_add(enum qb_loop_priority p, int32_t fd, int32_t evts, fd 531 lib/common/mainloop.c return gio_poll_dispatch_update(p, fd, evts, data, fn, QB_TRUE); fd 535 lib/common/mainloop.c gio_poll_dispatch_mod(enum qb_loop_priority p, int32_t fd, int32_t evts, fd 538 lib/common/mainloop.c return gio_poll_dispatch_update(p, fd, evts, data, fn, QB_FALSE); fd 542 lib/common/mainloop.c gio_poll_dispatch_del(int32_t fd) fd 546 lib/common/mainloop.c crm_trace("Looking for fd=%d", fd); fd 547 lib/common/mainloop.c if (qb_array_index(gio_map, fd, (void **)&adaptor) == 0) { fd 630 lib/common/mainloop.c int fd; fd 647 lib/common/mainloop.c CRM_ASSERT(client->fd == g_io_channel_unix_get_fd(gio)); fd 774 lib/common/mainloop.c int32_t fd = crm_ipc_get_fd(conn); fd 776 lib/common/mainloop.c client = mainloop_add_fd(name, priority, fd, userdata, NULL); fd 810 lib/common/mainloop.c mainloop_add_fd(const char *name, int priority, int fd, void *userdata, fd 815 lib/common/mainloop.c if (fd >= 0) { fd 828 lib/common/mainloop.c client->fd = fd; fd 829 lib/common/mainloop.c client->channel = g_io_channel_unix_new(fd); fd 845 lib/common/mainloop.c crm_trace("Added connection %d for %s[%p].%d", client->source, client->name, client, fd); fd 49 lib/common/procfs.c int fd, local_pid; fd 70 lib/common/procfs.c fd = open(procpath, O_RDONLY); fd 71 lib/common/procfs.c if (fd < 0 ) { fd 74 lib/common/procfs.c if (fstat(fd, &statbuf) < 0) { fd 75 lib/common/procfs.c close(fd); fd 78 lib/common/procfs.c close(fd); fd 485 lib/common/remote.c fds.fd = sock; fd 624 lib/common/schemas.c int fd = 0; fd 633 lib/common/schemas.c fd = mkstemp(filename); fd 634 lib/common/schemas.c write_xml_fd(xml_blob, filename, fd, FALSE); fd 783 lib/common/utils.c int fd; fd 788 lib/common/utils.c if ((fd = open(filename, O_RDONLY)) < 0) { fd 792 lib/common/utils.c if (fstat(fd, &sbuf) >= 0 && sbuf.st_size < LOCKSTRLEN) { fd 798 lib/common/utils.c if (read(fd, buf, sizeof(buf)) < 1) { fd 811 lib/common/utils.c if (fd >= 0) { fd 812 lib/common/utils.c close(fd); fd 848 lib/common/utils.c int fd = 0, rc = 0; fd 862 lib/common/utils.c if ((fd = open(filename, O_CREAT | O_WRONLY | O_EXCL, 0644)) < 0) { fd 868 lib/common/utils.c rc = write(fd, buf, LOCKSTRLEN); fd 869 lib/common/utils.c close(fd); fd 3143 lib/common/xml.c write_xml_fd(xmlNode * xml_node, const char *filename, int fd, gboolean compress) fd 3147 lib/common/xml.c CRM_CHECK(fd > 0, return -1); fd 3148 lib/common/xml.c stream = fdopen(fd, "w"); fd 711 lib/fencing/st_client.c read_output(int fd) fd 718 lib/fencing/st_client.c if (!fd) { fd 725 lib/fencing/st_client.c more = read(fd, buffer, READ_MAX - 1); fd 958 lib/lrmd/lrmd_client.c lrmd_ipc_connect(lrmd_t * lrmd, int *fd) fd 970 lib/lrmd/lrmd_client.c if (fd) { fd 974 lib/lrmd/lrmd_client.c *fd = crm_ipc_get_fd(native->ipc); fd 1207 lib/lrmd/lrmd_client.c lrmd_tls_connect(lrmd_t * lrmd, int *fd) fd 1254 lib/lrmd/lrmd_client.c if (fd) { fd 1255 lib/lrmd/lrmd_client.c *fd = sock; fd 1270 lib/lrmd/lrmd_client.c lrmd_api_connect(lrmd_t * lrmd, const char *name, int *fd) fd 1277 lib/lrmd/lrmd_client.c rc = lrmd_ipc_connect(lrmd, fd); fd 1281 lib/lrmd/lrmd_client.c rc = lrmd_tls_connect(lrmd, fd); fd 546 lib/services/dbus.c int fd = dbus_watch_get_unix_fd(watch); fd 549 lib/services/dbus.c "dbus", G_PRIORITY_DEFAULT, fd, watch, &pcmk_dbus_cb); fd 551 lib/services/dbus.c crm_trace("Added watch %p with fd=%d to client %p", watch, fd, client); fd 39 lib/services/services_linux.c svc_read_output(int fd, svc_action_t * op, bool is_stderr) fd 47 lib/services/services_linux.c if (fd < 0) { fd 67 lib/services/services_linux.c rc = read(fd, buf, buf_read_len); fd 481 lib/services/services_linux.c fds[0].fd = op->opaque->stdout_fd; fd 485 lib/services/services_linux.c fds[1].fd = op->opaque->stderr_fd; fd 489 lib/services/services_linux.c fds[2].fd = sfd; fd 246 lrmd/tls_backend.c int fd; fd 253 lrmd/tls_backend.c fd = socket(addr->ai_family, addr->ai_socktype, addr->ai_protocol); fd 254 lrmd/tls_backend.c if (fd < 0) { fd 260 lrmd/tls_backend.c rc = setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval)); fd 263 lrmd/tls_backend.c close(fd); fd 269 lrmd/tls_backend.c rc = setsockopt(fd, IPPROTO_IPV6, IPV6_V6ONLY, &optval, sizeof(optval)); fd 272 lrmd/tls_backend.c close(fd); fd 277 lrmd/tls_backend.c if (bind(fd, addr->ai_addr, addr->ai_addrlen) != 0) { fd 278 lrmd/tls_backend.c close(fd); fd 282 lrmd/tls_backend.c if (listen(fd, 10) == -1) { fd 284 lrmd/tls_backend.c close(fd); fd 290 lrmd/tls_backend.c return fd; fd 114 mcp/corosync.c int fd = 0, retries = 0; fd 128 mcp/corosync.c rc = corosync_cfg_fd_get(cfg_handle, &fd); fd 143 mcp/corosync.c mainloop_add_fd("corosync-cfg", G_PRIORITY_DEFAULT, fd, &cfg_handle, &cfg_fd_callbacks); fd 293 replace/uuid_parse.c static int fd = -2; fd 296 replace/uuid_parse.c if (fd == -2) { fd 298 replace/uuid_parse.c fd = open("/dev/urandom", O_RDONLY); fd 299 replace/uuid_parse.c if (fd == -1) fd 300 replace/uuid_parse.c fd = open("/dev/random", O_RDONLY | O_NONBLOCK); fd 307 replace/uuid_parse.c return fd; fd 317 replace/uuid_parse.c int i, n = nbytes, fd = get_random_fd(); fd 321 replace/uuid_parse.c if (fd >= 0) { fd 323 replace/uuid_parse.c i = read(fd, cp, n); fd 485 tools/crm_node.c int (*ccm_api_activate) (const oc_ev_t * token, int *fd) = fd 163 tools/crm_uuid.c int fd; fd 176 tools/crm_uuid.c if ((fd = open(UUID_FILE, O_WRONLY | O_SYNC | O_CREAT, 0644)) < 0) { fd 181 tools/crm_uuid.c if (write(fd, uuid.uuid, UUID_LEN) != UUID_LEN) { fd 186 tools/crm_uuid.c if (close(fd) < 0) {