| /illumos-gate/usr/src/uts/common/ktli/ |
| H A D | t_ksndudat.c | 67 int msgsz; in t_ksndudata() local
77 msgsz = unitdata->udata.len; in t_ksndudata()
91 (size_t)msgsz, BPRI_LO, frtn)) == NULL) in t_ksndudata()
96 KTLILOG(2, "len %d, ", msgsz); in t_ksndudata()
101 while (!(dbp = allocb(msgsz, BPRI_LO))) in t_ksndudata()
102 if (strwaitbuf((size_t)msgsz, BPRI_LO)) in t_ksndudata()
124 dbp->b_wptr += msgsz; /* on behalf of the user */ in t_ksndudata()
130 msgsz = (int)TUNITDATAREQSZ; in t_ksndudata()
143 while (!(bp = allocb_cred(msgsz + unitdata->addr.len + in t_ksndudata()
145 if (strwaitbuf(msgsz + unitdata->addr.len + unitdata->opt.len, in t_ksndudata()
[all …]
|
| H A D | t_kconnect.c | 72 int msgsz; in t_kconnect() local
85 msgsz = (int)TCONNREQSZ; in t_kconnect()
98 while (!(bp = allocb_cred(msgsz + sndcall->addr.len + sndcall->opt.len, in t_kconnect()
100 if (strwaitbuf(msgsz + sndcall->addr.len + sndcall->opt.len, in t_kconnect()
112 bcopy(sndcall->addr.buf, (bp->b_wptr+msgsz), sndcall->addr.len); in t_kconnect()
113 creq->DEST_offset = (t_scalar_t)msgsz; in t_kconnect()
114 msgsz += sndcall->addr.len; in t_kconnect()
119 bcopy(sndcall->opt.buf, (bp->b_wptr+msgsz), sndcall->opt.len); in t_kconnect()
120 creq->OPT_offset = (t_scalar_t)msgsz; in t_kconnect()
121 msgsz += sndcall->opt.len; in t_kconnect()
[all …]
|
| H A D | t_kutil.c | 116 int msgsz; in get_ok_ack() local
130 if ((msgsz = (int)MBLKL(bp)) < sizeof (int)) { in get_ok_ack()
138 if (msgsz < TOKACKSZ || pptr->ok_ack.CORRECT_prim != type) in get_ok_ack()
143 if (msgsz < TERRORACKSZ) { in get_ok_ack()
|
| /illumos-gate/usr/src/lib/libc/port/sys/ |
| H A D | msgsys.c | 74 __msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg) in __msgrcv() argument
76 if (msgsz > INT_MAX) { in __msgrcv()
86 msgp, msgsz, msgtyp, msgflg); in __msgrcv()
92 msgp, msgsz, msgtyp, msgflg)); in __msgrcv()
96 __msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg) in __msgsnd() argument
98 if (msgsz > INT_MAX) { in __msgsnd()
103 msgp, msgsz, msgflg); in __msgsnd()
108 return (syscall(SYS_msgsys, MSGSND, msqid, msgp, msgsz, msgflg)); in __msgsnd()
|
| /illumos-gate/usr/src/uts/common/os/ |
| H A D | msg.c | 666 msgrcv(int msqid, struct ipcmsgbuf *msgp, size_t msgsz, long msgtyp, int msgflg) in msgrcv() argument
710 error = msg_copyout(qp, msgtyp, &lock, &xtsz, msgsz, in msgrcv()
805 size_t msgsz, struct msg *smp, struct ipcmsgbuf *msgp, int msgflg) in msg_copyout() argument
813 if (msgsz < smp->msg_size) { in msg_copyout()
817 xtsz = msgsz; in msg_copyout()
1094 msgsnd(int msqid, struct ipcmsgbuf *msgp, size_t msgsz, int msgflg) in msgsnd() argument
1128 if (msgsz <= MSG_PREALLOC_LIMIT) { in msgsnd()
1136 mp->msg_size = msgsz; in msgsnd()
1137 if (msgsz) { in msgsnd()
1138 mp->msg_addr = kmem_alloc(msgsz, KM_SLEEP); in msgsnd()
[all …]
|
| /illumos-gate/usr/src/cmd/picl/plugins/sun4v/lib/snmp/ |
| H A D | pdu.c | 187 size_t msgsz = reply_pktsz; in snmp_parse_reply() local
200 if ((p = asn_parse_sequence(reply_pkt, &msgsz, exp_id)) == NULL) { in snmp_parse_reply()
208 if ((p = asn_parse_int(p, &msgsz, &reply_pdu->version)) == NULL) { in snmp_parse_reply()
221 p = asn_parse_string(p, &msgsz, &reply_pdu->community, in snmp_parse_reply()
231 if ((p = snmp_parse_pdu(reqid, p, &msgsz, reply_pdu)) == NULL) { in snmp_parse_reply()
|
| H A D | snmplib.c | 1041 ssize_t msgsz; in snmp_recv_reply() local
1053 msgsz = recvfrom(smd->fd, pkt, SNMP_MAX_RECV_PKTSZ, 0, in snmp_recv_reply()
1055 if (msgsz < 0 || msgsz >= SNMP_MAX_RECV_PKTSZ) { in snmp_recv_reply()
1060 pktsz = (size_t)msgsz; in snmp_recv_reply()
|
| /illumos-gate/usr/src/uts/common/rpc/ |
| H A D | svc_clts.c | 438 int msgsz; in svc_clts_ksend() local
519 msgsz = (int)xmsgsize(ud->ud_resp->b_cont); in svc_clts_ksend()
521 if (msgsz <= 0 || (clone_xprt->xp_msg_size != -1 && in svc_clts_ksend()
522 msgsz > clone_xprt->xp_msg_size)) { in svc_clts_ksend()
526 msgsz, clone_xprt->xp_msg_size); in svc_clts_ksend()
|
| H A D | clnt_clts.c | 2032 int msgsz; in clnt_clts_dispatch_send() local
2052 msgsz = (int)TUNITDATAREQSZ; in clnt_clts_dispatch_send()
2057 while (!(bp = allocb_cred(msgsz + addr->len, cr, NOPID))) { in clnt_clts_dispatch_send()
2058 if (strwaitbuf(msgsz + addr->len, BPRI_LO)) in clnt_clts_dispatch_send()
2067 bcopy(addr->buf, bp->b_wptr + msgsz, addr->len); in clnt_clts_dispatch_send()
2068 udreq->DEST_offset = (t_scalar_t)msgsz; in clnt_clts_dispatch_send()
2069 msgsz += addr->len; in clnt_clts_dispatch_send()
2076 bp->b_wptr += msgsz; in clnt_clts_dispatch_send()
|
| /illumos-gate/usr/src/lib/libc/port/threads/ |
| H A D | scalls.c | 810 msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg) in msgrcv() argument
815 PERFORM(__msgrcv(msqid, msgp, msgsz, msgtyp, msgflg)) in msgrcv()
819 msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg) in msgsnd() argument
824 PERFORM(__msgsnd(msqid, msgp, msgsz, msgflg)) in msgsnd()
|
| /illumos-gate/usr/src/cmd/truss/ |
| H A D | expound.c | 2201 show_msgbuf(private_t *pri, long offset, long msgsz) in show_msgbuf() argument
2209 if (msgsz > MYBUFSIZ / 4) in show_msgbuf()
2216 (long)(offset + sizeof (msgb.mtype)), msgsz); in show_msgbuf()
2219 if (msgsz > MYBUFSIZ / 4) in show_msgbuf()
2225 show_msgbuf32(private_t *pri, long offset, long msgsz) in show_msgbuf32() argument
2233 if (msgsz > MYBUFSIZ / 4) in show_msgbuf32()
2240 (long)(offset + sizeof (msgb.mtype)), msgsz); in show_msgbuf32()
2243 if (msgsz > MYBUFSIZ / 4) in show_msgbuf32()
2249 show_msgsys(private_t *pri, long msgsz) in show_msgsys() argument
2282 show_msgbuf(pri, pri->sys_args[2], msgsz); in show_msgsys()
[all …]
|
| /illumos-gate/usr/src/uts/sun4v/io/ |
| H A D | ds_common.c | 1565 int msgsz; in ds_handle_data() local
1580 msgsz = len - hdrsz; in ds_handle_data()
1583 msg = (msgsz) ? (buf + hdrsz) : NULL; in ds_handle_data()
1603 DS_DUMP_MSG(DS_DBG_FLAG_PRCL, msg, msgsz); in ds_handle_data()
1606 (*svc->ops.ds_data_cb)(svc->ops.cb_arg, msg, msgsz); in ds_handle_data()
|