2 * Copyright (c) 2010, Linux Box Corporation.
5 * Portions Copyright (c) 2007, Hartmut Reuter,
6 * RZG, Max-Planck-Institut f. Plasmaphysik.
9 * Redistribution and use in source and binary forms, with or without
10 * modification, are permitted provided that the following conditions are met:
12 * 1. Redistributions of source code must retain the above copyright
13 * notice, this list of conditions and the following disclaimer.
14 * 2. Redistributions in binary form must reproduce the above copyright
15 * notice, this list of conditions and the following disclaimer in
16 * the documentation and/or other materials provided with the
19 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES,
20 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
21 * AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
22 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
23 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
24 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
25 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
26 * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
27 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
28 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
31 #include <afsconfig.h>
32 #include <afs/param.h>
38 #include "rpc_test_procs.h"
41 #include <sys/types.h>
49 #include <afs/cellconfig.h>
51 #include <afs/com_err.h>
59 #include <sys/malloc.h>
61 #include <afs/errors.h>
62 #include <afs/sys_prototypes.h>
63 #include <rx/rx_prototypes.h>
64 #ifdef AFS_PTHREAD_ENV
68 extern const char *prog;
69 extern pthread_key_t ctx_key;
71 #if defined(AFS_EXTENDED_CALLBACK)
72 #define RPC_TEST_EXTENDED_CALLBACK 1
74 afs_int32 SRXAFSCB_ExtendedCallBack(
75 /*IN */ struct rx_call *a_call,
76 /*IN */ HostIdentifier * Server,
77 /*IN */ AFSXCBInvocationSeq * Invocations_Array,
78 /*OUT*/ AFSExtendedCallBackRSeq * CallBack_Result_Array)
80 rpc_test_request_ctx *ctx;
82 ctx = CTX_FOR_RXCALL(a_call);
84 printf("%s: SRXAFSCB_ExtendedCallBack: enter (%s)\n", prog,
89 #endif /* AFS_EXTENDED_CALLBACK */
91 #if defined(AFS_BYTE_RANGE_FLOCKS)
92 afs_int32 SRXAFSCB_AsyncIssueByteRangeLock(
93 /*IN */ struct rx_call *a_call,
94 /*IN */ HostIdentifier * Server,
95 /*IN */ AFSByteRangeLockSeq Locks_Array)
97 rpc_test_request_ctx *ctx = CTX_FOR_RXCALL(a_call);
99 printf("%s: SRXAFSCB_AsyncIssueByteRangeLock: enter (%s)\n", prog,
104 #endif /* AFS_BYTE_RANGE_FLOCKS */
107 SRXAFSCB_CallBack(struct rx_call *a_call, AFSCBFids *Fids_Array,
108 AFSCBs *CallBack_Array)
110 rpc_test_request_ctx *ctx = CTX_FOR_RXCALL(a_call);
112 printf("%s: SRXAFSCB_CallBack: enter (%s)\n", prog,
120 SRXAFSCB_InitCallBackState(struct rx_call *a_call)
127 SRXAFSCB_Probe(struct rx_call *a_call)
134 SRXAFSCB_GetCE(struct rx_call *a_call,
136 AFSDBCacheEntry * ce)
143 SRXAFSCB_GetLock(struct rx_call *a_call,
152 SRXAFSCB_XStatsVersion(struct rx_call *a_call,
153 afs_int32 * versionNumberP)
160 SRXAFSCB_GetXStats(struct rx_call *a_call,
161 afs_int32 clientVersionNumber,
162 afs_int32 collectionNumber,
163 afs_int32 * srvVersionNumberP,
165 AFSCB_CollData * dataP)
171 SRXAFSCB_ProbeUuid(struct rx_call *a_call, afsUUID *a_uuid)
173 rpc_test_request_ctx *ctx = CTX_FOR_RXCALL(a_call);
174 if ( !afs_uuid_equal(&ctx->cb_listen_addr.uuid, a_uuid) )
182 SRXAFSCB_WhoAreYou(struct rx_call *a_call, struct interfaceAddr *addr)
184 return SRXAFSCB_TellMeAboutYourself(a_call, addr, NULL);
189 SRXAFSCB_InitCallBackState2(struct rx_call *a_call, struct interfaceAddr *
197 SRXAFSCB_InitCallBackState3(struct rx_call *a_call, afsUUID *a_uuid)
204 SRXAFSCB_GetCacheConfig(struct rx_call *a_call, afs_uint32 callerVersion,
205 afs_uint32 *serverVersion, afs_uint32 *configCount,
212 SRXAFSCB_GetLocalCell(struct rx_call *a_call, char **a_name)
219 SRXAFSCB_GetCellServDB(struct rx_call *a_call, afs_int32 a_index,
220 char **a_name, serverList *a_hosts)
227 SRXAFSCB_GetServerPrefs(struct rx_call *a_call, afs_int32 a_index,
228 afs_int32 *a_srvr_addr, afs_int32 *a_srvr_rank)
235 SRXAFSCB_TellMeAboutYourself(struct rx_call *a_call, struct interfaceAddr *
236 addr, Capabilities *capabilities)
238 rpc_test_request_ctx *ctx = CTX_FOR_RXCALL(a_call);
240 printf("%s: SRXAFSCB_TellMeAboutYourself: enter (%s)\n", prog,
243 addr->numberOfInterfaces = ctx->cb_listen_addr.numberOfInterfaces;
244 addr->uuid = ctx->cb_listen_addr.uuid;
247 afs_uint32 *dataBuffP;
250 dataBytes = 1 * sizeof(afs_uint32);
251 dataBuffP = (afs_uint32 *) xdr_alloc(dataBytes);
252 dataBuffP[0] = CLIENT_CAPABILITY_ERRORTRANS;
253 #if defined(AFS_EXTENDED_CALLBACK)
254 if (ctx->flags & RPC_TEST_REQ_CTX_FLAG_XCB)
255 dataBuffP[0] |= CLIENT_CAPABILITY_EXT_CALLBACK;
256 #endif /* AFS_EXTENDED_CALLBACK */
257 capabilities->Capabilities_len = dataBytes / sizeof(afs_uint32);
258 capabilities->Capabilities_val = dataBuffP;
263 } /* SRXAFSCB_TellMeAboutYourself */
267 SRXAFSCB_GetCellByNum(struct rx_call *a_call, afs_int32 a_cellnum,
268 char **a_name, serverList *a_hosts)
275 SRXAFSCB_GetCE64(struct rx_call *a_call, afs_int32 a_index,
276 struct AFSDBCacheEntry64 *a_result)