Home
last modified time | relevance | path

Searched refs:send_flags (Results 1 – 25 of 427) sorted by relevance

12345678910>>...18

/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/sw/rdmavt/
H A Dtrace_tx.h108 __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 Dtrace_tx.h108 __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 Dtrace_tx.h108 __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 Dtest_event.cc63 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 Dxdap_tcp_client.cpp79 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 Dxzmq_messenger.cpp47 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 Dsocket.cpp461 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 Drecv_multipart.cpp24 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 Dactive_poller.cpp120 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 Dnet.hh252 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 Dextforce.cc336 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 Donsend.c71 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 Dforward.h163 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 Dtcp_main.c827 &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 Dverbs_msg.c113 .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 Dud_verbs.c69 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 Dtcp_client.h126 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 Dtcp_client.h126 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 Dtcp_client.h126 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 Dpubsub_multithread_inproc.cpp18 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 Drc_verbs_ep.c33 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 Dib_send.c273 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 Dib_send.c273 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 Dib_send.c273 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 Dib_log.c140 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()

12345678910>>...18