| /dports/www/quark/quark-68b4f733b2755762e43df90f73db5a6ec8d14104/ |
| H A D | queue.c | 18 int qfd; in queue_create() local
21 if ((qfd = epoll_create1(0)) < 0) { in queue_create()
25 if ((qfd = kqueue()) < 0) { in queue_create()
30 return qfd; in queue_create()
72 if (epoll_ctl(qfd, EPOLL_CTL_ADD, fd, &e) < 0) { in queue_add_fd()
94 if (kevent(qfd, &e, 1, NULL, 0, NULL) < 0) { in queue_add_fd()
125 if (epoll_ctl(qfd, EPOLL_CTL_MOD, fd, &e) < 0) { in queue_mod_fd()
146 if (kevent(qfd, &e, 1, NULL, 0, NULL) < 0) { in queue_mod_fd()
156 queue_rem_fd(int qfd, int fd) in queue_rem_fd() argument
170 if (kevent(qfd, &e, 1, NULL, 0, NULL) < 0) { in queue_rem_fd()
[all …]
|
| H A D | server.c | 25 int qfd; in server_worker() local
35 if ((qfd = queue_create()) < 0) { in server_worker()
40 if (queue_add_fd(qfd, d->insock, QUEUE_EVENT_IN, 1, NULL) < 0) { in server_worker()
51 if ((nready = queue_wait(qfd, event, d->nslots)) < 0) { in server_worker()
61 queue_rem_fd(qfd, c->fd); in server_worker()
88 if (queue_add_fd(qfd, newc->fd, in server_worker()
110 if (queue_mod_fd(qfd, c->fd, in server_worker()
119 if (queue_mod_fd(qfd, c->fd, in server_worker()
|
| /dports/net-mgmt/nagios-check_bacula11/bacula-11.0.5/src/stored/ |
| H A D | append.c | 153 qfd->start_read_sock(); in do_append_data()
169 n = qfd->bget_msg(NULL); in do_append_data()
171 if (n == BNET_SIGNAL && qfd->msglen == BNET_EOD) { in do_append_data()
176 n, qfd->msglen, fd->bstrerror()); in do_append_data()
186 …Jmsg1(jcr, M_FATAL, 0, _("Malformed data header from FD: %s\n"), asciidump(qfd->msg, qfd->msglen, … in do_append_data()
232 rec.data_len = qfd->msglen; in do_append_data()
255 char *rbuf = qfd->msg; in do_append_data()
257 int rbuflen = qfd->msglen; in do_append_data()
285 rec.extra_bytes = qfd->bmsg->dedup_size; in do_append_data()
332 if (qfd->commit(errmsg.addr(), jcr->JobId)) { in do_append_data()
[all …]
|
| /dports/sysutils/bacula11-server/bacula-11.0.5/src/stored/ |
| H A D | append.c | 153 qfd->start_read_sock(); in do_append_data()
169 n = qfd->bget_msg(NULL); in do_append_data()
171 if (n == BNET_SIGNAL && qfd->msglen == BNET_EOD) { in do_append_data()
176 n, qfd->msglen, fd->bstrerror()); in do_append_data()
186 …Jmsg1(jcr, M_FATAL, 0, _("Malformed data header from FD: %s\n"), asciidump(qfd->msg, qfd->msglen, … in do_append_data()
232 rec.data_len = qfd->msglen; in do_append_data()
255 char *rbuf = qfd->msg; in do_append_data()
257 int rbuflen = qfd->msglen; in do_append_data()
285 rec.extra_bytes = qfd->bmsg->dedup_size; in do_append_data()
332 if (qfd->commit(errmsg.addr(), jcr->JobId)) { in do_append_data()
[all …]
|
| /dports/sysutils/bacula11-client-static/bacula-11.0.5/src/stored/ |
| H A D | append.c | 153 qfd->start_read_sock(); in do_append_data()
169 n = qfd->bget_msg(NULL); in do_append_data()
171 if (n == BNET_SIGNAL && qfd->msglen == BNET_EOD) { in do_append_data()
176 n, qfd->msglen, fd->bstrerror()); in do_append_data()
186 …Jmsg1(jcr, M_FATAL, 0, _("Malformed data header from FD: %s\n"), asciidump(qfd->msg, qfd->msglen, … in do_append_data()
232 rec.data_len = qfd->msglen; in do_append_data()
255 char *rbuf = qfd->msg; in do_append_data()
257 int rbuflen = qfd->msglen; in do_append_data()
285 rec.extra_bytes = qfd->bmsg->dedup_size; in do_append_data()
332 if (qfd->commit(errmsg.addr(), jcr->JobId)) { in do_append_data()
[all …]
|
| /dports/sysutils/bacula11-client/bacula-11.0.5/src/stored/ |
| H A D | append.c | 153 qfd->start_read_sock(); in do_append_data()
169 n = qfd->bget_msg(NULL); in do_append_data()
171 if (n == BNET_SIGNAL && qfd->msglen == BNET_EOD) { in do_append_data()
176 n, qfd->msglen, fd->bstrerror()); in do_append_data()
186 …Jmsg1(jcr, M_FATAL, 0, _("Malformed data header from FD: %s\n"), asciidump(qfd->msg, qfd->msglen, … in do_append_data()
232 rec.data_len = qfd->msglen; in do_append_data()
255 char *rbuf = qfd->msg; in do_append_data()
257 int rbuflen = qfd->msglen; in do_append_data()
285 rec.extra_bytes = qfd->bmsg->dedup_size; in do_append_data()
332 if (qfd->commit(errmsg.addr(), jcr->JobId)) { in do_append_data()
[all …]
|
| /dports/net-mgmt/nagios-check_bacula9/bacula-9.6.7/src/stored/ |
| H A D | append.c | 153 GetMsg *qfd; in do_append_data() local
155 qfd = New(GetMsg(jcr, fd, NULL, GETMSG_MAX_MSG_SIZE)); in do_append_data()
156 qfd->start_read_sock(); in do_append_data()
168 n = qfd->bget_msg(NULL); in do_append_data()
170 if (n == BNET_SIGNAL && qfd->msglen == BNET_EOD) { in do_append_data()
175 n, qfd->msglen, fd->bstrerror()); in do_append_data()
185 …Jmsg1(jcr, M_FATAL, 0, _("Malformed data header from FD: %s\n"), asciidump(qfd->msg, qfd->msglen, … in do_append_data()
230 rec.data_len = qfd->msglen; in do_append_data()
231 rec.data = qfd->msg; /* use message buffer */ in do_append_data()
270 qfd->wait_read_sock((ok == false) || jcr->is_job_canceled()); in do_append_data()
[all …]
|
| /dports/sysutils/bacula9-client-static/bacula-9.6.7/src/stored/ |
| H A D | append.c | 153 GetMsg *qfd; in do_append_data() local
155 qfd = New(GetMsg(jcr, fd, NULL, GETMSG_MAX_MSG_SIZE)); in do_append_data()
156 qfd->start_read_sock(); in do_append_data()
168 n = qfd->bget_msg(NULL); in do_append_data()
170 if (n == BNET_SIGNAL && qfd->msglen == BNET_EOD) { in do_append_data()
175 n, qfd->msglen, fd->bstrerror()); in do_append_data()
185 …Jmsg1(jcr, M_FATAL, 0, _("Malformed data header from FD: %s\n"), asciidump(qfd->msg, qfd->msglen, … in do_append_data()
230 rec.data_len = qfd->msglen; in do_append_data()
231 rec.data = qfd->msg; /* use message buffer */ in do_append_data()
270 qfd->wait_read_sock((ok == false) || jcr->is_job_canceled()); in do_append_data()
[all …]
|
| /dports/sysutils/bacula9-server/bacula-9.6.7/src/stored/ |
| H A D | append.c | 153 GetMsg *qfd; in do_append_data() local
155 qfd = New(GetMsg(jcr, fd, NULL, GETMSG_MAX_MSG_SIZE)); in do_append_data()
156 qfd->start_read_sock(); in do_append_data()
168 n = qfd->bget_msg(NULL); in do_append_data()
170 if (n == BNET_SIGNAL && qfd->msglen == BNET_EOD) { in do_append_data()
175 n, qfd->msglen, fd->bstrerror()); in do_append_data()
185 …Jmsg1(jcr, M_FATAL, 0, _("Malformed data header from FD: %s\n"), asciidump(qfd->msg, qfd->msglen, … in do_append_data()
230 rec.data_len = qfd->msglen; in do_append_data()
231 rec.data = qfd->msg; /* use message buffer */ in do_append_data()
270 qfd->wait_read_sock((ok == false) || jcr->is_job_canceled()); in do_append_data()
[all …]
|
| /dports/sysutils/bacula9-client/bacula-9.6.7/src/stored/ |
| H A D | append.c | 153 GetMsg *qfd; in do_append_data() local
155 qfd = New(GetMsg(jcr, fd, NULL, GETMSG_MAX_MSG_SIZE)); in do_append_data()
156 qfd->start_read_sock(); in do_append_data()
168 n = qfd->bget_msg(NULL); in do_append_data()
170 if (n == BNET_SIGNAL && qfd->msglen == BNET_EOD) { in do_append_data()
175 n, qfd->msglen, fd->bstrerror()); in do_append_data()
185 …Jmsg1(jcr, M_FATAL, 0, _("Malformed data header from FD: %s\n"), asciidump(qfd->msg, qfd->msglen, … in do_append_data()
230 rec.data_len = qfd->msglen; in do_append_data()
231 rec.data = qfd->msg; /* use message buffer */ in do_append_data()
270 qfd->wait_read_sock((ok == false) || jcr->is_job_canceled()); in do_append_data()
[all …]
|
| /dports/chinese/bitchx/bitchx-1.2.1/dll/qbx/ |
| H A D | qbx.c | 17 int qfd, querying = 0, qbx_on = 1, q_type = 0; variable
43 close_socketread(qfd); in q_timeout()
195 close(qfd); in query_q_server()
200 qfd = connect_by_number(server, &port, SERVICE_CLIENT, PROTOCOL_UDP, 1); in query_q_server()
219 sendto(qfd, buffer, strlen(buffer), 0, (struct sockaddr *)&qsock, sizeof(struct sockaddr)); in query_q_server()
224 add_socketread(qfd, port, 0, server, q_timer, NULL); in query_q_server()
225 add_sockettimeout(qfd, 5, q_timeout); in query_q_server()
|
| /dports/irc/bitchx/bitchx-1.2.1/dll/qbx/ |
| H A D | qbx.c | 17 int qfd, querying = 0, qbx_on = 1, q_type = 0; variable
43 close_socketread(qfd); in q_timeout()
195 close(qfd); in query_q_server()
200 qfd = connect_by_number(server, &port, SERVICE_CLIENT, PROTOCOL_UDP, 1); in query_q_server()
219 sendto(qfd, buffer, strlen(buffer), 0, (struct sockaddr *)&qsock, sizeof(struct sockaddr)); in query_q_server()
224 add_socketread(qfd, port, 0, server, q_timer, NULL); in query_q_server()
225 add_sockettimeout(qfd, 5, q_timeout); in query_q_server()
|
| /dports/security/proxycheck/proxycheck-0.49a/ |
| H A D | event.c | 94 int qfd; /* fd for epoll, kqueue, devpoll */ member
126 ct->qfd = epfd; in _syscall1()
134 return epoll_ctl(ct->qfd, func, fd, &ev); in evio_epoll_ctl()
184 ct->qfd = dpfd; in evio_devpoll_init()
218 ready = ioctl(ct->qfd, DP_POLL, &dvp); in evio_devpoll_wait()
244 ct->qfd = kqfd; in evio_kqueue_init()
255 if (kevent(ct->qfd, &kev, 1, 0, 0, &zero_ts)) in evio_kqueue_mod()
267 if (kevent(ct->qfd, &kev, 1, 0, 0, &zero_ts)) in evio_kqueue_mod()
571 ct->qfd = -1; in ev_ct_new()
600 if (ct->qfd >= 0) close(ct->qfd); in ev_ct_new()
[all …]
|
| /dports/math/cgal/CGAL-5.3/examples/Polygon_mesh_processing/ |
| H A D | triangulate_faces_split_visitor_example.cpp | 50 face_descriptor qfd; member
60 qfd = it->second; in before_subface_creations()
67 container[fd]=qfd; in after_subface_created()
|
| /dports/audio/mumble/mumble-1.3.3/src/mumble/ |
| H A D | OverlayEditorScene.cpp | 753 QFontDialog qfd; in contextMenuEvent() local
754 qfd.setOptions(QFontDialog::DontUseNativeDialog); in contextMenuEvent()
755 qfd.setCurrentFont(*fontptr); in contextMenuEvent()
756 qfd.setWindowTitle(tr("Pick font")); in contextMenuEvent()
761 qgpw->setWidget(&qfd); in contextMenuEvent()
770 ret = qfd.exec(); in contextMenuEvent()
778 qfd.setWindowFlags(qfd.windowFlags() | Qt::WindowStaysOnTopHint); in contextMenuEvent()
779 ret = qfd.exec(); in contextMenuEvent()
784 *fontptr = qfd.selectedFont(); in contextMenuEvent()
|
| /dports/audio/murmur/mumble-1.3.3/src/mumble/ |
| H A D | OverlayEditorScene.cpp | 753 QFontDialog qfd; in contextMenuEvent() local
754 qfd.setOptions(QFontDialog::DontUseNativeDialog); in contextMenuEvent()
755 qfd.setCurrentFont(*fontptr); in contextMenuEvent()
756 qfd.setWindowTitle(tr("Pick font")); in contextMenuEvent()
761 qgpw->setWidget(&qfd); in contextMenuEvent()
770 ret = qfd.exec(); in contextMenuEvent()
778 qfd.setWindowFlags(qfd.windowFlags() | Qt::WindowStaysOnTopHint); in contextMenuEvent()
779 ret = qfd.exec(); in contextMenuEvent()
784 *fontptr = qfd.selectedFont(); in contextMenuEvent()
|
| /dports/science/xdrawchem/xdrawchem-a3f74c34eb09fa72ee16848ec6901049ca5309d5/xdrawchem/ |
| H A D | charsel.cpp | 43 QFontDatabase qfd; in CharSelDialog() local
44 QStringList families = qfd.families(); in CharSelDialog()
|
| /dports/mail/nullmailer/nullmailer-2.2/src/ |
| H A D | smtpd.cc | 114 static bool qwrite(int qfd, const char* data, size_t len) in qwrite() argument
118 wr = write(qfd, data, len); in qwrite()
|
| /dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/curl-sys-0.4.51+curl-7.80.0/curl/lib/vquic/ |
| H A D | quiche.c | 241 int qfd; in Curl_quic_connect() local
242 (void)Curl_qlogdir(data, qs->scid, sizeof(qs->scid), &qfd); in Curl_quic_connect()
243 if(qfd != -1) in Curl_quic_connect()
244 quiche_conn_set_qlog_fd(qs->conn, qfd, in Curl_quic_connect()
|
| /dports/devel/cmake-doc/cmake-3.22.1/Utilities/cmcurl/lib/vquic/ |
| H A D | quiche.c | 241 int qfd; in Curl_quic_connect() local
242 (void)Curl_qlogdir(data, qs->scid, sizeof(qs->scid), &qfd); in Curl_quic_connect()
243 if(qfd != -1) in Curl_quic_connect()
244 quiche_conn_set_qlog_fd(qs->conn, qfd, in Curl_quic_connect()
|
| /dports/devel/cmake-gui/cmake-3.22.1/Utilities/cmcurl/lib/vquic/ |
| H A D | quiche.c | 241 int qfd; in Curl_quic_connect() local
242 (void)Curl_qlogdir(data, qs->scid, sizeof(qs->scid), &qfd); in Curl_quic_connect()
243 if(qfd != -1) in Curl_quic_connect()
244 quiche_conn_set_qlog_fd(qs->conn, qfd, in Curl_quic_connect()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/curl-sys-0.4.34+curl-7.71.1/curl/lib/vquic/ |
| H A D | quiche.c | 225 int qfd; in Curl_quic_connect() local
226 (void)Curl_qlogdir(data, qs->scid, sizeof(qs->scid), &qfd); in Curl_quic_connect()
227 if(qfd != -1) in Curl_quic_connect()
228 quiche_conn_set_qlog_fd(qs->conn, qfd, in Curl_quic_connect()
|
| /dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/curl-sys-0.4.41+curl-7.75.0/curl/lib/vquic/ |
| H A D | quiche.c | 240 int qfd; in Curl_quic_connect() local
241 (void)Curl_qlogdir(data, qs->scid, sizeof(qs->scid), &qfd); in Curl_quic_connect()
242 if(qfd != -1) in Curl_quic_connect()
243 quiche_conn_set_qlog_fd(qs->conn, qfd, in Curl_quic_connect()
|
| /dports/devel/cmake/cmake-3.22.1/Utilities/cmcurl/lib/vquic/ |
| H A D | quiche.c | 241 int qfd; in Curl_quic_connect() local
242 (void)Curl_qlogdir(data, qs->scid, sizeof(qs->scid), &qfd); in Curl_quic_connect()
243 if(qfd != -1) in Curl_quic_connect()
244 quiche_conn_set_qlog_fd(qs->conn, qfd, in Curl_quic_connect()
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/curl-sys/curl/lib/vquic/ |
| H A D | quiche.c | 241 int qfd; in Curl_quic_connect() local
242 (void)Curl_qlogdir(data, qs->scid, sizeof(qs->scid), &qfd); in Curl_quic_connect()
243 if(qfd != -1) in Curl_quic_connect()
244 quiche_conn_set_qlog_fd(qs->conn, qfd, in Curl_quic_connect()
|