4 * Copyright 2001 Ove Kåven, TransGaming Technologies
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.
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.
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
21 #ifndef __WINE_RPC_BINDING_H
22 #define __WINE_RPC_BINDING_H
24 #include "wine/rpcss_shared.h"
26 #include "wine/list.h"
29 typedef struct _RpcAuthInfo
38 /* the auth identity pointer that the application passed us (freed by application) */
39 RPC_AUTH_IDENTITY_HANDLE
*identity
;
40 /* our copy of NT auth identity structure, if the authentication service
41 * takes an NT auth identity */
42 SEC_WINNT_AUTH_IDENTITY_W
*nt_identity
;
45 typedef struct _RpcQualityOfService
49 RPC_SECURITY_QOS_V2_W
*qos
;
50 } RpcQualityOfService
;
52 typedef struct _RpcAssoc
54 struct list entry
; /* entry in the global list of associations */
60 LPWSTR NetworkOptions
;
62 /* id of this association group */
66 struct list connection_pool
;
69 struct connection_ops
;
71 typedef struct _RpcConnection
73 struct _RpcConnection
* Next
;
77 LPWSTR NetworkOptions
;
78 const struct connection_ops
*ops
;
79 USHORT MaxTransmissionSize
;
80 /* The active interface bound to server. */
81 RPC_SYNTAX_IDENTIFIER ActiveInterface
;
88 RpcAuthInfo
*AuthInfo
;
89 ULONG encryption_auth_len
;
90 ULONG signature_auth_len
;
91 RpcQualityOfService
*QOS
;
94 struct list conn_pool_entry
;
95 ULONG assoc_group_id
; /* association group returned during binding */
98 struct connection_ops
{
100 unsigned char epm_protocols
[2]; /* only floors 3 and 4. see http://www.opengroup.org/onlinepubs/9629399/apdxl.htm */
101 RpcConnection
*(*alloc
)(void);
102 RPC_STATUS (*open_connection_client
)(RpcConnection
*conn
);
103 RPC_STATUS (*handoff
)(RpcConnection
*old_conn
, RpcConnection
*new_conn
);
104 int (*read
)(RpcConnection
*conn
, void *buffer
, unsigned int len
);
105 int (*write
)(RpcConnection
*conn
, const void *buffer
, unsigned int len
);
106 int (*close
)(RpcConnection
*conn
);
107 void (*cancel_call
)(RpcConnection
*conn
);
108 size_t (*get_top_of_tower
)(unsigned char *tower_data
, const char *networkaddr
, const char *endpoint
);
109 RPC_STATUS (*parse_top_of_tower
)(const unsigned char *tower_data
, size_t tower_size
, char **networkaddr
, char **endpoint
);
112 /* don't know what MS's structure looks like */
113 typedef struct _RpcBinding
116 struct _RpcBinding
* Next
;
122 LPWSTR NetworkOptions
;
123 RPC_BLOCKING_FN BlockingFn
;
125 RpcConnection
* FromConn
;
129 RpcAuthInfo
*AuthInfo
;
130 RpcQualityOfService
*QOS
;
133 LPSTR
RPCRT4_strndupA(LPCSTR src
, INT len
);
134 LPWSTR
RPCRT4_strndupW(LPCWSTR src
, INT len
);
135 LPSTR
RPCRT4_strdupWtoA(LPCWSTR src
);
136 LPWSTR
RPCRT4_strdupAtoW(LPCSTR src
);
137 void RPCRT4_strfree(LPSTR src
);
139 #define RPCRT4_strdupA(x) RPCRT4_strndupA((x),-1)
140 #define RPCRT4_strdupW(x) RPCRT4_strndupW((x),-1)
142 ULONG
RpcAuthInfo_AddRef(RpcAuthInfo
*AuthInfo
);
143 ULONG
RpcAuthInfo_Release(RpcAuthInfo
*AuthInfo
);
144 BOOL
RpcAuthInfo_IsEqual(const RpcAuthInfo
*AuthInfo1
, const RpcAuthInfo
*AuthInfo2
);
145 ULONG
RpcQualityOfService_AddRef(RpcQualityOfService
*qos
);
146 ULONG
RpcQualityOfService_Release(RpcQualityOfService
*qos
);
147 BOOL
RpcQualityOfService_IsEqual(const RpcQualityOfService
*qos1
, const RpcQualityOfService
*qos2
);
149 RPC_STATUS
RPCRT4_GetAssociation(LPCSTR Protseq
, LPCSTR NetworkAddr
, LPCSTR Endpoint
, LPCWSTR NetworkOptions
, RpcAssoc
**assoc
);
150 RPC_STATUS
RpcAssoc_GetClientConnection(RpcAssoc
*assoc
, const RPC_SYNTAX_IDENTIFIER
*InterfaceId
, const RPC_SYNTAX_IDENTIFIER
*TransferSyntax
, RpcAuthInfo
*AuthInfo
, RpcQualityOfService
*QOS
, RpcConnection
**Connection
);
151 void RpcAssoc_ReleaseIdleConnection(RpcAssoc
*assoc
, RpcConnection
*Connection
);
152 ULONG
RpcAssoc_Release(RpcAssoc
*assoc
);
154 RPC_STATUS
RPCRT4_CreateConnection(RpcConnection
** Connection
, BOOL server
, LPCSTR Protseq
, LPCSTR NetworkAddr
, LPCSTR Endpoint
, LPCWSTR NetworkOptions
, RpcAuthInfo
* AuthInfo
, RpcQualityOfService
*QOS
);
155 RPC_STATUS
RPCRT4_DestroyConnection(RpcConnection
* Connection
);
156 RPC_STATUS
RPCRT4_OpenClientConnection(RpcConnection
* Connection
);
157 RPC_STATUS
RPCRT4_CloseConnection(RpcConnection
* Connection
);
158 RPC_STATUS
RPCRT4_SpawnConnection(RpcConnection
** Connection
, RpcConnection
* OldConnection
);
160 RPC_STATUS
RPCRT4_ResolveBinding(RpcBinding
* Binding
, LPCSTR Endpoint
);
161 RPC_STATUS
RPCRT4_SetBindingObject(RpcBinding
* Binding
, const UUID
* ObjectUuid
);
162 RPC_STATUS
RPCRT4_MakeBinding(RpcBinding
** Binding
, RpcConnection
* Connection
);
163 RPC_STATUS
RPCRT4_ExportBinding(RpcBinding
** Binding
, RpcBinding
* OldBinding
);
164 RPC_STATUS
RPCRT4_DestroyBinding(RpcBinding
* Binding
);
165 RPC_STATUS
RPCRT4_OpenBinding(RpcBinding
* Binding
, RpcConnection
** Connection
,
166 const RPC_SYNTAX_IDENTIFIER
*TransferSyntax
, const RPC_SYNTAX_IDENTIFIER
*InterfaceId
);
167 RPC_STATUS
RPCRT4_CloseBinding(RpcBinding
* Binding
, RpcConnection
* Connection
);
168 BOOL
RPCRT4_RPCSSOnDemandCall(PRPCSS_NP_MESSAGE msg
, char *vardata_payload
, PRPCSS_NP_REPLY reply
);
169 HANDLE
RPCRT4_GetMasterMutex(void);
170 HANDLE
RPCRT4_RpcssNPConnect(void);
172 static inline const char *rpcrt4_conn_get_name(const RpcConnection
*Connection
)
174 return Connection
->ops
->name
;
177 static inline int rpcrt4_conn_read(RpcConnection
*Connection
,
178 void *buffer
, unsigned int len
)
180 return Connection
->ops
->read(Connection
, buffer
, len
);
183 static inline int rpcrt4_conn_write(RpcConnection
*Connection
,
184 const void *buffer
, unsigned int len
)
186 return Connection
->ops
->write(Connection
, buffer
, len
);
189 static inline int rpcrt4_conn_close(RpcConnection
*Connection
)
191 return Connection
->ops
->close(Connection
);
194 static inline void rpcrt4_conn_cancel_call(RpcConnection
*Connection
)
196 Connection
->ops
->cancel_call(Connection
);
199 static inline RPC_STATUS
rpcrt4_conn_handoff(RpcConnection
*old_conn
, RpcConnection
*new_conn
)
201 return old_conn
->ops
->handoff(old_conn
, new_conn
);
204 /* floors 3 and up */
205 RPC_STATUS
RpcTransport_GetTopOfTower(unsigned char *tower_data
, size_t *tower_size
, const char *protseq
, const char *networkaddr
, const char *endpoint
);
206 RPC_STATUS
RpcTransport_ParseTopOfTower(const unsigned char *tower_data
, size_t tower_size
, char **protseq
, char **networkaddr
, char **endpoint
);
208 void RPCRT4_SetThreadCurrentConnection(RpcConnection
*Connection
);