push 6fe5edf8439c19d3885814583531c2f2b1495177
[wine/hacks.git] / dlls / rpcrt4 / rpc_binding.c
blob87ac4138b04caaea318b8cd6c221ad5fb4fc792f
1 /*
2 * RPC binding API
4 * Copyright 2001 Ove Kåven, TransGaming Technologies
5 * Copyright 2003 Mike Hearn
6 * Copyright 2004 Filip Navara
7 * Copyright 2006 CodeWeavers
9 * This library is free software; you can redistribute it and/or
10 * modify it under the terms of the GNU Lesser General Public
11 * License as published by the Free Software Foundation; either
12 * version 2.1 of the License, or (at your option) any later version.
14 * This library is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
17 * Lesser General Public License for more details.
19 * You should have received a copy of the GNU Lesser General Public
20 * License along with this library; if not, write to the Free Software
21 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
24 #include <stdarg.h>
25 #include <stdio.h>
26 #include <string.h>
27 #include <assert.h>
29 #include "windef.h"
30 #include "winbase.h"
31 #include "winnls.h"
32 #include "winerror.h"
33 #include "winternl.h"
34 #include "wine/unicode.h"
36 #include "rpc.h"
37 #include "rpcndr.h"
39 #include "wine/debug.h"
41 #include "rpc_binding.h"
42 #include "rpc_assoc.h"
44 WINE_DEFAULT_DEBUG_CHANNEL(rpc);
46 LPSTR RPCRT4_strndupA(LPCSTR src, INT slen)
48 DWORD len;
49 LPSTR s;
50 if (!src) return NULL;
51 if (slen == -1) slen = strlen(src);
52 len = slen;
53 s = HeapAlloc(GetProcessHeap(), 0, len+1);
54 memcpy(s, src, len);
55 s[len] = 0;
56 return s;
59 LPSTR RPCRT4_strdupWtoA(LPCWSTR src)
61 DWORD len;
62 LPSTR s;
63 if (!src) return NULL;
64 len = WideCharToMultiByte(CP_ACP, 0, src, -1, NULL, 0, NULL, NULL);
65 s = HeapAlloc(GetProcessHeap(), 0, len);
66 WideCharToMultiByte(CP_ACP, 0, src, -1, s, len, NULL, NULL);
67 return s;
70 LPWSTR RPCRT4_strdupAtoW(LPCSTR src)
72 DWORD len;
73 LPWSTR s;
74 if (!src) return NULL;
75 len = MultiByteToWideChar(CP_ACP, 0, src, -1, NULL, 0);
76 s = HeapAlloc(GetProcessHeap(), 0, len*sizeof(WCHAR));
77 MultiByteToWideChar(CP_ACP, 0, src, -1, s, len);
78 return s;
81 static LPWSTR RPCRT4_strndupAtoW(LPCSTR src, INT slen)
83 DWORD len;
84 LPWSTR s;
85 if (!src) return NULL;
86 len = MultiByteToWideChar(CP_ACP, 0, src, slen, NULL, 0);
87 s = HeapAlloc(GetProcessHeap(), 0, len*sizeof(WCHAR));
88 MultiByteToWideChar(CP_ACP, 0, src, slen, s, len);
89 return s;
92 LPWSTR RPCRT4_strndupW(LPCWSTR src, INT slen)
94 DWORD len;
95 LPWSTR s;
96 if (!src) return NULL;
97 if (slen == -1) slen = strlenW(src);
98 len = slen;
99 s = HeapAlloc(GetProcessHeap(), 0, (len+1)*sizeof(WCHAR));
100 memcpy(s, src, len*sizeof(WCHAR));
101 s[len] = 0;
102 return s;
105 void RPCRT4_strfree(LPSTR src)
107 HeapFree(GetProcessHeap(), 0, src);
110 static RPC_STATUS RPCRT4_AllocBinding(RpcBinding** Binding, BOOL server)
112 RpcBinding* NewBinding;
114 NewBinding = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(RpcBinding));
115 NewBinding->refs = 1;
116 NewBinding->server = server;
118 *Binding = NewBinding;
120 return RPC_S_OK;
123 static RPC_STATUS RPCRT4_CreateBindingA(RpcBinding** Binding, BOOL server, LPCSTR Protseq)
125 RpcBinding* NewBinding;
127 RPCRT4_AllocBinding(&NewBinding, server);
128 NewBinding->Protseq = RPCRT4_strdupA(Protseq);
130 TRACE("binding: %p\n", NewBinding);
131 *Binding = NewBinding;
133 return RPC_S_OK;
136 static RPC_STATUS RPCRT4_CreateBindingW(RpcBinding** Binding, BOOL server, LPCWSTR Protseq)
138 RpcBinding* NewBinding;
140 RPCRT4_AllocBinding(&NewBinding, server);
141 NewBinding->Protseq = RPCRT4_strdupWtoA(Protseq);
143 TRACE("binding: %p\n", NewBinding);
144 *Binding = NewBinding;
146 return RPC_S_OK;
149 static RPC_STATUS RPCRT4_CompleteBindingA(RpcBinding* Binding, LPCSTR NetworkAddr,
150 LPCSTR Endpoint, LPCSTR NetworkOptions)
152 RPC_STATUS status;
154 TRACE("(RpcBinding == ^%p, NetworkAddr == %s, EndPoint == %s, NetworkOptions == %s)\n", Binding,
155 debugstr_a(NetworkAddr), debugstr_a(Endpoint), debugstr_a(NetworkOptions));
157 RPCRT4_strfree(Binding->NetworkAddr);
158 Binding->NetworkAddr = RPCRT4_strdupA(NetworkAddr);
159 RPCRT4_strfree(Binding->Endpoint);
160 if (Endpoint) {
161 Binding->Endpoint = RPCRT4_strdupA(Endpoint);
162 } else {
163 Binding->Endpoint = RPCRT4_strdupA("");
165 HeapFree(GetProcessHeap(), 0, Binding->NetworkOptions);
166 Binding->NetworkOptions = RPCRT4_strdupAtoW(NetworkOptions);
167 if (!Binding->Endpoint) ERR("out of memory?\n");
169 status = RPCRT4_GetAssociation(Binding->Protseq, Binding->NetworkAddr,
170 Binding->Endpoint, Binding->NetworkOptions,
171 &Binding->Assoc);
172 if (status != RPC_S_OK)
173 return status;
175 return RPC_S_OK;
178 static RPC_STATUS RPCRT4_CompleteBindingW(RpcBinding* Binding, LPCWSTR NetworkAddr,
179 LPCWSTR Endpoint, LPCWSTR NetworkOptions)
181 RPC_STATUS status;
183 TRACE("(RpcBinding == ^%p, NetworkAddr == %s, EndPoint == %s, NetworkOptions == %s)\n", Binding,
184 debugstr_w(NetworkAddr), debugstr_w(Endpoint), debugstr_w(NetworkOptions));
186 RPCRT4_strfree(Binding->NetworkAddr);
187 Binding->NetworkAddr = RPCRT4_strdupWtoA(NetworkAddr);
188 RPCRT4_strfree(Binding->Endpoint);
189 if (Endpoint) {
190 Binding->Endpoint = RPCRT4_strdupWtoA(Endpoint);
191 } else {
192 Binding->Endpoint = RPCRT4_strdupA("");
194 if (!Binding->Endpoint) ERR("out of memory?\n");
195 HeapFree(GetProcessHeap(), 0, Binding->NetworkOptions);
196 Binding->NetworkOptions = RPCRT4_strdupW(NetworkOptions);
198 status = RPCRT4_GetAssociation(Binding->Protseq, Binding->NetworkAddr,
199 Binding->Endpoint, Binding->NetworkOptions,
200 &Binding->Assoc);
201 if (status != RPC_S_OK)
202 return status;
204 return RPC_S_OK;
207 RPC_STATUS RPCRT4_ResolveBinding(RpcBinding* Binding, LPCSTR Endpoint)
209 RPC_STATUS status;
211 TRACE("(RpcBinding == ^%p, EndPoint == \"%s\"\n", Binding, Endpoint);
213 RPCRT4_strfree(Binding->Endpoint);
214 Binding->Endpoint = RPCRT4_strdupA(Endpoint);
216 RpcAssoc_Release(Binding->Assoc);
217 Binding->Assoc = NULL;
218 status = RPCRT4_GetAssociation(Binding->Protseq, Binding->NetworkAddr,
219 Binding->Endpoint, Binding->NetworkOptions,
220 &Binding->Assoc);
221 if (status != RPC_S_OK)
222 return status;
224 return RPC_S_OK;
227 RPC_STATUS RPCRT4_SetBindingObject(RpcBinding* Binding, const UUID* ObjectUuid)
229 TRACE("(*RpcBinding == ^%p, UUID == %s)\n", Binding, debugstr_guid(ObjectUuid));
230 if (ObjectUuid) Binding->ObjectUuid = *ObjectUuid;
231 else UuidCreateNil(&Binding->ObjectUuid);
232 return RPC_S_OK;
235 RPC_STATUS RPCRT4_MakeBinding(RpcBinding** Binding, RpcConnection* Connection)
237 RpcBinding* NewBinding;
238 TRACE("(RpcBinding == ^%p, Connection == ^%p)\n", Binding, Connection);
240 RPCRT4_AllocBinding(&NewBinding, Connection->server);
241 NewBinding->Protseq = RPCRT4_strdupA(rpcrt4_conn_get_name(Connection));
242 NewBinding->NetworkAddr = RPCRT4_strdupA(Connection->NetworkAddr);
243 NewBinding->Endpoint = RPCRT4_strdupA(Connection->Endpoint);
244 NewBinding->FromConn = Connection;
246 TRACE("binding: %p\n", NewBinding);
247 *Binding = NewBinding;
249 return RPC_S_OK;
252 void RPCRT4_AddRefBinding(RpcBinding* Binding)
254 InterlockedIncrement(&Binding->refs);
257 RPC_STATUS RPCRT4_ReleaseBinding(RpcBinding* Binding)
259 if (InterlockedDecrement(&Binding->refs))
260 return RPC_S_OK;
262 TRACE("binding: %p\n", Binding);
263 if (Binding->Assoc) RpcAssoc_Release(Binding->Assoc);
264 RPCRT4_strfree(Binding->Endpoint);
265 RPCRT4_strfree(Binding->NetworkAddr);
266 RPCRT4_strfree(Binding->Protseq);
267 HeapFree(GetProcessHeap(), 0, Binding->NetworkOptions);
268 if (Binding->AuthInfo) RpcAuthInfo_Release(Binding->AuthInfo);
269 if (Binding->QOS) RpcQualityOfService_Release(Binding->QOS);
270 HeapFree(GetProcessHeap(), 0, Binding);
271 return RPC_S_OK;
274 RPC_STATUS RPCRT4_OpenBinding(RpcBinding* Binding, RpcConnection** Connection,
275 const RPC_SYNTAX_IDENTIFIER *TransferSyntax,
276 const RPC_SYNTAX_IDENTIFIER *InterfaceId)
278 TRACE("(Binding == ^%p)\n", Binding);
280 if (!Binding->server) {
281 return RpcAssoc_GetClientConnection(Binding->Assoc, InterfaceId,
282 TransferSyntax, Binding->AuthInfo, Binding->QOS, Connection);
283 } else {
284 /* we already have a connection with acceptable binding, so use it */
285 if (Binding->FromConn) {
286 *Connection = Binding->FromConn;
287 return RPC_S_OK;
288 } else {
289 ERR("no connection in binding\n");
290 return RPC_S_INTERNAL_ERROR;
295 RPC_STATUS RPCRT4_CloseBinding(RpcBinding* Binding, RpcConnection* Connection)
297 TRACE("(Binding == ^%p)\n", Binding);
298 if (!Connection) return RPC_S_OK;
299 if (Binding->server) {
300 /* don't destroy a connection that is cached in the binding */
301 if (Binding->FromConn == Connection)
302 return RPC_S_OK;
303 return RPCRT4_DestroyConnection(Connection);
305 else {
306 RpcAssoc_ReleaseIdleConnection(Binding->Assoc, Connection);
307 return RPC_S_OK;
311 /* utility functions for string composing and parsing */
312 static unsigned RPCRT4_strcopyA(LPSTR data, LPCSTR src)
314 unsigned len = strlen(src);
315 memcpy(data, src, len*sizeof(CHAR));
316 return len;
319 static unsigned RPCRT4_strcopyW(LPWSTR data, LPCWSTR src)
321 unsigned len = strlenW(src);
322 memcpy(data, src, len*sizeof(WCHAR));
323 return len;
326 static LPSTR RPCRT4_strconcatA(LPSTR dst, LPCSTR src)
328 DWORD len = strlen(dst), slen = strlen(src);
329 LPSTR ndst = HeapReAlloc(GetProcessHeap(), 0, dst, (len+slen+2)*sizeof(CHAR));
330 if (!ndst)
332 HeapFree(GetProcessHeap(), 0, dst);
333 return NULL;
335 ndst[len] = ',';
336 memcpy(ndst+len+1, src, slen+1);
337 return ndst;
340 static LPWSTR RPCRT4_strconcatW(LPWSTR dst, LPCWSTR src)
342 DWORD len = strlenW(dst), slen = strlenW(src);
343 LPWSTR ndst = HeapReAlloc(GetProcessHeap(), 0, dst, (len+slen+2)*sizeof(WCHAR));
344 if (!ndst)
346 HeapFree(GetProcessHeap(), 0, dst);
347 return NULL;
349 ndst[len] = ',';
350 memcpy(ndst+len+1, src, (slen+1)*sizeof(WCHAR));
351 return ndst;
355 /***********************************************************************
356 * RpcStringBindingComposeA (RPCRT4.@)
358 RPC_STATUS WINAPI RpcStringBindingComposeA(RPC_CSTR ObjUuid, RPC_CSTR Protseq,
359 RPC_CSTR NetworkAddr, RPC_CSTR Endpoint,
360 RPC_CSTR Options, RPC_CSTR *StringBinding )
362 DWORD len = 1;
363 LPSTR data;
365 TRACE( "(%s,%s,%s,%s,%s,%p)\n",
366 debugstr_a( (char*)ObjUuid ), debugstr_a( (char*)Protseq ),
367 debugstr_a( (char*)NetworkAddr ), debugstr_a( (char*)Endpoint ),
368 debugstr_a( (char*)Options ), StringBinding );
370 if (ObjUuid && *ObjUuid) len += strlen((char*)ObjUuid) + 1;
371 if (Protseq && *Protseq) len += strlen((char*)Protseq) + 1;
372 if (NetworkAddr && *NetworkAddr) len += strlen((char*)NetworkAddr);
373 if (Endpoint && *Endpoint) len += strlen((char*)Endpoint) + 2;
374 if (Options && *Options) len += strlen((char*)Options) + 2;
376 data = HeapAlloc(GetProcessHeap(), 0, len);
377 *StringBinding = (unsigned char*)data;
379 if (ObjUuid && *ObjUuid) {
380 data += RPCRT4_strcopyA(data, (char*)ObjUuid);
381 *data++ = '@';
383 if (Protseq && *Protseq) {
384 data += RPCRT4_strcopyA(data, (char*)Protseq);
385 *data++ = ':';
387 if (NetworkAddr && *NetworkAddr)
388 data += RPCRT4_strcopyA(data, (char*)NetworkAddr);
390 if ((Endpoint && *Endpoint) ||
391 (Options && *Options)) {
392 *data++ = '[';
393 if (Endpoint && *Endpoint) {
394 data += RPCRT4_strcopyA(data, (char*)Endpoint);
395 if (Options && *Options) *data++ = ',';
397 if (Options && *Options) {
398 data += RPCRT4_strcopyA(data, (char*)Options);
400 *data++ = ']';
402 *data = 0;
404 return RPC_S_OK;
407 /***********************************************************************
408 * RpcStringBindingComposeW (RPCRT4.@)
410 RPC_STATUS WINAPI RpcStringBindingComposeW( RPC_WSTR ObjUuid, RPC_WSTR Protseq,
411 RPC_WSTR NetworkAddr, RPC_WSTR Endpoint,
412 RPC_WSTR Options, RPC_WSTR* StringBinding )
414 DWORD len = 1;
415 RPC_WSTR data;
417 TRACE("(%s,%s,%s,%s,%s,%p)\n",
418 debugstr_w( ObjUuid ), debugstr_w( Protseq ),
419 debugstr_w( NetworkAddr ), debugstr_w( Endpoint ),
420 debugstr_w( Options ), StringBinding);
422 if (ObjUuid && *ObjUuid) len += strlenW(ObjUuid) + 1;
423 if (Protseq && *Protseq) len += strlenW(Protseq) + 1;
424 if (NetworkAddr && *NetworkAddr) len += strlenW(NetworkAddr);
425 if (Endpoint && *Endpoint) len += strlenW(Endpoint) + 2;
426 if (Options && *Options) len += strlenW(Options) + 2;
428 data = HeapAlloc(GetProcessHeap(), 0, len*sizeof(WCHAR));
429 *StringBinding = data;
431 if (ObjUuid && *ObjUuid) {
432 data += RPCRT4_strcopyW(data, ObjUuid);
433 *data++ = '@';
435 if (Protseq && *Protseq) {
436 data += RPCRT4_strcopyW(data, Protseq);
437 *data++ = ':';
439 if (NetworkAddr && *NetworkAddr) {
440 data += RPCRT4_strcopyW(data, NetworkAddr);
442 if ((Endpoint && *Endpoint) ||
443 (Options && *Options)) {
444 *data++ = '[';
445 if (Endpoint && *Endpoint) {
446 data += RPCRT4_strcopyW(data, Endpoint);
447 if (Options && *Options) *data++ = ',';
449 if (Options && *Options) {
450 data += RPCRT4_strcopyW(data, Options);
452 *data++ = ']';
454 *data = 0;
456 return RPC_S_OK;
460 /***********************************************************************
461 * RpcStringBindingParseA (RPCRT4.@)
463 RPC_STATUS WINAPI RpcStringBindingParseA( RPC_CSTR StringBinding, RPC_CSTR *ObjUuid,
464 RPC_CSTR *Protseq, RPC_CSTR *NetworkAddr,
465 RPC_CSTR *Endpoint, RPC_CSTR *Options)
467 CHAR *data, *next;
468 static const char ep_opt[] = "endpoint=";
469 BOOL endpoint_already_found = FALSE;
471 TRACE("(%s,%p,%p,%p,%p,%p)\n", debugstr_a((char*)StringBinding),
472 ObjUuid, Protseq, NetworkAddr, Endpoint, Options);
474 if (ObjUuid) *ObjUuid = NULL;
475 if (Protseq) *Protseq = NULL;
476 if (NetworkAddr) *NetworkAddr = NULL;
477 if (Endpoint) *Endpoint = NULL;
478 if (Options) *Options = NULL;
480 data = (char*) StringBinding;
482 next = strchr(data, '@');
483 if (next) {
484 if (ObjUuid) *ObjUuid = (unsigned char*)RPCRT4_strndupA(data, next - data);
485 data = next+1;
488 next = strchr(data, ':');
489 if (next) {
490 if (Protseq) *Protseq = (unsigned char*)RPCRT4_strndupA(data, next - data);
491 data = next+1;
494 next = strchr(data, '[');
495 if (next) {
496 CHAR *close, *opt;
498 if (NetworkAddr) *NetworkAddr = (unsigned char*)RPCRT4_strndupA(data, next - data);
499 data = next+1;
500 close = strchr(data, ']');
501 if (!close) goto fail;
503 /* tokenize options */
504 while (data < close) {
505 next = strchr(data, ',');
506 if (!next || next > close) next = close;
507 /* FIXME: this is kind of inefficient */
508 opt = RPCRT4_strndupA(data, next - data);
509 data = next+1;
511 /* parse option */
512 next = strchr(opt, '=');
513 if (!next) {
514 /* not an option, must be an endpoint */
515 if (endpoint_already_found) goto fail;
516 if (Endpoint) *Endpoint = (unsigned char*) opt;
517 else HeapFree(GetProcessHeap(), 0, opt);
518 endpoint_already_found = TRUE;
519 } else {
520 if (strncmp(opt, ep_opt, strlen(ep_opt)) == 0) {
521 /* endpoint option */
522 if (endpoint_already_found) goto fail;
523 if (Endpoint) *Endpoint = (unsigned char*) RPCRT4_strdupA(next+1);
524 HeapFree(GetProcessHeap(), 0, opt);
525 endpoint_already_found = TRUE;
526 } else {
527 /* network option */
528 if (Options) {
529 if (*Options) {
530 /* FIXME: this is kind of inefficient */
531 *Options = (unsigned char*) RPCRT4_strconcatA( (char*)*Options, opt);
532 HeapFree(GetProcessHeap(), 0, opt);
533 } else
534 *Options = (unsigned char*) opt;
535 } else
536 HeapFree(GetProcessHeap(), 0, opt);
541 data = close+1;
542 if (*data) goto fail;
544 else if (NetworkAddr)
545 *NetworkAddr = (unsigned char*)RPCRT4_strdupA(data);
547 return RPC_S_OK;
549 fail:
550 if (ObjUuid) RpcStringFreeA((unsigned char**)ObjUuid);
551 if (Protseq) RpcStringFreeA((unsigned char**)Protseq);
552 if (NetworkAddr) RpcStringFreeA((unsigned char**)NetworkAddr);
553 if (Endpoint) RpcStringFreeA((unsigned char**)Endpoint);
554 if (Options) RpcStringFreeA((unsigned char**)Options);
555 return RPC_S_INVALID_STRING_BINDING;
558 /***********************************************************************
559 * RpcStringBindingParseW (RPCRT4.@)
561 RPC_STATUS WINAPI RpcStringBindingParseW( RPC_WSTR StringBinding, RPC_WSTR *ObjUuid,
562 RPC_WSTR *Protseq, RPC_WSTR *NetworkAddr,
563 RPC_WSTR *Endpoint, RPC_WSTR *Options)
565 WCHAR *data, *next;
566 static const WCHAR ep_opt[] = {'e','n','d','p','o','i','n','t','=',0};
567 BOOL endpoint_already_found = FALSE;
569 TRACE("(%s,%p,%p,%p,%p,%p)\n", debugstr_w(StringBinding),
570 ObjUuid, Protseq, NetworkAddr, Endpoint, Options);
572 if (ObjUuid) *ObjUuid = NULL;
573 if (Protseq) *Protseq = NULL;
574 if (NetworkAddr) *NetworkAddr = NULL;
575 if (Endpoint) *Endpoint = NULL;
576 if (Options) *Options = NULL;
578 data = StringBinding;
580 next = strchrW(data, '@');
581 if (next) {
582 if (ObjUuid) *ObjUuid = RPCRT4_strndupW(data, next - data);
583 data = next+1;
586 next = strchrW(data, ':');
587 if (next) {
588 if (Protseq) *Protseq = RPCRT4_strndupW(data, next - data);
589 data = next+1;
592 next = strchrW(data, '[');
593 if (next) {
594 WCHAR *close, *opt;
596 if (NetworkAddr) *NetworkAddr = RPCRT4_strndupW(data, next - data);
597 data = next+1;
598 close = strchrW(data, ']');
599 if (!close) goto fail;
601 /* tokenize options */
602 while (data < close) {
603 next = strchrW(data, ',');
604 if (!next || next > close) next = close;
605 /* FIXME: this is kind of inefficient */
606 opt = RPCRT4_strndupW(data, next - data);
607 data = next+1;
609 /* parse option */
610 next = strchrW(opt, '=');
611 if (!next) {
612 /* not an option, must be an endpoint */
613 if (endpoint_already_found) goto fail;
614 if (Endpoint) *Endpoint = opt;
615 else HeapFree(GetProcessHeap(), 0, opt);
616 endpoint_already_found = TRUE;
617 } else {
618 if (strncmpW(opt, ep_opt, strlenW(ep_opt)) == 0) {
619 /* endpoint option */
620 if (endpoint_already_found) goto fail;
621 if (Endpoint) *Endpoint = RPCRT4_strdupW(next+1);
622 HeapFree(GetProcessHeap(), 0, opt);
623 endpoint_already_found = TRUE;
624 } else {
625 /* network option */
626 if (Options) {
627 if (*Options) {
628 /* FIXME: this is kind of inefficient */
629 *Options = RPCRT4_strconcatW(*Options, opt);
630 HeapFree(GetProcessHeap(), 0, opt);
631 } else
632 *Options = opt;
633 } else
634 HeapFree(GetProcessHeap(), 0, opt);
639 data = close+1;
640 if (*data) goto fail;
641 } else if (NetworkAddr)
642 *NetworkAddr = RPCRT4_strdupW(data);
644 return RPC_S_OK;
646 fail:
647 if (ObjUuid) RpcStringFreeW(ObjUuid);
648 if (Protseq) RpcStringFreeW(Protseq);
649 if (NetworkAddr) RpcStringFreeW(NetworkAddr);
650 if (Endpoint) RpcStringFreeW(Endpoint);
651 if (Options) RpcStringFreeW(Options);
652 return RPC_S_INVALID_STRING_BINDING;
655 /***********************************************************************
656 * RpcBindingFree (RPCRT4.@)
658 RPC_STATUS WINAPI RpcBindingFree( RPC_BINDING_HANDLE* Binding )
660 RPC_STATUS status;
661 TRACE("(%p) = %p\n", Binding, *Binding);
662 status = RPCRT4_ReleaseBinding(*Binding);
663 if (status == RPC_S_OK) *Binding = 0;
664 return status;
667 /***********************************************************************
668 * RpcBindingVectorFree (RPCRT4.@)
670 RPC_STATUS WINAPI RpcBindingVectorFree( RPC_BINDING_VECTOR** BindingVector )
672 RPC_STATUS status;
673 unsigned long c;
675 TRACE("(%p)\n", BindingVector);
676 for (c=0; c<(*BindingVector)->Count; c++) {
677 status = RpcBindingFree(&(*BindingVector)->BindingH[c]);
679 HeapFree(GetProcessHeap(), 0, *BindingVector);
680 *BindingVector = NULL;
681 return RPC_S_OK;
684 /***********************************************************************
685 * RpcBindingInqObject (RPCRT4.@)
687 RPC_STATUS WINAPI RpcBindingInqObject( RPC_BINDING_HANDLE Binding, UUID* ObjectUuid )
689 RpcBinding* bind = (RpcBinding*)Binding;
691 TRACE("(%p,%p) = %s\n", Binding, ObjectUuid, debugstr_guid(&bind->ObjectUuid));
692 *ObjectUuid = bind->ObjectUuid;
693 return RPC_S_OK;
696 /***********************************************************************
697 * RpcBindingSetObject (RPCRT4.@)
699 RPC_STATUS WINAPI RpcBindingSetObject( RPC_BINDING_HANDLE Binding, UUID* ObjectUuid )
701 RpcBinding* bind = (RpcBinding*)Binding;
703 TRACE("(%p,%s)\n", Binding, debugstr_guid(ObjectUuid));
704 if (bind->server) return RPC_S_WRONG_KIND_OF_BINDING;
705 return RPCRT4_SetBindingObject(Binding, ObjectUuid);
708 /***********************************************************************
709 * RpcBindingFromStringBindingA (RPCRT4.@)
711 RPC_STATUS WINAPI RpcBindingFromStringBindingA( RPC_CSTR StringBinding, RPC_BINDING_HANDLE* Binding )
713 RPC_STATUS ret;
714 RpcBinding* bind = NULL;
715 RPC_CSTR ObjectUuid, Protseq, NetworkAddr, Endpoint, Options;
716 UUID Uuid;
718 TRACE("(%s,%p)\n", debugstr_a((char*)StringBinding), Binding);
720 ret = RpcStringBindingParseA(StringBinding, &ObjectUuid, &Protseq,
721 &NetworkAddr, &Endpoint, &Options);
722 if (ret != RPC_S_OK) return ret;
724 ret = UuidFromStringA(ObjectUuid, &Uuid);
726 if (ret == RPC_S_OK)
727 ret = RPCRT4_CreateBindingA(&bind, FALSE, (char*)Protseq);
728 if (ret != RPC_S_OK) return ret;
729 ret = RPCRT4_SetBindingObject(bind, &Uuid);
730 if (ret == RPC_S_OK)
731 ret = RPCRT4_CompleteBindingA(bind, (char*)NetworkAddr, (char*)Endpoint, (char*)Options);
733 RpcStringFreeA((unsigned char**)&Options);
734 RpcStringFreeA((unsigned char**)&Endpoint);
735 RpcStringFreeA((unsigned char**)&NetworkAddr);
736 RpcStringFreeA((unsigned char**)&Protseq);
737 RpcStringFreeA((unsigned char**)&ObjectUuid);
739 if (ret == RPC_S_OK)
740 *Binding = (RPC_BINDING_HANDLE)bind;
741 else
742 RPCRT4_ReleaseBinding(bind);
744 return ret;
747 /***********************************************************************
748 * RpcBindingFromStringBindingW (RPCRT4.@)
750 RPC_STATUS WINAPI RpcBindingFromStringBindingW( RPC_WSTR StringBinding, RPC_BINDING_HANDLE* Binding )
752 RPC_STATUS ret;
753 RpcBinding* bind = NULL;
754 RPC_WSTR ObjectUuid, Protseq, NetworkAddr, Endpoint, Options;
755 UUID Uuid;
757 TRACE("(%s,%p)\n", debugstr_w(StringBinding), Binding);
759 ret = RpcStringBindingParseW(StringBinding, &ObjectUuid, &Protseq,
760 &NetworkAddr, &Endpoint, &Options);
761 if (ret != RPC_S_OK) return ret;
763 ret = UuidFromStringW(ObjectUuid, &Uuid);
765 if (ret == RPC_S_OK)
766 ret = RPCRT4_CreateBindingW(&bind, FALSE, Protseq);
767 if (ret != RPC_S_OK) return ret;
768 ret = RPCRT4_SetBindingObject(bind, &Uuid);
769 if (ret == RPC_S_OK)
770 ret = RPCRT4_CompleteBindingW(bind, NetworkAddr, Endpoint, Options);
772 RpcStringFreeW(&Options);
773 RpcStringFreeW(&Endpoint);
774 RpcStringFreeW(&NetworkAddr);
775 RpcStringFreeW(&Protseq);
776 RpcStringFreeW(&ObjectUuid);
778 if (ret == RPC_S_OK)
779 *Binding = (RPC_BINDING_HANDLE)bind;
780 else
781 RPCRT4_ReleaseBinding(bind);
783 return ret;
786 /***********************************************************************
787 * RpcBindingToStringBindingA (RPCRT4.@)
789 RPC_STATUS WINAPI RpcBindingToStringBindingA( RPC_BINDING_HANDLE Binding, RPC_CSTR *StringBinding )
791 RPC_STATUS ret;
792 RpcBinding* bind = (RpcBinding*)Binding;
793 RPC_CSTR ObjectUuid;
795 TRACE("(%p,%p)\n", Binding, StringBinding);
797 ret = UuidToStringA(&bind->ObjectUuid, &ObjectUuid);
798 if (ret != RPC_S_OK) return ret;
800 ret = RpcStringBindingComposeA(ObjectUuid, (unsigned char*)bind->Protseq, (unsigned char*) bind->NetworkAddr,
801 (unsigned char*) bind->Endpoint, NULL, StringBinding);
803 RpcStringFreeA(&ObjectUuid);
805 return ret;
808 /***********************************************************************
809 * RpcBindingToStringBindingW (RPCRT4.@)
811 RPC_STATUS WINAPI RpcBindingToStringBindingW( RPC_BINDING_HANDLE Binding, RPC_WSTR *StringBinding )
813 RPC_STATUS ret;
814 unsigned char *str = NULL;
815 TRACE("(%p,%p)\n", Binding, StringBinding);
816 ret = RpcBindingToStringBindingA(Binding, &str);
817 *StringBinding = RPCRT4_strdupAtoW((char*)str);
818 RpcStringFreeA((unsigned char**)&str);
819 return ret;
822 /***********************************************************************
823 * I_RpcBindingSetAsync (RPCRT4.@)
824 * NOTES
825 * Exists in win9x and winNT, but with different number of arguments
826 * (9x version has 3 arguments, NT has 2).
828 RPC_STATUS WINAPI I_RpcBindingSetAsync( RPC_BINDING_HANDLE Binding, RPC_BLOCKING_FN BlockingFn)
830 RpcBinding* bind = (RpcBinding*)Binding;
832 TRACE( "(%p,%p): stub\n", Binding, BlockingFn );
834 bind->BlockingFn = BlockingFn;
836 return RPC_S_OK;
839 /***********************************************************************
840 * RpcBindingCopy (RPCRT4.@)
842 RPC_STATUS RPC_ENTRY RpcBindingCopy(
843 RPC_BINDING_HANDLE SourceBinding,
844 RPC_BINDING_HANDLE* DestinationBinding)
846 RpcBinding *DestBinding;
847 RpcBinding *SrcBinding = (RpcBinding*)SourceBinding;
848 RPC_STATUS status;
850 TRACE("(%p, %p)\n", SourceBinding, DestinationBinding);
852 status = RPCRT4_AllocBinding(&DestBinding, SrcBinding->server);
853 if (status != RPC_S_OK) return status;
855 DestBinding->ObjectUuid = SrcBinding->ObjectUuid;
856 DestBinding->BlockingFn = SrcBinding->BlockingFn;
857 DestBinding->Protseq = RPCRT4_strndupA(SrcBinding->Protseq, -1);
858 DestBinding->NetworkAddr = RPCRT4_strndupA(SrcBinding->NetworkAddr, -1);
859 DestBinding->Endpoint = RPCRT4_strndupA(SrcBinding->Endpoint, -1);
860 DestBinding->NetworkOptions = RPCRT4_strdupW(SrcBinding->NetworkOptions);
861 if (SrcBinding->Assoc) SrcBinding->Assoc->refs++;
862 DestBinding->Assoc = SrcBinding->Assoc;
864 if (SrcBinding->AuthInfo) RpcAuthInfo_AddRef(SrcBinding->AuthInfo);
865 DestBinding->AuthInfo = SrcBinding->AuthInfo;
866 if (SrcBinding->QOS) RpcQualityOfService_AddRef(SrcBinding->QOS);
867 DestBinding->QOS = SrcBinding->QOS;
869 *DestinationBinding = DestBinding;
870 return RPC_S_OK;
873 /***********************************************************************
874 * RpcImpersonateClient (RPCRT4.@)
876 * Impersonates the client connected via a binding handle so that security
877 * checks are done in the context of the client.
879 * PARAMS
880 * BindingHandle [I] Handle to the binding to the client.
882 * RETURNS
883 * Success: RPS_S_OK.
884 * Failure: RPC_STATUS value.
886 * NOTES
888 * If BindingHandle is NULL then the function impersonates the client
889 * connected to the binding handle of the current thread.
891 RPC_STATUS WINAPI RpcImpersonateClient(RPC_BINDING_HANDLE BindingHandle)
893 FIXME("(%p): stub\n", BindingHandle);
894 ImpersonateSelf(SecurityImpersonation);
895 return RPC_S_OK;
898 /***********************************************************************
899 * RpcRevertToSelfEx (RPCRT4.@)
901 * Stops impersonating the client connected to the binding handle so that security
902 * checks are no longer done in the context of the client.
904 * PARAMS
905 * BindingHandle [I] Handle to the binding to the client.
907 * RETURNS
908 * Success: RPS_S_OK.
909 * Failure: RPC_STATUS value.
911 * NOTES
913 * If BindingHandle is NULL then the function stops impersonating the client
914 * connected to the binding handle of the current thread.
916 RPC_STATUS WINAPI RpcRevertToSelfEx(RPC_BINDING_HANDLE BindingHandle)
918 FIXME("(%p): stub\n", BindingHandle);
919 return RPC_S_OK;
922 static inline BOOL has_nt_auth_identity(ULONG AuthnLevel)
924 switch (AuthnLevel)
926 case RPC_C_AUTHN_GSS_NEGOTIATE:
927 case RPC_C_AUTHN_WINNT:
928 case RPC_C_AUTHN_GSS_KERBEROS:
929 return TRUE;
930 default:
931 return FALSE;
935 static RPC_STATUS RpcAuthInfo_Create(ULONG AuthnLevel, ULONG AuthnSvc,
936 CredHandle cred, TimeStamp exp,
937 ULONG cbMaxToken,
938 RPC_AUTH_IDENTITY_HANDLE identity,
939 RpcAuthInfo **ret)
941 RpcAuthInfo *AuthInfo = HeapAlloc(GetProcessHeap(), 0, sizeof(*AuthInfo));
942 if (!AuthInfo)
943 return ERROR_OUTOFMEMORY;
945 AuthInfo->refs = 1;
946 AuthInfo->AuthnLevel = AuthnLevel;
947 AuthInfo->AuthnSvc = AuthnSvc;
948 AuthInfo->cred = cred;
949 AuthInfo->exp = exp;
950 AuthInfo->cbMaxToken = cbMaxToken;
951 AuthInfo->identity = identity;
952 AuthInfo->server_principal_name = NULL;
954 /* duplicate the SEC_WINNT_AUTH_IDENTITY structure, if applicable, to
955 * enable better matching in RpcAuthInfo_IsEqual */
956 if (identity && has_nt_auth_identity(AuthnSvc))
958 const SEC_WINNT_AUTH_IDENTITY_W *nt_identity = identity;
959 AuthInfo->nt_identity = HeapAlloc(GetProcessHeap(), 0, sizeof(*AuthInfo->nt_identity));
960 if (!AuthInfo->nt_identity)
962 HeapFree(GetProcessHeap(), 0, AuthInfo);
963 return ERROR_OUTOFMEMORY;
966 AuthInfo->nt_identity->Flags = SEC_WINNT_AUTH_IDENTITY_UNICODE;
967 if (nt_identity->Flags & SEC_WINNT_AUTH_IDENTITY_UNICODE)
968 AuthInfo->nt_identity->User = RPCRT4_strndupW(nt_identity->User, nt_identity->UserLength);
969 else
970 AuthInfo->nt_identity->User = RPCRT4_strndupAtoW((const char *)nt_identity->User, nt_identity->UserLength);
971 AuthInfo->nt_identity->UserLength = nt_identity->UserLength;
972 if (nt_identity->Flags & SEC_WINNT_AUTH_IDENTITY_UNICODE)
973 AuthInfo->nt_identity->Domain = RPCRT4_strndupW(nt_identity->Domain, nt_identity->DomainLength);
974 else
975 AuthInfo->nt_identity->Domain = RPCRT4_strndupAtoW((const char *)nt_identity->Domain, nt_identity->DomainLength);
976 AuthInfo->nt_identity->DomainLength = nt_identity->DomainLength;
977 if (nt_identity->Flags & SEC_WINNT_AUTH_IDENTITY_UNICODE)
978 AuthInfo->nt_identity->Password = RPCRT4_strndupW(nt_identity->Password, nt_identity->PasswordLength);
979 else
980 AuthInfo->nt_identity->Password = RPCRT4_strndupAtoW((const char *)nt_identity->Password, nt_identity->PasswordLength);
981 AuthInfo->nt_identity->PasswordLength = nt_identity->PasswordLength;
983 if ((nt_identity->User && !AuthInfo->nt_identity->User) ||
984 (nt_identity->Domain && !AuthInfo->nt_identity->Domain) ||
985 (nt_identity->Password && !AuthInfo->nt_identity->Password))
987 HeapFree(GetProcessHeap(), 0, AuthInfo->nt_identity->User);
988 HeapFree(GetProcessHeap(), 0, AuthInfo->nt_identity->Domain);
989 HeapFree(GetProcessHeap(), 0, AuthInfo->nt_identity->Password);
990 HeapFree(GetProcessHeap(), 0, AuthInfo->nt_identity);
991 HeapFree(GetProcessHeap(), 0, AuthInfo);
992 return ERROR_OUTOFMEMORY;
995 else
996 AuthInfo->nt_identity = NULL;
997 *ret = AuthInfo;
998 return RPC_S_OK;
1001 ULONG RpcAuthInfo_AddRef(RpcAuthInfo *AuthInfo)
1003 return InterlockedIncrement(&AuthInfo->refs);
1006 ULONG RpcAuthInfo_Release(RpcAuthInfo *AuthInfo)
1008 ULONG refs = InterlockedDecrement(&AuthInfo->refs);
1010 if (!refs)
1012 FreeCredentialsHandle(&AuthInfo->cred);
1013 if (AuthInfo->nt_identity)
1015 HeapFree(GetProcessHeap(), 0, AuthInfo->nt_identity->User);
1016 HeapFree(GetProcessHeap(), 0, AuthInfo->nt_identity->Domain);
1017 HeapFree(GetProcessHeap(), 0, AuthInfo->nt_identity->Password);
1018 HeapFree(GetProcessHeap(), 0, AuthInfo->nt_identity);
1020 HeapFree(GetProcessHeap(), 0, AuthInfo->server_principal_name);
1021 HeapFree(GetProcessHeap(), 0, AuthInfo);
1024 return refs;
1027 BOOL RpcAuthInfo_IsEqual(const RpcAuthInfo *AuthInfo1, const RpcAuthInfo *AuthInfo2)
1029 if (AuthInfo1 == AuthInfo2)
1030 return TRUE;
1032 if (!AuthInfo1 || !AuthInfo2)
1033 return FALSE;
1035 if ((AuthInfo1->AuthnLevel != AuthInfo2->AuthnLevel) ||
1036 (AuthInfo1->AuthnSvc != AuthInfo2->AuthnSvc))
1037 return FALSE;
1039 if (AuthInfo1->identity == AuthInfo2->identity)
1040 return TRUE;
1042 if (!AuthInfo1->identity || !AuthInfo2->identity)
1043 return FALSE;
1045 if (has_nt_auth_identity(AuthInfo1->AuthnSvc))
1047 const SEC_WINNT_AUTH_IDENTITY_W *identity1 = AuthInfo1->nt_identity;
1048 const SEC_WINNT_AUTH_IDENTITY_W *identity2 = AuthInfo2->nt_identity;
1049 /* compare user names */
1050 if (identity1->UserLength != identity2->UserLength ||
1051 memcmp(identity1->User, identity2->User, identity1->UserLength))
1052 return FALSE;
1053 /* compare domain names */
1054 if (identity1->DomainLength != identity2->DomainLength ||
1055 memcmp(identity1->Domain, identity2->Domain, identity1->DomainLength))
1056 return FALSE;
1057 /* compare passwords */
1058 if (identity1->PasswordLength != identity2->PasswordLength ||
1059 memcmp(identity1->Password, identity2->Password, identity1->PasswordLength))
1060 return FALSE;
1062 else
1063 return FALSE;
1065 return TRUE;
1068 static RPC_STATUS RpcQualityOfService_Create(const RPC_SECURITY_QOS *qos_src, BOOL unicode, RpcQualityOfService **qos_dst)
1070 RpcQualityOfService *qos = HeapAlloc(GetProcessHeap(), 0, sizeof(*qos));
1072 if (!qos)
1073 return RPC_S_OUT_OF_RESOURCES;
1075 qos->refs = 1;
1076 qos->qos = HeapAlloc(GetProcessHeap(), 0, sizeof(*qos->qos));
1077 if (!qos->qos) goto error;
1078 qos->qos->Version = qos_src->Version;
1079 qos->qos->Capabilities = qos_src->Capabilities;
1080 qos->qos->IdentityTracking = qos_src->IdentityTracking;
1081 qos->qos->ImpersonationType = qos_src->ImpersonationType;
1082 qos->qos->AdditionalSecurityInfoType = 0;
1084 if (qos_src->Version >= 2)
1086 const RPC_SECURITY_QOS_V2_W *qos_src2 = (const RPC_SECURITY_QOS_V2_W *)qos_src;
1087 qos->qos->AdditionalSecurityInfoType = qos_src2->AdditionalSecurityInfoType;
1088 if (qos_src2->AdditionalSecurityInfoType == RPC_C_AUTHN_INFO_TYPE_HTTP)
1090 const RPC_HTTP_TRANSPORT_CREDENTIALS_W *http_credentials_src = qos_src2->u.HttpCredentials;
1091 RPC_HTTP_TRANSPORT_CREDENTIALS_W *http_credentials_dst;
1093 http_credentials_dst = HeapAlloc(GetProcessHeap(), 0, sizeof(*http_credentials_dst));
1094 qos->qos->u.HttpCredentials = http_credentials_dst;
1095 if (!http_credentials_dst) goto error;
1096 http_credentials_dst->TransportCredentials = NULL;
1097 http_credentials_dst->Flags = http_credentials_src->Flags;
1098 http_credentials_dst->AuthenticationTarget = http_credentials_src->AuthenticationTarget;
1099 http_credentials_dst->NumberOfAuthnSchemes = http_credentials_src->NumberOfAuthnSchemes;
1100 http_credentials_dst->AuthnSchemes = NULL;
1101 http_credentials_dst->ServerCertificateSubject = NULL;
1102 if (http_credentials_src->TransportCredentials)
1104 SEC_WINNT_AUTH_IDENTITY_W *cred_dst;
1105 cred_dst = http_credentials_dst->TransportCredentials = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(*cred_dst));
1106 if (!cred_dst) goto error;
1107 cred_dst->Flags = SEC_WINNT_AUTH_IDENTITY_UNICODE;
1108 if (unicode)
1110 const SEC_WINNT_AUTH_IDENTITY_W *cred_src = http_credentials_src->TransportCredentials;
1111 cred_dst->UserLength = cred_src->UserLength;
1112 cred_dst->PasswordLength = cred_src->PasswordLength;
1113 cred_dst->DomainLength = cred_src->DomainLength;
1114 cred_dst->User = RPCRT4_strndupW(cred_src->User, cred_src->UserLength);
1115 cred_dst->Password = RPCRT4_strndupW(cred_src->Password, cred_src->PasswordLength);
1116 cred_dst->Domain = RPCRT4_strndupW(cred_src->Domain, cred_src->DomainLength);
1118 else
1120 const SEC_WINNT_AUTH_IDENTITY_A *cred_src = (const SEC_WINNT_AUTH_IDENTITY_A *)http_credentials_src->TransportCredentials;
1121 cred_dst->UserLength = MultiByteToWideChar(CP_ACP, 0, (char *)cred_src->User, cred_src->UserLength, NULL, 0);
1122 cred_dst->DomainLength = MultiByteToWideChar(CP_ACP, 0, (char *)cred_src->Domain, cred_src->DomainLength, NULL, 0);
1123 cred_dst->PasswordLength = MultiByteToWideChar(CP_ACP, 0, (char *)cred_src->Password, cred_src->PasswordLength, NULL, 0);
1124 cred_dst->User = HeapAlloc(GetProcessHeap(), 0, cred_dst->UserLength * sizeof(WCHAR));
1125 cred_dst->Password = HeapAlloc(GetProcessHeap(), 0, cred_dst->PasswordLength * sizeof(WCHAR));
1126 cred_dst->Domain = HeapAlloc(GetProcessHeap(), 0, cred_dst->DomainLength * sizeof(WCHAR));
1127 if (!cred_dst || !cred_dst->Password || !cred_dst->Domain) goto error;
1128 MultiByteToWideChar(CP_ACP, 0, (char *)cred_src->User, cred_src->UserLength, cred_dst->User, cred_dst->UserLength);
1129 MultiByteToWideChar(CP_ACP, 0, (char *)cred_src->Domain, cred_src->DomainLength, cred_dst->Domain, cred_dst->DomainLength);
1130 MultiByteToWideChar(CP_ACP, 0, (char *)cred_src->Password, cred_src->PasswordLength, cred_dst->Password, cred_dst->PasswordLength);
1133 if (http_credentials_src->NumberOfAuthnSchemes)
1135 http_credentials_dst->AuthnSchemes = HeapAlloc(GetProcessHeap(), 0, http_credentials_src->NumberOfAuthnSchemes * sizeof(*http_credentials_dst->AuthnSchemes));
1136 if (!http_credentials_dst->AuthnSchemes) goto error;
1137 memcpy(http_credentials_dst->AuthnSchemes, http_credentials_src->AuthnSchemes, http_credentials_src->NumberOfAuthnSchemes * sizeof(*http_credentials_dst->AuthnSchemes));
1139 if (http_credentials_src->ServerCertificateSubject)
1141 if (unicode)
1142 http_credentials_dst->ServerCertificateSubject =
1143 RPCRT4_strndupW(http_credentials_src->ServerCertificateSubject,
1144 strlenW(http_credentials_src->ServerCertificateSubject));
1145 else
1146 http_credentials_dst->ServerCertificateSubject =
1147 RPCRT4_strdupAtoW((char *)http_credentials_src->ServerCertificateSubject);
1148 if (!http_credentials_dst->ServerCertificateSubject) goto error;
1152 *qos_dst = qos;
1153 return RPC_S_OK;
1155 error:
1156 if (qos->qos)
1158 if (qos->qos->AdditionalSecurityInfoType == RPC_C_AUTHN_INFO_TYPE_HTTP &&
1159 qos->qos->u.HttpCredentials)
1161 if (qos->qos->u.HttpCredentials->TransportCredentials)
1163 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials->TransportCredentials->User);
1164 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials->TransportCredentials->Domain);
1165 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials->TransportCredentials->Password);
1166 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials->TransportCredentials);
1168 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials->AuthnSchemes);
1169 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials->ServerCertificateSubject);
1170 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials);
1172 HeapFree(GetProcessHeap(), 0, qos->qos);
1174 HeapFree(GetProcessHeap(), 0, qos);
1175 return RPC_S_OUT_OF_RESOURCES;
1178 ULONG RpcQualityOfService_AddRef(RpcQualityOfService *qos)
1180 return InterlockedIncrement(&qos->refs);
1183 ULONG RpcQualityOfService_Release(RpcQualityOfService *qos)
1185 ULONG refs = InterlockedDecrement(&qos->refs);
1187 if (!refs)
1189 if (qos->qos->AdditionalSecurityInfoType == RPC_C_AUTHN_INFO_TYPE_HTTP)
1191 if (qos->qos->u.HttpCredentials->TransportCredentials)
1193 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials->TransportCredentials->User);
1194 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials->TransportCredentials->Domain);
1195 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials->TransportCredentials->Password);
1196 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials->TransportCredentials);
1198 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials->AuthnSchemes);
1199 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials->ServerCertificateSubject);
1200 HeapFree(GetProcessHeap(), 0, qos->qos->u.HttpCredentials);
1202 HeapFree(GetProcessHeap(), 0, qos->qos);
1203 HeapFree(GetProcessHeap(), 0, qos);
1205 return refs;
1208 BOOL RpcQualityOfService_IsEqual(const RpcQualityOfService *qos1, const RpcQualityOfService *qos2)
1210 if (qos1 == qos2)
1211 return TRUE;
1213 if (!qos1 || !qos2)
1214 return FALSE;
1216 TRACE("qos1 = { %ld %ld %ld %ld }, qos2 = { %ld %ld %ld %ld }\n",
1217 qos1->qos->Capabilities, qos1->qos->IdentityTracking,
1218 qos1->qos->ImpersonationType, qos1->qos->AdditionalSecurityInfoType,
1219 qos2->qos->Capabilities, qos2->qos->IdentityTracking,
1220 qos2->qos->ImpersonationType, qos2->qos->AdditionalSecurityInfoType);
1222 if ((qos1->qos->Capabilities != qos2->qos->Capabilities) ||
1223 (qos1->qos->IdentityTracking != qos2->qos->IdentityTracking) ||
1224 (qos1->qos->ImpersonationType != qos2->qos->ImpersonationType) ||
1225 (qos1->qos->AdditionalSecurityInfoType != qos2->qos->AdditionalSecurityInfoType))
1226 return FALSE;
1228 if (qos1->qos->AdditionalSecurityInfoType == RPC_C_AUTHN_INFO_TYPE_HTTP)
1230 const RPC_HTTP_TRANSPORT_CREDENTIALS_W *http_credentials1 = qos1->qos->u.HttpCredentials;
1231 const RPC_HTTP_TRANSPORT_CREDENTIALS_W *http_credentials2 = qos2->qos->u.HttpCredentials;
1233 if (http_credentials1->Flags != http_credentials2->Flags)
1234 return FALSE;
1236 if (http_credentials1->AuthenticationTarget != http_credentials2->AuthenticationTarget)
1237 return FALSE;
1239 /* authentication schemes and server certificate subject not currently used */
1241 if (http_credentials1->TransportCredentials != http_credentials2->TransportCredentials)
1243 const SEC_WINNT_AUTH_IDENTITY_W *identity1 = http_credentials1->TransportCredentials;
1244 const SEC_WINNT_AUTH_IDENTITY_W *identity2 = http_credentials2->TransportCredentials;
1246 if (!identity1 || !identity2)
1247 return FALSE;
1249 /* compare user names */
1250 if (identity1->UserLength != identity2->UserLength ||
1251 memcmp(identity1->User, identity2->User, identity1->UserLength))
1252 return FALSE;
1253 /* compare domain names */
1254 if (identity1->DomainLength != identity2->DomainLength ||
1255 memcmp(identity1->Domain, identity2->Domain, identity1->DomainLength))
1256 return FALSE;
1257 /* compare passwords */
1258 if (identity1->PasswordLength != identity2->PasswordLength ||
1259 memcmp(identity1->Password, identity2->Password, identity1->PasswordLength))
1260 return FALSE;
1264 return TRUE;
1267 /***********************************************************************
1268 * RpcRevertToSelf (RPCRT4.@)
1270 RPC_STATUS WINAPI RpcRevertToSelf(void)
1272 FIXME("stub\n");
1273 RevertToSelf();
1274 return RPC_S_OK;
1277 /***********************************************************************
1278 * RpcMgmtSetComTimeout (RPCRT4.@)
1280 RPC_STATUS WINAPI RpcMgmtSetComTimeout(RPC_BINDING_HANDLE BindingHandle, unsigned int Timeout)
1282 FIXME("(%p, %d): stub\n", BindingHandle, Timeout);
1283 return RPC_S_OK;
1286 /***********************************************************************
1287 * RpcBindingInqAuthInfoExA (RPCRT4.@)
1289 RPCRTAPI RPC_STATUS RPC_ENTRY
1290 RpcBindingInqAuthInfoExA( RPC_BINDING_HANDLE Binding, RPC_CSTR *ServerPrincName, ULONG *AuthnLevel,
1291 ULONG *AuthnSvc, RPC_AUTH_IDENTITY_HANDLE *AuthIdentity, ULONG *AuthzSvc,
1292 ULONG RpcQosVersion, RPC_SECURITY_QOS *SecurityQOS )
1294 FIXME("%p %p %p %p %p %p %u %p\n", Binding, ServerPrincName, AuthnLevel,
1295 AuthnSvc, AuthIdentity, AuthzSvc, RpcQosVersion, SecurityQOS);
1296 return RPC_S_INVALID_BINDING;
1299 /***********************************************************************
1300 * RpcBindingInqAuthInfoExW (RPCRT4.@)
1302 RPCRTAPI RPC_STATUS RPC_ENTRY
1303 RpcBindingInqAuthInfoExW( RPC_BINDING_HANDLE Binding, RPC_WSTR *ServerPrincName, ULONG *AuthnLevel,
1304 ULONG *AuthnSvc, RPC_AUTH_IDENTITY_HANDLE *AuthIdentity, ULONG *AuthzSvc,
1305 ULONG RpcQosVersion, RPC_SECURITY_QOS *SecurityQOS )
1307 FIXME("%p %p %p %p %p %p %u %p\n", Binding, ServerPrincName, AuthnLevel,
1308 AuthnSvc, AuthIdentity, AuthzSvc, RpcQosVersion, SecurityQOS);
1309 return RPC_S_INVALID_BINDING;
1312 /***********************************************************************
1313 * RpcBindingInqAuthInfoA (RPCRT4.@)
1315 RPCRTAPI RPC_STATUS RPC_ENTRY
1316 RpcBindingInqAuthInfoA( RPC_BINDING_HANDLE Binding, RPC_CSTR *ServerPrincName, ULONG *AuthnLevel,
1317 ULONG *AuthnSvc, RPC_AUTH_IDENTITY_HANDLE *AuthIdentity, ULONG *AuthzSvc )
1319 FIXME("%p %p %p %p %p %p\n", Binding, ServerPrincName, AuthnLevel,
1320 AuthnSvc, AuthIdentity, AuthzSvc);
1321 return RPC_S_INVALID_BINDING;
1324 /***********************************************************************
1325 * RpcBindingInqAuthInfoW (RPCRT4.@)
1327 RPCRTAPI RPC_STATUS RPC_ENTRY
1328 RpcBindingInqAuthInfoW( RPC_BINDING_HANDLE Binding, RPC_WSTR *ServerPrincName, ULONG *AuthnLevel,
1329 ULONG *AuthnSvc, RPC_AUTH_IDENTITY_HANDLE *AuthIdentity, ULONG *AuthzSvc )
1331 FIXME("%p %p %p %p %p %p\n", Binding, ServerPrincName, AuthnLevel,
1332 AuthnSvc, AuthIdentity, AuthzSvc);
1333 return RPC_S_INVALID_BINDING;
1336 /***********************************************************************
1337 * RpcBindingSetAuthInfoExA (RPCRT4.@)
1339 RPCRTAPI RPC_STATUS RPC_ENTRY
1340 RpcBindingSetAuthInfoExA( RPC_BINDING_HANDLE Binding, RPC_CSTR ServerPrincName,
1341 ULONG AuthnLevel, ULONG AuthnSvc,
1342 RPC_AUTH_IDENTITY_HANDLE AuthIdentity, ULONG AuthzSvr,
1343 RPC_SECURITY_QOS *SecurityQos )
1345 RpcBinding* bind = (RpcBinding*)Binding;
1346 SECURITY_STATUS r;
1347 CredHandle cred;
1348 TimeStamp exp;
1349 ULONG package_count;
1350 ULONG i;
1351 PSecPkgInfoA packages;
1352 ULONG cbMaxToken;
1354 TRACE("%p %s %u %u %p %u %p\n", Binding, debugstr_a((const char*)ServerPrincName),
1355 AuthnLevel, AuthnSvc, AuthIdentity, AuthzSvr, SecurityQos);
1357 if (SecurityQos)
1359 RPC_STATUS status;
1361 TRACE("SecurityQos { Version=%ld, Capabilties=0x%lx, IdentityTracking=%ld, ImpersonationLevel=%ld",
1362 SecurityQos->Version, SecurityQos->Capabilities, SecurityQos->IdentityTracking, SecurityQos->ImpersonationType);
1363 if (SecurityQos->Version >= 2)
1365 const RPC_SECURITY_QOS_V2_A *SecurityQos2 = (const RPC_SECURITY_QOS_V2_A *)SecurityQos;
1366 TRACE(", AdditionalSecurityInfoType=%ld", SecurityQos2->AdditionalSecurityInfoType);
1367 if (SecurityQos2->AdditionalSecurityInfoType == RPC_C_AUTHN_INFO_TYPE_HTTP)
1368 TRACE(", { %p, 0x%lx, %ld, %ld, %p, %s }",
1369 SecurityQos2->u.HttpCredentials->TransportCredentials,
1370 SecurityQos2->u.HttpCredentials->Flags,
1371 SecurityQos2->u.HttpCredentials->AuthenticationTarget,
1372 SecurityQos2->u.HttpCredentials->NumberOfAuthnSchemes,
1373 SecurityQos2->u.HttpCredentials->AuthnSchemes,
1374 SecurityQos2->u.HttpCredentials->ServerCertificateSubject);
1376 TRACE("}\n");
1377 status = RpcQualityOfService_Create(SecurityQos, FALSE, &bind->QOS);
1378 if (status != RPC_S_OK)
1379 return status;
1381 else
1383 if (bind->QOS) RpcQualityOfService_Release(bind->QOS);
1384 bind->QOS = NULL;
1387 if (AuthnSvc == RPC_C_AUTHN_DEFAULT)
1388 AuthnSvc = RPC_C_AUTHN_WINNT;
1390 /* FIXME: the mapping should probably be retrieved using SSPI somehow */
1391 if (AuthnLevel == RPC_C_AUTHN_LEVEL_DEFAULT)
1392 AuthnLevel = RPC_C_AUTHN_LEVEL_NONE;
1394 if ((AuthnLevel == RPC_C_AUTHN_LEVEL_NONE) || (AuthnSvc == RPC_C_AUTHN_NONE))
1396 if (bind->AuthInfo) RpcAuthInfo_Release(bind->AuthInfo);
1397 bind->AuthInfo = NULL;
1398 return RPC_S_OK;
1401 if (AuthnLevel > RPC_C_AUTHN_LEVEL_PKT_PRIVACY)
1403 FIXME("unknown AuthnLevel %u\n", AuthnLevel);
1404 return RPC_S_UNKNOWN_AUTHN_LEVEL;
1407 if (AuthzSvr)
1409 FIXME("unsupported AuthzSvr %u\n", AuthzSvr);
1410 return RPC_S_UNKNOWN_AUTHZ_SERVICE;
1413 r = EnumerateSecurityPackagesA(&package_count, &packages);
1414 if (r != SEC_E_OK)
1416 ERR("EnumerateSecurityPackagesA failed with error 0x%08x\n", r);
1417 return RPC_S_SEC_PKG_ERROR;
1420 for (i = 0; i < package_count; i++)
1421 if (packages[i].wRPCID == AuthnSvc)
1422 break;
1424 if (i == package_count)
1426 FIXME("unsupported AuthnSvc %u\n", AuthnSvc);
1427 FreeContextBuffer(packages);
1428 return RPC_S_UNKNOWN_AUTHN_SERVICE;
1431 TRACE("found package %s for service %u\n", packages[i].Name, AuthnSvc);
1432 r = AcquireCredentialsHandleA(NULL, packages[i].Name, SECPKG_CRED_OUTBOUND, NULL,
1433 AuthIdentity, NULL, NULL, &cred, &exp);
1434 cbMaxToken = packages[i].cbMaxToken;
1435 FreeContextBuffer(packages);
1436 if (r == ERROR_SUCCESS)
1438 RpcAuthInfo *new_auth_info;
1439 r = RpcAuthInfo_Create(AuthnLevel, AuthnSvc, cred, exp, cbMaxToken,
1440 AuthIdentity, &new_auth_info);
1441 if (r == RPC_S_OK)
1443 new_auth_info->server_principal_name = RPCRT4_strdupAtoW((char *)ServerPrincName);
1444 if (new_auth_info->server_principal_name)
1446 if (bind->AuthInfo) RpcAuthInfo_Release(bind->AuthInfo);
1447 bind->AuthInfo = new_auth_info;
1449 else
1451 RpcAuthInfo_Release(new_auth_info);
1452 r = ERROR_OUTOFMEMORY;
1455 else
1456 FreeCredentialsHandle(&cred);
1457 return r;
1459 else
1461 ERR("AcquireCredentialsHandleA failed with error 0x%08x\n", r);
1462 return RPC_S_SEC_PKG_ERROR;
1466 /***********************************************************************
1467 * RpcBindingSetAuthInfoExW (RPCRT4.@)
1469 RPCRTAPI RPC_STATUS RPC_ENTRY
1470 RpcBindingSetAuthInfoExW( RPC_BINDING_HANDLE Binding, RPC_WSTR ServerPrincName, ULONG AuthnLevel,
1471 ULONG AuthnSvc, RPC_AUTH_IDENTITY_HANDLE AuthIdentity, ULONG AuthzSvr,
1472 RPC_SECURITY_QOS *SecurityQos )
1474 RpcBinding* bind = (RpcBinding*)Binding;
1475 SECURITY_STATUS r;
1476 CredHandle cred;
1477 TimeStamp exp;
1478 ULONG package_count;
1479 ULONG i;
1480 PSecPkgInfoW packages;
1481 ULONG cbMaxToken;
1483 TRACE("%p %s %u %u %p %u %p\n", Binding, debugstr_w((const WCHAR*)ServerPrincName),
1484 AuthnLevel, AuthnSvc, AuthIdentity, AuthzSvr, SecurityQos);
1486 if (SecurityQos)
1488 RPC_STATUS status;
1490 TRACE("SecurityQos { Version=%ld, Capabilties=0x%lx, IdentityTracking=%ld, ImpersonationLevel=%ld",
1491 SecurityQos->Version, SecurityQos->Capabilities, SecurityQos->IdentityTracking, SecurityQos->ImpersonationType);
1492 if (SecurityQos->Version >= 2)
1494 const RPC_SECURITY_QOS_V2_W *SecurityQos2 = (const RPC_SECURITY_QOS_V2_W *)SecurityQos;
1495 TRACE(", AdditionalSecurityInfoType=%ld", SecurityQos2->AdditionalSecurityInfoType);
1496 if (SecurityQos2->AdditionalSecurityInfoType == RPC_C_AUTHN_INFO_TYPE_HTTP)
1497 TRACE(", { %p, 0x%lx, %ld, %ld, %p, %s }",
1498 SecurityQos2->u.HttpCredentials->TransportCredentials,
1499 SecurityQos2->u.HttpCredentials->Flags,
1500 SecurityQos2->u.HttpCredentials->AuthenticationTarget,
1501 SecurityQos2->u.HttpCredentials->NumberOfAuthnSchemes,
1502 SecurityQos2->u.HttpCredentials->AuthnSchemes,
1503 debugstr_w(SecurityQos2->u.HttpCredentials->ServerCertificateSubject));
1505 TRACE("}\n");
1506 status = RpcQualityOfService_Create(SecurityQos, TRUE, &bind->QOS);
1507 if (status != RPC_S_OK)
1508 return status;
1510 else
1512 if (bind->QOS) RpcQualityOfService_Release(bind->QOS);
1513 bind->QOS = NULL;
1516 if (AuthnSvc == RPC_C_AUTHN_DEFAULT)
1517 AuthnSvc = RPC_C_AUTHN_WINNT;
1519 /* FIXME: the mapping should probably be retrieved using SSPI somehow */
1520 if (AuthnLevel == RPC_C_AUTHN_LEVEL_DEFAULT)
1521 AuthnLevel = RPC_C_AUTHN_LEVEL_NONE;
1523 if ((AuthnLevel == RPC_C_AUTHN_LEVEL_NONE) || (AuthnSvc == RPC_C_AUTHN_NONE))
1525 if (bind->AuthInfo) RpcAuthInfo_Release(bind->AuthInfo);
1526 bind->AuthInfo = NULL;
1527 return RPC_S_OK;
1530 if (AuthnLevel > RPC_C_AUTHN_LEVEL_PKT_PRIVACY)
1532 FIXME("unknown AuthnLevel %u\n", AuthnLevel);
1533 return RPC_S_UNKNOWN_AUTHN_LEVEL;
1536 if (AuthzSvr)
1538 FIXME("unsupported AuthzSvr %u\n", AuthzSvr);
1539 return RPC_S_UNKNOWN_AUTHZ_SERVICE;
1542 r = EnumerateSecurityPackagesW(&package_count, &packages);
1543 if (r != SEC_E_OK)
1545 ERR("EnumerateSecurityPackagesA failed with error 0x%08x\n", r);
1546 return RPC_S_SEC_PKG_ERROR;
1549 for (i = 0; i < package_count; i++)
1550 if (packages[i].wRPCID == AuthnSvc)
1551 break;
1553 if (i == package_count)
1555 FIXME("unsupported AuthnSvc %u\n", AuthnSvc);
1556 FreeContextBuffer(packages);
1557 return RPC_S_UNKNOWN_AUTHN_SERVICE;
1560 TRACE("found package %s for service %u\n", debugstr_w(packages[i].Name), AuthnSvc);
1561 r = AcquireCredentialsHandleW(NULL, packages[i].Name, SECPKG_CRED_OUTBOUND, NULL,
1562 AuthIdentity, NULL, NULL, &cred, &exp);
1563 cbMaxToken = packages[i].cbMaxToken;
1564 FreeContextBuffer(packages);
1565 if (r == ERROR_SUCCESS)
1567 RpcAuthInfo *new_auth_info;
1568 r = RpcAuthInfo_Create(AuthnLevel, AuthnSvc, cred, exp, cbMaxToken,
1569 AuthIdentity, &new_auth_info);
1570 if (r == RPC_S_OK)
1572 new_auth_info->server_principal_name = RPCRT4_strdupW(ServerPrincName);
1573 if (!ServerPrincName || new_auth_info->server_principal_name)
1575 if (bind->AuthInfo) RpcAuthInfo_Release(bind->AuthInfo);
1576 bind->AuthInfo = new_auth_info;
1578 else
1580 RpcAuthInfo_Release(new_auth_info);
1581 r = ERROR_OUTOFMEMORY;
1584 else
1585 FreeCredentialsHandle(&cred);
1586 return r;
1588 else
1590 ERR("AcquireCredentialsHandleA failed with error 0x%08x\n", r);
1591 return RPC_S_SEC_PKG_ERROR;
1595 /***********************************************************************
1596 * RpcBindingSetAuthInfoA (RPCRT4.@)
1598 RPCRTAPI RPC_STATUS RPC_ENTRY
1599 RpcBindingSetAuthInfoA( RPC_BINDING_HANDLE Binding, RPC_CSTR ServerPrincName, ULONG AuthnLevel,
1600 ULONG AuthnSvc, RPC_AUTH_IDENTITY_HANDLE AuthIdentity, ULONG AuthzSvr )
1602 TRACE("%p %s %u %u %p %u\n", Binding, debugstr_a((const char*)ServerPrincName),
1603 AuthnLevel, AuthnSvc, AuthIdentity, AuthzSvr);
1604 return RpcBindingSetAuthInfoExA(Binding, ServerPrincName, AuthnLevel, AuthnSvc, AuthIdentity, AuthzSvr, NULL);
1607 /***********************************************************************
1608 * RpcBindingSetAuthInfoW (RPCRT4.@)
1610 RPCRTAPI RPC_STATUS RPC_ENTRY
1611 RpcBindingSetAuthInfoW( RPC_BINDING_HANDLE Binding, RPC_WSTR ServerPrincName, ULONG AuthnLevel,
1612 ULONG AuthnSvc, RPC_AUTH_IDENTITY_HANDLE AuthIdentity, ULONG AuthzSvr )
1614 TRACE("%p %s %u %u %p %u\n", Binding, debugstr_w((const WCHAR*)ServerPrincName),
1615 AuthnLevel, AuthnSvc, AuthIdentity, AuthzSvr);
1616 return RpcBindingSetAuthInfoExW(Binding, ServerPrincName, AuthnLevel, AuthnSvc, AuthIdentity, AuthzSvr, NULL);
1619 /***********************************************************************
1620 * RpcBindingSetOption (RPCRT4.@)
1622 RPC_STATUS WINAPI RpcBindingSetOption(RPC_BINDING_HANDLE BindingHandle, ULONG Option, ULONG OptionValue)
1624 FIXME("(%p, %d, %d): stub\n", BindingHandle, Option, OptionValue);
1625 return RPC_S_OK;