Home
last modified time | relevance | path

Searched refs:rply (Results 1 – 10 of 10) sorted by relevance

/titanic_50/usr/src/lib/libslp/javalib/com/sun/slp/
H A DTransact.java279 SrvLocMsg rply = transactDatagramMsg(ds, addr, msg); in transactUnicastMsg() local
281 if (!filterRply(msg, rply, addr)) { in transactUnicastMsg()
286 SrvLocHeader rhdr = rply.getHeader(); in transactUnicastMsg()
307 rply = transactTCPMsg(addr, msg, false); in transactUnicastMsg()
318 if (rply == null) { in transactUnicastMsg()
327 SrvLocHeader hdr = rply.getHeader(); in transactUnicastMsg()
333 ret.addElement(rply); in transactUnicastMsg()
416 SrvLocMsg rply = null; in transactDatagramMsg() local
448 rply = internalize(dis, addr); in transactDatagramMsg()
484 if (rply == null) { in transactDatagramMsg()
[all …]
H A DRequestHandler.java517 SrvLocMsg rply = msg; in handleRequest() local
536 rply = dispatch(msg); in handleRequest()
540 if (rply == null) { in handleRequest()
560 rply = null; in handleRequest()
591 if (rply != null) { in handleRequest()
592 SrvLocHeader hdr = rply.getHeader(); in handleRequest()
609 rply.getHeader()}); in handleRequest()
614 rply = hdr.makeErrorReply(ex); in handleRequest()
620 hdr = rply.getHeader(); in handleRequest()
1067 SrvLocMsg rply = serviceTable.register(rqst); in dispatchReg() local
[all …]
H A DServerDATable.java558 SrvLocMsg rply = null; in forwardRegOrDereg() local
573 rply = msg; in forwardRegOrDereg()
582 rply = msg; in forwardRegOrDereg()
585 rply = rqst; in forwardRegOrDereg()
589 rply = Transact.transactTCPMsg(addr, rply, false); in forwardRegOrDereg()
606 if (rply == null || in forwardRegOrDereg()
607 rply.getErrorCode() != ServiceLocationException.OK) { in forwardRegOrDereg()
613 (rply == null ? "<null>": in forwardRegOrDereg()
614 Integer.toString(rply.getErrorCode()))}); in forwardRegOrDereg()
H A DServiceLocationManager.java226 CAttrMsg rply = in getRefreshInterval() local
231 if (rply == null || in getRefreshInterval()
232 rply.getErrorCode() != ServiceLocationException.OK) { in getRefreshInterval()
234 (rply == null ? in getRefreshInterval()
236 rply.getErrorCode()); in getRefreshInterval()
248 Vector attrs = rply.attrList; in getRefreshInterval()
H A DSunDATable.java328 SrvLocMsg rply = in getSrvReply() local
333 if (rply == null || in getSrvReply()
334 rply.getErrorCode() != ServiceLocationException.OK) { in getSrvReply()
336 (rply == null ? in getSrvReply()
338 rply.getErrorCode()); in getSrvReply()
347 return (CSrvMsg)rply; in getSrvReply()
H A DSLPHeaderV2.java218 SrvLocMsg rply = null; in parseMsg() local
232 rply = new CSrvMsg(this, dis); in parseMsg()
236 rply = new CAttrMsg(this, dis); in parseMsg()
240 rply = new CSrvTypeMsg(this, dis); in parseMsg()
244 rply = new CDAAdvert(this, dis); in parseMsg()
251 rply = this; in parseMsg()
256 rply = new CSAAdvert(this, dis); in parseMsg()
281 return rply; in parseMsg()
/titanic_50/usr/src/uts/common/rpc/
H A Dsvc.c1106 struct rpc_msg rply; in svc_sendreply() local
1108 rply.rm_direction = REPLY; in svc_sendreply()
1109 rply.rm_reply.rp_stat = MSG_ACCEPTED; in svc_sendreply()
1110 rply.acpted_rply.ar_verf = clone_xprt->xp_verf; in svc_sendreply()
1111 rply.acpted_rply.ar_stat = SUCCESS; in svc_sendreply()
1112 rply.acpted_rply.ar_results.where = xdr_location; in svc_sendreply()
1113 rply.acpted_rply.ar_results.proc = xdr_results; in svc_sendreply()
1115 return (SVC_REPLY((SVCXPRT *)clone_xprt, &rply)); in svc_sendreply()
1129 struct rpc_msg rply; in svcerr_noproc() local
1131 rply.rm_direction = REPLY; in svcerr_noproc()
[all …]
H A Dsvc_cots.c609 struct rpc_msg rply; in svc_cots_kgetres() local
668 rply.rm_xid = clone_xprt->xp_xid; in svc_cots_kgetres()
669 rply.rm_direction = REPLY; in svc_cots_kgetres()
670 rply.rm_reply.rp_stat = MSG_ACCEPTED; in svc_cots_kgetres()
671 rply.acpted_rply.ar_verf = clone_xprt->xp_verf; in svc_cots_kgetres()
672 rply.acpted_rply.ar_stat = SUCCESS; in svc_cots_kgetres()
674 if (!xdr_replymsg_hdr(xdrs, &rply)) { in svc_cots_kgetres()
H A Dsvc_clts.c663 struct rpc_msg rply; in svc_clts_kgetres() local
692 rply.rm_xid = clone_xprt->xp_xid; in svc_clts_kgetres()
693 rply.rm_direction = REPLY; in svc_clts_kgetres()
694 rply.rm_reply.rp_stat = MSG_ACCEPTED; in svc_clts_kgetres()
695 rply.acpted_rply.ar_verf = clone_xprt->xp_verf; in svc_clts_kgetres()
696 rply.acpted_rply.ar_stat = SUCCESS; in svc_clts_kgetres()
698 if (!xdr_replymsg_hdr(xdrs, &rply)) { in svc_clts_kgetres()
/titanic_50/usr/src/lib/libnsl/rpc/
H A Dsvc.c1098 struct rpc_msg rply; in svc_sendreply() local
1100 rply.rm_direction = REPLY; in svc_sendreply()
1101 rply.rm_reply.rp_stat = MSG_ACCEPTED; in svc_sendreply()
1102 rply.acpted_rply.ar_verf = xprt->xp_verf; in svc_sendreply()
1103 rply.acpted_rply.ar_stat = SUCCESS; in svc_sendreply()
1104 rply.acpted_rply.ar_results.where = xdr_location; in svc_sendreply()
1105 rply.acpted_rply.ar_results.proc = xdr_results; in svc_sendreply()
1106 return (SVC_REPLY((SVCXPRT *)xprt, &rply)); in svc_sendreply()
1115 struct rpc_msg rply; in svcerr_noproc() local
1117 rply.rm_direction = REPLY; in svcerr_noproc()
[all …]