Lines Matching refs:fd
266 writeall (int fd, const void *buf, size_t len) in writeall() argument
272 ret = TEMP_FAILURE_RETRY (send (fd, buf, n, MSG_NOSIGNAL)); in writeall()
502 int fd = open (dbs[cnt].db_filename, O_RDWR | O_CLOEXEC); in nscd_init() local
503 if (fd != -1) in nscd_init()
510 ssize_t n = TEMP_FAILURE_RETRY (read (fd, &head, in nscd_init()
512 if (n != sizeof (head) || fstat64 (fd, &st) != 0) in nscd_init()
553 MAP_SHARED, fd, 0)) in nscd_init()
576 dbs[cnt].wr_fd = fd; in nscd_init()
577 fd = -1; in nscd_init()
596 if (fd != -1) in nscd_init()
597 close (fd); in nscd_init()
617 int fd; in nscd_init() local
621 fd = open (dbs[cnt].db_filename, in nscd_init()
624 if (fd != -1 && dbs[cnt].shared) in nscd_init()
631 fd = mkostemp (fname, O_CLOEXEC); in nscd_init()
635 if (fd != -1) in nscd_init()
644 if (fd == -1) in nscd_init()
688 if (pwrite (fd, tmpbuf, towrite, offset) != towrite) in nscd_init()
696 if (pwrite (fd, tmpbuf, ps, offset) == -1) in nscd_init()
703 && pwrite (fd, tmpbuf, remaining, offset) != remaining) in nscd_init()
718 if ((TEMP_FAILURE_RETRY (write (fd, &head, sizeof (head))) in nscd_init()
720 || (TEMP_FAILURE_RETRY_VAL (posix_fallocate (fd, 0, total)) in nscd_init()
724 MAP_SHARED, fd, 0)) == MAP_FAILED) in nscd_init()
743 dbs[cnt].wr_fd = fd; in nscd_init()
745 fd = -1; in nscd_init()
749 if (fd != -1) in nscd_init()
750 close (fd); in nscd_init()
941 invalidate_cache (char *key, int fd) in invalidate_cache() argument
974 writeall (fd, &resp, sizeof (resp)); in invalidate_cache()
981 prune_cache (&dbs[number], LONG_MAX, fd); in invalidate_cache()
987 writeall (fd, &resp, sizeof (resp)); in invalidate_cache()
994 send_ro_fd (struct database_dyn *db, char *key, int fd) in send_ro_fd() argument
1035 (void) TEMP_FAILURE_RETRY (sendmsg (fd, &msg, MSG_NOSIGNAL)); in send_ro_fd()
1045 handle_request (int fd, request_header *req, void *key, uid_t uid, pid_t pid) in handle_request() argument
1057 if (selinux_enabled && nscd_request_avc_has_perm (fd, req->type) != 0) in handle_request()
1113 if (TEMP_FAILURE_RETRY (send (fd, db->disabled_iov->iov_base, in handle_request()
1142 if (writeall (fd, cached->data, cached->recsize) != cached->recsize in handle_request()
1170 addpwbyname (db, fd, req, key, uid); in handle_request()
1174 addpwbyuid (db, fd, req, key, uid); in handle_request()
1178 addgrbyname (db, fd, req, key, uid); in handle_request()
1182 addgrbygid (db, fd, req, key, uid); in handle_request()
1186 addhstbyname (db, fd, req, key, uid); in handle_request()
1190 addhstbynamev6 (db, fd, req, key, uid); in handle_request()
1194 addhstbyaddr (db, fd, req, key, uid); in handle_request()
1198 addhstbyaddrv6 (db, fd, req, key, uid); in handle_request()
1202 addhstai (db, fd, req, key, uid); in handle_request()
1206 addinitgroups (db, fd, req, key, uid); in handle_request()
1210 addservbyname (db, fd, req, key, uid); in handle_request()
1214 addservbyport (db, fd, req, key, uid); in handle_request()
1218 addgetnetgrent (db, fd, req, key, uid); in handle_request()
1222 addinnetgr (db, fd, req, key, uid); in handle_request()
1234 if (getsockopt (fd, SOL_SOCKET, SO_PEERCRED, &caller, &optlen) < 0) in handle_request()
1256 send_stats (fd, dbs); in handle_request()
1261 invalidate_cache (key, fd); in handle_request()
1273 send_ro_fd (reqinfo[req->type].db, key, fd); in handle_request()
1286 int fd = open ("/proc/self/cmdline", O_RDONLY); in read_cmdline() local
1287 if (fd < 0) in read_cmdline()
1294 close (fd); in read_cmdline()
1307 close (fd); in read_cmdline()
1315 ssize_t n = TEMP_FAILURE_RETRY (read (fd, buffer + current, in read_cmdline()
1321 close (fd); in read_cmdline()
1330 close (fd); in read_cmdline()
1471 int fd; member
1619 int fd = it->fd; in nscd_run_worker() local
1630 if (__builtin_expect (TEMP_FAILURE_RETRY (read (fd, &req, sizeof (req))) in nscd_run_worker()
1656 if (getsockopt (fd, SOL_SOCKET, SO_PEERCRED, &caller, &optlen) == 0) in nscd_run_worker()
1676 if (__builtin_expect (TEMP_FAILURE_RETRY (read (fd, keybuf, in nscd_run_worker()
1702 handle_request (fd, &req, keybuf, uid, pid); in nscd_run_worker()
1707 close (fd); in nscd_run_worker()
1722 fd_ready (int fd) in fd_ready() argument
1733 fdlist[inner].fd = fd; in fd_ready()
2018 conns[0].fd = sock; in main_loop_poll()
2026 conns[1].fd = inotify_fd; in main_loop_poll()
2038 conns[nused].fd = nl_status_fd; in main_loop_poll()
2067 int fd = TEMP_FAILURE_RETRY (accept4 (sock, NULL, NULL, in main_loop_poll() local
2071 if (fd >= 0) in main_loop_poll()
2075 conns[firstfree].fd = fd; in main_loop_poll()
2083 while (firstfree < nused && conns[firstfree].fd != -1); in main_loop_poll()
2087 close (fd); in main_loop_poll()
2095 if (inotify_fd != -1 && conns[1].fd == inotify_fd) in main_loop_poll()
2106 conns[1].fd = -1; in main_loop_poll()
2137 fd_ready (conns[cnt].fd); in main_loop_poll()
2140 conns[cnt].fd = -1; in main_loop_poll()
2146 while (conns[nused - 1].fd == -1); in main_loop_poll()
2164 if (conns[cnt].fd != -1 && starttime[cnt] < laststart) in main_loop_poll()
2167 (void) close (conns[cnt].fd); in main_loop_poll()
2168 conns[cnt].fd = -1; in main_loop_poll()
2175 while (conns[nused - 1].fd == -1); in main_loop_poll()
2195 ev.data.fd = sock; in main_loop_epoll()
2204 ev.data.fd = inotify_fd; in main_loop_epoll()
2216 ev.data.fd = nl_status_fd; in main_loop_epoll()
2233 if (revs[cnt].data.fd == sock) in main_loop_epoll()
2236 int fd = TEMP_FAILURE_RETRY (accept4 (sock, NULL, NULL, in main_loop_epoll() local
2240 if (fd >= 0) in main_loop_epoll()
2243 ev.data.fd = fd; in main_loop_epoll()
2244 if (fd >= nconns in main_loop_epoll()
2245 || epoll_ctl (efd, EPOLL_CTL_ADD, fd, &ev) == -1) in main_loop_epoll()
2248 close (fd); in main_loop_epoll()
2252 starttime[fd] = now; in main_loop_epoll()
2254 if (fd > highest) in main_loop_epoll()
2255 highest = fd; in main_loop_epoll()
2262 else if (revs[cnt].data.fd == inotify_fd) in main_loop_epoll()
2279 else if (revs[cnt].data.fd == nl_status_fd) in main_loop_epoll()
2293 (void) epoll_ctl (efd, EPOLL_CTL_DEL, revs[cnt].data.fd, NULL); in main_loop_epoll()
2296 fd_ready (revs[cnt].data.fd); in main_loop_epoll()
2299 starttime[revs[cnt].data.fd] = 0; in main_loop_epoll()
2300 if (revs[cnt].data.fd == highest) in main_loop_epoll()