/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/sw/rdmavt/ |
H A D | trace_tx.h | 108 __field(int, send_flags) 129 __entry->send_flags = wqe->wr.send_flags; 138 __entry->send_flags, 170 __field(int, send_flags) 182 __entry->send_flags = wqe->wr.send_flags; 195 __entry->send_flags
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/infiniband/sw/rdmavt/ |
H A D | trace_tx.h | 108 __field(int, send_flags) 129 __entry->send_flags = wqe->wr.send_flags; 138 __entry->send_flags, 170 __field(int, send_flags) 182 __entry->send_flags = wqe->wr.send_flags; 195 __entry->send_flags
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/infiniband/sw/rdmavt/ |
H A D | trace_tx.h | 108 __field(int, send_flags) 129 __entry->send_flags = wqe->wr.send_flags; 138 __entry->send_flags, 170 __field(int, send_flags) 182 __entry->send_flags = wqe->wr.send_flags; 195 __entry->send_flags
|
/dports/net/mpich/mpich-3.4.3/modules/ucx/test/gtest/uct/ |
H A D | test_event.cc | 63 void send_am_data(unsigned send_flags, int &am_send_count) { in send_am_data() argument 69 &m_send_data, send_flags); in send_am_data() 77 void test_recv_am(unsigned arm_flags, unsigned send_flags); 107 void test_uct_event::test_recv_am(unsigned arm_flags, unsigned send_flags) in test_recv_am() argument 125 send_am_data(send_flags, am_send_count); in test_recv_am() 143 send_am_data(send_flags, am_send_count); in test_recv_am()
|
/dports/devel/xeus/xeus-0.24.4/src/ |
H A D | xdap_tcp_client.cpp | 79 m_tcp_socket.send(get_tcp_id(), zmq::send_flags::sndmore); in send_dap_request() 80 m_tcp_socket.send(raw_message, zmq::send_flags::none); in send_dap_request() 139 m_controller.send(zmq::message_t("ACK", 3), zmq::send_flags::none); in start_debugger() 220 m_controller_header.send(zmq::message_t("ACK", 3), zmq::send_flags::none); in handle_header_socket() 237 m_tcp_socket.send(get_tcp_id(), zmq::send_flags::sndmore); in handle_control_socket() 238 m_tcp_socket.send(message, zmq::send_flags::none); in handle_control_socket() 250 m_tcp_socket.send(get_tcp_id(), zmq::send_flags::sndmore); in handle_control_socket() 251 m_tcp_socket.send(message, zmq::send_flags::none); in handle_control_socket() 342 m_controller.send(reply, zmq::send_flags::none); in process_message_queue() 381 m_controller.send(reply, zmq::send_flags::none); in handle_init_sequence()
|
H A D | xzmq_messenger.cpp | 47 m_shell_controller.send(stop_msg, zmq::send_flags::none); in stop_channels() 51 m_publisher_controller.send(stop_msg, zmq::send_flags::none); in stop_channels() 55 m_heartbeat_controller.send(stop_msg, zmq::send_flags::none); in stop_channels()
|
/dports/net/cppzmq/cppzmq-4.8.1/tests/ |
H A D | socket.cpp | 461 CHECK((zmq::send_flags::dontwait | zmq::send_flags::sndmore) 462 == static_cast<zmq::send_flags>(ZMQ_DONTWAIT | ZMQ_SNDMORE)); 463 CHECK((zmq::send_flags::dontwait & zmq::send_flags::sndmore) 465 CHECK((zmq::send_flags::dontwait ^ zmq::send_flags::sndmore) 467 CHECK(~zmq::send_flags::dontwait == static_cast<zmq::send_flags>(~ZMQ_DONTWAIT)); 512 auto res = s.send(zmq::buffer(buf), zmq::send_flags::sndmore); 527 auto res = s.send(zmq::buffer(buf), zmq::send_flags::dontwait); 530 s.send(zmq::buffer(buf), zmq::send_flags::dontwait | zmq::send_flags::sndmore); 534 auto resm = s.send(msg, zmq::send_flags::dontwait); 588 const auto res_send = s2.send(smsg, zmq::send_flags::none); [all …]
|
H A D | recv_multipart.cpp | 24 input.send(zmq::str_buffer("hello"), zmq::send_flags::sndmore); 43 input.send(zmq::str_buffer("hello"), zmq::send_flags::sndmore); 87 input.send(zmq::str_buffer("hello"), zmq::send_flags::sndmore); 96 input.send(zmq::str_buffer("hello"), zmq::send_flags::sndmore); 105 input.send(zmq::str_buffer("hello"), zmq::send_flags::sndmore); 123 input.send(zmq::str_buffer("hello"), zmq::send_flags::sndmore);
|
H A D | active_poller.cpp | 120 CHECK(s.client.send(zmq::message_t{}, zmq::send_flags::none)); 185 CHECK_NOTHROW(s.client.send(zmq::message_t{hi_str}, zmq::send_flags::none)); 226 CHECK_NOTHROW(s.client.send(zmq::message_t{send_msg}, zmq::send_flags::none)); 266 CHECK_NOTHROW(s.client.send(zmq::message_t{hi_str}, zmq::send_flags::none)); 323 CHECK_NOTHROW(s.client.send(zmq::message_t{hi_str}, zmq::send_flags::none)); 349 CHECK_NOTHROW(s.client.send(zmq::message_t{hi_str}, zmq::send_flags::none)); 359 CHECK_NOTHROW(s.client.send(zmq::message_t{hi_str}, zmq::send_flags::none)); 372 CHECK_NOTHROW(s.client.send(zmq::message_t{hi_str}, zmq::send_flags::none)); 393 CHECK_NOTHROW(s.client.send(zmq::message_t{hi_str}, zmq::send_flags::none)); 400 CHECK_NOTHROW(s.client.send(zmq::message_t{hi_str}, zmq::send_flags::none)); [all …]
|
/dports/net-mgmt/irrtoolset/irrtoolset-release-5.1.3/src/irrutil/ |
H A D | net.hh | 252 int send_flags; member in Socket 269 send_flags = 0; in Socket() 281 void setSendflags (int flags) { send_flags = flags; } in setSendflags() 341 if (flags == 0 && send_flags != 0) in sendto() 342 flags = send_flags; in sendto() 350 if (flags == 0 && send_flags != 0) in send() 351 flags = send_flags; in send() 352 int c = ::send (sock, (char *) buf, len, send_flags); in send()
|
/dports/science/mbdyn/mbdyn-1.7.3/mbdyn/base/ |
H A D | extforce.cc | 336 int recv_flags, int send_flags) in ExtSocketHandler() argument 338 pUS(pUS), recv_flags(recv_flags), send_flags(send_flags), in ExtSocketHandler() 350 (void)send(pUS->GetSock(), (void *)&u, sizeof(u), send_flags); in ~ExtSocketHandler() 376 rc = send(pUS->GetSock(), (void *)&u, sizeof(u), send_flags); in Prepare_pre() 423 send_flags); in Prepare_post() 485 ssize_t rc = send(pUS->GetSock(), (void *)&u, sizeof(u), send_flags); in Send_pre() 633 return send_flags; in GetSendFlags() 1012 int send_flags = 0; in ReadExtSocketHandler() local 1021 send_flags &= ~MSG_NOSIGNAL; in ReadExtSocketHandler() 1034 send_flags |= MSG_NOSIGNAL; in ReadExtSocketHandler() [all …]
|
/dports/net/kamailio/kamailio-5.4.5/src/core/ |
H A D | onsend.c | 71 orig_msg->fwd_send_flags=dst->send_flags; /* intial value */ in run_onsend() 84 dst->send_flags=orig_msg->fwd_send_flags; in run_onsend() 138 sndinfo->msg->fwd_send_flags=sndinfo->dst->send_flags; /* intial value */ in run_onsend_evroute() 151 sndinfo->dst->send_flags=sndinfo->msg->fwd_send_flags; in run_onsend_evroute()
|
H A D | forward.h | 163 if (unlikely(dst->send_flags.f & SND_F_FORCE_SOCKET in msg_send_buffer() 171 (dst->send_flags.f & SND_F_FORCE_SOCKET), in msg_send_buffer() 241 if (unlikely((dst->send_flags.f & SND_F_FORCE_SOCKET) && in msg_send_buffer() 248 (dst->send_flags.f & SND_F_FORCE_SOCKET), in msg_send_buffer() 272 if (unlikely((dst->send_flags.f & SND_F_FORCE_SOCKET) && in msg_send_buffer() 279 (dst->send_flags.f & SND_F_FORCE_SOCKET), in msg_send_buffer()
|
H A D | tcp_main.c | 827 &c->send_flags, 0); in wbufq_run() 839 &c->send_flags, 0); in wbufq_run() 863 &c->send_flags, 0); in wbufq_run() 1210 snd_flags_t* send_flags, in tcp_do_connect() argument 1256 send_flags, 0); in tcp_do_connect() 1263 send_flags, 0); in tcp_do_connect() 1271 send_flags, 0); in tcp_do_connect() 2435 t_send_flags = send_flags; in tcpconn_send_put() 2542 t_send_flags = send_flags; in tcpconn_send_put() 4573 &c->send_flags, 0); [all …]
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/verbs/src/ |
H A D | verbs_msg.c | 113 .send_flags = VERBS_INJECT(ep, len), in vrb_msg_ep_send() 129 .send_flags = VERBS_INJECT(ep, len), in vrb_msg_ep_senddata() 157 .send_flags = IBV_SEND_INLINE, in vrb_msg_ep_inject() 172 .send_flags = IBV_SEND_INLINE, in vrb_msg_ep_injectdata() 265 .send_flags = VERBS_INJECT(&ep->base_ep, len), in vrb_msg_xrc_ep_send() 283 .send_flags = VERBS_INJECT(&ep->base_ep, len), in vrb_msg_xrc_ep_senddata() 315 .send_flags = IBV_SEND_INLINE, in vrb_msg_xrc_ep_inject() 332 .send_flags = IBV_SEND_INLINE, in vrb_msg_xrc_ep_injectdata()
|
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/ib/ud/verbs/ |
H A D | ud_verbs.c | 69 struct ibv_send_wr *wr, unsigned send_flags, in uct_ud_verbs_post_send() argument 75 if ((send_flags & IBV_SEND_SIGNALED) || in uct_ud_verbs_post_send() 77 wr->send_flags = send_flags | IBV_SEND_SIGNALED; in uct_ud_verbs_post_send() 81 wr->send_flags = send_flags; in uct_ud_verbs_post_send() 113 uct_ud_send_skb_t *skb, unsigned send_flags, in uct_ud_verbs_ep_tx_skb() argument 130 unsigned send_flags; in uct_ud_verbs_ep_send_ctl() local 134 send_flags = 0; in uct_ud_verbs_ep_send_ctl() 136 send_flags |= IBV_SEND_INLINE; in uct_ud_verbs_ep_send_ctl() 141 send_flags |= IBV_SEND_SOLICITED; in uct_ud_verbs_ep_send_ctl() 144 send_flags |= IBV_SEND_SIGNALED; in uct_ud_verbs_ep_send_ctl() [all …]
|
/dports/devel/spdlog/spdlog-1.9.2/include/spdlog/details/ |
H A D | tcp_client.h | 126 const int send_flags = MSG_NOSIGNAL; in send() local 128 const int send_flags = 0; in send() 130 … auto write_result = ::send(socket_, data + bytes_sent, n_bytes - bytes_sent, send_flags); in send()
|
/dports/deskutils/flameshot/flameshot-0.10.2/external/spdlog/include/spdlog/details/ |
H A D | tcp_client.h | 126 const int send_flags = MSG_NOSIGNAL; in send() local 128 const int send_flags = 0; in send() 130 … auto write_result = ::send(socket_, data + bytes_sent, n_bytes - bytes_sent, send_flags); in send()
|
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/spdlog/details/ |
H A D | tcp_client.h | 126 const int send_flags = MSG_NOSIGNAL; in send() local 128 const int send_flags = 0; in send() 130 … auto write_result = ::send(socket_, data + bytes_sent, n_bytes - bytes_sent, send_flags); in send()
|
/dports/net/cppzmq/cppzmq-4.8.1/examples/ |
H A D | pubsub_multithread_inproc.cpp | 18 publisher.send(zmq::str_buffer("A"), zmq::send_flags::sndmore); in PublisherThread() 20 publisher.send(zmq::str_buffer("B"), zmq::send_flags::sndmore); in PublisherThread() 22 publisher.send(zmq::str_buffer("C"), zmq::send_flags::sndmore); in PublisherThread()
|
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/ib/rc/verbs/ |
H A D | rc_verbs_ep.c | 33 struct ibv_send_wr *wr, int send_flags, int max_log_sge) in uct_rc_verbs_ep_post_send() argument 41 if (!(send_flags & IBV_SEND_SIGNALED)) { in uct_rc_verbs_ep_post_send() 42 send_flags |= uct_rc_iface_tx_moderation(&iface->super, &ep->super.txqp, in uct_rc_verbs_ep_post_send() 46 send_flags |= uct_rc_ep_fm(&iface->super, &ep->fi, IBV_SEND_FENCE); in uct_rc_verbs_ep_post_send() 49 wr->send_flags = send_flags; in uct_rc_verbs_ep_post_send() 60 …uct_rc_verbs_txqp_posted(&ep->super.txqp, &ep->txcnt, &iface->super, send_flags & IBV_SEND_SIGNALE… in uct_rc_verbs_ep_post_send() 70 uct_rc_iface_send_desc_t *desc, int send_flags, in uct_rc_verbs_ep_post_send_desc() argument 76 uct_rc_verbs_ep_post_send(iface, ep, wr, send_flags, max_log_sge); in uct_rc_verbs_ep_post_send_desc() 314 int send_flags; in uct_rc_verbs_ep_am_zcopy() local 328 &send_flags); in uct_rc_verbs_ep_am_zcopy() [all …]
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/net/rds/ |
H A D | ib_send.c | 273 if (send->s_wr.send_flags & IB_SEND_SIGNALED) in rds_ib_send_cqe_handler() 465 send->s_wr.send_flags |= IB_SEND_SIGNALED; in rds_ib_set_wr_signal_state() 500 int send_flags = 0; in rds_ib_xmit() local 616 send_flags = IB_SEND_FENCE; in rds_ib_xmit() 628 send->s_wr.send_flags = send_flags; in rds_ib_xmit() 676 send->s_wr.send_flags |= IB_SEND_SOLICITED; in rds_ib_xmit() 679 if (send->s_wr.send_flags & IB_SEND_SIGNALED) in rds_ib_xmit() 718 prev->s_wr.send_flags |= IB_SEND_SOLICITED; in rds_ib_xmit() 719 if (!(prev->s_wr.send_flags & IB_SEND_SIGNALED)) in rds_ib_xmit() 800 send->s_wr.send_flags = 0; in rds_ib_xmit_atomic() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/net/rds/ |
H A D | ib_send.c | 273 if (send->s_wr.send_flags & IB_SEND_SIGNALED) in rds_ib_send_cqe_handler() 465 send->s_wr.send_flags |= IB_SEND_SIGNALED; in rds_ib_set_wr_signal_state() 500 int send_flags = 0; in rds_ib_xmit() local 616 send_flags = IB_SEND_FENCE; in rds_ib_xmit() 628 send->s_wr.send_flags = send_flags; in rds_ib_xmit() 676 send->s_wr.send_flags |= IB_SEND_SOLICITED; in rds_ib_xmit() 679 if (send->s_wr.send_flags & IB_SEND_SIGNALED) in rds_ib_xmit() 718 prev->s_wr.send_flags |= IB_SEND_SOLICITED; in rds_ib_xmit() 719 if (!(prev->s_wr.send_flags & IB_SEND_SIGNALED)) in rds_ib_xmit() 800 send->s_wr.send_flags = 0; in rds_ib_xmit_atomic() [all …]
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/net/rds/ |
H A D | ib_send.c | 273 if (send->s_wr.send_flags & IB_SEND_SIGNALED) in rds_ib_send_cqe_handler() 465 send->s_wr.send_flags |= IB_SEND_SIGNALED; in rds_ib_set_wr_signal_state() 500 int send_flags = 0; in rds_ib_xmit() local 616 send_flags = IB_SEND_FENCE; in rds_ib_xmit() 628 send->s_wr.send_flags = send_flags; in rds_ib_xmit() 676 send->s_wr.send_flags |= IB_SEND_SOLICITED; in rds_ib_xmit() 679 if (send->s_wr.send_flags & IB_SEND_SIGNALED) in rds_ib_xmit() 718 prev->s_wr.send_flags |= IB_SEND_SOLICITED; in rds_ib_xmit() 719 if (!(prev->s_wr.send_flags & IB_SEND_SIGNALED)) in rds_ib_xmit() 800 send->s_wr.send_flags = 0; in rds_ib_xmit_atomic() [all …]
|
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/ib/base/ |
H A D | ib_log.c | 140 uct_ib_opcode_t *op, int send_flags, in uct_ib_dump_wr_opcode() argument 150 send_flags & IBV_SEND_SIGNALED, in uct_ib_dump_wr_opcode() 151 send_flags & IBV_SEND_FENCE, in uct_ib_dump_wr_opcode() 152 send_flags & IBV_SEND_SOLICITED, in uct_ib_dump_wr_opcode() 209 uct_ib_dump_wr_opcode(qp, wr->wr_id, op, wr->send_flags, s, ends - s); in uct_ib_dump_send_wr() 217 (wr->send_flags & IBV_SEND_INLINE) ? -1 : 0, in uct_ib_dump_send_wr()
|