]>
git.saurik.com Git - apple/libinfo.git/blob - rpc.subproj/clnt_raw.c
2 * Copyright (c) 1999-2018 Apple Inc. All rights reserved.
4 * @APPLE_LICENSE_HEADER_START@
6 * Portions Copyright (c) 1999 Apple Computer, Inc. All Rights
7 * Reserved. This file contains Original Code and/or Modifications of
8 * Original Code as defined in and that are subject to the Apple Public
9 * Source License Version 1.1 (the "License"). You may not use this file
10 * except in compliance with the License. Please obtain a copy of the
11 * License at http://www.apple.com/publicsource and read it before using
14 * The Original Code and all software distributed under the License are
15 * distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND, EITHER
16 * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
17 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
18 * FITNESS FOR A PARTICULAR PURPOSE OR NON- INFRINGEMENT. Please see the
19 * License for the specific language governing rights and limitations
22 * @APPLE_LICENSE_HEADER_END@
25 * Sun RPC is a product of Sun Microsystems, Inc. and is provided for
26 * unrestricted use provided that this legend is included on all tape
27 * media and as a part of the software program in whole or part. Users
28 * may copy or modify Sun RPC without charge, but are not authorized
29 * to license or distribute it to anyone else except as part of a product or
30 * program developed by the user.
32 * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE
33 * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR
34 * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.
36 * Sun RPC is provided with no support and without any obligation on the
37 * part of Sun Microsystems, Inc. to assist in its use, correction,
38 * modification or enhancement.
40 * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE
41 * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC
42 * OR ANY PART THEREOF.
44 * In no event will Sun Microsystems, Inc. be liable for any lost revenue
45 * or profits or other special, indirect and consequential damages, even if
46 * Sun has been advised of the possibility of such damages.
48 * Sun Microsystems, Inc.
50 * Mountain View, California 94043
53 #if defined(LIBC_SCCS) && !defined(lint)
54 /*static char *sccsid = "from: @(#)clnt_raw.c 1.22 87/08/11 Copyr 1984 Sun Micro";*/
55 /*static char *sccsid = "from: @(#)clnt_raw.c 2.2 88/08/01 4.0 RPCSRC";*/
56 static char *rcsid
= "$Id: clnt_raw.c,v 1.3 2002/02/19 20:36:22 epeyton Exp $";
62 * Copyright (C) 1984, Sun Microsystems, Inc.
64 * Memory based rpc for simple testing and timing.
65 * Interface to create an rpc client and server in the same process.
66 * This lets us similate rpc and get round trip overhead, without
67 * any interference from the kernal.
70 #include "libinfo_common.h"
76 extern bool_t
xdr_opaque_auth();
78 #define MCALL_MSG_SIZE 24
81 * This is the "network" we will be moving stuff over.
83 static struct clntraw_private
{
86 char _raw_buf
[UDPMSGSIZE
];
87 char mashl_callmsg
[MCALL_MSG_SIZE
];
91 static enum clnt_stat
clntraw_call();
92 static void clntraw_abort();
93 static void clntraw_geterr();
94 static bool_t
clntraw_freeres();
95 static bool_t
clntraw_control();
96 static void clntraw_destroy();
98 static struct clnt_ops client_ops
= {
110 * Create a client handle for memory based rpc.
114 clntraw_create(prog
, vers
)
123 register struct clntraw_private
*clp
= clntraw_private
;
124 struct rpc_msg call_msg
;
127 clp
= (struct clntraw_private
*)calloc(1, sizeof (*clp
));
130 clntraw_private
= clp
;
132 XDR
*xdrs
= &clp
->xdr_stream
;
133 CLIENT
*client
= &clp
->client_object
;
135 * pre-serialize the staic part of the call msg and stash it away
137 call_msg
.rm_direction
= CALL
;
138 call_msg
.rm_call
.cb_rpcvers
= RPC_MSG_VERSION
;
139 call_msg
.rm_call
.cb_prog
= prog
;
140 call_msg
.rm_call
.cb_vers
= vers
;
141 xdrmem_create(xdrs
, clp
->mashl_callmsg
, MCALL_MSG_SIZE
, XDR_ENCODE
);
142 if (! xdr_callhdr(xdrs
, &call_msg
)) {
143 perror("clnt_raw.c - Fatal header serialization error.");
145 clp
->mcnt
= XDR_GETPOS(xdrs
);
149 * Set xdrmem for client/server shared buffer
151 xdrmem_create(xdrs
, clp
->_raw_buf
, UDPMSGSIZE
, XDR_FREE
);
154 * create client handle
156 client
->cl_ops
= &client_ops
;
157 client
->cl_auth
= authnone_create();
161 static enum clnt_stat
162 clntraw_call(h
, proc
, xargs
, argsp
, xresults
, resultsp
, timeout
)
169 struct timeval timeout
;
171 register struct clntraw_private
*clp
= clntraw_private
;
172 register XDR
*xdrs
= &clp
->xdr_stream
;
174 enum clnt_stat status
;
175 struct rpc_err error
;
183 xdrs
->x_op
= XDR_ENCODE
;
185 ((struct rpc_msg
*)clp
->mashl_callmsg
)->rm_xid
++ ;
187 if ((! XDR_PUTBYTES(xdrs
, clp
->mashl_callmsg
, clp
->mcnt
)) ||
188 (! XDR_PUTLONG(xdrs
, (int *)&proc
)) ||
189 (! AUTH_MARSHALL(h
->cl_auth
, xdrs
)) ||
190 (! (*xargs
)(xdrs
, argsp
, 0))) return (RPC_CANTENCODEARGS
);
192 if ((! XDR_PUTBYTES(xdrs
, clp
->mashl_callmsg
, clp
->mcnt
)) ||
193 (! XDR_PUTLONG(xdrs
, (long *)&proc
)) ||
194 (! AUTH_MARSHALL(h
->cl_auth
, xdrs
)) ||
195 (! (*xargs
)(xdrs
, argsp
, 0))) return (RPC_CANTENCODEARGS
);
197 (void)XDR_GETPOS(xdrs
); /* called just to cause overhead */
200 * We have to call server input routine here because this is
201 * all going on in one process. Yuk.
208 xdrs
->x_op
= XDR_DECODE
;
210 msg
.acpted_rply
.ar_verf
= _null_auth
;
211 msg
.acpted_rply
.ar_results
.where
= resultsp
;
212 msg
.acpted_rply
.ar_results
.proc
= xresults
;
213 if (! xdr_replymsg(xdrs
, &msg
))
214 return (RPC_CANTDECODERES
);
215 _seterr_reply(&msg
, &error
);
216 status
= error
.re_status
;
218 if (status
== RPC_SUCCESS
) {
219 if (! AUTH_VALIDATE(h
->cl_auth
, &msg
.acpted_rply
.ar_verf
)) {
220 status
= RPC_AUTHERROR
;
222 } /* end successful completion */
224 if (AUTH_REFRESH(h
->cl_auth
))
226 } /* end of unsuccessful completion */
228 if (status
== RPC_SUCCESS
) {
229 if (! AUTH_VALIDATE(h
->cl_auth
, &msg
.acpted_rply
.ar_verf
)) {
230 status
= RPC_AUTHERROR
;
232 if (msg
.acpted_rply
.ar_verf
.oa_base
!= NULL
) {
233 xdrs
->x_op
= XDR_FREE
;
234 (void)xdr_opaque_auth(xdrs
, &(msg
.acpted_rply
.ar_verf
));
248 clntraw_freeres(cl
, xdr_res
, res_ptr
)
253 register struct clntraw_private
*clp
= clntraw_private
;
254 register XDR
*xdrs
= &clp
->xdr_stream
;
259 rval
= (bool_t
) RPC_FAILED
;
262 xdrs
->x_op
= XDR_FREE
;
263 return ((*xdr_res
)(xdrs
, res_ptr
, 0));