Lines Matching defs:fd
144 "fd > FD_SETSIZE; Use rpc_control(RPC_SVC_USE_POLLFD,...);";
201 * xprt = svc_vc_create(fd, sendsize, recvsize);
205 * fd should be open and bound.
208 svc_vc_create_private(int fd, uint_t sendsize, uint_t recvsize)
214 if (RPC_FD_NOTIN_FDSET(fd)) {
236 if (t_getinfo(fd, &tinfo) == -1) {
261 r->t_call = (struct t_call *)t_alloc(fd, T_CALL, T_ADDR | T_OPT);
270 r->t_bind = (struct t_bind *)t_alloc(fd, T_BIND, T_ADDR);
284 xprt->xp_fd = fd;
298 svc_vc_create(const int fd, const uint_t sendsize, const uint_t recvsize)
302 if ((xprt = svc_vc_create_private(fd, sendsize, recvsize)) != NULL)
312 int fd = parent->xp_fd;
322 xprt->xp_fd = fd;
365 r->t_call = (struct t_call *)t_alloc(fd, T_CALL, T_ADDR | T_OPT);
370 r->t_bind = (struct t_bind *)t_alloc(fd, T_BIND, T_ADDR);
399 svc_fd_create_private(int fd, uint_t sendsize, uint_t recvsize)
405 if (RPC_FD_NOTIN_FDSET(fd)) {
412 if (t_getinfo(fd, &tinfo) == -1) {
431 dummy = makefd_xprt(fd, sendsize, recvsize, tinfo.tsdu, NULL);
434 if (t_getname(fd, &tres, LOCALNAME) == -1)
443 svc_fd_create(const int fd, const uint_t sendsize, const uint_t recvsize)
447 if ((xprt = svc_fd_create_private(fd, sendsize, recvsize)) != NULL)
486 makefd_xprt(int fd, uint_t sendsize, uint_t recvsize, t_scalar_t tsdu,
538 while (fd >= nsvc_xdrs) {
559 if (svc_xdrs[fd] != NULL) {
560 XDR_DESTROY(svc_xdrs[fd]);
561 } else if ((svc_xdrs[fd] = malloc(sizeof (XDR))) == NULL) {
569 (void) memset(svc_xdrs[fd], 0, sizeof (XDR));
570 xdrrec_create(svc_xdrs[fd], 0, recvsize, (caddr_t)xprt,
572 if (svc_xdrs[fd]->x_ops == NULL) {
573 free(svc_xdrs[fd]);
574 svc_xdrs[fd] = NULL;
587 xprt->xp_fd = fd;
901 * the listening fd will be hosed otherwise!).
1035 * If a nonblocked connection fd has been requested,
1064 * a nonblocked connection fd.
1254 update_timestamps(int fd)
1261 while (fd >= ntimestamps) {
1280 timestamps[fd] = tv.tv_sec;
1304 int fd = xprt->xp_fd;
1305 XDR *xdrs = svc_xdrs[fd];
1325 * The poll() for the connection fd is performed
1334 update_timestamps(fd);
1344 pfd.fd = fd;
1363 if ((len = t_rcvall(fd, buf, len)) > 0) {
1364 update_timestamps(fd);
1383 int fd = xprt->xp_fd;
1387 res = t_rcv(fd, buf, (unsigned)len, &flag);
1391 switch (t_look(fd)) {
1393 (void) t_rcvdis(fd, NULL);
1396 (void) t_rcvrel(fd);
1397 (void) t_sndrel(fd);
1405 * Either poll() lied, or the xprt/fd was closed and
1421 * If there has been no activity on the fd for __rpc_irtimeout
1422 * seconds, timeout the fd by destroying its xprt.
1504 t_rcvall(int fd, char *buf, int len)
1511 res = t_rcv(fd, buf, (unsigned)len, &flag);
1514 switch (t_look(fd)) {
1516 (void) t_rcvdis(fd, NULL);
1519 (void) t_rcvrel(fd);
1520 (void) t_sndrel(fd);
1583 pfd.fd = xprt->xp_fd;
1846 fd_is_dead(int fd)
1852 if (!_t_do_ioctl(fd, (caddr_t)&inforeq, sizeof (struct T_info_req),