rpcrt4: Disable TCP/IP connection support if we don't have socketpair.
[wine] / dlls / rpcrt4 / ndr_es.c
1 /*
2  * NDR Serialization Services
3  *
4  * Copyright (c) 2007 Robert Shearman for CodeWeavers
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 #include <stdarg.h>
22 #include <stdio.h>
23
24 #include "windef.h"
25 #include "winbase.h"
26 #include "winerror.h"
27 #include "rpc.h"
28 #include "midles.h"
29 #include "ndrtypes.h"
30
31 #include "ndr_misc.h"
32 #include "ndr_stubless.h"
33
34 #include "wine/debug.h"
35 #include "wine/rpcfc.h"
36
37 WINE_DEFAULT_DEBUG_CHANNEL(ole);
38
39 static inline void init_MIDL_ES_MESSAGE(MIDL_ES_MESSAGE *pEsMsg)
40 {
41     memset(pEsMsg, 0, sizeof(*pEsMsg));
42     /* even if we are unmarshalling, as we don't want pointers to be pointed
43      * to buffer memory */
44     pEsMsg->StubMsg.IsClient = TRUE;
45 }
46
47 /***********************************************************************
48  *            MesEncodeIncrementalHandleCreate [RPCRT4.@]
49  */
50 RPC_STATUS WINAPI MesEncodeIncrementalHandleCreate(
51     void *UserState, MIDL_ES_ALLOC AllocFn, MIDL_ES_WRITE WriteFn,
52     handle_t *pHandle)
53 {
54     MIDL_ES_MESSAGE *pEsMsg;
55
56     TRACE("(%p, %p, %p, %p)\n", UserState, AllocFn, WriteFn, pHandle);
57
58     pEsMsg = HeapAlloc(GetProcessHeap(), 0, sizeof(*pEsMsg));
59     if (!pEsMsg)
60         return ERROR_OUTOFMEMORY;
61
62     init_MIDL_ES_MESSAGE(pEsMsg);
63
64     pEsMsg->Operation = MES_ENCODE;
65     pEsMsg->UserState = UserState;
66     pEsMsg->HandleStyle = MES_INCREMENTAL_HANDLE;
67     pEsMsg->Alloc = AllocFn;
68     pEsMsg->Write = WriteFn;
69
70     *pHandle = (handle_t)pEsMsg;
71
72     return RPC_S_OK;
73 }
74
75 /***********************************************************************
76  *            MesDecodeIncrementalHandleCreate [RPCRT4.@]
77  */
78 RPC_STATUS WINAPI MesDecodeIncrementalHandleCreate(
79     void *UserState, MIDL_ES_READ ReadFn, handle_t *pHandle)
80 {
81     MIDL_ES_MESSAGE *pEsMsg;
82
83     TRACE("(%p, %p, %p)\n", UserState, ReadFn, pHandle);
84
85     pEsMsg = HeapAlloc(GetProcessHeap(), 0, sizeof(*pEsMsg));
86     if (!pEsMsg)
87         return ERROR_OUTOFMEMORY;
88
89     init_MIDL_ES_MESSAGE(pEsMsg);
90
91     pEsMsg->Operation = MES_DECODE;
92     pEsMsg->UserState = UserState;
93     pEsMsg->HandleStyle = MES_INCREMENTAL_HANDLE;
94     pEsMsg->Read = ReadFn;
95
96     *pHandle = (handle_t)pEsMsg;
97
98     return RPC_S_OK;
99 }
100
101 /***********************************************************************
102  *            MesIncrementalHandleReset [RPCRT4.@]
103  */
104 RPC_STATUS WINAPI MesIncrementalHandleReset(
105     handle_t Handle, void *UserState, MIDL_ES_ALLOC AllocFn,
106     MIDL_ES_WRITE WriteFn, MIDL_ES_READ ReadFn, MIDL_ES_CODE Operation)
107 {
108     MIDL_ES_MESSAGE *pEsMsg = (MIDL_ES_MESSAGE *)Handle;
109
110     TRACE("(%p, %p, %p, %p, %p, %d)\n", Handle, UserState, AllocFn,
111         WriteFn, ReadFn, Operation);
112
113     init_MIDL_ES_MESSAGE(pEsMsg);
114
115     pEsMsg->Operation = Operation;
116     pEsMsg->UserState = UserState;
117     pEsMsg->HandleStyle = MES_INCREMENTAL_HANDLE;
118     pEsMsg->Alloc = AllocFn;
119     pEsMsg->Write = WriteFn;
120     pEsMsg->Read = ReadFn;
121
122     return RPC_S_OK;
123 }
124
125 /***********************************************************************
126  *            MesHandleFree [RPCRT4.@]
127  */
128 RPC_STATUS WINAPI MesHandleFree(handle_t Handle)
129 {
130     TRACE("(%p)\n", Handle);
131     HeapFree(GetProcessHeap(), 0, Handle);
132     return RPC_S_OK;
133 }
134
135 /***********************************************************************
136  *            MesEncodeFixedBufferHandleCreate [RPCRT4.@]
137  */
138 RPC_STATUS RPC_ENTRY MesEncodeFixedBufferHandleCreate(
139     char *Buffer, ULONG BufferSize, ULONG *pEncodedSize, handle_t *pHandle)
140 {
141     MIDL_ES_MESSAGE *pEsMsg;
142
143     TRACE("(%p, %d, %p, %p)\n", Buffer, BufferSize, pEncodedSize, pHandle);
144
145     pEsMsg = HeapAlloc(GetProcessHeap(), 0, sizeof(*pEsMsg));
146     if (!pEsMsg)
147         return ERROR_OUTOFMEMORY;
148
149     init_MIDL_ES_MESSAGE(pEsMsg);
150
151     pEsMsg->Operation = MES_ENCODE;
152     pEsMsg->HandleStyle = MES_FIXED_BUFFER_HANDLE;
153     pEsMsg->Buffer = (unsigned char *)Buffer;
154     pEsMsg->BufferSize = BufferSize;
155     pEsMsg->pEncodedSize = pEncodedSize;
156
157     *pHandle = (handle_t)pEsMsg;
158
159     return RPC_S_OK;
160 }
161
162 /***********************************************************************
163  *            MesEncodeDynBufferHandleCreate [RPCRT4.@]
164  */
165 RPC_STATUS RPC_ENTRY MesEncodeDynBufferHandleCreate(char **ppBuffer,
166         ULONG *pEncodedSize, handle_t *pHandle)
167 {
168     FIXME("%p %p %p stub\n", ppBuffer, pEncodedSize, pHandle);
169     return RPC_S_OK;
170 }
171
172 /***********************************************************************
173  *            MesDecodeBufferHandleCreate [RPCRT4.@]
174  */
175 RPC_STATUS RPC_ENTRY MesDecodeBufferHandleCreate(
176     char *Buffer, ULONG BufferSize, handle_t *pHandle)
177 {
178     MIDL_ES_MESSAGE *pEsMsg;
179
180     TRACE("(%p, %d, %p)\n", Buffer, BufferSize, pHandle);
181
182     pEsMsg = HeapAlloc(GetProcessHeap(), 0, sizeof(*pEsMsg));
183     if (!pEsMsg)
184         return ERROR_OUTOFMEMORY;
185
186     init_MIDL_ES_MESSAGE(pEsMsg);
187
188     pEsMsg->Operation = MES_DECODE;
189     pEsMsg->HandleStyle = MES_FIXED_BUFFER_HANDLE;
190     pEsMsg->Buffer = (unsigned char *)Buffer;
191     pEsMsg->BufferSize = BufferSize;
192
193     *pHandle = (handle_t)pEsMsg;
194
195     return RPC_S_OK;
196 }
197
198 static void es_data_alloc(MIDL_ES_MESSAGE *pEsMsg, ULONG size)
199 {
200     if (pEsMsg->HandleStyle == MES_INCREMENTAL_HANDLE)
201     {
202         unsigned int tmpsize = size;
203         TRACE("%d with incremental handle\n", size);
204         pEsMsg->Alloc(pEsMsg->UserState, (char **)&pEsMsg->StubMsg.Buffer, &tmpsize);
205         if (tmpsize < size)
206         {
207             ERR("not enough bytes allocated - requested %d, got %d\n", size, tmpsize);
208             RpcRaiseException(ERROR_OUTOFMEMORY);
209         }
210     }
211     else if (pEsMsg->HandleStyle == MES_FIXED_BUFFER_HANDLE)
212     {
213         TRACE("%d with fixed buffer handle\n", size);
214         pEsMsg->StubMsg.Buffer = pEsMsg->Buffer;
215     }
216     pEsMsg->StubMsg.RpcMsg->Buffer = pEsMsg->StubMsg.BufferStart = pEsMsg->StubMsg.Buffer;
217 }
218
219 static void es_data_read(MIDL_ES_MESSAGE *pEsMsg, ULONG size)
220 {
221     if (pEsMsg->HandleStyle == MES_INCREMENTAL_HANDLE)
222     {
223         unsigned int tmpsize = size;
224         TRACE("%d from incremental handle\n", size);
225         pEsMsg->Read(pEsMsg->UserState, (char **)&pEsMsg->StubMsg.Buffer, &tmpsize);
226         if (tmpsize < size)
227         {
228             ERR("not enough bytes read - requested %d, got %d\n", size, tmpsize);
229             RpcRaiseException(ERROR_OUTOFMEMORY);
230         }
231     }
232     else
233     {
234         TRACE("%d from fixed or dynamic buffer handle\n", size);
235         /* FIXME: validate BufferSize? */
236         pEsMsg->StubMsg.Buffer = pEsMsg->Buffer;
237         pEsMsg->Buffer += size;
238         pEsMsg->BufferSize -= size;
239     }
240     pEsMsg->StubMsg.BufferLength = size;
241     pEsMsg->StubMsg.RpcMsg->Buffer = pEsMsg->StubMsg.BufferStart = pEsMsg->StubMsg.Buffer;
242     pEsMsg->StubMsg.BufferEnd = pEsMsg->StubMsg.Buffer + size;
243 }
244
245 static void es_data_write(MIDL_ES_MESSAGE *pEsMsg, ULONG size)
246 {
247     if (pEsMsg->HandleStyle == MES_INCREMENTAL_HANDLE)
248     {
249         TRACE("%d to incremental handle\n", size);
250         pEsMsg->Write(pEsMsg->UserState, (char *)pEsMsg->StubMsg.BufferStart, size);
251     }
252     else
253     {
254         TRACE("%d to dynamic or fixed buffer handle\n", size);
255         *pEsMsg->pEncodedSize += size;
256     }
257 }
258
259 static inline ULONG mes_proc_header_buffer_size(void)
260 {
261     return 4 + 2*sizeof(RPC_SYNTAX_IDENTIFIER) + 12;
262 }
263
264 static void mes_proc_header_marshal(MIDL_ES_MESSAGE *pEsMsg)
265 {
266     const RPC_CLIENT_INTERFACE *client_interface = pEsMsg->StubMsg.StubDesc->RpcInterfaceInformation;
267     *(WORD *)pEsMsg->StubMsg.Buffer = 0x0101;
268     pEsMsg->StubMsg.Buffer += 2;
269     *(WORD *)pEsMsg->StubMsg.Buffer = 0xcccc;
270     pEsMsg->StubMsg.Buffer += 2;
271     memcpy(pEsMsg->StubMsg.Buffer, &client_interface->TransferSyntax, sizeof(RPC_SYNTAX_IDENTIFIER));
272     pEsMsg->StubMsg.Buffer += sizeof(RPC_SYNTAX_IDENTIFIER);
273     memcpy(pEsMsg->StubMsg.Buffer, &pEsMsg->InterfaceId, sizeof(RPC_SYNTAX_IDENTIFIER));
274     pEsMsg->StubMsg.Buffer += sizeof(RPC_SYNTAX_IDENTIFIER);
275     *(DWORD *)pEsMsg->StubMsg.Buffer = pEsMsg->ProcNumber;
276     pEsMsg->StubMsg.Buffer += 4;
277     *(DWORD *)pEsMsg->StubMsg.Buffer = 0x00000001;
278     pEsMsg->StubMsg.Buffer += 4;
279     *(DWORD *)pEsMsg->StubMsg.Buffer = pEsMsg->ByteCount;
280     pEsMsg->StubMsg.Buffer += 4;
281 }
282
283 static void mes_proc_header_unmarshal(MIDL_ES_MESSAGE *pEsMsg)
284 {
285     const RPC_CLIENT_INTERFACE *client_interface = pEsMsg->StubMsg.StubDesc->RpcInterfaceInformation;
286
287     es_data_read(pEsMsg, mes_proc_header_buffer_size());
288
289     if (*(WORD *)pEsMsg->StubMsg.Buffer != 0x0101)
290     {
291         FIXME("unknown value at Buffer[0] 0x%04x\n", *(WORD *)pEsMsg->StubMsg.Buffer);
292         RpcRaiseException(RPC_X_WRONG_ES_VERSION);
293     }
294     pEsMsg->StubMsg.Buffer += 2;
295     if (*(WORD *)pEsMsg->StubMsg.Buffer != 0xcccc)
296         FIXME("unknown value at Buffer[2] 0x%04x\n", *(WORD *)pEsMsg->StubMsg.Buffer);
297     pEsMsg->StubMsg.Buffer += 2;
298     if (memcmp(pEsMsg->StubMsg.Buffer, &client_interface->TransferSyntax, sizeof(RPC_SYNTAX_IDENTIFIER)))
299     {
300         const RPC_SYNTAX_IDENTIFIER *AlienTransferSyntax = (const RPC_SYNTAX_IDENTIFIER *)pEsMsg->StubMsg.Buffer;
301         ERR("bad transfer syntax %s {%d.%d}\n", debugstr_guid(&AlienTransferSyntax->SyntaxGUID),
302             AlienTransferSyntax->SyntaxVersion.MajorVersion,
303             AlienTransferSyntax->SyntaxVersion.MinorVersion);
304         RpcRaiseException(RPC_S_UNSUPPORTED_TRANS_SYN);
305     }
306     pEsMsg->StubMsg.Buffer += sizeof(RPC_SYNTAX_IDENTIFIER);
307     memcpy(&pEsMsg->InterfaceId, pEsMsg->StubMsg.Buffer, sizeof(RPC_SYNTAX_IDENTIFIER));
308     pEsMsg->StubMsg.Buffer += sizeof(RPC_SYNTAX_IDENTIFIER);
309     pEsMsg->ProcNumber = *(DWORD *)pEsMsg->StubMsg.Buffer;
310     pEsMsg->StubMsg.Buffer += 4;
311     if (*(DWORD *)pEsMsg->StubMsg.Buffer != 0x00000001)
312         FIXME("unknown value 0x%08x, expected 0x00000001\n", *(DWORD *)pEsMsg->StubMsg.Buffer);
313     pEsMsg->StubMsg.Buffer += 4;
314     pEsMsg->ByteCount = *(DWORD *)pEsMsg->StubMsg.Buffer;
315     pEsMsg->StubMsg.Buffer += 4;
316     if (pEsMsg->ByteCount + mes_proc_header_buffer_size() < pEsMsg->ByteCount)
317         RpcRaiseException(RPC_S_INVALID_BOUND);
318 }
319
320 /***********************************************************************
321  *            NdrMesProcEncodeDecode [RPCRT4.@]
322  */
323 void WINAPIV NdrMesProcEncodeDecode(handle_t Handle, const MIDL_STUB_DESC * pStubDesc, PFORMAT_STRING pFormat, ...)
324 {
325     /* pointer to start of stack where arguments start */
326     RPC_MESSAGE rpcMsg;
327     MIDL_ES_MESSAGE *pEsMsg = (MIDL_ES_MESSAGE *)Handle;
328     /* size of stack */
329     unsigned short stack_size;
330     /* header for procedure string */
331     const NDR_PROC_HEADER *pProcHeader = (const NDR_PROC_HEADER *)&pFormat[0];
332     /* the value to return to the client from the remote procedure */
333     LONG_PTR RetVal = 0;
334     const RPC_CLIENT_INTERFACE *client_interface;
335
336     TRACE("Handle %p, pStubDesc %p, pFormat %p, ...\n", Handle, pStubDesc, pFormat);
337
338     /* Later NDR language versions probably won't be backwards compatible */
339     if (pStubDesc->Version > 0x50002)
340     {
341         FIXME("Incompatible stub description version: 0x%x\n", pStubDesc->Version);
342         RpcRaiseException(RPC_X_WRONG_STUB_VERSION);
343     }
344
345     client_interface = pStubDesc->RpcInterfaceInformation;
346     pEsMsg->InterfaceId = client_interface->InterfaceId;
347
348     if (pProcHeader->Oi_flags & RPC_FC_PROC_OIF_RPCFLAGS)
349     {
350         const NDR_PROC_HEADER_RPC *pProcHeader = (const NDR_PROC_HEADER_RPC *)&pFormat[0];
351         stack_size = pProcHeader->stack_size;
352         pEsMsg->ProcNumber = pProcHeader->proc_num;
353         pFormat += sizeof(NDR_PROC_HEADER_RPC);
354     }
355     else
356     {
357         stack_size = pProcHeader->stack_size;
358         pEsMsg->ProcNumber = pProcHeader->proc_num;
359         pFormat += sizeof(NDR_PROC_HEADER);
360     }
361
362     if (pProcHeader->handle_type == RPC_FC_BIND_EXPLICIT)
363     {
364         switch (*pFormat) /* handle_type */
365         {
366         case RPC_FC_BIND_PRIMITIVE: /* explicit primitive */
367             pFormat += sizeof(NDR_EHD_PRIMITIVE);
368             break;
369         case RPC_FC_BIND_GENERIC: /* explicit generic */
370             pFormat += sizeof(NDR_EHD_GENERIC);
371             break;
372         case RPC_FC_BIND_CONTEXT: /* explicit context */
373             pFormat += sizeof(NDR_EHD_CONTEXT);
374             break;
375         default:
376             ERR("bad explicit binding handle type (0x%02x)\n", pProcHeader->handle_type);
377             RpcRaiseException(RPC_X_BAD_STUB_DATA);
378         }
379     }
380
381     TRACE("stack size: 0x%x\n", stack_size);
382     TRACE("proc num: %d\n", pEsMsg->ProcNumber);
383
384     memset(&rpcMsg, 0, sizeof(rpcMsg));
385     pEsMsg->StubMsg.RpcMsg = &rpcMsg;
386     pEsMsg->StubMsg.StubDesc = pStubDesc;
387     pEsMsg->StubMsg.pfnAllocate = pStubDesc->pfnAllocate;
388     pEsMsg->StubMsg.pfnFree = pStubDesc->pfnFree;
389
390     /* create the full pointer translation tables, if requested */
391     if (pProcHeader->Oi_flags & RPC_FC_PROC_OIF_FULLPTR)
392         pEsMsg->StubMsg.FullPtrXlatTables = NdrFullPointerXlatInit(0,XLAT_CLIENT);
393
394     TRACE("Oi_flags = 0x%02x\n", pProcHeader->Oi_flags);
395     TRACE("stubdesc version = 0x%x\n", pStubDesc->Version);
396     TRACE("MIDL stub version = 0x%x\n", pStubDesc->MIDLVersion);
397
398     /* needed for conformance of top-level objects */
399 #ifdef __i386__
400     pEsMsg->StubMsg.StackTop = *(unsigned char **)(&pFormat+1);
401 #else
402 # warning Stack not retrieved for your CPU architecture
403 #endif
404
405     switch (pEsMsg->Operation)
406     {
407     case MES_ENCODE:
408         pEsMsg->StubMsg.BufferLength = mes_proc_header_buffer_size();
409
410         client_do_args_old_format(&pEsMsg->StubMsg, pFormat, PROXY_CALCSIZE,
411             pEsMsg->StubMsg.StackTop, stack_size, (unsigned char *)&RetVal,
412             FALSE /* object_proc */, TRUE /* ignore_retval */);
413
414         pEsMsg->ByteCount = pEsMsg->StubMsg.BufferLength - mes_proc_header_buffer_size();
415         es_data_alloc(pEsMsg, pEsMsg->StubMsg.BufferLength);
416
417         mes_proc_header_marshal(pEsMsg);
418
419         client_do_args_old_format(&pEsMsg->StubMsg, pFormat, PROXY_MARSHAL,
420             pEsMsg->StubMsg.StackTop, stack_size, (unsigned char *)&RetVal,
421             FALSE /* object_proc */, TRUE /* ignore_retval */);
422
423         es_data_write(pEsMsg, pEsMsg->ByteCount);
424         break;
425     case MES_DECODE:
426         mes_proc_header_unmarshal(pEsMsg);
427
428         es_data_read(pEsMsg, pEsMsg->ByteCount);
429
430         client_do_args_old_format(&pEsMsg->StubMsg, pFormat, PROXY_UNMARSHAL,
431             pEsMsg->StubMsg.StackTop, stack_size, (unsigned char *)&RetVal,
432             FALSE /* object_proc */, TRUE /* ignore_retval */);
433         break;
434     default:
435         RpcRaiseException(RPC_S_INTERNAL_ERROR);
436         return;
437     }
438     /* free the full pointer translation tables */
439     if (pProcHeader->Oi_flags & RPC_FC_PROC_OIF_FULLPTR)
440         NdrFullPointerXlatFree(pEsMsg->StubMsg.FullPtrXlatTables);
441 }