| /dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/include/uhdlib/transport/dpdk/ |
| H A D | service_queue.hpp | 48 struct wait_req struct
72 inline wait_req* wait_req_alloc(wait_type t, void* priv_data) in wait_req_alloc()
74 wait_req* req = (wait_req*)rte_zmalloc(NULL, sizeof(*req), 0); in wait_req_alloc()
78 req = new (req) wait_req(); in wait_req_alloc()
91 inline void wait_req_put(wait_req* req) in wait_req_put()
104 inline void wait_req_get(wait_req* req) in wait_req_get()
150 int submit(wait_req* req, std::chrono::microseconds timeout) in submit()
179 wait_req* pop() in pop()
181 wait_req* req; in pop()
195 int requeue(wait_req* req) in requeue()
[all …]
|
| H A D | arp.hpp | 24 std::vector<wait_req*> reqs;
|
| /dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/include/uhdlib/transport/ |
| H A D | dpdk_io_service.hpp | 92 void _service_flow_open(dpdk::wait_req* req);
99 void _service_flow_close(dpdk::wait_req* req);
106 void _service_xport_connect(dpdk::wait_req* req);
113 void _service_xport_disconnect(dpdk::wait_req* req);
126 int _service_arp_request(dpdk::wait_req* req);
|
| H A D | dpdk_io_service_client.hpp | 174 dpdk::wait_req* _waiter;
284 dpdk::wait_req* _waiter;
|
| /dports/databases/timescaledb/timescaledb-2.5.1/tsl/src/remote/ |
| H A D | async.c | 678 AsyncRequest *wait_req; in wait_to_consume_data() local
715 wait_req = NULL; in wait_to_consume_data()
730 wait_req = event.user_data; in wait_to_consume_data()
731 Assert(wait_req != NULL); in wait_to_consume_data()
733 if (0 == PQconsumeInput(remote_connection_get_pg_conn(wait_req->conn))) in wait_to_consume_data()
736 set->requests = list_delete_ptr(set->requests, wait_req); in wait_to_consume_data()
737 result = &async_response_communication_error_create(wait_req)->base; in wait_to_consume_data()
|
| /dports/science/cp2k/cp2k-2e995eec7fd208c8a72d9544807bd8b8ba8cd1cc/src/ |
| H A D | ipi_driver.F | 327 wait_req(2)
403 tag=666, request=wait_req(2))
404 CALL mp_testany(wait_req(2:), flag=fwait)
406 CALL mp_testany(wait_req(2:), flag=fwait)
|
| /dports/science/cp2k-data/cp2k-7.1.0/src/ |
| H A D | ipi_driver.F | 327 wait_req(2)
403 tag=666, request=wait_req(2))
404 CALL mp_testany(wait_req(2:), flag=fwait)
406 CALL mp_testany(wait_req(2:), flag=fwait)
|
| /dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/transport/uhd-dpdk/ |
| H A D | dpdk_io_service.cpp | 82 dpdk::wait_req* req = dpdk::wait_req_alloc(dpdk::wait_type::WAIT_LCORE_TERM, NULL); in ~dpdk_io_service()
332 dpdk::wait_req* req = _servq.pop(); in _service_requests()
384 void dpdk_io_service::_service_flow_open(dpdk::wait_req* req) in _service_flow_open()
418 void dpdk_io_service::_service_flow_close(dpdk::wait_req* req) in _service_flow_close()
444 void dpdk_io_service::_service_xport_connect(dpdk::wait_req* req) in _service_xport_connect()
498 void dpdk_io_service::_service_xport_disconnect(dpdk::wait_req* req) in _service_xport_disconnect()
571 int dpdk_io_service::_service_arp_request(dpdk::wait_req* req) in _service_arp_request()
899 dpdk::wait_req* req; in _wake_client()
|
| /dports/net-mgmt/nagios-check_bacula11/bacula-11.0.5/src/lib/ |
| H A D | waitq.h | 48 pthread_cond_t wait_req; /* wait for OK */ member
|
| /dports/net-mgmt/nagios-check_bacula9/bacula-9.6.7/src/lib/ |
| H A D | waitq.h | 48 pthread_cond_t wait_req; /* wait for OK */ member
|
| /dports/sysutils/bacula11-server/bacula-11.0.5/src/lib/ |
| H A D | waitq.h | 48 pthread_cond_t wait_req; /* wait for OK */ member
|
| /dports/sysutils/bacula11-client-static/bacula-11.0.5/src/lib/ |
| H A D | waitq.h | 48 pthread_cond_t wait_req; /* wait for OK */ member
|
| /dports/sysutils/bacula9-client-static/bacula-9.6.7/src/lib/ |
| H A D | waitq.h | 48 pthread_cond_t wait_req; /* wait for OK */ member
|
| /dports/sysutils/bacula9-client/bacula-9.6.7/src/lib/ |
| H A D | waitq.h | 48 pthread_cond_t wait_req; /* wait for OK */ member
|
| /dports/sysutils/bacula9-server/bacula-9.6.7/src/lib/ |
| H A D | waitq.h | 48 pthread_cond_t wait_req; /* wait for OK */ member
|
| /dports/sysutils/bacula11-client/bacula-11.0.5/src/lib/ |
| H A D | waitq.h | 48 pthread_cond_t wait_req; /* wait for OK */ member
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/fs/nilfs2/ |
| H A D | segment.c | 2161 struct nilfs_segctor_wait_request wait_req; in nilfs_segctor_sync() local
2165 init_wait(&wait_req.wq); in nilfs_segctor_sync()
2166 wait_req.err = 0; in nilfs_segctor_sync()
2167 atomic_set(&wait_req.done, 0); in nilfs_segctor_sync()
2168 wait_req.seq = ++sci->sc_seq_request; in nilfs_segctor_sync()
2171 init_waitqueue_entry(&wait_req.wq, current); in nilfs_segctor_sync()
2172 add_wait_queue(&sci->sc_wait_request, &wait_req.wq); in nilfs_segctor_sync()
2177 if (atomic_read(&wait_req.done)) { in nilfs_segctor_sync()
2178 err = wait_req.err; in nilfs_segctor_sync()
2188 finish_wait(&sci->sc_wait_request, &wait_req.wq); in nilfs_segctor_sync()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/fs/nilfs2/ |
| H A D | segment.c | 2161 struct nilfs_segctor_wait_request wait_req; in nilfs_segctor_sync() local
2165 init_wait(&wait_req.wq); in nilfs_segctor_sync()
2166 wait_req.err = 0; in nilfs_segctor_sync()
2167 atomic_set(&wait_req.done, 0); in nilfs_segctor_sync()
2168 wait_req.seq = ++sci->sc_seq_request; in nilfs_segctor_sync()
2171 init_waitqueue_entry(&wait_req.wq, current); in nilfs_segctor_sync()
2172 add_wait_queue(&sci->sc_wait_request, &wait_req.wq); in nilfs_segctor_sync()
2177 if (atomic_read(&wait_req.done)) { in nilfs_segctor_sync()
2178 err = wait_req.err; in nilfs_segctor_sync()
2188 finish_wait(&sci->sc_wait_request, &wait_req.wq); in nilfs_segctor_sync()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/fs/nilfs2/ |
| H A D | segment.c | 2161 struct nilfs_segctor_wait_request wait_req; in nilfs_segctor_sync() local
2165 init_wait(&wait_req.wq); in nilfs_segctor_sync()
2166 wait_req.err = 0; in nilfs_segctor_sync()
2167 atomic_set(&wait_req.done, 0); in nilfs_segctor_sync()
2168 wait_req.seq = ++sci->sc_seq_request; in nilfs_segctor_sync()
2171 init_waitqueue_entry(&wait_req.wq, current); in nilfs_segctor_sync()
2172 add_wait_queue(&sci->sc_wait_request, &wait_req.wq); in nilfs_segctor_sync()
2177 if (atomic_read(&wait_req.done)) { in nilfs_segctor_sync()
2178 err = wait_req.err; in nilfs_segctor_sync()
2188 finish_wait(&sci->sc_wait_request, &wait_req.wq); in nilfs_segctor_sync()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/fs/f2fs/ |
| H A D | checkpoint.c | 1776 struct ckpt_req *wait_req) in flush_remained_ckpt_reqs() argument
1784 if (wait_req) in flush_remained_ckpt_reqs()
1785 wait_for_completion(&wait_req->wait); in flush_remained_ckpt_reqs()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/fs/f2fs/ |
| H A D | checkpoint.c | 1776 struct ckpt_req *wait_req) in flush_remained_ckpt_reqs() argument
1784 if (wait_req) in flush_remained_ckpt_reqs()
1785 wait_for_completion(&wait_req->wait); in flush_remained_ckpt_reqs()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/fs/f2fs/ |
| H A D | checkpoint.c | 1776 struct ckpt_req *wait_req) in flush_remained_ckpt_reqs() argument
1784 if (wait_req) in flush_remained_ckpt_reqs()
1785 wait_for_completion(&wait_req->wait); in flush_remained_ckpt_reqs()
|