Home
last modified time | relevance | path

Searched refs:msg_flags (Results 1 – 25 of 45) sorted by relevance

12

/titanic_41/usr/src/uts/common/io/ib/mgt/ibmf/
H A Dibmf_timers.c189 int msg_flags; in ibmf_i_recv_timeout() local
280 msg_flags = msgimplp->im_trans_state_flags; in ibmf_i_recv_timeout()
288 msgimplp, tnf_uint, flags, msg_flags); in ibmf_i_recv_timeout()
294 if (msg_flags & IBMF_TRANS_STATE_FLAG_DONE) { in ibmf_i_recv_timeout()
374 int msg_flags; in ibmf_i_send_timeout() local
516 msg_flags = msgimplp->im_trans_state_flags; in ibmf_i_send_timeout()
521 if (msg_flags & IBMF_TRANS_STATE_FLAG_DONE) { in ibmf_i_send_timeout()
632 msg_flags = msgimplp->im_trans_state_flags; in ibmf_i_send_timeout()
643 if (msg_flags & IBMF_TRANS_STATE_FLAG_DONE) { in ibmf_i_send_timeout()
671 int msg_flags; in ibmf_i_err_terminate_timeout() local
[all …]
H A Dibmf_send.c401 int msg_trans_state_flags, msg_flags; in ibmf_i_do_send_cb() local
526 msg_flags = msgimplp->im_flags; in ibmf_i_do_send_cb()
545 !(msg_flags & IBMF_MSG_FLAGS_ON_LIST) && in ibmf_i_do_send_cb()
548 ibmf_i_notify_sequence(clientp, msgimplp, msg_flags); in ibmf_i_do_send_cb()
583 msg_flags = msgimplp->im_flags; in ibmf_i_do_send_cb()
650 ibmf_i_notify_sequence(clientp, msgimplp, msg_flags); in ibmf_i_do_send_cb()
692 tnf_opaque, msg_flags, msgimplp->im_flags); in ibmf_i_do_send_compl()
H A Dibmf_trans.c358 int msg_flags) in ibmf_i_notify_sequence() argument
367 if (msg_flags & IBMF_MSG_FLAGS_TERMINATION) { in ibmf_i_notify_sequence()
377 if (msg_flags & IBMF_MSG_FLAGS_SET_TERMINATION) { in ibmf_i_notify_sequence()
H A Dibmf_dr.c217 int msg_trans_state_flags, msg_flags; in ibmf_i_dr_loopback_filter() local
319 msg_flags = rmsgimplp->im_flags; in ibmf_i_dr_loopback_filter()
339 !(msg_flags & IBMF_MSG_FLAGS_ON_LIST) && in ibmf_i_dr_loopback_filter()
H A Dibmf_recv.c443 int msg_trans_state_flags, msg_flags; in ibmf_i_do_recv_cb() local
585 msg_flags = msgimplp->im_flags; in ibmf_i_do_recv_cb()
607 !(msg_flags & IBMF_MSG_FLAGS_ON_LIST) && in ibmf_i_do_recv_cb()
611 msg_flags); in ibmf_i_do_recv_cb()
982 msg_flags = msgimplp->im_flags; in ibmf_i_do_recv_cb()
1066 ibmf_i_notify_sequence(clientp, msgimplp, msg_flags); in ibmf_i_do_recv_cb()
/titanic_41/usr/src/lib/libsctp/common/
H A Dsctp.c262 socklen_t *fromlen, struct sctp_sndrcvinfo *sinfo, int *msg_flags) in sctp_recvmsg() argument
285 err = recvmsg(s, &hdr, msg_flags == NULL ? 0 : *msg_flags); in sctp_recvmsg()
292 if (msg_flags != NULL) { in sctp_recvmsg()
293 *msg_flags = hdr.msg_flags; in sctp_recvmsg()
/titanic_41/usr/src/uts/common/io/ib/clients/rdsv3/
H A Drds_recv.c456 struct nmsghdr *msg, size_t size, int msg_flags) in rdsv3_recvmsg() argument
466 "Enter(rs: %p size: %d msg_flags: 0x%x)", rs, size, msg_flags); in rdsv3_recvmsg()
469 (msg_flags & MSG_DONTWAIT)) in rdsv3_recvmsg()
475 if (msg_flags & MSG_OOB) in rdsv3_recvmsg()
578 if (!rdsv3_still_queued(rs, inc, !(msg_flags & MSG_PEEK))) { in rdsv3_recvmsg()
586 if (msg_flags & MSG_TRUNC) in rdsv3_recvmsg()
588 msg->msg_flags |= MSG_TRUNC; in rdsv3_recvmsg()
/titanic_41/usr/src/uts/common/fs/sockfs/
H A Dsockcommon_sops.c378 flags = msg->msg_flags; in so_sendmsg()
497 dontblock = (msg->msg_flags & MSG_DONTWAIT) || in so_sendmblk_impl()
1597 if (msg->msg_flags & MSG_PEEK) in so_recvmsg()
1598 msg->msg_flags &= ~MSG_WAITALL; in so_recvmsg()
1601 msg->msg_flags |= MSG_TRUNC; in so_recvmsg()
1603 if (msg->msg_flags & MSG_OOB) { in so_recvmsg()
1610 error = sorecvoob(so, msg, uiop, msg->msg_flags, in so_recvmsg()
1631 flags = msg->msg_flags; in so_recvmsg()
1632 msg->msg_flags = 0; in so_recvmsg()
1666 msg->msg_flags |= MSG_TRUNC; in so_recvmsg()
[all …]
H A Dsocksyscalls.c857 msg->msg_flags = flags & (MSG_OOB | MSG_PEEK | MSG_WAITALL | in recvit()
877 msg->msg_flags &= ~MSG_XPG4_2; in recvit()
889 msg->msg_flags |= MSG_CTRUNC; in recvit()
891 if (copyout(&msg->msg_flags, flagsp, in recvit()
892 sizeof (msg->msg_flags))) { in recvit()
971 lmsg.msg_flags = 0; in recv()
1008 lmsg.msg_flags = 0; in recvfrom()
1041 flagsp = STRUCT_FADDR(umsgptr, msg_flags); in recvmsg()
1050 STRUCT_FSET(u_lmsg, msg_flags, 0); in recvmsg()
1065 lmsg.msg_flags = STRUCT_FGET(u_lmsg, msg_flags); in recvmsg()
[all …]
/titanic_41/usr/src/lib/lvm/libmeta/common/
H A Dmeta_mn_comm.c78 prefix, msg->msg_flags); in ldump_msg()
451 nmsg->msg_flags = msg->msg_flags; in copy_msg()
472 msgod->msg_flags = msg->msg_flags; in copy_msg_2()
484 msg->msg_flags = msgod->msg_flags; in copy_msg_2()
713 msg.msg_flags = flags; in mdmn_send_message_with_msgid()
H A Dmeta_mn_handlers.c447 myflags |= msg->msg_flags & MD_MSGF_INHERIT_BITS; in mdmn_do_choose_owner()
603 nmsg->msg_flags = MD_MSGF_NO_LOG; /* Don't log submessages */ in mdmn_smgen_state_upd()
615 nmsg->msg_flags = MD_MSGF_NO_LOG; /* Don't log submessages */ in mdmn_smgen_state_upd()
1067 nmsg->msg_flags = (MD_MSGF_NO_LOG | MD_MSGF_NO_BCAST); in mdmn_smgen_mddb_attach()
1080 nmsg->msg_flags = MD_MSGF_NO_LOG | in mdmn_smgen_mddb_attach()
1099 nmsg->msg_flags = (MD_MSGF_NO_LOG | MD_MSGF_NO_BCAST); in mdmn_smgen_mddb_attach()
1129 nmsg->msg_flags = (MD_MSGF_NO_LOG | MD_MSGF_NO_BCAST); in mdmn_smgen_mddb_detach()
1142 nmsg->msg_flags = MD_MSGF_NO_LOG | in mdmn_smgen_mddb_detach()
1156 nmsg->msg_flags = (MD_MSGF_NO_LOG | MD_MSGF_NO_BCAST); in mdmn_smgen_mddb_detach()
1706 nmsg->msg_flags = MD_MSGF_NO_LOG; /* Don't log submessages */ in mdmn_smgen_test6()
[all …]
/titanic_41/usr/src/cmd/lvm/rpc.mdcommd/
H A Dmdmn_commd_server.c1188 result->mmr_flags = msg->msg_flags; in do_message_locally()
1512 if ((msg->msg_flags & (MD_MSGF_NO_LOG | MD_MSGF_REPLAY_MSG)) == 0) { in mdmn_master_process_msg()
1615 inherit_flags = msg->msg_flags & MD_MSGF_INHERIT_BITS; in mdmn_master_process_msg()
1624 cmsg->msg_flags |= inherit_flags; in mdmn_master_process_msg()
1695 if (cmsg->msg_flags & MD_MSGF_STOP_ON_ERROR) { in mdmn_master_process_msg()
1715 if (cmsg->msg_flags & MD_MSGF_NO_BCAST) { in mdmn_master_process_msg()
1754 if ((cmsg->msg_flags & MD_MSGF_DIRECTED) && in mdmn_master_process_msg()
1802 if ((cmsg->msg_flags & in mdmn_master_process_msg()
1811 if (cmsg->msg_flags & MD_MSGF_STOP_ON_ERROR) { in mdmn_master_process_msg()
1832 if ((cmsg->msg_flags & in mdmn_master_process_msg()
[all …]
H A Dmdmn_subr.c445 commd_debug(dbc, "%s flags = 0x%x\n", prefix, msg->msg_flags); in dump_msg()
578 if (msg->msg_flags & MD_MSGF_NO_MCT) { in mdmn_mark_completion()
650 if (msg->msg_flags & MD_MSGF_NO_MCT) { in mdmn_check_completion()
/titanic_41/usr/src/uts/common/io/scsi/adapters/iscsi/
H A Discsi_net.c445 int flag = msg->msg_flags; in iscsi_net_sendmsg()
458 int prflag = msg->msg_flags; in iscsi_net_recvmsg()
591 msg.msg_flags = MSG_WAITALL; in iscsi_net_sendpdu()
635 msg.msg_flags = MSG_WAITALL; in iscsi_net_recvhdr()
692 msg.msg_flags = MSG_WAITALL; in iscsi_net_recvhdr()
794 msg.msg_flags = MSG_WAITALL; in iscsi_net_recvdata()
/titanic_41/usr/src/uts/common/io/ksocket/
H A Dksocket.c221 msghdr.msg_flags = flags | MSG_EOR; in ksocket_send()
275 msghdr.msg_flags = flags | MSG_EOR; in ksocket_sendto()
327 msg->msg_flags = flags | MSG_EOR; in ksocket_sendmsg()
380 msghdr.msg_flags = flags & (MSG_OOB | MSG_PEEK | MSG_WAITALL | in ksocket_recv()
433 msghdr.msg_flags = flags & (MSG_OOB | MSG_PEEK | MSG_WAITALL | in ksocket_recvfrom()
472 if (msg->msg_flags & MSG_USERSPACE) in ksocket_recvmsg()
490 msg->msg_flags = flags & (MSG_OOB | MSG_PEEK | MSG_WAITALL | in ksocket_recvmsg()
/titanic_41/usr/src/cmd/ldmad/
H A Dldma.h158 uint32_t msg_flags; /* message flags */ member
/titanic_41/usr/src/uts/common/sys/
H A Dsocket.h357 int msg_flags; /* flags on received message */ member
400 int32_t msg_flags; /* flags on received message */ member
H A Dmsg_impl.h76 long msg_flags; /* message flags */ member
/titanic_41/usr/src/uts/common/io/comstar/port/iscsit/
H A Discsit_radiuspacket.c191 msg.msg_flags = MSG_WAITALL; in iscsit_rcv_radius_response()
312 int prflag = msg->msg_flags; in iscsit_net_recvmsg()
/titanic_41/usr/src/uts/common/os/
H A Dmsg.c703 if ((smp->msg_flags & MSG_RCVCOPY) == 0) { in msgrcv()
829 ASSERT((smp->msg_flags & MSG_RCVCOPY) == 0); in msg_copyout()
830 smp->msg_flags |= MSG_RCVCOPY; in msg_copyout()
864 ASSERT(smp->msg_flags & MSG_RCVCOPY); in msg_copyout()
865 smp->msg_flags &= ~MSG_RCVCOPY; in msg_copyout()
923 neg_copy_smp.msg_flags = MSG_RCVCOPY; in msgrcv_lookup()
/titanic_41/usr/src/uts/common/sys/lvm/
H A Dmdmn_commd.x455 u_int msg_flags; /* See MD_MSGF_* above */ member
473 uint32_t msg_flags; /* See MD_MSGF_* above */ member
/titanic_41/usr/src/cmd/cmd-inet/usr.lib/in.ripngd/
H A Dinput.c105 if (rmsg.msg_flags & (MSG_TRUNC | MSG_CTRUNC)) { in in_data()
109 rmsg.msg_flags, buf1); in in_data()
/titanic_41/usr/src/uts/common/inet/sockmods/
H A Dsocksctp.c496 flags = msg->msg_flags; in sosctp_recvmsg()
497 msg->msg_flags = 0; in sosctp_recvmsg()
583 msg->msg_flags |= MSG_CTRUNC; in sosctp_recvmsg()
594 msg->msg_flags |= MSG_NOTIFICATION; in sosctp_recvmsg()
599 msg->msg_flags |= MSG_EOR; in sosctp_recvmsg()
737 flags = msg->msg_flags; in sosctp_sendmsg()
983 if (msg->msg_flags & MSG_DONTWAIT) { in sosctp_seq_sendmsg()
1021 flags = msg->msg_flags; in sosctp_seq_sendmsg()
/titanic_41/usr/src/cmd/cmd-inet/usr.sbin/traceroute/
H A Dtraceroute_aux6.c410 if (msg->msg_flags & (MSG_TRUNC|MSG_CTRUNC)) { in check_reply6()
413 msg->msg_flags, in check_reply6()
/titanic_41/usr/src/cmd/cmd-inet/usr.lib/mdnsd/
H A DmDNSUNP.c793 msg.msg_flags = 0; in recvfrom_flags()
829 *flagsp = msg.msg_flags; /* pass back results */ in recvfrom_flags()
831 (msg.msg_flags & MSG_CTRUNC) || pktp == NULL) in recvfrom_flags()

12