git.oblomov.eu Git - wine/blob - dlls/rpcrt4/rpc_binding.h

   1 /*
   2  * RPC binding 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_BINDING_H
  22 #define __WINE_RPC_BINDING_H
  23
  24 #include "rpcndr.h"
  25 #include "security.h"
  26 #include "wine/list.h"
  27 #include "rpc_defs.h"
  28
  29
  30 typedef struct _RpcAuthInfo
  31 {
  32   LONG refs;
  33
  34   ULONG AuthnLevel;
  35   ULONG AuthnSvc;
  36   CredHandle cred;
  37   TimeStamp exp;
  38   ULONG cbMaxToken;
  39   /* the auth identity pointer that the application passed us (freed by application) */
  40   RPC_AUTH_IDENTITY_HANDLE *identity;
  41   /* our copy of NT auth identity structure, if the authentication service
  42    * takes an NT auth identity */
  43   SEC_WINNT_AUTH_IDENTITY_W *nt_identity;
  44   LPWSTR server_principal_name;
  45 } RpcAuthInfo;
  46
  47 typedef struct _RpcQualityOfService
  48 {
  49     LONG refs;
  50
  51     RPC_SECURITY_QOS_V2_W *qos;
  52 } RpcQualityOfService;
  53
  54 struct connection_ops;
  55
  56 typedef struct _RpcConnection
  57 {
  58   BOOL server;
  59   LPSTR NetworkAddr;
  60   LPSTR Endpoint;
  61   LPWSTR NetworkOptions;
  62   const struct connection_ops *ops;
  63   USHORT MaxTransmissionSize;
  64
  65   /* authentication */
  66   CtxtHandle ctx;
  67   TimeStamp exp;
  68   ULONG attr;
  69   RpcAuthInfo *AuthInfo;
  70   ULONG encryption_auth_len;
  71   ULONG signature_auth_len;
  72   RpcQualityOfService *QOS;
  73
  74   /* client-only */
  75   struct list conn_pool_entry;
  76   ULONG assoc_group_id; /* association group returned during binding */
  77   RPC_ASYNC_STATE *async_state;
  78   struct _RpcAssoc *assoc; /* association this connection is part of */
  79
  80   /* server-only */
  81   /* The active interface bound to server. */
  82   RPC_SYNTAX_IDENTIFIER ActiveInterface;
  83   USHORT NextCallId;
  84   struct _RpcConnection* Next;
  85   struct _RpcBinding *server_binding;
  86 } RpcConnection;
  87
  88 struct connection_ops {
  89   const char *name;
  90   unsigned char epm_protocols[2]; /* only floors 3 and 4. see http://www.opengroup.org/onlinepubs/9629399/apdxl.htm */
  91   RpcConnection *(*alloc)(void);
  92   RPC_STATUS (*open_connection_client)(RpcConnection *conn);
  93   RPC_STATUS (*handoff)(RpcConnection *old_conn, RpcConnection *new_conn);
  94   int (*read)(RpcConnection *conn, void *buffer, unsigned int len);
  95   int (*write)(RpcConnection *conn, const void *buffer, unsigned int len);
  96   int (*close)(RpcConnection *conn);
  97   void (*cancel_call)(RpcConnection *conn);
  98   int (*wait_for_incoming_data)(RpcConnection *conn);
  99   size_t (*get_top_of_tower)(unsigned char *tower_data, const char *networkaddr, const char *endpoint);
 100   RPC_STATUS (*parse_top_of_tower)(const unsigned char *tower_data, size_t tower_size, char **networkaddr, char **endpoint);
 101   RPC_STATUS (*receive_fragment)(RpcConnection *conn, RpcPktHdr **Header, void **Payload);
 102 };
 103
 104 /* don't know what MS's structure looks like */
 105 typedef struct _RpcBinding
 106 {
 107   LONG refs;
 108   struct _RpcBinding* Next;
 109   BOOL server;
 110   UUID ObjectUuid;
 111   LPSTR Protseq;
 112   LPSTR NetworkAddr;
 113   LPSTR Endpoint;
 114   LPWSTR NetworkOptions;
 115   RPC_BLOCKING_FN BlockingFn;
 116   ULONG ServerTid;
 117   RpcConnection* FromConn;
 118   struct _RpcAssoc *Assoc;
 119
 120   /* authentication */
 121   RpcAuthInfo *AuthInfo;
 122   RpcQualityOfService *QOS;
 123 } RpcBinding;
 124
 125 LPSTR RPCRT4_strndupA(LPCSTR src, INT len);
 126 LPWSTR RPCRT4_strndupW(LPCWSTR src, INT len);
 127 LPSTR RPCRT4_strdupWtoA(LPCWSTR src);
 128 LPWSTR RPCRT4_strdupAtoW(LPCSTR src);
 129 void RPCRT4_strfree(LPSTR src);
 130
 131 #define RPCRT4_strdupA(x) RPCRT4_strndupA((x),-1)
 132 #define RPCRT4_strdupW(x) RPCRT4_strndupW((x),-1)
 133
 134 ULONG RpcAuthInfo_AddRef(RpcAuthInfo *AuthInfo);
 135 ULONG RpcAuthInfo_Release(RpcAuthInfo *AuthInfo);
 136 BOOL RpcAuthInfo_IsEqual(const RpcAuthInfo *AuthInfo1, const RpcAuthInfo *AuthInfo2);
 137 ULONG RpcQualityOfService_AddRef(RpcQualityOfService *qos);
 138 ULONG RpcQualityOfService_Release(RpcQualityOfService *qos);
 139 BOOL RpcQualityOfService_IsEqual(const RpcQualityOfService *qos1, const RpcQualityOfService *qos2);
 140
 141 RPC_STATUS RPCRT4_CreateConnection(RpcConnection** Connection, BOOL server, LPCSTR Protseq, LPCSTR NetworkAddr, LPCSTR Endpoint, LPCWSTR NetworkOptions, RpcAuthInfo* AuthInfo, RpcQualityOfService *QOS);
 142 RPC_STATUS RPCRT4_DestroyConnection(RpcConnection* Connection);
 143 RPC_STATUS RPCRT4_OpenClientConnection(RpcConnection* Connection);
 144 RPC_STATUS RPCRT4_CloseConnection(RpcConnection* Connection);
 145
 146 RPC_STATUS RPCRT4_ResolveBinding(RpcBinding* Binding, LPCSTR Endpoint);
 147 RPC_STATUS RPCRT4_SetBindingObject(RpcBinding* Binding, const UUID* ObjectUuid);
 148 RPC_STATUS RPCRT4_MakeBinding(RpcBinding** Binding, RpcConnection* Connection);
 149 void       RPCRT4_AddRefBinding(RpcBinding* Binding);
 150 RPC_STATUS RPCRT4_ReleaseBinding(RpcBinding* Binding);
 151 RPC_STATUS RPCRT4_OpenBinding(RpcBinding* Binding, RpcConnection** Connection,
 152                               const RPC_SYNTAX_IDENTIFIER *TransferSyntax, const RPC_SYNTAX_IDENTIFIER *InterfaceId);
 153 RPC_STATUS RPCRT4_CloseBinding(RpcBinding* Binding, RpcConnection* Connection);
 154
 155 static inline const char *rpcrt4_conn_get_name(const RpcConnection *Connection)
 156 {
 157   return Connection->ops->name;
 158 }
 159
 160 static inline int rpcrt4_conn_read(RpcConnection *Connection,
 161                      void *buffer, unsigned int len)
 162 {
 163   return Connection->ops->read(Connection, buffer, len);
 164 }
 165
 166 static inline int rpcrt4_conn_write(RpcConnection *Connection,
 167                      const void *buffer, unsigned int len)
 168 {
 169   return Connection->ops->write(Connection, buffer, len);
 170 }
 171
 172 static inline int rpcrt4_conn_close(RpcConnection *Connection)
 173 {
 174   return Connection->ops->close(Connection);
 175 }
 176
 177 static inline void rpcrt4_conn_cancel_call(RpcConnection *Connection)
 178 {
 179   Connection->ops->cancel_call(Connection);
 180 }
 181
 182 static inline RPC_STATUS rpcrt4_conn_handoff(RpcConnection *old_conn, RpcConnection *new_conn)
 183 {
 184   return old_conn->ops->handoff(old_conn, new_conn);
 185 }
 186
 187 /* floors 3 and up */
 188 RPC_STATUS RpcTransport_GetTopOfTower(unsigned char *tower_data, size_t *tower_size, const char *protseq, const char *networkaddr, const char *endpoint);
 189 RPC_STATUS RpcTransport_ParseTopOfTower(const unsigned char *tower_data, size_t tower_size, char **protseq, char **networkaddr, char **endpoint);
 190
 191 void RPCRT4_SetThreadCurrentConnection(RpcConnection *Connection);
 192 void RPCRT4_SetThreadCurrentCallHandle(RpcBinding *Binding);
 193 RpcBinding *RPCRT4_GetThreadCurrentCallHandle(void);
 194 void RPCRT4_PushThreadContextHandle(NDR_SCONTEXT SContext);
 195 void RPCRT4_RemoveThreadContextHandle(NDR_SCONTEXT SContext);
 196 NDR_SCONTEXT RPCRT4_PopThreadContextHandle(void);
 197
 198 #endif