OpenAFS
OpenAFS distributed network file system
/cygdrive/c/src/openafs/openafs.git/repo/src/rx/rx_prototypes.h
00001 /*
00002  * Copyright 2000, International Business Machines Corporation and others.
00003  * All Rights Reserved.
00004  *
00005  * This software has been released under the terms of the IBM Public
00006  * License.  For details, see the LICENSE file in the top-level source
00007  * directory or online at http://www.openafs.org/dl/license10.html
00008  */
00009 
00010 #ifndef _RX_PROTOTYPES_H
00011 #define _RX_PROTOTYPES_H
00012 
00013 /* rx.c */
00014 #ifndef KERNEL
00015 #ifndef AFS_PTHREAD_ENV
00016 extern int (*registerProgram) (PROCESS, char *);
00017 extern int (*swapNameProgram) (PROCESS, const char *, char *);
00018 #endif
00019 #endif
00020 extern int (*rx_justReceived) (struct rx_packet *, struct sockaddr_in *);
00021 extern int (*rx_almostSent) (struct rx_packet *, struct sockaddr_in *);
00022 
00023 extern void rx_rto_setPeerTimeoutSecs(struct rx_peer *, int secs);
00024 
00025 extern void rx_SetEpoch(afs_uint32 epoch);
00026 extern int rx_Init(u_int port);
00027 extern int rx_InitHost(u_int host, u_int port);
00028 extern void rx_SetBusyChannelError(afs_int32 onoff);
00029 #ifdef AFS_NT40_ENV
00030 extern void rx_DebugOnOff(int on);
00031 extern void rx_StatsOnOff(int on);
00032 extern void rx_StartClientThread(void);
00033 #endif
00034 extern void rx_StartServer(int donateMe);
00035 extern struct rx_connection *rx_NewConnection(afs_uint32 shost,
00036                                               u_short sport, u_short sservice,
00037                                               struct rx_securityClass
00038                                               *securityObject,
00039                                               int serviceSecurityIndex);
00040 extern void rx_SetConnDeadTime(struct rx_connection *conn,
00041                                int seconds);
00042 extern void rx_SetConnHardDeadTime(struct rx_connection *conn, int seconds);
00043 extern void rx_SetConnIdleDeadTime(struct rx_connection *conn, int seconds);
00044 extern void rxi_DestroyConnection(struct rx_connection *conn);
00045 extern void rx_GetConnection(struct rx_connection *conn);
00046 extern void rx_DestroyConnection(struct rx_connection *conn);
00047 extern struct rx_call *rx_NewCall(struct rx_connection *conn);
00048 extern int rxi_GetCallNumberVector(struct rx_connection *aconn,
00049                                    afs_int32 * aint32s);
00050 extern int rxi_SetCallNumberVector(struct rx_connection *aconn,
00051                                    afs_int32 * aint32s);
00052 extern struct rx_service *rx_NewService(u_short port, u_short serviceId,
00053                                         char *serviceName,
00054                                         struct rx_securityClass
00055                                         **securityObjects,
00056                                         int nSecurityObjects,
00057                                         afs_int32(*serviceProc) (struct
00058                                                                  rx_call *
00059                                                                  acall));
00060 extern struct rx_service *rx_NewServiceHost(afs_uint32 host, u_short port,
00061                                             u_short serviceId,
00062                                             char *serviceName,
00063                                             struct rx_securityClass
00064                                             **securityObjects,
00065                                             int nSecurityObjects,
00066                                             afs_int32(*serviceProc) (struct
00067                                                                      rx_call *
00068                                                                      acall));
00069 extern void rxi_ServerProc(int threadID, struct rx_call *newcall,
00070                            osi_socket * socketp);
00071 extern void rx_WakeupServerProcs(void);
00072 extern struct rx_call *rx_GetCall(int tno, struct rx_service *cur_service,
00073                                   osi_socket * socketp);
00074 extern void rx_SetArrivalProc(struct rx_call *call,
00075                               void (*proc) (struct rx_call *
00076                                                     call,
00077                                                     void * mh,
00078                                                     int index),
00079                               void * handle, int arg);
00080 extern afs_int32 rx_EndCall(struct rx_call *call, afs_int32 rc);
00081 extern void rx_InterruptCall(struct rx_call *call, afs_int32 error);
00082 extern void rx_Finalize(void);
00083 extern void *rxi_Alloc(size_t size);
00084 extern void rxi_Free(void *addr, size_t size);
00085 extern void rxi_CallError(struct rx_call *call, afs_int32 error);
00086 extern void rx_SetConnSecondsUntilNatPing(struct rx_connection *conn,
00087                                           afs_int32 seconds);
00088 extern void rx_KeepAliveOn(struct rx_call *call);
00089 extern void rx_KeepAliveOff(struct rx_call *call);
00090 extern int rxs_Release(struct rx_securityClass *aobj);
00091 #ifndef KERNEL
00092 extern void rx_PrintTheseStats(FILE * file, struct rx_statistics *s, int size,
00093                                afs_int32 freePackets, char version);
00094 extern void rx_PrintStats(FILE * file);
00095 extern void rx_PrintPeerStats(FILE * file, struct rx_peer *peer);
00096 #endif
00097 extern afs_int32 rx_GetServerDebug(osi_socket socket, afs_uint32 remoteAddr,
00098                                    afs_uint16 remotePort,
00099                                    struct rx_debugStats *stat,
00100                                    afs_uint32 * supportedValues);
00101 extern afs_int32 rx_GetServerStats(osi_socket socket, afs_uint32 remoteAddr,
00102                                    afs_uint16 remotePort,
00103                                    struct rx_statistics *stat,
00104                                    afs_uint32 * supportedValues);
00105 extern afs_int32 rx_GetServerVersion(osi_socket socket, afs_uint32 remoteAddr,
00106                                      afs_uint16 remotePort,
00107                                      size_t version_length, char *version);
00108 extern afs_int32 rx_GetServerConnections(osi_socket socket,
00109                                          afs_uint32 remoteAddr,
00110                                          afs_uint16 remotePort,
00111                                          afs_int32 * nextConnection,
00112                                          int allConnections,
00113                                          afs_uint32 debugSupportedValues,
00114                                          struct rx_debugConn *conn,
00115                                          afs_uint32 * supportedValues);
00116 extern afs_int32 rx_GetServerPeers(osi_socket socket, afs_uint32 remoteAddr,
00117                                    afs_uint16 remotePort,
00118                                    afs_int32 * nextPeer,
00119                                    afs_uint32 debugSupportedValues,
00120                                    struct rx_debugPeer *peer,
00121                                    afs_uint32 * supportedValues);
00122 extern afs_int32 rx_GetLocalPeers(afs_uint32 peerHost, afs_uint16 peerPort,
00123                                       struct rx_debugPeer * peerStats);
00124 extern void shutdown_rx(void);
00125 #ifndef osirx_AssertMine
00126 extern void osirx_AssertMine(afs_kmutex_t * lockaddr, char *msg);
00127 #endif
00128 #ifndef KERNEL
00129 extern int rx_KeyCreate(rx_destructor_t rtn);
00130 #endif
00131 extern void rx_SetSpecific(struct rx_connection *conn, int key, void *ptr);
00132 extern void *rx_GetSpecific(struct rx_connection *conn, int key);
00133 extern void rx_SetServiceSpecific(struct rx_service *svc, int key, void *ptr);
00134 extern void * rx_GetServiceSpecific(struct rx_service *svc, int key);
00135 extern void rx_IncrementTimeAndCount(struct rx_peer *peer,
00136                                      afs_uint32 rxInterface,
00137                                      afs_uint32 currentFunc,
00138                                      afs_uint32 totalFunc,
00139                                      struct clock *queueTime,
00140                                      struct clock *execTime,
00141                                      afs_hyper_t * bytesSent,
00142                                      afs_hyper_t * bytesRcvd, int isServer);
00143 extern void rx_MarshallProcessRPCStats(afs_uint32 callerVersion, int count,
00144                                        rx_function_entry_v1_t * stats,
00145                                        afs_uint32 ** ptrP);
00146 extern int rx_RetrieveProcessRPCStats(afs_uint32 callerVersion,
00147                                       afs_uint32 * myVersion,
00148                                       afs_uint32 * clock_sec,
00149                                       afs_uint32 * clock_usec,
00150                                       size_t * allocSize,
00151                                       afs_uint32 * statCount,
00152                                       afs_uint32 ** stats);
00153 extern int rx_RetrievePeerRPCStats(afs_uint32 callerVersion,
00154                                    afs_uint32 * myVersion,
00155                                    afs_uint32 * clock_sec,
00156                                    afs_uint32 * clock_usec,
00157                                    size_t * allocSize, afs_uint32 * statCount,
00158                                    afs_uint32 ** stats);
00159 extern void rx_FreeRPCStats(afs_uint32 * stats, size_t allocSize);
00160 extern int rx_queryProcessRPCStats(void);
00161 extern int rx_queryPeerRPCStats(void);
00162 extern void rx_enableProcessRPCStats(void);
00163 extern void rx_enablePeerRPCStats(void);
00164 extern void rx_disableProcessRPCStats(void);
00165 extern void rx_disablePeerRPCStats(void);
00166 extern void rx_clearProcessRPCStats(afs_uint32 clearFlag);
00167 extern void rx_clearPeerRPCStats(afs_uint32 clearFlag);
00168 extern void rx_SetRxStatUserOk(int (*proc) (struct rx_call * call));
00169 extern int rx_RxStatUserOk(struct rx_call *call);
00170 extern void rx_ClearProcessRPCStats(afs_int32 rxInterface);
00171 extern void rx_ClearPeerRPCStats(afs_int32 rxInterface, afs_uint32 peerHost, afs_uint16 peerPort);
00172 extern void *rx_CopyProcessRPCStats(afs_uint64 op);
00173 extern void *rx_CopyPeerRPCStats(afs_uint64 op, afs_uint32 peerHost, afs_uint16 peerPort);
00174 extern void rx_ReleaseRPCStats(void *stats);
00175 extern afs_int32 rx_SetSecurityConfiguration(struct rx_service *service,
00176                                              rx_securityConfigVariables type,
00177                                              void *value);
00178 extern int rx_GetThreadNum(void);
00179 extern int rx_SetThreadNum(void);
00180 
00181 void rxi_DebugInit(void);
00182 void rxi_DebugPrint(char *format, ...)
00183     AFS_ATTRIBUTE_FORMAT(__printf__, 1, 2);
00184 
00185 /* rx_clock.c */
00186 #if !defined(clock_Init)
00187 extern void clock_Init(void);
00188 #endif
00189 #if !defined(clock_UnInit)
00190 extern int clock_UnInit(void);
00191 #endif
00192 #if !defined(clock_UpdateTime)
00193 extern void clock_UpdateTime(void);
00194 #endif
00195 #if defined(UKERNEL) && !defined(osi_GetTime)
00196 extern int osi_GetTime(struct timeval *tv);
00197 #endif
00198 
00199 /* rx_clock_nt.c */
00200 
00201 
00202 /* rx_conncache.c */
00203 extern void rxi_DeleteCachedConnections(void);
00204 extern struct rx_connection *rx_GetCachedConnection(unsigned int remoteAddr,
00205                                                     unsigned short port,
00206                                                     unsigned short service,
00207                                                     struct rx_securityClass
00208                                                     *securityObject,
00209                                                     int securityIndex);
00210 extern void rx_ReleaseCachedConnection(struct rx_connection *conn);
00211 
00212 
00213 /* rxdebug.c */
00214 
00215 
00216 /* rx_event.c */
00217 extern int rxevent_nFree;
00218 extern int rxevent_nPosted;
00219 extern struct rxevent *rxevent_Post(struct clock *when, struct clock *now,
00220                                      void (*func) (struct rxevent *, void *,
00221                                                    void *, int),
00222                                      void *arg, void *arg1, int arg2);
00223 extern void shutdown_rxevent(void);
00224 extern struct rxepoch *rxepoch_Allocate(struct clock *when);
00225 extern void rxevent_Init(int nEvents, void (*scheduler) (void));
00226 extern void rxevent_Cancel(struct rxevent **ev, struct rx_call *call,
00227                            int type);
00228 extern int rxevent_RaiseEvents(struct clock *next);
00229 
00230 
00231 
00232 
00233 /* rx_getaddr.c */
00234 extern void rxi_setaddr(afs_uint32 x);
00235 extern afs_uint32 rxi_getaddr(void);
00236 extern int rx_getAllAddr(afs_uint32 * buffer, int maxSize);
00237 extern int rx_getAllAddrMaskMtu(afs_uint32 addrBuffer[],
00238                                  afs_uint32 maskBuffer[],
00239                                  afs_uint32 mtuBuffer[],
00240                                  int maxSize);
00241 
00242 /* rx_globals.c */
00243 extern int rx_GetMaxReceiveWindow(void);
00244 extern int rx_GetMaxSendWindow(void);
00245 extern void rx_SetMaxReceiveWindow(int packets);
00246 extern void rx_SetMaxSendWindow(int packets);
00247 extern int rx_GetMinPeerTimeout(void);
00248 extern void rx_SetMinPeerTimeout(int msecs);
00249 
00250 #ifdef KERNEL
00251 /* rx_kcommon.c */
00252 struct socket;
00253 extern int (*rxk_PacketArrivalProc) (struct rx_packet * ahandle,
00254                                      struct sockaddr_in * afrom,
00255                                      struct socket *arock,
00256                                      afs_int32 asize);
00257 extern int (*rxk_GetPacketProc) (struct rx_packet **ahandle, int asize);
00258 extern afs_int32 afs_termState;
00259 extern int rxk_initDone;
00260 
00261 extern int rxk_DelPort(u_short aport);
00262 extern void rxk_shutdownPorts(void);
00263 extern osi_socket rxi_GetUDPSocket(u_short port);
00264 extern osi_socket rxi_GetHostUDPSocket(u_int host, u_short port);
00265 # if defined(AFS_LINUX26_ENV)
00266 # define osi_Panic(msg...) do { printk(KERN_CRIT "openafs: " msg); BUG(); } while (0)
00267 # undef osi_Assert
00268 # define osi_Assert(expr) \
00269     do { if (!(expr)) osi_Panic("assertion failed: %s, file: %s, line: %d\n", #expr, __FILE__, __LINE__); } while (0)
00270 # elif defined(AFS_AIX_ENV)
00271 extern void osi_Panic(char *fmt, void *a1, void *a2, void *a3);
00272 # else
00273 extern void osi_Panic(char *fmt, ...)
00274     AFS_ATTRIBUTE_FORMAT(__printf__, 1, 2)
00275     AFS_NORETURN;
00276 #endif
00277 extern int osi_utoa(char *buf, size_t len, unsigned long val);
00278 extern void rxi_InitPeerParams(struct rx_peer *pp);
00279 extern void shutdown_rxkernel(void);
00280 # ifdef AFS_USERSPACE_IP_ADDR
00281 extern int rxi_GetcbiInfo(void);
00282 extern afs_int32 rxi_Findcbi(afs_uint32 addr);
00283 # else
00284 extern int rxi_GetIFInfo(void);
00285 # endif
00286 # ifndef UKERNEL
00287 extern int rxk_FreeSocket(struct socket *asocket);
00288 extern osi_socket *rxk_NewSocket(short aport);
00289 # endif
00290 extern int rxk_ReadPacket(osi_socket so, struct rx_packet *p, int *host,
00291                           int *port);
00292 # ifdef UKERNEL
00293 extern void *rx_ServerProc(void *);
00294 # endif
00295 # ifndef AFS_LINUX26_ENV
00296 extern void osi_AssertFailK(const char *expr, const char *file, int line) AFS_NORETURN;
00297 # endif
00298 extern void rxk_ListenerProc(void);
00299 extern void rxk_Listener(void);
00300 # ifndef UKERNEL
00301 extern void afs_rxevent_daemon(void);
00302 # endif
00303 extern rx_ifnet_t rxi_FindIfnet(afs_uint32 addr, afs_uint32 * maskp);
00304 extern void osi_StopListener(void);
00305 
00306 /* ARCH/rx_kmutex.c */
00307 # if defined(AFS_LINUX20_ENV)
00308 extern void afs_mutex_init(afs_kmutex_t * l);
00309 extern void afs_mutex_enter(afs_kmutex_t * l);
00310 extern int afs_mutex_tryenter(afs_kmutex_t * l);
00311 extern void afs_mutex_exit(afs_kmutex_t * l);
00312 extern int afs_cv_wait(afs_kcondvar_t * cv, afs_kmutex_t * l, int sigok);
00313 extern void afs_cv_timedwait(afs_kcondvar_t * cv, afs_kmutex_t * l,
00314                              int waittime);
00315 # endif
00316 
00317 
00318 
00319 /* ARCH/rx_knet.c */
00320 # if !defined(AFS_SGI_ENV)
00321 extern int osi_NetSend(osi_socket asocket, struct sockaddr_in *addr,
00322                        struct iovec *dvec, int nvecs, afs_int32 asize,
00323                        int istack);
00324 # endif
00325 # ifdef RXK_UPCALL_ENV
00326 extern void rx_upcall(socket_t so, void *arg, __unused int waitflag);
00327 # else
00328 extern int osi_NetReceive(osi_socket so, struct sockaddr_in *addr,
00329                           struct iovec *dvec, int nvecs, int *lengthp);
00330 # endif
00331 # if defined(AFS_SUN510_ENV)
00332 extern void osi_StartNetIfPoller(void);
00333 extern void osi_NetIfPoller(void);
00334 extern void osi_StopNetIfPoller(void);
00335 extern struct afs_ifinfo afsifinfo[ADDRSPERSITE];
00336 # endif
00337 extern void osi_StopListener(void);
00338 extern int rxi_FindIfMTU(afs_uint32 addr);
00339 # if defined(UKERNEL)
00340 extern void rxi_ListenerProc(osi_socket usockp, int *tnop,
00341                              struct rx_call **newcallp);
00342 # endif
00343 
00344 # if !defined(RXK_LISTENER_ENV) && !defined(RXK_UPCALL_ENV)
00345 extern void rxk_init(void);
00346 # endif
00347 
00348 /* UKERNEL/rx_knet.c */
00349 # ifdef UKERNEL
00350 extern void afs_rxevent_daemon(void);
00351 # endif
00352 #endif
00353 
00354 /* rx_lwp.c */
00355 extern void rxi_Sleep(void *addr);
00356 extern void rxi_Delay(int seconds);
00357 extern void rxi_InitializeThreadSupport(void);
00358 extern void rxi_Wakeup(void *addr);
00359 extern void rxi_StopListener(void);
00360 #ifndef KERNEL
00361 extern void rxi_ReScheduleEvents(void);
00362 #endif
00363 extern void rxi_InitializeThreadSupport(void);
00364 extern void rxi_StartServerProc(void *(*proc) (void *), int stacksize);
00365 extern void rxi_StartListener(void);
00366 extern void *rx_ServerProc(void *);
00367 extern int rxi_Listen(osi_socket sock);
00368 extern int rxi_Recvmsg(osi_socket socket, struct msghdr *msg_p, int flags);
00369 extern int rxi_Sendmsg(osi_socket socket, struct msghdr *msg_p, int flags);
00370 
00371 
00372 /* rx_misc.c */
00373 #ifndef osi_alloc
00374 extern char *osi_alloc(afs_int32 x);
00375 #endif
00376 #ifndef osi_free
00377 extern int osi_free(char *x, afs_int32 size);
00378 #endif
00379 extern int hton_syserr_conv(afs_int32 code);
00380 extern int ntoh_syserr_conv(int code);
00381 
00382 
00383 /* rx_multi.c */
00384 extern struct multi_handle *multi_Init(struct rx_connection **conns,
00385                                        int nConns);
00386 extern int multi_Select(struct multi_handle *mh);
00387 extern void multi_Ready(struct rx_call *call,
00388                         void *mh, int index);
00389 extern void multi_Finalize(struct multi_handle *mh);
00390 extern void multi_Finalize_Ignore(struct multi_handle *mh);
00391 
00392 
00393 
00394 /* rx_null.c */
00395 extern struct rx_securityClass *rxnull_NewServerSecurityObject(void);
00396 extern struct rx_securityClass *rxnull_NewClientSecurityObject(void);
00397 
00398 
00399 /* rx_packet.c */
00400 extern afs_int32 rx_SlowGetInt32(struct rx_packet *packet, size_t offset);
00401 extern afs_int32 rx_SlowPutInt32(struct rx_packet *packet, size_t offset,
00402                                  afs_int32 data);
00403 extern afs_int32 rx_SlowReadPacket(struct rx_packet *packet,
00404                                    unsigned int offset, int resid, char *out);
00405 extern afs_int32 rx_SlowWritePacket(struct rx_packet *packet, int offset,
00406                                     int resid, char *in);
00407 extern int rxi_RoundUpPacket(struct rx_packet *p, unsigned int nb);
00408 extern int rxi_AllocDataBuf(struct rx_packet *p, int nb, int cla_ss);
00409 extern void rxi_MorePackets(int apackets);
00410 #if defined(AFS_PTHREAD_ENV)
00411 extern void rxi_MorePacketsTSFPQ(int apackets, int flush_global, int num_keep_local); /* more flexible packet alloc function */
00412 extern void rxi_FlushLocalPacketsTSFPQ(void); /* flush all thread-local packets to global queue */
00413 #endif
00414 extern void rxi_FreeAllPackets(void);
00415 extern void rx_CheckPackets(void);
00416 extern void rxi_RestoreDataBufs(struct rx_packet *p);
00417 extern int rxi_TrimDataBufs(struct rx_packet *p, int first);
00418 extern void rxi_FreePacket(struct rx_packet *p);
00419 extern struct rx_packet *rxi_AllocPacket(int cla_ss);
00420 extern int rxi_AllocPackets(int cla_ss, int num_pkts, struct rx_queue *q);
00421 extern int rxi_FreePackets(int num_pkts, struct rx_queue *q);
00422 extern struct rx_packet *rxi_AllocSendPacket(struct rx_call *call,
00423                                              int want);
00424 extern int rxi_ReadPacket(osi_socket socket, struct rx_packet *p,
00425                           afs_uint32 * host, u_short * port);
00426 extern struct rx_packet *rxi_SplitJumboPacket(struct rx_packet *p,
00427                                               afs_uint32 host, short port,
00428                                               int first);
00429 #ifndef KERNEL
00430 extern int osi_NetSend(osi_socket socket, void *addr, struct iovec *dvec,
00431                        int nvecs, int length, int istack);
00432 #endif
00433 extern struct rx_packet *rxi_ReceiveDebugPacket(struct rx_packet *ap,
00434                                                 osi_socket asocket,
00435                                                 afs_uint32 ahost, short aport,
00436                                                 int istack);
00437 extern struct rx_packet *rxi_ReceiveVersionPacket(struct rx_packet
00438                                                   *ap, osi_socket asocket,
00439                                                   afs_uint32 ahost,
00440                                                   short aport, int istack);
00441 extern void rxi_SendPacket(struct rx_call *call, struct rx_connection *conn,
00442                            struct rx_packet *p, int istack);
00443 extern void rxi_SendPacketList(struct rx_call *call,
00444                                struct rx_connection *conn,
00445                                struct rx_packet **list, int len, int istack);
00446 extern void rxi_SendRawAbort(osi_socket socket, afs_uint32 host, u_short port,
00447                              afs_int32 error, struct rx_packet *source,
00448                              int istack);
00449 extern struct rx_packet *rxi_SendSpecial(struct rx_call *call,
00450                                          struct rx_connection *conn,
00451                                          struct rx_packet *optionalPacket,
00452                                          int type, char *data, int nbytes,
00453                                          int istack);
00454 extern void rxi_EncodePacketHeader(struct rx_packet *p);
00455 extern void rxi_DecodePacketHeader(struct rx_packet *p);
00456 extern void rxi_PrepareSendPacket(struct rx_call *call,
00457                                   struct rx_packet *p,
00458                                   int last);
00459 extern int rxi_AdjustIfMTU(int mtu);
00460 extern int rxi_AdjustMaxMTU(int mtu, int peerMaxMTU);
00461 extern int rxi_AdjustDgramPackets(int frags, int mtu);
00462 #ifdef  AFS_GLOBAL_RXLOCK_KERNEL
00463 extern void rxi_WaitforTQBusy(struct rx_call *call);
00464 #endif
00465 
00466 /* rxperf.c */
00467 
00468 
00469 /* rx_pthread.c */
00470 extern int rx_NewThreadId(void);
00471 extern void rxi_Delay(int sec);
00472 extern void rxi_InitializeThreadSupport(void);
00473 extern void rxi_StartServerProc(void *(*proc) (void *), int stacksize);
00474 #ifndef rxi_ReScheduleEvents
00475 extern void rxi_ReScheduleEvents(void);
00476 #endif
00477 extern void *rx_ServerProc(void *);
00478 extern void rxi_StartListener(void);
00479 extern int rxi_Listen(osi_socket sock);
00480 extern int rxi_Recvmsg(osi_socket socket, struct msghdr *msg_p, int flags);
00481 extern int rxi_Sendmsg(osi_socket socket, struct msghdr *msg_p, int flags);
00482 
00483 /* rx_rdwr.c */
00484 extern int rxi_ReadProc(struct rx_call *call, char *buf,
00485                         int nbytes);
00486 extern int rx_ReadProc(struct rx_call *call, char *buf, int nbytes);
00487 extern int rx_ReadProc32(struct rx_call *call, afs_int32 * value);
00488 extern int rxi_FillReadVec(struct rx_call *call, afs_uint32 serial);
00489 extern int rxi_ReadvProc(struct rx_call *call, struct iovec *iov, int *nio,
00490                          int maxio, int nbytes);
00491 extern int rx_ReadvProc(struct rx_call *call, struct iovec *iov, int *nio,
00492                         int maxio, int nbytes);
00493 extern int rxi_WriteProc(struct rx_call *call, char *buf,
00494                          int nbytes);
00495 extern int rx_WriteProc(struct rx_call *call, char *buf, int nbytes);
00496 extern int rx_WriteProc32(struct rx_call *call,
00497                           afs_int32 * value);
00498 extern int rx_WritevAlloc(struct rx_call *call, struct iovec *iov, int *nio,
00499                           int maxio, int nbytes);
00500 extern int rxi_WritevProc(struct rx_call *call, struct iovec *iov, int nio,
00501                           int nbytes);
00502 extern int rx_WritevProc(struct rx_call *call, struct iovec *iov, int nio,
00503                          int nbytes);
00504 extern void rxi_FlushWrite(struct rx_call *call);
00505 extern void rx_FlushWrite(struct rx_call *call);
00506 
00507 
00508 
00509 /* rx_stats.c */
00510 extern struct rx_statistics * rx_GetStatistics(void);
00511 extern void rx_FreeStatistics(struct rx_statistics **);
00512 
00513 /* rx_trace.c */
00514 
00515 
00516 /* rx_user.c */
00517 #ifdef AFS_PTHREAD_ENV
00518 extern afs_kmutex_t rx_if_init_mutex;
00519 extern afs_kmutex_t rx_if_mutex;
00520 #endif
00521 extern osi_socket rxi_GetUDPSocket(u_short port);
00522 extern void rxi_InitPeerParams(struct rx_peer *pp);
00523 extern int rxi_HandleSocketError(int socket);
00524 
00525 #if defined(AFS_AIX32_ENV) && !defined(KERNEL)
00526 #ifndef osi_Alloc
00527 extern void *osi_Alloc(afs_int32 x);
00528 #endif
00529 #ifndef osi_Free
00530 extern void osi_Free(void *x, afs_int32 size);
00531 #endif
00532 #endif /* defined(AFS_AIX32_ENV) && !defined(KERNEL) */
00533 #ifndef KERNEL
00534 extern void osi_Panic(char *fmt, ...) AFS_NORETURN;
00535 #endif
00536 
00537 extern void rx_GetIFInfo(void);
00538 extern void rx_SetNoJumbo(void);
00539 extern int rx_SetMaxMTU(int mtu);
00540 
00541 /* rx_xmit_nt.c */
00542 
00543 
00544 /* MISC PROTOTYPES - MOVE TO APPROPRIATE LOCATION LATER */
00545 
00546 /* EXTERNAL PROTOTYPES - include here cause it causes too many issues to
00547    include the afs_prototypes.h file - just make sure they match */
00548 #ifndef afs_osi_Alloc
00549 extern void *afs_osi_Alloc(size_t x);
00550 #endif
00551 #ifndef afs_osi_Free
00552 extern void afs_osi_Free(void *x, size_t asize);
00553 #endif
00554 #ifndef afs_osi_Wakeup
00555 extern int afs_osi_Wakeup(void *event);
00556 #endif
00557 #ifndef afs_osi_Sleep
00558 extern void afs_osi_Sleep(void *event);
00559 #endif
00560 extern unsigned int afs_random(void);
00561 extern void osi_linux_rxkreg(void);
00562 
00563 #endif /* _RX_PROTOTYPES_H */
 All Data Structures Files Functions Variables