Home
last modified time | relevance | path

Searched refs:rfd (Results 1 – 25 of 2817) sorted by relevance

12345678910>>...113

/dports/lang/racket/racket-8.3/src/rktio/
H A Drktio_fd.c205 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 Drktio_fd.c205 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 Drfapi_ap.c136 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 Drfapi.c253 *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 Drfapi_monitor.c121 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 Drfapi_rib.c352 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 Drfapi_ap.c136 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 Drfapi.c253 *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 Drfapi_monitor.c121 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 Drfapi_rib.c352 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 Dsel.c210 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 Dsel.c210 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 Drsprox.c65 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 Drstemp.c128 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 Drsisamb.c30 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 Drsbool.c36 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 Drsisams.c29 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 Drsbetween.c44 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 Drset.c75 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 Drsisamc.c30 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 Dssl_timeoutio.c9 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 Dfont_data_test.cc144 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 Dfont_data_test.cc144 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 Dcheck_parent.c142 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 Dparent.c194 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 …]

12345678910>>...113