1 /* 2 * RPC server API 3 * 4 * Copyright 2001 Ove Kåven, TransGaming Technologies 5 * 6 * This library is free software; you can redistribute it and/or 7 * modify it under the terms of the GNU Lesser General Public 8 * License as published by the Free Software Foundation; either 9 * version 2.1 of the License, or (at your option) any later version. 10 * 11 * This library is distributed in the hope that it will be useful, 12 * but WITHOUT ANY WARRANTY; without even the implied warranty of 13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 14 * Lesser General Public License for more details. 15 * 16 * You should have received a copy of the GNU Lesser General Public 17 * License along with this library; if not, write to the Free Software 18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA 19 */ 20 21 #ifndef __WINE_RPC_SERVER_H 22 #define __WINE_RPC_SERVER_H 23 24 #include "rpc_binding.h" 25 #include "wine/list.h" 26 27 struct protseq_ops; 28 29 typedef struct _RpcServerProtseq 30 { 31 const struct protseq_ops *ops; /* RO */ 32 struct list entry; /* CS ::server_cs */ 33 LPSTR Protseq; /* RO */ 34 UINT MaxCalls; /* RO */ 35 /* list of listening connections */ 36 struct list listeners; /* CS cs */ 37 struct list connections; /* CS cs */ 38 CRITICAL_SECTION cs; 39 40 /* handle to listening thread */ 41 HANDLE server_thread; /* CS ::listen_cs */ 42 /* mutex for ensuring only one thread can change state at a time */ 43 HANDLE mgr_mutex; 44 /* set when server thread has finished opening connections */ 45 HANDLE server_ready_event; 46 } RpcServerProtseq; 47 48 struct protseq_ops 49 { 50 const char *name; 51 RpcServerProtseq *(*alloc)(void); 52 void (*signal_state_changed)(RpcServerProtseq *protseq); 53 /* previous array is passed in to allow reuse of memory */ 54 void *(*get_wait_array)(RpcServerProtseq *protseq, void *prev_array, unsigned int *count); 55 void (*free_wait_array)(RpcServerProtseq *protseq, void *array); 56 /* returns -1 for failure, 0 for server state changed and 1 to indicate a 57 * new connection was established */ 58 int (*wait_for_new_connection)(RpcServerProtseq *protseq, unsigned int count, void *wait_array); 59 /* opens the endpoint and optionally begins listening */ 60 RPC_STATUS (*open_endpoint)(RpcServerProtseq *protseq, const char *endpoint); 61 }; 62 63 typedef struct _RpcServerInterface 64 { 65 struct list entry; 66 RPC_SERVER_INTERFACE* If; 67 UUID MgrTypeUuid; 68 RPC_MGR_EPV* MgrEpv; 69 UINT Flags; 70 UINT MaxCalls; 71 UINT MaxRpcSize; 72 RPC_IF_CALLBACK_FN* IfCallbackFn; 73 LONG CurrentCalls; /* number of calls currently executing */ 74 /* set when unregistering interface to let the caller of 75 * RpcServerUnregisterIf* know that all calls have finished */ 76 HANDLE CallsCompletedEvent; 77 BOOL Delete; /* delete when the last call finishes */ 78 } RpcServerInterface; 79 80 void RPCRT4_new_client(RpcConnection* conn) DECLSPEC_HIDDEN; 81 const struct protseq_ops *rpcrt4_get_protseq_ops(const char *protseq) DECLSPEC_HIDDEN; 82 83 void RPCRT4_destroy_all_protseqs(void) DECLSPEC_HIDDEN; 84 void RPCRT4_ServerFreeAllRegisteredAuthInfo(void) DECLSPEC_HIDDEN; 85 86 #endif /* __WINE_RPC_SERVER_H */ 87