dlls/rpcrt4/rpc_server.h

   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 */