/dports/lang/racket/racket-8.3/src/rktio/ |
H A D | rktio_fd.c | 205 return rfd; in rktio_system_fd() 212 rktio_pending_open_poll(rktio, rfd, rfd->pending); in rktio_fd_is_pending_open() 228 return rfd; in rktio_pending_system_fd() 469 if (!rfd->th && !rfd->oth && (rfd->fd != DELAYED_CONSOLE_HANDLE)) { in do_close() 505 free(rfd); in rktio_forget() 531 return rfd; in rktio_fd_attach() 649 } else if (rfd->th->avail || rfd->th->err || rfd->th->eof) { in rktio_poll_read_ready() 831 if (rfd->th->avail || rfd->th->err || rfd->th->eof) { in rktio_poll_add() 1425 rfd->leftover_len, rfd->leftover); in rktio_write() 1503 if (!rfd->oth || rfd->oth->nonblocking) { in rktio_write() [all …]
|
/dports/lang/racket-minimal/racket-8.3/src/rktio/ |
H A D | rktio_fd.c | 205 return rfd; in rktio_system_fd() 212 rktio_pending_open_poll(rktio, rfd, rfd->pending); in rktio_fd_is_pending_open() 228 return rfd; in rktio_pending_system_fd() 469 if (!rfd->th && !rfd->oth && (rfd->fd != DELAYED_CONSOLE_HANDLE)) { in do_close() 505 free(rfd); in rktio_forget() 531 return rfd; in rktio_fd_attach() 649 } else if (rfd->th->avail || rfd->th->err || rfd->th->eof) { in rktio_poll_read_ready() 831 if (rfd->th->avail || rfd->th->err || rfd->th->eof) { in rktio_poll_add() 1425 rfd->leftover_len, rfd->leftover); in rktio_write() 1503 if (!rfd->oth || rfd->oth->nonblocking) { in rktio_write() [all …]
|
/dports/net/frr7-pythontools/frr-frr-7.5.1/bgpd/rfapi/ |
H A D | rfapi_ap.c | 136 if (!rfd->advertised.by_lifetime) in rfapiApCount() 146 struct rfapi_descriptor *rfd; in rfapiApCountAll() local 152 total += rfapiApCount(rfd); in rfapiApCountAll() 173 prd = rfd->rd; in rfapiApReadvertiseAll() 231 del_vnc_route(rfd, rfd->peer, bgp, SAFI_MPLS_VPN, in rfapiApWithdrawAll() 242 struct rfapi_descriptor *rfd, in rfapiApAdjustLifetimeStats() argument 321 if (rfd->max_prefix_lifetime == rfd->min_prefix_lifetime) { in rfapiApAdjustLifetimeStats() 329 if (!rfapiApCount(rfd)) { in rfapiApAdjustLifetimeStats() 330 rfd->max_prefix_lifetime = 0; in rfapiApAdjustLifetimeStats() 416 rfd->max_prefix_lifetime = max; in rfapiApAdjustLifetimeStats() [all …]
|
H A D | rfapi.c | 253 *rfd = (*rfd)->next) { in rfapi_find_rfd() 308 if (!rfd || rfd->bgp == NULL) in is_valid_rfd() 316 if (rfapi_find_handle(rfd->bgp, &rfd->vn_addr, &rfd->un_addr, &hh)) in is_valid_rfd() 334 if (!rfd || rfd->bgp == NULL) in rfapi_check() 342 if ((rc = rfapi_find_handle(rfd->bgp, &rfd->vn_addr, &rfd->un_addr, in rfapi_check() 1339 RFD_RTINIT(rfd, rfd->rib); in rfapi_open_inner() 1340 RFD_RTINIT(rfd, rfd->rib_pending); in rfapi_open_inner() 1341 RFD_RTINIT(rfd, rfd->rsp_times); in rfapi_open_inner() 2121 listnode_delete(rfd->rfg->nves, rfd); in rfapi_close_inner() 2579 rfd, rfd->peer, bgp, SAFI_MPLS_VPN, in rfapi_register() [all …]
|
H A D | rfapi_monitor.c | 121 if (!rfd->mon) in rfapiMonitorDupCheck() 136 if (!rfd->mon) in rfapiMonitorDupCheck() 445 if (!rfd->mon) { in rfapiMonitorAttachImportHd() 484 if (!rfd->mon) { in rfapiMonitorAdd() 503 m->rfd = rfd; in rfapiMonitorAdd() 593 if (!rfd->mon) in rfapiMonitorDetachImportHd() 610 assert(rfd->mon); in rfapiMonitorDel() 653 if (rfd->mon) { in rfapiMonitorDelHd() 678 rfd->mon = NULL; in rfapiMonitorDelHd() 681 if (rfd->mon_eth) { in rfapiMonitorDelHd() [all …]
|
H A D | rfapi_rib.c | 352 tcb->rfd = rfd; in rfapiRibStartTimer() 476 if (rfd->bgp) in rfapiRibClear() 477 bgp = rfd->bgp; in rfapiRibClear() 590 rfapiRibClear(rfd); in rfapiRibFree() 604 if (rfd->rib[afi]) in rfapiRibFree() 786 RFAPI_RIB_PREFIX_COUNT_INCR(rfd, rfd->bgp->rfapi); in rfapiRibPreloadBi() 1530 rfd = ((struct rfapi_updated_responses_queue *)data)->rfd; in rfapiRibDoQueuedCallback() 1742 urq->rfd = rfd; in rfapiRibUpdatePendingNode() 2191 rfd)) { in rfapiRibPendingDeleteRoute() 2197 __func__, rfd, rfd->import_table, it); in rfapiRibPendingDeleteRoute() [all …]
|
/dports/net/frr7/frr-frr-7.5.1/bgpd/rfapi/ |
H A D | rfapi_ap.c | 136 if (!rfd->advertised.by_lifetime) in rfapiApCount() 146 struct rfapi_descriptor *rfd; in rfapiApCountAll() local 152 total += rfapiApCount(rfd); in rfapiApCountAll() 173 prd = rfd->rd; in rfapiApReadvertiseAll() 231 del_vnc_route(rfd, rfd->peer, bgp, SAFI_MPLS_VPN, in rfapiApWithdrawAll() 242 struct rfapi_descriptor *rfd, in rfapiApAdjustLifetimeStats() argument 321 if (rfd->max_prefix_lifetime == rfd->min_prefix_lifetime) { in rfapiApAdjustLifetimeStats() 329 if (!rfapiApCount(rfd)) { in rfapiApAdjustLifetimeStats() 330 rfd->max_prefix_lifetime = 0; in rfapiApAdjustLifetimeStats() 416 rfd->max_prefix_lifetime = max; in rfapiApAdjustLifetimeStats() [all …]
|
H A D | rfapi.c | 253 *rfd = (*rfd)->next) { in rfapi_find_rfd() 308 if (!rfd || rfd->bgp == NULL) in is_valid_rfd() 316 if (rfapi_find_handle(rfd->bgp, &rfd->vn_addr, &rfd->un_addr, &hh)) in is_valid_rfd() 334 if (!rfd || rfd->bgp == NULL) in rfapi_check() 342 if ((rc = rfapi_find_handle(rfd->bgp, &rfd->vn_addr, &rfd->un_addr, in rfapi_check() 1339 RFD_RTINIT(rfd, rfd->rib); in rfapi_open_inner() 1340 RFD_RTINIT(rfd, rfd->rib_pending); in rfapi_open_inner() 1341 RFD_RTINIT(rfd, rfd->rsp_times); in rfapi_open_inner() 2121 listnode_delete(rfd->rfg->nves, rfd); in rfapi_close_inner() 2579 rfd, rfd->peer, bgp, SAFI_MPLS_VPN, in rfapi_register() [all …]
|
H A D | rfapi_monitor.c | 121 if (!rfd->mon) in rfapiMonitorDupCheck() 136 if (!rfd->mon) in rfapiMonitorDupCheck() 445 if (!rfd->mon) { in rfapiMonitorAttachImportHd() 484 if (!rfd->mon) { in rfapiMonitorAdd() 503 m->rfd = rfd; in rfapiMonitorAdd() 593 if (!rfd->mon) in rfapiMonitorDetachImportHd() 610 assert(rfd->mon); in rfapiMonitorDel() 653 if (rfd->mon) { in rfapiMonitorDelHd() 678 rfd->mon = NULL; in rfapiMonitorDelHd() 681 if (rfd->mon_eth) { in rfapiMonitorDelHd() [all …]
|
H A D | rfapi_rib.c | 352 tcb->rfd = rfd; in rfapiRibStartTimer() 476 if (rfd->bgp) in rfapiRibClear() 477 bgp = rfd->bgp; in rfapiRibClear() 590 rfapiRibClear(rfd); in rfapiRibFree() 604 if (rfd->rib[afi]) in rfapiRibFree() 786 RFAPI_RIB_PREFIX_COUNT_INCR(rfd, rfd->bgp->rfapi); in rfapiRibPreloadBi() 1530 rfd = ((struct rfapi_updated_responses_queue *)data)->rfd; in rfapiRibDoQueuedCallback() 1742 urq->rfd = rfd; in rfapiRibUpdatePendingNode() 2191 rfd)) { in rfapiRibPendingDeleteRoute() 2197 __func__, rfd, rfd->import_table, it); in rfapiRibPendingDeleteRoute() [all …]
|
/dports/security/putty-nogtk/putty-0.76/contrib/cygtermd/ |
H A D | sel.c | 210 return rfd; in sel_rfd_add() 266 rfd->prev->next = rfd->next; in sel_rfd_delete() 270 rfd->next->prev = rfd->prev; in sel_rfd_delete() 275 sfree(rfd); in sel_rfd_delete() 292 void *sel_rfd_get_ctx(sel_rfd *rfd) { return rfd->ctx; } in sel_rfd_get_ctx() argument 308 for (rfd = sel->rhead; rfd; rfd = rfd->next) { in sel_iterate() 309 if (rfd->fd >= 0 && !rfd->frozen) { in sel_iterate() 370 for (rfd = sel->rhead; rfd; rfd = rfd->next) in sel_iterate() 371 if (rfd->fd >= 0 && !rfd->frozen && FD_ISSET(rfd->fd, &rset)) { in sel_iterate() 376 rfd->readerr(rfd, errno); in sel_iterate() [all …]
|
/dports/security/putty/putty-0.76/contrib/cygtermd/ |
H A D | sel.c | 210 return rfd; in sel_rfd_add() 266 rfd->prev->next = rfd->next; in sel_rfd_delete() 270 rfd->next->prev = rfd->prev; in sel_rfd_delete() 275 sfree(rfd); in sel_rfd_delete() 292 void *sel_rfd_get_ctx(sel_rfd *rfd) { return rfd->ctx; } in sel_rfd_get_ctx() argument 308 for (rfd = sel->rhead; rfd; rfd = rfd->next) { in sel_iterate() 309 if (rfd->fd >= 0 && !rfd->frozen) { in sel_iterate() 370 for (rfd = sel->rhead; rfd; rfd = rfd->next) in sel_iterate() 371 if (rfd->fd >= 0 && !rfd->frozen && FD_ISSET(rfd->fd, &rset)) { in sel_iterate() 376 rfd->readerr(rfd, errno); in sel_iterate() [all …]
|
/dports/net/zebra-server/idzebra-2.0.55/rset/ |
H A D | rsprox.c | 65 RSFD *rfd; member 97 RSFD rfd; in r_open() local 107 if (rfd->priv) in r_open() 112 rfd->priv = p; in r_open() 121 p->rfd = nmem_malloc(ct->nmem,sizeof(*p->rfd) * ct->no_children); in r_open() 132 return rfd; in r_open() 137 RSET ct = rfd->rset; in r_close() 147 RSET ct = rfd->rset; in r_forward() 237 if (cmp <= - rfd->rset->scope || cmp >= rfd->rset->scope) in r_forward() 293 if (cmp <= - rfd->rset->scope || cmp >= rfd->rset->scope) in r_forward() [all …]
|
H A D | rstemp.c | 128 RSFD rfd; in r_open() local 144 if (!rfd->priv) in r_open() 151 prfd= rfd->priv; in r_open() 152 r_flush(rfd, 0); in r_open() 155 r_reread(rfd); in r_open() 157 return rfd; in r_open() 231 if (rfd_is_last(rfd)) in r_close() 233 r_flush(rfd, 0); in r_close() 295 r_flush(rfd, 0); in r_read() 297 r_reread(rfd); in r_read() [all …]
|
H A D | rsisamb.c | 30 static void r_close(RSFD rfd); 107 RSFD rfd; in r_open() local 115 rfd = rfd_create_base(ct); in r_open() 116 if (rfd->priv) in r_open() 121 rfd->priv = ptinfo; in r_open() 125 return rfd; in r_open() 128 static void r_close(RSFD rfd) in r_close() argument 142 *term = rfd->rset->term; in r_forward() 150 assert(rfd); in r_pos() 162 *term = rfd->rset->term; in r_read() [all …]
|
H A D | rsbool.c | 36 static void r_close(RSFD rfd); 41 static int r_write(RSFD rfd, const void *buf); 107 RSFD rfd; in r_open() local 115 rfd = rfd_create_base(ct); in r_open() 116 if (rfd->priv) in r_open() 120 rfd->priv = p; in r_open() 133 return rfd; in r_open() 136 static void r_close (RSFD rfd) in r_close() argument 155 return rset_read(rfd,buf,term); in r_forward() 186 cmp = -rfd->rset->scope; in r_read_not() [all …]
|
H A D | rsisams.c | 29 static void r_close (RSFD rfd); 32 static int r_write (RSFD rfd, const void *buf); 79 RSFD rfd; in r_open() local 88 rfd = rfd_create_base(ct); in r_open() 89 if (rfd->priv) in r_open() 90 ptinfo = (struct rfd_private *)(rfd->priv); in r_open() 93 rfd->priv = ptinfo; in r_open() 96 return rfd; in r_open() 99 static void r_close (RSFD rfd) in r_close() argument 112 *term = rfd->rset->term; in r_read() [all …]
|
H A D | rsbetween.c | 44 static void r_close(RSFD rfd); 46 static int r_forward(RSFD rfd, void *buf, 158 RSFD rfd; in r_open() local 166 rfd = rfd_create_base(ct); in r_open() 167 if (rfd->priv) in r_open() 171 rfd->priv = p; in r_open() 183 return rfd; in r_open() 186 static void r_close(RSFD rfd) in r_close() argument 203 static void checkattr(RSFD rfd) in checkattr() argument 206 rfd->rset->priv; in checkattr() [all …]
|
H A D | rset.c | 75 rfd, rs, rfd->priv, rs->free_list); in rset_close_int() 77 if (*pfd == rfd) in rset_close_int() 81 rs->free_list = rfd; in rset_close_int() 98 void rset_close(RSFD rfd) in rset_close() argument 100 RSET rs = rfd->rset; in rset_close() 146 rset_close_int(rs, rfd); in rset_close() 242 int rfd_is_last(RSFD rfd) in rfd_is_last() argument 244 if (rfd->rset->use_list == rfd && rfd->next == 0) in rfd_is_last() 375 RSET rset = rfd->rset; in rset_default_read() 392 rfd->counted_items++; in rset_default_read() [all …]
|
H A D | rsisamc.c | 30 static void r_close (RSFD rfd); 33 static int r_write (RSFD rfd, const void *buf); 90 RSFD rfd; in r_open() local 99 rfd = rfd_create_base(ct); in r_open() 100 if (rfd->priv) in r_open() 101 ptinfo = (struct rset_pp_info *)rfd->priv; in r_open() 104 rfd->priv = ptinfo; in r_open() 108 return rfd; in r_open() 111 static void r_close (RSFD rfd) in r_close() argument 125 *term = rfd->rset->term; in r_read() [all …]
|
/dports/mail/qmail-tls/netqmail-1.06/ |
H A D | ssl_timeoutio.c | 9 int t, int rfd, int wfd, SSL *ssl, char *buf, int len) in ssl_timeoutio() argument 30 FD_SET(rfd, &fds); n = select(rfd + 1, &fds, NULL, NULL, &tv); in ssl_timeoutio() 44 int ssl_timeoutaccept(int t, int rfd, int wfd, SSL *ssl) in ssl_timeoutaccept() argument 49 if (ndelay_on(rfd) == -1 || ndelay_on(wfd) == -1) return -1; in ssl_timeoutaccept() 50 r = ssl_timeoutio(SSL_accept, t, rfd, wfd, ssl, NULL, 0); in ssl_timeoutaccept() 52 if (r <= 0) { ndelay_off(rfd); ndelay_off(wfd); } in ssl_timeoutaccept() 58 int ssl_timeoutconn(int t, int rfd, int wfd, SSL *ssl) in ssl_timeoutconn() argument 64 r = ssl_timeoutio(SSL_connect, t, rfd, wfd, ssl, NULL, 0); in ssl_timeoutconn() 66 if (r <= 0) { ndelay_off(rfd); ndelay_off(wfd); } in ssl_timeoutconn() 98 FD_ZERO(&fds); FD_SET(rfd, &fds); in ssl_timeoutrehandshake() [all …]
|
/dports/lang/spidermonkey78/firefox-78.9.0/gfx/sfntly/cpp/src/test/ |
H A D | font_data_test.cc | 144 buffer->resize(rfd->Length()); in ReadFontDataWithSingleByte() 154 b->resize(rfd->Length()); in ReadFontDataWithBuffer() 157 while (index < rfd->Length()) { in ReadFontDataWithBuffer() 167 b->resize(rfd->Length()); in ReadFontDataWithSlidingWindow() 169 while (index < rfd->Length()) { in ReadFontDataWithSlidingWindow() 191 while (index < rfd->Length()) { in WriteFontDataWithBuffer() 201 ByteVector b(rfd->Length()); in WriteFontDataWithSlidingWindow() 203 while (index < rfd->Length()) { in WriteFontDataWithSlidingWindow() 257 trim += (rfd->Length() / 21) + 1) { in SlicingReadTest() 270 trim += (rfd->Length() / 21) + 1) { in SlicingWriteTest() [all …]
|
/dports/lang/spidermonkey60/firefox-60.9.0/gfx/sfntly/cpp/src/test/ |
H A D | font_data_test.cc | 144 buffer->resize(rfd->Length()); in ReadFontDataWithSingleByte() 154 b->resize(rfd->Length()); in ReadFontDataWithBuffer() 157 while (index < rfd->Length()) { in ReadFontDataWithBuffer() 167 b->resize(rfd->Length()); in ReadFontDataWithSlidingWindow() 169 while (index < rfd->Length()) { in ReadFontDataWithSlidingWindow() 191 while (index < rfd->Length()) { in WriteFontDataWithBuffer() 201 ByteVector b(rfd->Length()); in WriteFontDataWithSlidingWindow() 203 while (index < rfd->Length()) { in WriteFontDataWithSlidingWindow() 257 trim += (rfd->Length() / 21) + 1) { in SlicingReadTest() 270 trim += (rfd->Length() / 21) + 1) { in SlicingWriteTest() [all …]
|
/dports/net/ladvd/ladvd-1.1.2/tests/ |
H A D | check_parent.c | 142 struct rawfd *rfd; in START_TEST() local 269 close(rfd->fd); in START_TEST() 336 struct rawfd *rfd; in START_TEST() local 385 close(rfd->fd); in START_TEST() 386 rfd->fd = -1; in START_TEST() 402 struct rawfd *rfd; in START_TEST() local 468 struct rawfd rfd; in START_TEST() local 545 parent_recv(rfd->fd, event, rfd); in START_TEST() 564 parent_recv(rfd->fd, event, rfd); in START_TEST() 585 parent_recv(rfd->fd, event, rfd); in START_TEST() [all …]
|
/dports/net/ladvd/ladvd-1.1.2/src/ |
H A D | parent.c | 194 struct rawfd *rfd; in parent_req() local 223 parent_close(rfd); in parent_req() 348 parent_close(rfd); in parent_send() 364 rfd->index = index; in parent_open() 367 rfd->fd = parent_socket(rfd); in parent_open() 368 if (rfd->fd < 0) { in parent_open() 370 free(rfd); in parent_open() 383 event_set(&rfd->event, rfd->fd, EV_READ|EV_PERSIST, in parent_open() 402 if (rfd->p_handle) in parent_close() 404 free(rfd); in parent_close() [all …]
|