rpc_binding.c File Reference

#include <stdarg.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <assert.h>
#include "windef.h"
#include "winbase.h"
#include "winnls.h"
#include "winerror.h"
#include "winternl.h"
#include "rpc.h"
#include "rpcndr.h"
#include "wine/debug.h"
#include "rpc_binding.h"
#include "rpc_assoc.h"

Include dependency graph for rpc_binding.c:

Go to the source code of this file.

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (rpc)
LPSTR	RPCRT4_strdupWtoA (LPCWSTR src)
LPWSTR	RPCRT4_strdupAtoW (LPCSTR src)
static LPWSTR	RPCRT4_strndupAtoW (LPCSTR src, INT slen)
LPWSTR	RPCRT4_strndupW (LPCWSTR src, INT slen)
static RPC_STATUS	RPCRT4_AllocBinding (RpcBinding **Binding, BOOL server)
static RPC_STATUS	RPCRT4_CreateBindingA (RpcBinding **Binding, BOOL server, LPCSTR Protseq)
static RPC_STATUS	RPCRT4_CreateBindingW (RpcBinding **Binding, BOOL server, LPCWSTR Protseq)
static RPC_STATUS	RPCRT4_CompleteBindingA (RpcBinding *Binding, LPCSTR NetworkAddr, LPCSTR Endpoint, LPCSTR NetworkOptions)
static RPC_STATUS	RPCRT4_CompleteBindingW (RpcBinding *Binding, LPCWSTR NetworkAddr, LPCWSTR Endpoint, LPCWSTR NetworkOptions)
RPC_STATUS	RPCRT4_ResolveBinding (RpcBinding *Binding, LPCSTR Endpoint)
RPC_STATUS	RPCRT4_SetBindingObject (RpcBinding *Binding, const UUID *ObjectUuid)
RPC_STATUS	RPCRT4_MakeBinding (RpcBinding **Binding, RpcConnection *Connection)
void	RPCRT4_AddRefBinding (RpcBinding *Binding)
RPC_STATUS	RPCRT4_ReleaseBinding (RpcBinding *Binding)
RPC_STATUS	RPCRT4_OpenBinding (RpcBinding *Binding, RpcConnection **Connection, const RPC_SYNTAX_IDENTIFIER *TransferSyntax, const RPC_SYNTAX_IDENTIFIER *InterfaceId, BOOL *from_cache)
RPC_STATUS	RPCRT4_CloseBinding (RpcBinding *Binding, RpcConnection *Connection)
static LPSTR	RPCRT4_strconcatA (LPSTR dst, LPCSTR src)
static LPWSTR	RPCRT4_strconcatW (LPWSTR dst, LPCWSTR src)
static RPC_CSTR	escape_string_binding_component (RPC_CSTR string_binding, const unsigned char *component)
static RPC_WSTR	escape_string_binding_componentW (RPC_WSTR string_binding, const WCHAR *component)
static const unsigned char *	string_binding_find_delimiter (const unsigned char *string_binding, unsigned char delim)
static const WCHAR *	string_binding_find_delimiterW (const WCHAR *string_binding, WCHAR delim)
static RPC_CSTR	unescape_string_binding_component (const unsigned char *string_binding, int len)
static RPC_WSTR	unescape_string_binding_componentW (const WCHAR *string_binding, int len)
RPC_STATUS WINAPI	RpcStringBindingComposeA (RPC_CSTR ObjUuid, RPC_CSTR Protseq, RPC_CSTR NetworkAddr, RPC_CSTR Endpoint, RPC_CSTR Options, RPC_CSTR *StringBinding)
RPC_STATUS WINAPI	RpcStringBindingComposeW (RPC_WSTR ObjUuid, RPC_WSTR Protseq, RPC_WSTR NetworkAddr, RPC_WSTR Endpoint, RPC_WSTR Options, RPC_WSTR *StringBinding)
RPC_STATUS WINAPI	RpcStringBindingParseA (RPC_CSTR StringBinding, RPC_CSTR *ObjUuid, RPC_CSTR *Protseq, RPC_CSTR *NetworkAddr, RPC_CSTR *Endpoint, RPC_CSTR *Options)
RPC_STATUS WINAPI	RpcStringBindingParseW (RPC_WSTR StringBinding, RPC_WSTR *ObjUuid, RPC_WSTR *Protseq, RPC_WSTR *NetworkAddr, RPC_WSTR *Endpoint, RPC_WSTR *Options)
RPC_STATUS WINAPI	RpcBindingFree (RPC_BINDING_HANDLE *Binding)
RPC_STATUS WINAPI	RpcBindingVectorFree (RPC_BINDING_VECTOR **BindingVector)
RPC_STATUS WINAPI	RpcBindingInqObject (RPC_BINDING_HANDLE Binding, UUID *ObjectUuid)
RPC_STATUS WINAPI	RpcBindingSetObject (RPC_BINDING_HANDLE Binding, UUID *ObjectUuid)
RPC_STATUS WINAPI	RpcBindingFromStringBindingA (RPC_CSTR StringBinding, RPC_BINDING_HANDLE *Binding)
RPC_STATUS WINAPI	RpcBindingFromStringBindingW (RPC_WSTR StringBinding, RPC_BINDING_HANDLE *Binding)
RPC_STATUS WINAPI	RpcBindingToStringBindingA (RPC_BINDING_HANDLE Binding, RPC_CSTR *StringBinding)
RPC_STATUS WINAPI	RpcBindingToStringBindingW (RPC_BINDING_HANDLE Binding, RPC_WSTR *StringBinding)
RPC_STATUS WINAPI	I_RpcBindingInqTransportType (RPC_BINDING_HANDLE Binding, unsigned int *Type)
RPC_STATUS WINAPI	I_RpcBindingSetAsync (RPC_BINDING_HANDLE Binding, RPC_BLOCKING_FN BlockingFn)
RPC_STATUS RPC_ENTRY	RpcBindingCopy (RPC_BINDING_HANDLE SourceBinding, RPC_BINDING_HANDLE *DestinationBinding)
RPC_STATUS RPC_ENTRY	RpcBindingReset (RPC_BINDING_HANDLE Binding)
RPC_STATUS WINAPI	RpcImpersonateClient (RPC_BINDING_HANDLE BindingHandle)
RPC_STATUS WINAPI	RpcRevertToSelfEx (RPC_BINDING_HANDLE BindingHandle)
static BOOL	has_nt_auth_identity (ULONG AuthnLevel)
RPC_STATUS	RpcAuthInfo_Create (ULONG AuthnLevel, ULONG AuthnSvc, CredHandle cred, TimeStamp exp, ULONG cbMaxToken, RPC_AUTH_IDENTITY_HANDLE identity, RpcAuthInfo **ret)
ULONG	RpcAuthInfo_AddRef (RpcAuthInfo *AuthInfo)
ULONG	RpcAuthInfo_Release (RpcAuthInfo *AuthInfo)
BOOL	RpcAuthInfo_IsEqual (const RpcAuthInfo *AuthInfo1, const RpcAuthInfo *AuthInfo2)
static RPC_STATUS	RpcQualityOfService_Create (const RPC_SECURITY_QOS *qos_src, BOOL unicode, RpcQualityOfService **qos_dst)
ULONG	RpcQualityOfService_AddRef (RpcQualityOfService *qos)
ULONG	RpcQualityOfService_Release (RpcQualityOfService *qos)
BOOL	RpcQualityOfService_IsEqual (const RpcQualityOfService *qos1, const RpcQualityOfService *qos2)
RPC_STATUS WINAPI	RpcRevertToSelf (void)
RPC_STATUS WINAPI	RpcMgmtSetComTimeout (RPC_BINDING_HANDLE BindingHandle, unsigned int Timeout)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingInqAuthInfoExA (RPC_BINDING_HANDLE Binding, RPC_CSTR *ServerPrincName, ULONG *AuthnLevel, ULONG *AuthnSvc, RPC_AUTH_IDENTITY_HANDLE *AuthIdentity, ULONG *AuthzSvc, ULONG RpcQosVersion, RPC_SECURITY_QOS *SecurityQOS)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingInqAuthInfoExW (RPC_BINDING_HANDLE Binding, RPC_WSTR *ServerPrincName, ULONG *AuthnLevel, ULONG *AuthnSvc, RPC_AUTH_IDENTITY_HANDLE *AuthIdentity, ULONG *AuthzSvc, ULONG RpcQosVersion, RPC_SECURITY_QOS *SecurityQOS)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingInqAuthInfoA (RPC_BINDING_HANDLE Binding, RPC_CSTR *ServerPrincName, ULONG *AuthnLevel, ULONG *AuthnSvc, RPC_AUTH_IDENTITY_HANDLE *AuthIdentity, ULONG *AuthzSvc)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingInqAuthInfoW (RPC_BINDING_HANDLE Binding, RPC_WSTR *ServerPrincName, ULONG *AuthnLevel, ULONG *AuthnSvc, RPC_AUTH_IDENTITY_HANDLE *AuthIdentity, ULONG *AuthzSvc)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingInqAuthClientA (RPC_BINDING_HANDLE ClientBinding, RPC_AUTHZ_HANDLE *Privs, RPC_CSTR *ServerPrincName, ULONG *AuthnLevel, ULONG *AuthnSvc, ULONG *AuthzSvc)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingInqAuthClientW (RPC_BINDING_HANDLE ClientBinding, RPC_AUTHZ_HANDLE *Privs, RPC_WSTR *ServerPrincName, ULONG *AuthnLevel, ULONG *AuthnSvc, ULONG *AuthzSvc)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingInqAuthClientExA (RPC_BINDING_HANDLE ClientBinding, RPC_AUTHZ_HANDLE *Privs, RPC_CSTR *ServerPrincName, ULONG *AuthnLevel, ULONG *AuthnSvc, ULONG *AuthzSvc, ULONG Flags)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingInqAuthClientExW (RPC_BINDING_HANDLE ClientBinding, RPC_AUTHZ_HANDLE *Privs, RPC_WSTR *ServerPrincName, ULONG *AuthnLevel, ULONG *AuthnSvc, ULONG *AuthzSvc, ULONG Flags)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingServerFromClient (RPC_BINDING_HANDLE ClientBinding, RPC_BINDING_HANDLE *ServerBinding)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingSetAuthInfoExA (RPC_BINDING_HANDLE Binding, RPC_CSTR ServerPrincName, ULONG AuthnLevel, ULONG AuthnSvc, RPC_AUTH_IDENTITY_HANDLE AuthIdentity, ULONG AuthzSvr, RPC_SECURITY_QOS *SecurityQos)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingSetAuthInfoExW (RPC_BINDING_HANDLE Binding, RPC_WSTR ServerPrincName, ULONG AuthnLevel, ULONG AuthnSvc, RPC_AUTH_IDENTITY_HANDLE AuthIdentity, ULONG AuthzSvr, RPC_SECURITY_QOS *SecurityQos)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingSetAuthInfoA (RPC_BINDING_HANDLE Binding, RPC_CSTR ServerPrincName, ULONG AuthnLevel, ULONG AuthnSvc, RPC_AUTH_IDENTITY_HANDLE AuthIdentity, ULONG AuthzSvr)
RPCRTAPI RPC_STATUS RPC_ENTRY	RpcBindingSetAuthInfoW (RPC_BINDING_HANDLE Binding, RPC_WSTR ServerPrincName, ULONG AuthnLevel, ULONG AuthnSvc, RPC_AUTH_IDENTITY_HANDLE AuthIdentity, ULONG AuthzSvr)
RPC_STATUS WINAPI	RpcBindingSetOption (RPC_BINDING_HANDLE BindingHandle, ULONG Option, ULONG_PTR OptionValue)
RPC_STATUS WINAPI	I_RpcBindingInqLocalClientPID (RPC_BINDING_HANDLE ClientBinding, ULONG *ClientPID)

Function Documentation

escape_string_binding_component()

static RPC_CSTR escape_string_binding_component ( RPC_CSTR  string_binding, const unsigned char *  component  )

static

Definition at line 321 of file rpc_binding.c.

{
  for (; *component; component++) {
    switch (*component) {
      case '@':
      case ':':
      case '[':
      case ']':
      case '\\':
        *string_binding++ = '\\';
        *string_binding++ = *component;
        break;
      default:
        *string_binding++ = *component;
        break;
    }
  }
  return string_binding;
}

Referenced by RpcStringBindingComposeA().

escape_string_binding_componentW()

static RPC_WSTR escape_string_binding_componentW ( RPC_WSTR  string_binding, const WCHAR *  component  )

static

Definition at line 342 of file rpc_binding.c.

{
  for (; *component; component++) {
    switch (*component) {
      case '@':
      case ':':
      case '[':
      case ']':
      case '\\':
        *string_binding++ = '\\';
        *string_binding++ = *component;
        break;
      default:
        *string_binding++ = *component;
        break;
    }
  }
  return string_binding;
}

Referenced by RpcStringBindingComposeW().

has_nt_auth_identity()

static BOOL has_nt_auth_identity ( ULONG  AuthnLevel )

inlinestatic

Definition at line 1086 of file rpc_binding.c.

{
    switch (AuthnLevel)
    {
    case RPC_C_AUTHN_GSS_NEGOTIATE:
    case RPC_C_AUTHN_WINNT:
    case RPC_C_AUTHN_GSS_KERBEROS:
        return TRUE;
    default:
        return FALSE;
    }
}

Referenced by RpcAuthInfo_Create(), and RpcAuthInfo_IsEqual().

I_RpcBindingInqLocalClientPID()

RPC_STATUS WINAPI I_RpcBindingInqLocalClientPID	(	RPC_BINDING_HANDLE	ClientBinding,
		ULONG *	ClientPID
	)

Definition at line 1969 of file rpc_binding.c.

{
    RpcConnection *connection = NULL;
    RpcBinding *binding;
 
    TRACE("%p %p\n", ClientBinding, ClientPID);
 
    binding = ClientBinding ? ClientBinding : RPCRT4_GetThreadCurrentCallHandle();
    if (!binding)
        return RPC_S_NO_CALL_ACTIVE;
 
    connection = binding->FromConn;
    if (!connection->ops->inquire_client_pid)
        return RPC_S_INVALID_BINDING;
 
    return connection->ops->inquire_client_pid(connection, ClientPID);
}

Referenced by s_Shutdown(), s_test_I_RpcBindingInqLocalClientPID(), and test_I_RpcBindingInqLocalClientPID_thread_func().

I_RpcBindingInqTransportType()

RPC_STATUS WINAPI I_RpcBindingInqTransportType	(	RPC_BINDING_HANDLE	Binding,
		unsigned int *	Type
	)

Definition at line 943 of file rpc_binding.c.

{
 
  FIXME( "(%p,%p): stub\n", Binding, Type);
  *Type = TRANSPORT_TYPE_LPC;
  return RPC_S_OK;
}

I_RpcBindingSetAsync()

RPC_STATUS WINAPI I_RpcBindingSetAsync	(	RPC_BINDING_HANDLE	Binding,
		RPC_BLOCKING_FN	BlockingFn
	)

Definition at line 957 of file rpc_binding.c.

{
  RpcBinding* bind = Binding;
 
  TRACE( "(%p,%p): stub\n", Binding, BlockingFn );
 
  bind->BlockingFn = BlockingFn;
 
  return RPC_S_OK;
}

RpcAuthInfo_AddRef()

ULONG RpcAuthInfo_AddRef

(

RpcAuthInfo *

AuthInfo

)

Definition at line 1165 of file rpc_binding.c.

{
    return InterlockedIncrement(&AuthInfo->refs);
}

Referenced by RpcBindingCopy(), and RPCRT4_CreateConnection().

RpcAuthInfo_Create()

RPC_STATUS RpcAuthInfo_Create	(	ULONG	AuthnLevel,
		ULONG	AuthnSvc,
		CredHandle	cred,
		TimeStamp	exp,
		ULONG	cbMaxToken,
		RPC_AUTH_IDENTITY_HANDLE	identity,
		RpcAuthInfo **	ret
	)

Definition at line 1099 of file rpc_binding.c.

{
    RpcAuthInfo *AuthInfo = malloc(sizeof(*AuthInfo));
    if (!AuthInfo)
        return RPC_S_OUT_OF_MEMORY;
 
    AuthInfo->refs = 1;
    AuthInfo->AuthnLevel = AuthnLevel;
    AuthInfo->AuthnSvc = AuthnSvc;
    AuthInfo->cred = cred;
    AuthInfo->exp = exp;
    AuthInfo->cbMaxToken = cbMaxToken;
    AuthInfo->identity = identity;
    AuthInfo->server_principal_name = NULL;
 
    /* duplicate the SEC_WINNT_AUTH_IDENTITY structure, if applicable, to
     * enable better matching in RpcAuthInfo_IsEqual */
    if (identity && has_nt_auth_identity(AuthnSvc))
    {
        const SEC_WINNT_AUTH_IDENTITY_W *nt_identity = identity;
        AuthInfo->nt_identity = malloc(sizeof(*AuthInfo->nt_identity));
        if (!AuthInfo->nt_identity)
        {
            free(AuthInfo);
            return RPC_S_OUT_OF_MEMORY;
        }
 
        AuthInfo->nt_identity->Flags = SEC_WINNT_AUTH_IDENTITY_UNICODE;
        if (nt_identity->Flags & SEC_WINNT_AUTH_IDENTITY_UNICODE)
            AuthInfo->nt_identity->User = RPCRT4_strndupW(nt_identity->User, nt_identity->UserLength);
        else
            AuthInfo->nt_identity->User = RPCRT4_strndupAtoW((const char *)nt_identity->User, nt_identity->UserLength);
        AuthInfo->nt_identity->UserLength = nt_identity->UserLength;
        if (nt_identity->Flags & SEC_WINNT_AUTH_IDENTITY_UNICODE)
            AuthInfo->nt_identity->Domain = RPCRT4_strndupW(nt_identity->Domain, nt_identity->DomainLength);
        else
            AuthInfo->nt_identity->Domain = RPCRT4_strndupAtoW((const char *)nt_identity->Domain, nt_identity->DomainLength);
        AuthInfo->nt_identity->DomainLength = nt_identity->DomainLength;
        if (nt_identity->Flags & SEC_WINNT_AUTH_IDENTITY_UNICODE)
            AuthInfo->nt_identity->Password = RPCRT4_strndupW(nt_identity->Password, nt_identity->PasswordLength);
        else
            AuthInfo->nt_identity->Password = RPCRT4_strndupAtoW((const char *)nt_identity->Password, nt_identity->PasswordLength);
        AuthInfo->nt_identity->PasswordLength = nt_identity->PasswordLength;
 
        if ((nt_identity->User && !AuthInfo->nt_identity->User) ||
            (nt_identity->Domain && !AuthInfo->nt_identity->Domain) ||
            (nt_identity->Password && !AuthInfo->nt_identity->Password))
        {
            free(AuthInfo->nt_identity->User);
            free(AuthInfo->nt_identity->Domain);
            free(AuthInfo->nt_identity->Password);
            free(AuthInfo->nt_identity);
            free(AuthInfo);
            return RPC_S_OUT_OF_MEMORY;
        }
    }
    else
        AuthInfo->nt_identity = NULL;
    *ret = AuthInfo;
    return RPC_S_OK;
}

Referenced by RpcBindingSetAuthInfoExA(), RpcBindingSetAuthInfoExW(), and RPCRT4_ServerConnectionAuth().

RpcAuthInfo_IsEqual()

BOOL RpcAuthInfo_IsEqual	(	const RpcAuthInfo *	AuthInfo1,
		const RpcAuthInfo *	AuthInfo2
	)

Definition at line 1191 of file rpc_binding.c.

{
    if (AuthInfo1 == AuthInfo2)
        return TRUE;
 
    if (!AuthInfo1 || !AuthInfo2)
        return FALSE;
 
    if ((AuthInfo1->AuthnLevel != AuthInfo2->AuthnLevel) ||
        (AuthInfo1->AuthnSvc != AuthInfo2->AuthnSvc))
        return FALSE;
 
    if (AuthInfo1->identity == AuthInfo2->identity)
        return TRUE;
 
    if (!AuthInfo1->identity || !AuthInfo2->identity)
        return FALSE;
 
    if (has_nt_auth_identity(AuthInfo1->AuthnSvc))
    {
        const SEC_WINNT_AUTH_IDENTITY_W *identity1 = AuthInfo1->nt_identity;
        const SEC_WINNT_AUTH_IDENTITY_W *identity2 = AuthInfo2->nt_identity;
        /* compare user names */
        if (identity1->UserLength != identity2->UserLength ||
            memcmp(identity1->User, identity2->User, identity1->UserLength))
            return FALSE;
        /* compare domain names */
        if (identity1->DomainLength != identity2->DomainLength ||
            memcmp(identity1->Domain, identity2->Domain, identity1->DomainLength))
            return FALSE;
        /* compare passwords */
        if (identity1->PasswordLength != identity2->PasswordLength ||
            memcmp(identity1->Password, identity2->Password, identity1->PasswordLength))
            return FALSE;
    }
    else
        return FALSE;
 
    return TRUE;
}

Referenced by RpcAssoc_GetIdleConnection().

RpcAuthInfo_Release()

ULONG RpcAuthInfo_Release

(

RpcAuthInfo *

AuthInfo

)

Definition at line 1170 of file rpc_binding.c.

{
    ULONG refs = InterlockedDecrement(&AuthInfo->refs);
 
    if (!refs)
    {
        FreeCredentialsHandle(&AuthInfo->cred);
        if (AuthInfo->nt_identity)
        {
            free(AuthInfo->nt_identity->User);
            free(AuthInfo->nt_identity->Domain);
            free(AuthInfo->nt_identity->Password);
            free(AuthInfo->nt_identity);
        }
        free(AuthInfo->server_principal_name);
        free(AuthInfo);
    }
 
    return refs;
}

Referenced by get_epm_handle_client(), RpcBindingSetAuthInfoExA(), RpcBindingSetAuthInfoExW(), RPCRT4_ReleaseBinding(), RPCRT4_ReleaseConnection(), and RPCRT4_ServerConnectionAuth().

RpcBindingCopy()

RPC_STATUS RPC_ENTRY RpcBindingCopy	(	RPC_BINDING_HANDLE	SourceBinding,
		RPC_BINDING_HANDLE *	DestinationBinding
	)

Definition at line 971 of file rpc_binding.c.

{
  RpcBinding *DestBinding;
  RpcBinding *SrcBinding = SourceBinding;
  RPC_STATUS status;
 
  TRACE("(%p, %p)\n", SourceBinding, DestinationBinding);
 
  status = RPCRT4_AllocBinding(&DestBinding, SrcBinding->server);
  if (status != RPC_S_OK) return status;
 
  DestBinding->ObjectUuid = SrcBinding->ObjectUuid;
  DestBinding->BlockingFn = SrcBinding->BlockingFn;
  DestBinding->Protseq = strdup(SrcBinding->Protseq);
  DestBinding->NetworkAddr = strdup(SrcBinding->NetworkAddr);
  DestBinding->Endpoint = strdup(SrcBinding->Endpoint);
  DestBinding->NetworkOptions = wcsdup(SrcBinding->NetworkOptions);
  DestBinding->CookieAuth = wcsdup(SrcBinding->CookieAuth);
  if (SrcBinding->Assoc) SrcBinding->Assoc->refs++;
  DestBinding->Assoc = SrcBinding->Assoc;
 
  if (SrcBinding->AuthInfo) RpcAuthInfo_AddRef(SrcBinding->AuthInfo);
  DestBinding->AuthInfo = SrcBinding->AuthInfo;
  if (SrcBinding->QOS) RpcQualityOfService_AddRef(SrcBinding->QOS);
  DestBinding->QOS = SrcBinding->QOS;
 
  *DestinationBinding = DestBinding;
  return RPC_S_OK;
}

Referenced by get_epm_handle_client(), and ndr_update_context_handle().

RpcBindingFree()

RPC_STATUS WINAPI RpcBindingFree

(

RPC_BINDING_HANDLE *

Binding

)

Definition at line 769 of file rpc_binding.c.

{
  RPC_STATUS status;
  TRACE("(%p) = %p\n", Binding, *Binding);
  if (*Binding)
    status = RPCRT4_ReleaseBinding(*Binding);
  else
    status = RPC_S_INVALID_BINDING;
  if (status == RPC_S_OK) *Binding = NULL;
  return status;
}

Referenced by ATSVC_HANDLE_unbind(), BROWSER_IDENTIFY_HANDLE_unbind(), client(), ClientRpcChannelBuffer_Release(), CreateJob(), CreateProcessWithLogonW(), DNSRSLVR_HANDLE_unbind(), DsSetupUnbind(), epm_register(), EVENTLOG_HANDLE_A_unbind(), EVENTLOG_HANDLE_W_unbind(), get_irot_handle(), listen_test_client_thread(), LOGONSRV_HANDLE_unbind(), main(), MSI_FreePackage(), ndr_update_context_handle(), NetpUnbind(), PDHCP_SERVER_NAME_unbind(), PLSAPR_SERVER_NAME_unbind(), PnpUnbindRpc(), PREGISTRY_SERVER_NAME_unbind(), PSAMPR_SERVER_NAME_unbind(), RPC_CreateClientChannel(), RpcBindingVectorFree(), RpcEpResolveBinding(), RpcEpUnregister(), RpcSmDestroyClientContext(), RunningObjectTableImpl_Destroy(), s_context_handle_test(), ScDestroyStatusBinding(), SRVSVC_HANDLE_unbind(), SVCCTL_HANDLEA_unbind(), SVCCTL_HANDLEW_unbind(), test_endpoint_mapper(), test_ndr_buffer(), test_reconnect(), test_rpc_ncacn_ip_tcp(), test_RpcBindingFree(), test_RpcStringBindingFromBinding(), WINSPOOL_HANDLE_unbind(), WKSSVC_IDENTIFY_HANDLE_unbind(), WKSSVC_IMPERSONATE_HANDLE_unbind(), and WLANSVC_HANDLE_unbind().

RpcBindingFromStringBindingA()

RPC_STATUS WINAPI RpcBindingFromStringBindingA	(	RPC_CSTR	StringBinding,
		RPC_BINDING_HANDLE *	Binding
	)

Definition at line 822 of file rpc_binding.c.

{
  RPC_STATUS ret;
  RpcBinding* bind = NULL;
  RPC_CSTR ObjectUuid, Protseq, NetworkAddr, Endpoint, Options;
  UUID Uuid;
 
  TRACE("(%s,%p)\n", debugstr_a((char*)StringBinding), Binding);
 
  ret = RpcStringBindingParseA(StringBinding, &ObjectUuid, &Protseq,
                              &NetworkAddr, &Endpoint, &Options);
  if (ret != RPC_S_OK) return ret;
 
  ret = UuidFromStringA(ObjectUuid, &Uuid);
 
  if (ret == RPC_S_OK)
    ret = RPCRT4_CreateBindingA(&bind, FALSE, (char*)Protseq);
  if (ret == RPC_S_OK) {
      ret = RPCRT4_SetBindingObject(bind, &Uuid);
      if (ret == RPC_S_OK)
        ret = RPCRT4_CompleteBindingA(bind, (char*)NetworkAddr, (char*)Endpoint, (char*)Options);
 
      if (ret == RPC_S_OK)
        *Binding = (RPC_BINDING_HANDLE)bind;
      else
        RPCRT4_ReleaseBinding(bind);
  }
 
  RpcStringFreeA(&Options);
  RpcStringFreeA(&Endpoint);
  RpcStringFreeA(&NetworkAddr);
  RpcStringFreeA(&Protseq);
  RpcStringFreeA(&ObjectUuid);
 
  return ret;
}

Referenced by client(), EVENTLOG_HANDLE_A_bind(), get_epm_handle_server(), listen_test_client_thread(), SVCCTL_HANDLEA_bind(), test_endpoint_mapper(), test_ndr_buffer(), test_reconnect(), test_rpc_ncacn_ip_tcp(), and test_RpcStringBindingFromBinding().

RpcBindingFromStringBindingW()

RPC_STATUS WINAPI RpcBindingFromStringBindingW	(	RPC_WSTR	StringBinding,
		RPC_BINDING_HANDLE *	Binding
	)

Definition at line 862 of file rpc_binding.c.

{
  RPC_STATUS ret;
  RpcBinding* bind = NULL;
  RPC_WSTR ObjectUuid, Protseq, NetworkAddr, Endpoint, Options;
  UUID Uuid;
 
  TRACE("(%s,%p)\n", debugstr_w(StringBinding), Binding);
 
  ret = RpcStringBindingParseW(StringBinding, &ObjectUuid, &Protseq,
                              &NetworkAddr, &Endpoint, &Options);
  if (ret != RPC_S_OK) return ret;
 
  ret = UuidFromStringW(ObjectUuid, &Uuid);
 
  if (ret == RPC_S_OK)
    ret = RPCRT4_CreateBindingW(&bind, FALSE, Protseq);
  if (ret == RPC_S_OK) {
      ret = RPCRT4_SetBindingObject(bind, &Uuid);
      if (ret == RPC_S_OK)
        ret = RPCRT4_CompleteBindingW(bind, NetworkAddr, Endpoint, Options);
 
      if (ret == RPC_S_OK)
        *Binding = (RPC_BINDING_HANDLE)bind;
      else
        RPCRT4_ReleaseBinding(bind);
  }
 
  RpcStringFreeW(&Options);
  RpcStringFreeW(&Endpoint);
  RpcStringFreeW(&NetworkAddr);
  RpcStringFreeW(&Protseq);
  RpcStringFreeW(&ObjectUuid);
 
  return ret;
}

Referenced by __wine_msi_call_dll_function(), ATSVC_HANDLE_bind(), BROWSER_IDENTIFY_HANDLE_bind(), CreateProcessWithLogonW(), DNSRSLVR_HANDLE_bind(), DsSetupBind(), EVENTLOG_HANDLE_W_bind(), get_irot_handle(), LOGONSRV_HANDLE_bind(), NetpBind(), PDHCP_SERVER_NAME_bind(), PLSAPR_SERVER_NAME_bind(), PnpBindRpc(), PREGISTRY_SERVER_NAME_bind(), PSAMPR_SERVER_NAME_bind(), RPC_CreateClientChannel(), ScCreateStatusBinding(), SRVSVC_HANDLE_bind(), SVCCTL_HANDLEW_bind(), WINSPOOL_HANDLE_bind(), WKSSVC_IDENTIFY_HANDLE_bind(), WKSSVC_IMPERSONATE_HANDLE_bind(), and WLANSVC_HANDLE_bind().

RpcBindingInqAuthClientA()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingInqAuthClientA	(	RPC_BINDING_HANDLE	ClientBinding,
		RPC_AUTHZ_HANDLE *	Privs,
		RPC_CSTR *	ServerPrincName,
		ULONG *	AuthnLevel,
		ULONG *	AuthnSvc,
		ULONG *	AuthzSvc
	)

Definition at line 1554 of file rpc_binding.c.

{
    return RpcBindingInqAuthClientExA(ClientBinding, Privs, ServerPrincName, AuthnLevel,
                                      AuthnSvc, AuthzSvc, 0);
}

Referenced by s_authinfo_test().

RpcBindingInqAuthClientExA()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingInqAuthClientExA	(	RPC_BINDING_HANDLE	ClientBinding,
		RPC_AUTHZ_HANDLE *	Privs,
		RPC_CSTR *	ServerPrincName,
		ULONG *	AuthnLevel,
		ULONG *	AuthnSvc,
		ULONG *	AuthzSvc,
		ULONG	Flags
	)

Definition at line 1578 of file rpc_binding.c.

{
    RPC_STATUS status;
    RPC_WSTR principal;
 
    TRACE("%p %p %p %p %p %p 0x%lx\n", ClientBinding, Privs, ServerPrincName, AuthnLevel,
          AuthnSvc, AuthzSvc, Flags);
 
    status = RpcBindingInqAuthClientExW(ClientBinding, Privs, ServerPrincName ? &principal : NULL,
                                        AuthnLevel, AuthnSvc, AuthzSvc, Flags);
    if (status == RPC_S_OK && ServerPrincName)
    {
        *ServerPrincName = (RPC_CSTR)RPCRT4_strdupWtoA(principal);
        if (!*ServerPrincName && principal) status = RPC_S_OUT_OF_MEMORY;
        RpcStringFreeW(&principal);
    }
 
    return status;
}

Referenced by RpcBindingInqAuthClientA(), and s_authinfo_test().

RpcBindingInqAuthClientExW()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingInqAuthClientExW	(	RPC_BINDING_HANDLE	ClientBinding,
		RPC_AUTHZ_HANDLE *	Privs,
		RPC_WSTR *	ServerPrincName,
		ULONG *	AuthnLevel,
		ULONG *	AuthnSvc,
		ULONG *	AuthzSvc,
		ULONG	Flags
	)

Definition at line 1604 of file rpc_binding.c.

{
    RpcBinding *bind;
 
    TRACE("%p %p %p %p %p %p 0x%lx\n", ClientBinding, Privs, ServerPrincName, AuthnLevel,
          AuthnSvc, AuthzSvc, Flags);
 
    if (!ClientBinding) ClientBinding = I_RpcGetCurrentCallHandle();
    if (!ClientBinding) return RPC_S_INVALID_BINDING;
 
    bind = ClientBinding;
    if (!bind->FromConn) return RPC_S_INVALID_BINDING;
 
    return rpcrt4_conn_inquire_auth_client(bind->FromConn, Privs,
                                           ServerPrincName, AuthnLevel,
                                           AuthnSvc, AuthzSvc, Flags);
}

Referenced by RpcBindingInqAuthClientExA(), and RpcBindingInqAuthClientW().

RpcBindingInqAuthClientW()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingInqAuthClientW	(	RPC_BINDING_HANDLE	ClientBinding,
		RPC_AUTHZ_HANDLE *	Privs,
		RPC_WSTR *	ServerPrincName,
		ULONG *	AuthnLevel,
		ULONG *	AuthnSvc,
		ULONG *	AuthzSvc
	)

Definition at line 1566 of file rpc_binding.c.

{
    return RpcBindingInqAuthClientExW(ClientBinding, Privs, ServerPrincName, AuthnLevel,
                                      AuthnSvc, AuthzSvc, 0);
}

RpcBindingInqAuthInfoA()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingInqAuthInfoA	(	RPC_BINDING_HANDLE	Binding,
		RPC_CSTR *	ServerPrincName,
		ULONG *	AuthnLevel,
		ULONG *	AuthnSvc,
		RPC_AUTH_IDENTITY_HANDLE *	AuthIdentity,
		ULONG *	AuthzSvc
	)

Definition at line 1532 of file rpc_binding.c.

{
    return RpcBindingInqAuthInfoExA(Binding, ServerPrincName, AuthnLevel, AuthnSvc, AuthIdentity,
                                    AuthzSvc, 0, NULL);
}

Referenced by test_rpc_ncacn_ip_tcp().

RpcBindingInqAuthInfoExA()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingInqAuthInfoExA	(	RPC_BINDING_HANDLE	Binding,
		RPC_CSTR *	ServerPrincName,
		ULONG *	AuthnLevel,
		ULONG *	AuthnSvc,
		RPC_AUTH_IDENTITY_HANDLE *	AuthIdentity,
		ULONG *	AuthzSvc,
		ULONG	RpcQosVersion,
		RPC_SECURITY_QOS *	SecurityQOS
	)

Definition at line 1464 of file rpc_binding.c.

{
    RPC_STATUS status;
    RPC_WSTR principal;
 
    TRACE("%p %p %p %p %p %p %lu %p\n", Binding, ServerPrincName, AuthnLevel,
          AuthnSvc, AuthIdentity, AuthzSvc, RpcQosVersion, SecurityQOS);
 
    status = RpcBindingInqAuthInfoExW(Binding, ServerPrincName ? &principal : NULL, AuthnLevel,
                                      AuthnSvc, AuthIdentity, AuthzSvc, RpcQosVersion, SecurityQOS);
    if (status == RPC_S_OK && ServerPrincName)
    {
        *ServerPrincName = (RPC_CSTR)RPCRT4_strdupWtoA(principal);
        RpcStringFreeW(&principal);
        if (!*ServerPrincName) return RPC_S_OUT_OF_MEMORY;
    }
 
    return status;
}

Referenced by RpcBindingInqAuthInfoA().

RpcBindingInqAuthInfoExW()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingInqAuthInfoExW	(	RPC_BINDING_HANDLE	Binding,
		RPC_WSTR *	ServerPrincName,
		ULONG *	AuthnLevel,
		ULONG *	AuthnSvc,
		RPC_AUTH_IDENTITY_HANDLE *	AuthIdentity,
		ULONG *	AuthzSvc,
		ULONG	RpcQosVersion,
		RPC_SECURITY_QOS *	SecurityQOS
	)

Definition at line 1490 of file rpc_binding.c.

{
    RpcBinding *bind = Binding;
 
    TRACE("%p %p %p %p %p %p %lu %p\n", Binding, ServerPrincName, AuthnLevel,
          AuthnSvc, AuthIdentity, AuthzSvc, RpcQosVersion, SecurityQOS);
 
    if (!bind->AuthInfo) return RPC_S_BINDING_HAS_NO_AUTH;
 
    if (SecurityQOS)
    {
        FIXME("QOS not implemented\n");
        return RPC_S_INVALID_BINDING;
    }
 
    if (ServerPrincName)
    {
        if (bind->AuthInfo->server_principal_name)
        {
            *ServerPrincName = wcsdup(bind->AuthInfo->server_principal_name);
            if (!*ServerPrincName) return RPC_S_OUT_OF_MEMORY;
        }
        else *ServerPrincName = NULL;
    }
    if (AuthnLevel) *AuthnLevel = bind->AuthInfo->AuthnLevel;
    if (AuthnSvc) *AuthnSvc = bind->AuthInfo->AuthnSvc;
    if (AuthIdentity) *AuthIdentity = bind->AuthInfo->identity;
    if (AuthzSvc)
    {
        FIXME("authorization service not implemented\n");
        *AuthzSvc = RPC_C_AUTHZ_NONE;
    }
 
    return RPC_S_OK;
}

Referenced by RpcBindingInqAuthInfoExA(), and RpcBindingInqAuthInfoW().

RpcBindingInqAuthInfoW()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingInqAuthInfoW	(	RPC_BINDING_HANDLE	Binding,
		RPC_WSTR *	ServerPrincName,
		ULONG *	AuthnLevel,
		ULONG *	AuthnSvc,
		RPC_AUTH_IDENTITY_HANDLE *	AuthIdentity,
		ULONG *	AuthzSvc
	)

Definition at line 1543 of file rpc_binding.c.

{
    return RpcBindingInqAuthInfoExW(Binding, ServerPrincName, AuthnLevel, AuthnSvc, AuthIdentity,
                                    AuthzSvc, 0, NULL);
}

RpcBindingInqObject()

RPC_STATUS WINAPI RpcBindingInqObject	(	RPC_BINDING_HANDLE	Binding,
		UUID *	ObjectUuid
	)

Definition at line 798 of file rpc_binding.c.

{
  RpcBinding* bind = Binding;
 
  TRACE("(%p,%p) = %s\n", Binding, ObjectUuid, debugstr_guid(&bind->ObjectUuid));
  *ObjectUuid = bind->ObjectUuid;
  return RPC_S_OK;
}

Referenced by ClientRpcChannelBuffer_GetBuffer(), and dispatch_rpc().

RpcBindingReset()

RPC_STATUS RPC_ENTRY RpcBindingReset

(

RPC_BINDING_HANDLE

Binding

)

Definition at line 1006 of file rpc_binding.c.

{
    RpcBinding *bind = Binding;
 
    TRACE("(%p)\n", Binding);
 
    free(bind->Endpoint);
    bind->Endpoint = NULL;
    if (bind->Assoc) RpcAssoc_Release(bind->Assoc);
    bind->Assoc = NULL;
 
    return RPC_S_OK;
}

Referenced by test_endpoint_mapper().

RpcBindingServerFromClient()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingServerFromClient	(	RPC_BINDING_HANDLE	ClientBinding,
		RPC_BINDING_HANDLE *	ServerBinding
	)

Definition at line 1628 of file rpc_binding.c.

{
    RpcBinding* bind = ClientBinding;
    RpcBinding* NewBinding;
 
    if (!bind)
        bind = I_RpcGetCurrentCallHandle();
 
    if (!bind->server)
        return RPC_S_INVALID_BINDING;
 
    RPCRT4_AllocBinding(&NewBinding, TRUE);
    NewBinding->Protseq = strdup(bind->Protseq);
    NewBinding->NetworkAddr = strdup(bind->NetworkAddr);
 
    *ServerBinding = NewBinding;
 
    return RPC_S_OK;
}

Referenced by CreateJob(), and s_context_handle_test().

RpcBindingSetAuthInfoA()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingSetAuthInfoA	(	RPC_BINDING_HANDLE	Binding,
		RPC_CSTR	ServerPrincName,
		ULONG	AuthnLevel,
		ULONG	AuthnSvc,
		RPC_AUTH_IDENTITY_HANDLE	AuthIdentity,
		ULONG	AuthzSvr
	)

Definition at line 1915 of file rpc_binding.c.

{
    TRACE("%p %s %lu %lu %p %lu\n", Binding, debugstr_a((const char*)ServerPrincName),
          AuthnLevel, AuthnSvc, AuthIdentity, AuthzSvr);
    return RpcBindingSetAuthInfoExA(Binding, ServerPrincName, AuthnLevel, AuthnSvc, AuthIdentity, AuthzSvr, NULL);
}

Referenced by test_rpc_ncacn_ip_tcp().

RpcBindingSetAuthInfoExA()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingSetAuthInfoExA	(	RPC_BINDING_HANDLE	Binding,
		RPC_CSTR	ServerPrincName,
		ULONG	AuthnLevel,
		ULONG	AuthnSvc,
		RPC_AUTH_IDENTITY_HANDLE	AuthIdentity,
		ULONG	AuthzSvr,
		RPC_SECURITY_QOS *	SecurityQos
	)

Definition at line 1652 of file rpc_binding.c.

{
  RpcBinding* bind = Binding;
  SECURITY_STATUS r;
  CredHandle cred;
  TimeStamp exp;
  ULONG package_count;
  ULONG i;
  PSecPkgInfoA packages;
  ULONG cbMaxToken;
 
  TRACE("%p %s %lu %lu %p %lu %p\n", Binding, debugstr_a((const char*)ServerPrincName),
        AuthnLevel, AuthnSvc, AuthIdentity, AuthzSvr, SecurityQos);
 
  if (SecurityQos)
  {
      RPC_STATUS status;
 
      TRACE("SecurityQos { Version=%ld, Capabilities=0x%lx, IdentityTracking=%ld, ImpersonationLevel=%ld",
            SecurityQos->Version, SecurityQos->Capabilities, SecurityQos->IdentityTracking, SecurityQos->ImpersonationType);
      if (SecurityQos->Version >= 2)
      {
          const RPC_SECURITY_QOS_V2_A *SecurityQos2 = (const RPC_SECURITY_QOS_V2_A *)SecurityQos;
          TRACE(", AdditionalSecurityInfoType=%ld", SecurityQos2->AdditionalSecurityInfoType);
          if (SecurityQos2->AdditionalSecurityInfoType == RPC_C_AUTHN_INFO_TYPE_HTTP)
              TRACE(", { %p, 0x%lx, %ld, %ld, %p(%lu), %s }",
                    SecurityQos2->u.HttpCredentials->TransportCredentials,
                    SecurityQos2->u.HttpCredentials->Flags,
                    SecurityQos2->u.HttpCredentials->AuthenticationTarget,
                    SecurityQos2->u.HttpCredentials->NumberOfAuthnSchemes,
                    SecurityQos2->u.HttpCredentials->AuthnSchemes,
                    SecurityQos2->u.HttpCredentials->AuthnSchemes ? *SecurityQos2->u.HttpCredentials->AuthnSchemes : 0,
                    SecurityQos2->u.HttpCredentials->ServerCertificateSubject);
      }
      TRACE("}\n");
      status = RpcQualityOfService_Create(SecurityQos, FALSE, &bind->QOS);
      if (status != RPC_S_OK)
          return status;
  }
  else
  {
      if (bind->QOS) RpcQualityOfService_Release(bind->QOS);
      bind->QOS = NULL;
  }
 
  if (AuthnSvc == RPC_C_AUTHN_DEFAULT)
    AuthnSvc = RPC_C_AUTHN_WINNT;
 
  /* FIXME: the mapping should probably be retrieved using SSPI somehow */
  if (AuthnLevel == RPC_C_AUTHN_LEVEL_DEFAULT)
    AuthnLevel = RPC_C_AUTHN_LEVEL_NONE;
 
  if ((AuthnLevel == RPC_C_AUTHN_LEVEL_NONE) || (AuthnSvc == RPC_C_AUTHN_NONE))
  {
    if (bind->AuthInfo) RpcAuthInfo_Release(bind->AuthInfo);
    bind->AuthInfo = NULL;
    return RPC_S_OK;
  }
 
  if (AuthnLevel > RPC_C_AUTHN_LEVEL_PKT_PRIVACY)
  {
    FIXME("unknown AuthnLevel %lu\n", AuthnLevel);
    return RPC_S_UNKNOWN_AUTHN_LEVEL;
  }
 
  /* RPC_C_AUTHN_WINNT ignores the AuthzSvr parameter */
  if (AuthzSvr && AuthnSvc != RPC_C_AUTHN_WINNT)
  {
    FIXME("unsupported AuthzSvr %lu\n", AuthzSvr);
    return RPC_S_UNKNOWN_AUTHZ_SERVICE;
  }
 
  r = EnumerateSecurityPackagesA(&package_count, &packages);
  if (r != SEC_E_OK)
  {
    ERR("EnumerateSecurityPackagesA failed with error 0x%08lx\n", r);
    return RPC_S_SEC_PKG_ERROR;
  }
 
  for (i = 0; i < package_count; i++)
    if (packages[i].wRPCID == AuthnSvc)
        break;
 
  if (i == package_count)
  {
    FIXME("unsupported AuthnSvc %lu\n", AuthnSvc);
    FreeContextBuffer(packages);
    return RPC_S_UNKNOWN_AUTHN_SERVICE;
  }
 
  TRACE("found package %s for service %lu\n", packages[i].Name, AuthnSvc);
  r = AcquireCredentialsHandleA(NULL, packages[i].Name, SECPKG_CRED_OUTBOUND, NULL,
                                AuthIdentity, NULL, NULL, &cred, &exp);
  cbMaxToken = packages[i].cbMaxToken;
  FreeContextBuffer(packages);
  if (r == ERROR_SUCCESS)
  {
    RpcAuthInfo *new_auth_info;
    r = RpcAuthInfo_Create(AuthnLevel, AuthnSvc, cred, exp, cbMaxToken,
                           AuthIdentity, &new_auth_info);
    if (r == RPC_S_OK)
    {
      new_auth_info->server_principal_name = RPCRT4_strdupAtoW((char *)ServerPrincName);
      if (!ServerPrincName || new_auth_info->server_principal_name)
      {
        if (bind->AuthInfo) RpcAuthInfo_Release(bind->AuthInfo);
        bind->AuthInfo = new_auth_info;
      }
      else
      {
        RpcAuthInfo_Release(new_auth_info);
        r = RPC_S_OUT_OF_MEMORY;
      }
    }
    else
      FreeCredentialsHandle(&cred);
    return r;
  }
  else
  {
    ERR("AcquireCredentialsHandleA failed with error 0x%08lx\n", r);
    return RPC_S_SEC_PKG_ERROR;
  }
}

Referenced by RpcBindingSetAuthInfoA().

RpcBindingSetAuthInfoExW()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingSetAuthInfoExW	(	RPC_BINDING_HANDLE	Binding,
		RPC_WSTR	ServerPrincName,
		ULONG	AuthnLevel,
		ULONG	AuthnSvc,
		RPC_AUTH_IDENTITY_HANDLE	AuthIdentity,
		ULONG	AuthzSvr,
		RPC_SECURITY_QOS *	SecurityQos
	)

Definition at line 1784 of file rpc_binding.c.

{
  RpcBinding* bind = Binding;
  SECURITY_STATUS r;
  CredHandle cred;
  TimeStamp exp;
  ULONG package_count;
  ULONG i;
  PSecPkgInfoW packages;
  ULONG cbMaxToken;
 
  TRACE("%p %s %lu %lu %p %lu %p\n", Binding, debugstr_w(ServerPrincName),
        AuthnLevel, AuthnSvc, AuthIdentity, AuthzSvr, SecurityQos);
 
  if (SecurityQos)
  {
      RPC_STATUS status;
 
      TRACE("SecurityQos { Version=%ld, Capabilities=0x%lx, IdentityTracking=%ld, ImpersonationLevel=%ld",
            SecurityQos->Version, SecurityQos->Capabilities, SecurityQos->IdentityTracking, SecurityQos->ImpersonationType);
      if (SecurityQos->Version >= 2)
      {
          const RPC_SECURITY_QOS_V2_W *SecurityQos2 = (const RPC_SECURITY_QOS_V2_W *)SecurityQos;
          TRACE(", AdditionalSecurityInfoType=%ld", SecurityQos2->AdditionalSecurityInfoType);
          if (SecurityQos2->AdditionalSecurityInfoType == RPC_C_AUTHN_INFO_TYPE_HTTP)
              TRACE(", { %p, 0x%lx, %ld, %ld, %p(%lu), %s }",
                    SecurityQos2->u.HttpCredentials->TransportCredentials,
                    SecurityQos2->u.HttpCredentials->Flags,
                    SecurityQos2->u.HttpCredentials->AuthenticationTarget,
                    SecurityQos2->u.HttpCredentials->NumberOfAuthnSchemes,
                    SecurityQos2->u.HttpCredentials->AuthnSchemes,
                    SecurityQos2->u.HttpCredentials->AuthnSchemes ? *SecurityQos2->u.HttpCredentials->AuthnSchemes : 0,
                    debugstr_w(SecurityQos2->u.HttpCredentials->ServerCertificateSubject));
      }
      TRACE("}\n");
      status = RpcQualityOfService_Create(SecurityQos, TRUE, &bind->QOS);
      if (status != RPC_S_OK)
          return status;
  }
  else
  {
      if (bind->QOS) RpcQualityOfService_Release(bind->QOS);
      bind->QOS = NULL;
  }
 
  if (AuthnSvc == RPC_C_AUTHN_DEFAULT)
    AuthnSvc = RPC_C_AUTHN_WINNT;
 
  /* FIXME: the mapping should probably be retrieved using SSPI somehow */
  if (AuthnLevel == RPC_C_AUTHN_LEVEL_DEFAULT)
    AuthnLevel = RPC_C_AUTHN_LEVEL_NONE;
 
  if ((AuthnLevel == RPC_C_AUTHN_LEVEL_NONE) || (AuthnSvc == RPC_C_AUTHN_NONE))
  {
    if (bind->AuthInfo) RpcAuthInfo_Release(bind->AuthInfo);
    bind->AuthInfo = NULL;
    return RPC_S_OK;
  }
 
  if (AuthnLevel > RPC_C_AUTHN_LEVEL_PKT_PRIVACY)
  {
    FIXME("unknown AuthnLevel %lu\n", AuthnLevel);
    return RPC_S_UNKNOWN_AUTHN_LEVEL;
  }
 
  /* RPC_C_AUTHN_WINNT ignores the AuthzSvr parameter */
  if (AuthzSvr && AuthnSvc != RPC_C_AUTHN_WINNT)
  {
    FIXME("unsupported AuthzSvr %lu\n", AuthzSvr);
    return RPC_S_UNKNOWN_AUTHZ_SERVICE;
  }
 
  r = EnumerateSecurityPackagesW(&package_count, &packages);
  if (r != SEC_E_OK)
  {
    ERR("EnumerateSecurityPackagesW failed with error 0x%08lx\n", r);
    return RPC_S_SEC_PKG_ERROR;
  }
 
  for (i = 0; i < package_count; i++)
    if (packages[i].wRPCID == AuthnSvc)
        break;
 
  if (i == package_count)
  {
    FIXME("unsupported AuthnSvc %lu\n", AuthnSvc);
    FreeContextBuffer(packages);
    return RPC_S_UNKNOWN_AUTHN_SERVICE;
  }
 
  TRACE("found package %s for service %lu\n", debugstr_w(packages[i].Name), AuthnSvc);
  r = AcquireCredentialsHandleW(NULL, packages[i].Name, SECPKG_CRED_OUTBOUND, NULL,
                                AuthIdentity, NULL, NULL, &cred, &exp);
  cbMaxToken = packages[i].cbMaxToken;
  FreeContextBuffer(packages);
  if (r == ERROR_SUCCESS)
  {
    RpcAuthInfo *new_auth_info;
    r = RpcAuthInfo_Create(AuthnLevel, AuthnSvc, cred, exp, cbMaxToken,
                           AuthIdentity, &new_auth_info);
    if (r == RPC_S_OK)
    {
      new_auth_info->server_principal_name = wcsdup(ServerPrincName);
      if (!ServerPrincName || new_auth_info->server_principal_name)
      {
        if (bind->AuthInfo) RpcAuthInfo_Release(bind->AuthInfo);
        bind->AuthInfo = new_auth_info;
      }
      else
      {
        RpcAuthInfo_Release(new_auth_info);
        r = RPC_S_OUT_OF_MEMORY;
      }
    }
    else
      FreeCredentialsHandle(&cred);
    return r;
  }
  else
  {
    ERR("AcquireCredentialsHandleW failed with error 0x%08lx\n", r);
    return RPC_S_SEC_PKG_ERROR;
  }
}

Referenced by RpcBindingSetAuthInfoW().

RpcBindingSetAuthInfoW()

RPCRTAPI RPC_STATUS RPC_ENTRY RpcBindingSetAuthInfoW	(	RPC_BINDING_HANDLE	Binding,
		RPC_WSTR	ServerPrincName,
		ULONG	AuthnLevel,
		ULONG	AuthnSvc,
		RPC_AUTH_IDENTITY_HANDLE	AuthIdentity,
		ULONG	AuthzSvr
	)

Definition at line 1927 of file rpc_binding.c.

{
    TRACE("%p %s %lu %lu %p %lu\n", Binding, debugstr_w(ServerPrincName),
          AuthnLevel, AuthnSvc, AuthIdentity, AuthzSvr);
    return RpcBindingSetAuthInfoExW(Binding, ServerPrincName, AuthnLevel, AuthnSvc, AuthIdentity, AuthzSvr, NULL);
}

RpcBindingSetObject()

RPC_STATUS WINAPI RpcBindingSetObject	(	RPC_BINDING_HANDLE	Binding,
		UUID *	ObjectUuid
	)

Definition at line 810 of file rpc_binding.c.

{
  RpcBinding* bind = Binding;
 
  TRACE("(%p,%s)\n", Binding, debugstr_guid(ObjectUuid));
  if (bind->server) return RPC_S_WRONG_KIND_OF_BINDING;
  return RPCRT4_SetBindingObject(Binding, ObjectUuid);
}

Referenced by RPC_CreateClientChannel().

RpcBindingSetOption()

RPC_STATUS WINAPI RpcBindingSetOption	(	RPC_BINDING_HANDLE	BindingHandle,
		ULONG	Option,
		ULONG_PTR	OptionValue
	)

Definition at line 1938 of file rpc_binding.c.

{
    TRACE("(%p, %ld, %Id)\n", BindingHandle, Option, OptionValue);
 
    switch (Option)
    {
    case RPC_C_OPT_COOKIE_AUTH:
    {
        RPC_C_OPT_COOKIE_AUTH_DESCRIPTOR *cookie = (RPC_C_OPT_COOKIE_AUTH_DESCRIPTOR *)OptionValue;
        RpcBinding *binding = BindingHandle;
        int len = MultiByteToWideChar(CP_ACP, 0, cookie->Buffer, cookie->BufferSize, NULL, 0);
        WCHAR *str;
 
        if (!(str = malloc((len + 1) * sizeof(WCHAR)))) return RPC_S_OUT_OF_MEMORY;
        MultiByteToWideChar(CP_ACP, 0, cookie->Buffer, cookie->BufferSize, str, len);
        str[len] = 0;
        free(binding->CookieAuth);
        binding->CookieAuth = str;
        break;
    }
    default:
        FIXME("option %lu not supported\n", Option);
        break;
    }
    return RPC_S_OK;
}

RpcBindingToStringBindingA()

RPC_STATUS WINAPI RpcBindingToStringBindingA	(	RPC_BINDING_HANDLE	Binding,
		RPC_CSTR *	StringBinding
	)

Definition at line 902 of file rpc_binding.c.

{
  RPC_STATUS ret;
  RpcBinding* bind = Binding;
  RPC_CSTR ObjectUuid;
 
  TRACE("(%p,%p)\n", Binding, StringBinding);
 
  if (UuidIsNil(&bind->ObjectUuid, &ret))
    ObjectUuid = NULL;
  else
  {
    ret = UuidToStringA(&bind->ObjectUuid, &ObjectUuid);
    if (ret != RPC_S_OK) return ret;
  }
 
  ret = RpcStringBindingComposeA(ObjectUuid, (unsigned char*)bind->Protseq, (unsigned char*) bind->NetworkAddr,
                                 (unsigned char*) bind->Endpoint, NULL, StringBinding);
 
  RpcStringFreeA(&ObjectUuid);
 
  return ret;
}

Referenced by RpcBindingToStringBindingW(), s_context_handle_test(), test_RpcServerUseProtseq(), and test_RpcStringBindingFromBinding().

RpcBindingToStringBindingW()

RPC_STATUS WINAPI RpcBindingToStringBindingW	(	RPC_BINDING_HANDLE	Binding,
		RPC_WSTR *	StringBinding
	)

Definition at line 929 of file rpc_binding.c.

{
  RPC_STATUS ret;
  unsigned char *str = NULL;
  TRACE("(%p,%p)\n", Binding, StringBinding);
  ret = RpcBindingToStringBindingA(Binding, &str);
  *StringBinding = RPCRT4_strdupAtoW((char*)str);
  RpcStringFreeA(&str);
  return ret;
}

Referenced by CreateJob().

RpcBindingVectorFree()

RPC_STATUS WINAPI RpcBindingVectorFree

(

RPC_BINDING_VECTOR **

BindingVector

)

Definition at line 784 of file rpc_binding.c.

{
  ULONG c;
 
  TRACE("(%p)\n", BindingVector);
  for (c=0; c<(*BindingVector)->Count; c++) RpcBindingFree(&(*BindingVector)->BindingH[c]);
  free(*BindingVector);
  *BindingVector = NULL;
  return RPC_S_OK;
}

Referenced by test_endpoint_mapper(), and test_RpcServerUseProtseq().

RpcImpersonateClient()

RPC_STATUS WINAPI RpcImpersonateClient

(

RPC_BINDING_HANDLE

BindingHandle

)

Definition at line 1038 of file rpc_binding.c.

{
    RpcBinding *bind;
 
    TRACE("(%p)\n", BindingHandle);
 
    if (!BindingHandle) BindingHandle = I_RpcGetCurrentCallHandle();
    if (!BindingHandle) return RPC_S_INVALID_BINDING;
 
    bind = BindingHandle;
    if (bind->FromConn)
        return rpcrt4_conn_impersonate_client(bind->FromConn);
    return RPC_S_WRONG_KIND_OF_BINDING;
}

Referenced by _RpcAbortPrinter(), _RpcAddForm(), _RpcAddJob(), _RpcAddMonitor(), _RpcAddPort(), _RpcAddPortEx(), _RpcAddPrinterDriver(), _RpcAddPrinterDriverEx(), _RpcAddPrintProcessor(), _RpcAddPrintProvidor(), _RpcClosePrinter(), _RpcCloseSpoolFileHandle(), _RpcCommitSpoolData(), _RpcCommitSpoolData2(), _RpcConfigurePort(), _RpcDeleteForm(), _RpcDeleteMonitor(), _RpcDeletePort(), _RpcDeletePrinter(), _RpcDeletePrinterDriver(), _RpcDeletePrinterDriverEx(), _RpcDeletePrintProcessor(), _RpcDeletePrintProvidor(), _RpcEndDocPrinter(), _RpcEndPagePrinter(), _RpcEnumForms(), _RpcEnumJobs(), _RpcEnumMonitors(), _RpcEnumPorts(), _RpcEnumPrinterDrivers(), _RpcEnumPrinters(), _RpcEnumPrintProcessorDatatypes(), _RpcEnumPrintProcessors(), _RpcGetForm(), _RpcGetJob(), _RpcGetPrinter(), _RpcGetPrinterDataEx(), _RpcGetPrinterDriver(), _RpcGetPrinterDriver2(), _RpcGetPrinterDriverDirectory(), _RpcGetPrintProcessorDirectory(), _RpcGetSpoolFileInfo(), _RpcGetSpoolFileInfo2(), _RpcOpenPrinter(), _RpcPrinterMessageBox(), _RpcReadPrinter(), _RpcResetPrinterEx(), _RpcScheduleJob(), _RpcSeekPrinter(), _RpcSetForm(), _RpcSetJob(), _RpcSetPort(), _RpcSetPrinterDataEx(), _RpcSpoolerInit(), _RpcStartDocPrinter(), _RpcStartPagePrinter(), _RpcWritePrinter(), _RpcXcvData(), IsCallerInteractive(), LsarSetSecurityObject(), NetpGetClientLogonId(), RSetServiceObjectSecurity(), s_authinfo_test(), and YGetPrinterDriver2().

RpcMgmtSetComTimeout()

RPC_STATUS WINAPI RpcMgmtSetComTimeout	(	RPC_BINDING_HANDLE	BindingHandle,
		unsigned int	Timeout
	)

Definition at line 1454 of file rpc_binding.c.

{
    FIXME("(%p, %d): stub\n", BindingHandle, Timeout);
    return RPC_S_OK;
}

RpcQualityOfService_AddRef()

ULONG RpcQualityOfService_AddRef

(

RpcQualityOfService *

qos

)

Definition at line 1342 of file rpc_binding.c.

{
    return InterlockedIncrement(&qos->refs);
}

Referenced by RpcBindingCopy(), and RPCRT4_CreateConnection().

RpcQualityOfService_Create()

static RPC_STATUS RpcQualityOfService_Create ( const RPC_SECURITY_QOS *  qos_src, BOOL  unicode, RpcQualityOfService **  qos_dst  )

static

Definition at line 1232 of file rpc_binding.c.

{
    RpcQualityOfService *qos = malloc(sizeof(*qos));
 
    if (!qos)
        return RPC_S_OUT_OF_RESOURCES;
 
    qos->refs = 1;
    qos->qos = malloc(sizeof(*qos->qos));
    if (!qos->qos) goto error;
    qos->qos->Version = qos_src->Version;
    qos->qos->Capabilities = qos_src->Capabilities;
    qos->qos->IdentityTracking = qos_src->IdentityTracking;
    qos->qos->ImpersonationType = qos_src->ImpersonationType;
    qos->qos->AdditionalSecurityInfoType = 0;
 
    if (qos_src->Version >= 2)
    {
        const RPC_SECURITY_QOS_V2_W *qos_src2 = (const RPC_SECURITY_QOS_V2_W *)qos_src;
        qos->qos->AdditionalSecurityInfoType = qos_src2->AdditionalSecurityInfoType;
        if (qos_src2->AdditionalSecurityInfoType == RPC_C_AUTHN_INFO_TYPE_HTTP)
        {
            const RPC_HTTP_TRANSPORT_CREDENTIALS_W *http_credentials_src = qos_src2->u.HttpCredentials;
            RPC_HTTP_TRANSPORT_CREDENTIALS_W *http_credentials_dst;
 
            http_credentials_dst = malloc(sizeof(*http_credentials_dst));
            qos->qos->u.HttpCredentials = http_credentials_dst;
            if (!http_credentials_dst) goto error;
            http_credentials_dst->TransportCredentials = NULL;
            http_credentials_dst->Flags = http_credentials_src->Flags;
            http_credentials_dst->AuthenticationTarget = http_credentials_src->AuthenticationTarget;
            http_credentials_dst->NumberOfAuthnSchemes = http_credentials_src->NumberOfAuthnSchemes;
            http_credentials_dst->AuthnSchemes = NULL;
            http_credentials_dst->ServerCertificateSubject = NULL;
            if (http_credentials_src->TransportCredentials)
            {
                SEC_WINNT_AUTH_IDENTITY_W *cred_dst;
                cred_dst = http_credentials_dst->TransportCredentials = calloc(1, sizeof(*cred_dst));
                if (!cred_dst) goto error;
                cred_dst->Flags = SEC_WINNT_AUTH_IDENTITY_UNICODE;
                if (unicode)
                {
                    const SEC_WINNT_AUTH_IDENTITY_W *cred_src = http_credentials_src->TransportCredentials;
                    cred_dst->UserLength = cred_src->UserLength;
                    cred_dst->PasswordLength = cred_src->PasswordLength;
                    cred_dst->DomainLength = cred_src->DomainLength;
                    cred_dst->User = RPCRT4_strndupW(cred_src->User, cred_src->UserLength);
                    cred_dst->Password = RPCRT4_strndupW(cred_src->Password, cred_src->PasswordLength);
                    cred_dst->Domain = RPCRT4_strndupW(cred_src->Domain, cred_src->DomainLength);
                }
                else
                {
                    const SEC_WINNT_AUTH_IDENTITY_A *cred_src = (const SEC_WINNT_AUTH_IDENTITY_A *)http_credentials_src->TransportCredentials;
                    cred_dst->UserLength = MultiByteToWideChar(CP_ACP, 0, (char *)cred_src->User, cred_src->UserLength, NULL, 0);
                    cred_dst->DomainLength = MultiByteToWideChar(CP_ACP, 0, (char *)cred_src->Domain, cred_src->DomainLength, NULL, 0);
                    cred_dst->PasswordLength = MultiByteToWideChar(CP_ACP, 0, (char *)cred_src->Password, cred_src->PasswordLength, NULL, 0);
                    cred_dst->User = malloc(cred_dst->UserLength * sizeof(WCHAR));
                    cred_dst->Password = malloc(cred_dst->PasswordLength * sizeof(WCHAR));
                    cred_dst->Domain = malloc(cred_dst->DomainLength * sizeof(WCHAR));
                    if (!cred_dst->Password || !cred_dst->Domain) goto error;
                    MultiByteToWideChar(CP_ACP, 0, (char *)cred_src->User, cred_src->UserLength, cred_dst->User, cred_dst->UserLength);
                    MultiByteToWideChar(CP_ACP, 0, (char *)cred_src->Domain, cred_src->DomainLength, cred_dst->Domain, cred_dst->DomainLength);
                    MultiByteToWideChar(CP_ACP, 0, (char *)cred_src->Password, cred_src->PasswordLength, cred_dst->Password, cred_dst->PasswordLength);
                }
            }
            if (http_credentials_src->NumberOfAuthnSchemes)
            {
                http_credentials_dst->AuthnSchemes = malloc(http_credentials_src->NumberOfAuthnSchemes * sizeof(*http_credentials_dst->AuthnSchemes));
                if (!http_credentials_dst->AuthnSchemes) goto error;
                memcpy(http_credentials_dst->AuthnSchemes, http_credentials_src->AuthnSchemes, http_credentials_src->NumberOfAuthnSchemes * sizeof(*http_credentials_dst->AuthnSchemes));
            }
            if (http_credentials_src->ServerCertificateSubject)
            {
                if (unicode)
                    http_credentials_dst->ServerCertificateSubject =
                        RPCRT4_strndupW(http_credentials_src->ServerCertificateSubject,
                                        lstrlenW(http_credentials_src->ServerCertificateSubject));
                else
                    http_credentials_dst->ServerCertificateSubject =
                        RPCRT4_strdupAtoW((char *)http_credentials_src->ServerCertificateSubject);
                if (!http_credentials_dst->ServerCertificateSubject) goto error;
            }
        }
    }
    *qos_dst = qos;
    return RPC_S_OK;
 
error:
    if (qos->qos)
    {
        if (qos->qos->AdditionalSecurityInfoType == RPC_C_AUTHN_INFO_TYPE_HTTP &&
            qos->qos->u.HttpCredentials)
        {
            if (qos->qos->u.HttpCredentials->TransportCredentials)
            {
                free(qos->qos->u.HttpCredentials->TransportCredentials->User);
                free(qos->qos->u.HttpCredentials->TransportCredentials->Domain);
                free(qos->qos->u.HttpCredentials->TransportCredentials->Password);
                free(qos->qos->u.HttpCredentials->TransportCredentials);
            }
            free(qos->qos->u.HttpCredentials->AuthnSchemes);
            free(qos->qos->u.HttpCredentials->ServerCertificateSubject);
            free(qos->qos->u.HttpCredentials);
        }
        free(qos->qos);
    }
    free(qos);
    return RPC_S_OUT_OF_RESOURCES;
}

Referenced by RpcBindingSetAuthInfoExA(), and RpcBindingSetAuthInfoExW().

RpcQualityOfService_IsEqual()

BOOL RpcQualityOfService_IsEqual	(	const RpcQualityOfService *	qos1,
		const RpcQualityOfService *	qos2
	)

Definition at line 1372 of file rpc_binding.c.

{
    if (qos1 == qos2)
        return TRUE;
 
    if (!qos1 || !qos2)
        return FALSE;
 
    TRACE("qos1 = { %ld %ld %ld %ld }, qos2 = { %ld %ld %ld %ld }\n",
        qos1->qos->Capabilities, qos1->qos->IdentityTracking,
        qos1->qos->ImpersonationType, qos1->qos->AdditionalSecurityInfoType,
        qos2->qos->Capabilities, qos2->qos->IdentityTracking,
        qos2->qos->ImpersonationType, qos2->qos->AdditionalSecurityInfoType);
 
    if ((qos1->qos->Capabilities != qos2->qos->Capabilities) ||
        (qos1->qos->IdentityTracking != qos2->qos->IdentityTracking) ||
        (qos1->qos->ImpersonationType != qos2->qos->ImpersonationType) ||
        (qos1->qos->AdditionalSecurityInfoType != qos2->qos->AdditionalSecurityInfoType))
        return FALSE;
 
    if (qos1->qos->AdditionalSecurityInfoType == RPC_C_AUTHN_INFO_TYPE_HTTP)
    {
        const RPC_HTTP_TRANSPORT_CREDENTIALS_W *http_credentials1 = qos1->qos->u.HttpCredentials;
        const RPC_HTTP_TRANSPORT_CREDENTIALS_W *http_credentials2 = qos2->qos->u.HttpCredentials;
 
        if (http_credentials1->Flags != http_credentials2->Flags)
            return FALSE;
 
        if (http_credentials1->AuthenticationTarget != http_credentials2->AuthenticationTarget)
            return FALSE;
 
        if (http_credentials1->NumberOfAuthnSchemes != http_credentials2->NumberOfAuthnSchemes)
            return FALSE;
 
        if ((!http_credentials1->AuthnSchemes && http_credentials2->AuthnSchemes) ||
            (http_credentials1->AuthnSchemes && !http_credentials2->AuthnSchemes))
            return FALSE;
 
        if (memcmp(http_credentials1->AuthnSchemes, http_credentials2->AuthnSchemes,
                   http_credentials1->NumberOfAuthnSchemes * sizeof(http_credentials1->AuthnSchemes[0])))
            return FALSE;
 
        /* server certificate subject not currently used */
 
        if (http_credentials1->TransportCredentials != http_credentials2->TransportCredentials)
        {
            const SEC_WINNT_AUTH_IDENTITY_W *identity1 = http_credentials1->TransportCredentials;
            const SEC_WINNT_AUTH_IDENTITY_W *identity2 = http_credentials2->TransportCredentials;
 
            if (!identity1 || !identity2)
                return FALSE;
 
            /* compare user names */
            if (identity1->UserLength != identity2->UserLength ||
                memcmp(identity1->User, identity2->User, identity1->UserLength))
                return FALSE;
            /* compare domain names */
            if (identity1->DomainLength != identity2->DomainLength ||
                memcmp(identity1->Domain, identity2->Domain, identity1->DomainLength))
                return FALSE;
            /* compare passwords */
            if (identity1->PasswordLength != identity2->PasswordLength ||
                memcmp(identity1->Password, identity2->Password, identity1->PasswordLength))
                return FALSE;
        }
    }
 
    return TRUE;
}

Referenced by RpcAssoc_GetIdleConnection().

RpcQualityOfService_Release()

ULONG RpcQualityOfService_Release

(

RpcQualityOfService *

qos

)

Definition at line 1347 of file rpc_binding.c.

{
    ULONG refs = InterlockedDecrement(&qos->refs);
 
    if (!refs)
    {
        if (qos->qos->AdditionalSecurityInfoType == RPC_C_AUTHN_INFO_TYPE_HTTP)
        {
            if (qos->qos->u.HttpCredentials->TransportCredentials)
            {
                free(qos->qos->u.HttpCredentials->TransportCredentials->User);
                free(qos->qos->u.HttpCredentials->TransportCredentials->Domain);
                free(qos->qos->u.HttpCredentials->TransportCredentials->Password);
                free(qos->qos->u.HttpCredentials->TransportCredentials);
            }
            free(qos->qos->u.HttpCredentials->AuthnSchemes);
            free(qos->qos->u.HttpCredentials->ServerCertificateSubject);
            free(qos->qos->u.HttpCredentials);
        }
        free(qos->qos);
        free(qos);
    }
    return refs;
}

Referenced by RpcBindingSetAuthInfoExA(), RpcBindingSetAuthInfoExW(), RPCRT4_ReleaseBinding(), and RPCRT4_ReleaseConnection().

RpcRevertToSelf()

RPC_STATUS WINAPI RpcRevertToSelf

(

void

)

Definition at line 1445 of file rpc_binding.c.

{
    TRACE("\n");
    return RpcRevertToSelfEx(NULL);
}

Referenced by _RpcAbortPrinter(), _RpcAddForm(), _RpcAddJob(), _RpcAddMonitor(), _RpcAddPort(), _RpcAddPortEx(), _RpcAddPrinterDriver(), _RpcAddPrinterDriverEx(), _RpcAddPrintProcessor(), _RpcAddPrintProvidor(), _RpcClosePrinter(), _RpcCloseSpoolFileHandle(), _RpcCommitSpoolData(), _RpcCommitSpoolData2(), _RpcConfigurePort(), _RpcDeleteForm(), _RpcDeleteMonitor(), _RpcDeletePort(), _RpcDeletePrinter(), _RpcDeletePrinterDriver(), _RpcDeletePrinterDriverEx(), _RpcDeletePrintProcessor(), _RpcDeletePrintProvidor(), _RpcEndDocPrinter(), _RpcEndPagePrinter(), _RpcEnumForms(), _RpcEnumJobs(), _RpcEnumMonitors(), _RpcEnumPorts(), _RpcEnumPrinterDrivers(), _RpcEnumPrinters(), _RpcEnumPrintProcessorDatatypes(), _RpcEnumPrintProcessors(), _RpcGetForm(), _RpcGetJob(), _RpcGetPrinter(), _RpcGetPrinterDataEx(), _RpcGetPrinterDriver(), _RpcGetPrinterDriver2(), _RpcGetPrinterDriverDirectory(), _RpcGetPrintProcessorDirectory(), _RpcGetSpoolFileInfo(), _RpcGetSpoolFileInfo2(), _RpcOpenPrinter(), _RpcPrinterMessageBox(), _RpcReadPrinter(), _RpcResetPrinterEx(), _RpcScheduleJob(), _RpcSeekPrinter(), _RpcSetForm(), _RpcSetJob(), _RpcSetPort(), _RpcSetPrinterDataEx(), _RpcSpoolerInit(), _RpcStartDocPrinter(), _RpcStartPagePrinter(), _RpcWritePrinter(), _RpcXcvData(), IsCallerInteractive(), LsarSetSecurityObject(), NetpGetClientLogonId(), RSetServiceObjectSecurity(), s_authinfo_test(), and YGetPrinterDriver2().

RpcRevertToSelfEx()

RPC_STATUS WINAPI RpcRevertToSelfEx

(

RPC_BINDING_HANDLE

BindingHandle

)

Definition at line 1071 of file rpc_binding.c.

{
    RpcBinding *bind;
 
    TRACE("(%p)\n", BindingHandle);
 
    if (!BindingHandle) BindingHandle = I_RpcGetCurrentCallHandle();
    if (!BindingHandle) return RPC_S_INVALID_BINDING;
 
    bind = BindingHandle;
    if (bind->FromConn)
        return rpcrt4_conn_revert_to_self(bind->FromConn);
    return RPC_S_WRONG_KIND_OF_BINDING;
}

Referenced by RpcRevertToSelf().

RPCRT4_AddRefBinding()

void RPCRT4_AddRefBinding

(

RpcBinding *

Binding

)

Definition at line 232 of file rpc_binding.c.

{
  InterlockedIncrement(&Binding->refs);
}

Referenced by I_RpcNegotiateTransferSyntax().

RPCRT4_AllocBinding()

static RPC_STATUS RPCRT4_AllocBinding ( RpcBinding **  Binding, BOOL  server  )

static

Definition at line 92 of file rpc_binding.c.

{
  RpcBinding* NewBinding;
 
  NewBinding = calloc(1, sizeof(RpcBinding));
  NewBinding->refs = 1;
  NewBinding->server = server;
 
  *Binding = NewBinding;
 
  return RPC_S_OK;
}

Referenced by RpcBindingCopy(), RpcBindingServerFromClient(), RPCRT4_CreateBindingA(), RPCRT4_CreateBindingW(), and RPCRT4_MakeBinding().

RPCRT4_CloseBinding()

RPC_STATUS RPCRT4_CloseBinding	(	RpcBinding *	Binding,
		RpcConnection *	Connection
	)

Definition at line 276 of file rpc_binding.c.

{
  TRACE("(Binding == ^%p)\n", Binding);
  if (!Connection) return RPC_S_OK;
  if (Binding->server) {
    /* don't destroy a connection that is cached in the binding */
    if (Binding->FromConn != Connection)
      RPCRT4_ReleaseConnection(Connection);
  }
  else {
    RpcAssoc_ReleaseIdleConnection(Binding->Assoc, Connection);
  }
  return RPC_S_OK;
}

Referenced by I_RpcFreeBuffer().

RPCRT4_CompleteBindingA()

static RPC_STATUS RPCRT4_CompleteBindingA ( RpcBinding *  Binding, LPCSTR  NetworkAddr, LPCSTR  Endpoint, LPCSTR  NetworkOptions  )

static

Definition at line 131 of file rpc_binding.c.

{
  RPC_STATUS status;
 
  TRACE("(RpcBinding == ^%p, NetworkAddr == %s, EndPoint == %s, NetworkOptions == %s)\n", Binding,
   debugstr_a(NetworkAddr), debugstr_a(Endpoint), debugstr_a(NetworkOptions));
 
  free(Binding->NetworkAddr);
  Binding->NetworkAddr = strdup(NetworkAddr);
  free(Binding->Endpoint);
  Binding->Endpoint = strdup(Endpoint);
  free(Binding->NetworkOptions);
  Binding->NetworkOptions = RPCRT4_strdupAtoW(NetworkOptions);
 
  /* only attempt to get an association if the binding is complete */
  if (Endpoint && Endpoint[0] != '\0')
  {
    status = RPCRT4_GetAssociation(Binding->Protseq, Binding->NetworkAddr,
                                   Binding->Endpoint, Binding->NetworkOptions,
                                   &Binding->Assoc);
    if (status != RPC_S_OK)
        return status;
  }
 
  return RPC_S_OK;
}

Referenced by RpcBindingFromStringBindingA().

RPCRT4_CompleteBindingW()

static RPC_STATUS RPCRT4_CompleteBindingW ( RpcBinding *  Binding, LPCWSTR  NetworkAddr, LPCWSTR  Endpoint, LPCWSTR  NetworkOptions  )

static

Definition at line 159 of file rpc_binding.c.

{
  RPC_STATUS status;
 
  TRACE("(RpcBinding == ^%p, NetworkAddr == %s, EndPoint == %s, NetworkOptions == %s)\n", Binding, 
   debugstr_w(NetworkAddr), debugstr_w(Endpoint), debugstr_w(NetworkOptions));
 
  free(Binding->NetworkAddr);
  Binding->NetworkAddr = RPCRT4_strdupWtoA(NetworkAddr);
  free(Binding->Endpoint);
  Binding->Endpoint = RPCRT4_strdupWtoA(Endpoint);
  free(Binding->NetworkOptions);
  Binding->NetworkOptions = wcsdup(NetworkOptions);
 
  /* only attempt to get an association if the binding is complete */
  if (Endpoint && Endpoint[0] != '\0')
  {
    status = RPCRT4_GetAssociation(Binding->Protseq, Binding->NetworkAddr,
                                   Binding->Endpoint, Binding->NetworkOptions,
                                   &Binding->Assoc);
    if (status != RPC_S_OK)
        return status;
  }
 
  return RPC_S_OK;
}

Referenced by RpcBindingFromStringBindingW().

RPCRT4_CreateBindingA()

static RPC_STATUS RPCRT4_CreateBindingA ( RpcBinding **  Binding, BOOL  server, LPCSTR  Protseq  )

static

Definition at line 105 of file rpc_binding.c.

{
  RpcBinding* NewBinding;
 
  RPCRT4_AllocBinding(&NewBinding, server);
  NewBinding->Protseq = strdup(Protseq);
 
  TRACE("binding: %p\n", NewBinding);
  *Binding = NewBinding;
 
  return RPC_S_OK;
}

Referenced by RpcBindingFromStringBindingA().

RPCRT4_CreateBindingW()

static RPC_STATUS RPCRT4_CreateBindingW ( RpcBinding **  Binding, BOOL  server, LPCWSTR  Protseq  )

static

Definition at line 118 of file rpc_binding.c.

{
  RpcBinding* NewBinding;
 
  RPCRT4_AllocBinding(&NewBinding, server);
  NewBinding->Protseq = RPCRT4_strdupWtoA(Protseq);
 
  TRACE("binding: %p\n", NewBinding);
  *Binding = NewBinding;
 
  return RPC_S_OK;
}

Referenced by RpcBindingFromStringBindingW().

RPCRT4_MakeBinding()

RPC_STATUS RPCRT4_MakeBinding	(	RpcBinding **	Binding,
		RpcConnection *	Connection
	)

Definition at line 215 of file rpc_binding.c.

{
  RpcBinding* NewBinding;
  TRACE("(RpcBinding == ^%p, Connection == ^%p)\n", Binding, Connection);
 
  RPCRT4_AllocBinding(&NewBinding, Connection->server);
  NewBinding->Protseq = strdup(rpcrt4_conn_get_name(Connection));
  NewBinding->NetworkAddr = strdup(Connection->NetworkAddr);
  NewBinding->Endpoint = strdup(Connection->Endpoint);
  NewBinding->FromConn = Connection;
 
  TRACE("binding: %p\n", NewBinding);
  *Binding = NewBinding;
 
  return RPC_S_OK;
}

Referenced by process_bind_packet_no_send(), and RpcServerInqBindings().

RPCRT4_OpenBinding()

RPC_STATUS RPCRT4_OpenBinding	(	RpcBinding *	Binding,
		RpcConnection **	Connection,
		const RPC_SYNTAX_IDENTIFIER *	TransferSyntax,
		const RPC_SYNTAX_IDENTIFIER *	InterfaceId,
		BOOL *	from_cache
	)

Definition at line 255 of file rpc_binding.c.

{
  TRACE("(Binding == ^%p)\n", Binding);
 
  if (!Binding->server) {
     return RpcAssoc_GetClientConnection(Binding->Assoc, InterfaceId,
         TransferSyntax, Binding->AuthInfo, Binding->QOS, Binding->CookieAuth, Connection, from_cache);
  } else {
    /* we already have a connection with acceptable binding, so use it */
    if (Binding->FromConn) {
      *Connection = Binding->FromConn;
      return RPC_S_OK;
    } else {
       ERR("no connection in binding\n");
       return RPC_S_INTERNAL_ERROR;
    }
  }
}

Referenced by I_RpcNegotiateTransferSyntax(), and I_RpcSend().

RPCRT4_ReleaseBinding()

RPC_STATUS RPCRT4_ReleaseBinding

(

RpcBinding *

Binding

)

Definition at line 237 of file rpc_binding.c.

{
  if (InterlockedDecrement(&Binding->refs))
    return RPC_S_OK;
 
  TRACE("binding: %p\n", Binding);
  if (Binding->Assoc) RpcAssoc_Release(Binding->Assoc);
  free(Binding->Endpoint);
  free(Binding->NetworkAddr);
  free(Binding->Protseq);
  free(Binding->NetworkOptions);
  free(Binding->CookieAuth);
  if (Binding->AuthInfo) RpcAuthInfo_Release(Binding->AuthInfo);
  if (Binding->QOS) RpcQualityOfService_Release(Binding->QOS);
  free(Binding);
  return RPC_S_OK;
}

Referenced by I_RpcFreeBuffer(), RpcBindingFree(), RpcBindingFromStringBindingA(), RpcBindingFromStringBindingW(), and RPCRT4_ReleaseConnection().

RPCRT4_ResolveBinding()

RPC_STATUS RPCRT4_ResolveBinding	(	RpcBinding *	Binding,
		LPCSTR	Endpoint
	)

Definition at line 187 of file rpc_binding.c.

{
  RPC_STATUS status;
 
  TRACE("(RpcBinding == ^%p, EndPoint == \"%s\"\n", Binding, Endpoint);
 
  free(Binding->Endpoint);
  Binding->Endpoint = strdup(Endpoint);
 
  if (Binding->Assoc) RpcAssoc_Release(Binding->Assoc);
  Binding->Assoc = NULL;
  status = RPCRT4_GetAssociation(Binding->Protseq, Binding->NetworkAddr,
                                 Binding->Endpoint, Binding->NetworkOptions,
                                 &Binding->Assoc);
  if (status != RPC_S_OK)
      return status;
 
  return RPC_S_OK;
}

Referenced by get_epm_handle_client(), and RpcEpResolveBinding().

RPCRT4_SetBindingObject()

RPC_STATUS RPCRT4_SetBindingObject	(	RpcBinding *	Binding,
		const UUID *	ObjectUuid
	)

Definition at line 207 of file rpc_binding.c.

{
  TRACE("(*RpcBinding == ^%p, UUID == %s)\n", Binding, debugstr_guid(ObjectUuid)); 
  if (ObjectUuid) Binding->ObjectUuid = *ObjectUuid;
  else UuidCreateNil(&Binding->ObjectUuid);
  return RPC_S_OK;
}

Referenced by process_request_packet(), RpcBindingFromStringBindingA(), RpcBindingFromStringBindingW(), and RpcBindingSetObject().

RPCRT4_strconcatA()

static LPSTR RPCRT4_strconcatA ( LPSTR  dst, LPCSTR  src  )

static

Definition at line 291 of file rpc_binding.c.

{
  DWORD len = strlen(dst), slen = strlen(src);
  char *ndst = realloc(dst, len + slen + 2);
  if (!ndst)
  {
    free(dst);
    return NULL;
  }
  ndst[len] = ',';
  memcpy(ndst+len+1, src, slen+1);
  return ndst;
}

Referenced by RpcStringBindingParseA().

RPCRT4_strconcatW()

static LPWSTR RPCRT4_strconcatW ( LPWSTR  dst, LPCWSTR  src  )

static

Definition at line 305 of file rpc_binding.c.

{
  DWORD len = lstrlenW(dst), slen = lstrlenW(src);
  WCHAR *ndst = realloc(dst, (len + slen + 2) * sizeof(WCHAR));
  if (!ndst)
  {
    free(dst);
    return NULL;
  }
  ndst[len] = ',';
  memcpy(ndst+len+1, src, (slen+1)*sizeof(WCHAR));
  return ndst;
}

Referenced by RpcStringBindingParseW().

RPCRT4_strdupAtoW()

LPWSTR RPCRT4_strdupAtoW

(

LPCSTR

src

)

Definition at line 57 of file rpc_binding.c.

{
  DWORD len;
  LPWSTR s;
  if (!src) return NULL;
  len = MultiByteToWideChar(CP_ACP, 0, src, -1, NULL, 0);
  s = malloc(len * sizeof(WCHAR));
  MultiByteToWideChar(CP_ACP, 0, src, -1, s, len);
  return s;
}

Referenced by RpcBindingSetAuthInfoExA(), RpcBindingToStringBindingW(), RpcQualityOfService_Create(), RPCRT4_CompleteBindingA(), RpcServerRegisterAuthInfoA(), and UuidToStringW().

RPCRT4_strdupWtoA()

LPSTR RPCRT4_strdupWtoA

(

LPCWSTR

src

)

Definition at line 46 of file rpc_binding.c.

{
  DWORD len;
  LPSTR s;
  if (!src) return NULL;
  len = WideCharToMultiByte(CP_ACP, 0, src, -1, NULL, 0, NULL, NULL);
  s = malloc(len);
  WideCharToMultiByte(CP_ACP, 0, src, -1, s, len, NULL, NULL);
  return s;
}

Referenced by RpcBindingInqAuthClientExA(), RpcBindingInqAuthInfoExA(), RpcEpRegisterNoReplaceW(), RpcEpRegisterW(), RPCRT4_CompleteBindingW(), RPCRT4_CreateBindingW(), RpcServerInqDefaultPrincNameA(), RpcServerUseProtseqEpExW(), and RpcServerUseProtseqW().

RPCRT4_strndupAtoW()

static LPWSTR RPCRT4_strndupAtoW ( LPCSTR  src, INT  slen  )

static

Definition at line 68 of file rpc_binding.c.

{
  DWORD len;
  LPWSTR s;
  if (!src) return NULL;
  len = MultiByteToWideChar(CP_ACP, 0, src, slen, NULL, 0);
  s = malloc(len * sizeof(WCHAR));
  MultiByteToWideChar(CP_ACP, 0, src, slen, s, len);
  return s;
}

Referenced by RpcAuthInfo_Create().

RPCRT4_strndupW()

LPWSTR RPCRT4_strndupW	(	LPCWSTR	src,
		INT	slen
	)

Definition at line 79 of file rpc_binding.c.

{
  DWORD len;
  LPWSTR s;
  if (!src) return NULL;
  if (slen == -1) slen = lstrlenW(src);
  len = slen;
  s = malloc((len + 1) * sizeof(WCHAR));
  memcpy(s, src, len*sizeof(WCHAR));
  s[len] = 0;
  return s;
}

Referenced by RpcAuthInfo_Create(), RpcQualityOfService_Create(), and rpcrt4_http_internet_connect().

RpcStringBindingComposeA()

RPC_STATUS WINAPI RpcStringBindingComposeA	(	RPC_CSTR	ObjUuid,
		RPC_CSTR	Protseq,
		RPC_CSTR	NetworkAddr,
		RPC_CSTR	Endpoint,
		RPC_CSTR	Options,
		RPC_CSTR *	StringBinding
	)

Definition at line 440 of file rpc_binding.c.

{
  DWORD len = 1;
  RPC_CSTR data;
 
  TRACE( "(%s,%s,%s,%s,%s,%p)\n",
        debugstr_a( (char*)ObjUuid ), debugstr_a( (char*)Protseq ),
        debugstr_a( (char*)NetworkAddr ), debugstr_a( (char*)Endpoint ),
        debugstr_a( (char*)Options ), StringBinding );
 
  /* overestimate for each component for escaping of delimiters */
  if (ObjUuid && *ObjUuid) len += strlen((char*)ObjUuid) * 2 + 1;
  if (Protseq && *Protseq) len += strlen((char*)Protseq) * 2 + 1;
  if (NetworkAddr && *NetworkAddr) len += strlen((char*)NetworkAddr) * 2;
  if (Endpoint && *Endpoint) len += strlen((char*)Endpoint) * 2 + 2;
  if (Options && *Options) len += strlen((char*)Options) * 2 + 2;
 
  data = malloc(len);
  *StringBinding = data;
 
  if (ObjUuid && *ObjUuid) {
    data = escape_string_binding_component(data, ObjUuid);
    *data++ = '@';
  }
  if (Protseq && *Protseq) {
    data = escape_string_binding_component(data, Protseq);
    *data++ = ':';
  }
  if (NetworkAddr && *NetworkAddr)
    data = escape_string_binding_component(data, NetworkAddr);
 
  if ((Endpoint && *Endpoint) ||
      (Options && *Options)) {
    *data++ = '[';
    if (Endpoint && *Endpoint) {
      data = escape_string_binding_component(data, Endpoint);
      if (Options && *Options) *data++ = ',';
    }
    if (Options && *Options) {
      data = escape_string_binding_component(data, Options);
    }
    *data++ = ']';
  }
  *data = 0;
 
  return RPC_S_OK;
}

Referenced by client(), EVENTLOG_HANDLE_A_bind(), RpcBindingToStringBindingA(), SVCCTL_HANDLEA_bind(), test_endpoint_mapper(), test_ndr_buffer(), test_reconnect(), test_rpc_ncacn_ip_tcp(), test_RpcStringBindingFromBinding(), and test_server_listening().

RpcStringBindingComposeW()

RPC_STATUS WINAPI RpcStringBindingComposeW	(	RPC_WSTR	ObjUuid,
		RPC_WSTR	Protseq,
		RPC_WSTR	NetworkAddr,
		RPC_WSTR	Endpoint,
		RPC_WSTR	Options,
		RPC_WSTR *	StringBinding
	)

Definition at line 493 of file rpc_binding.c.

{
  DWORD len = 1;
  RPC_WSTR data;
 
  TRACE("(%s,%s,%s,%s,%s,%p)\n",
       debugstr_w( ObjUuid ), debugstr_w( Protseq ),
       debugstr_w( NetworkAddr ), debugstr_w( Endpoint ),
       debugstr_w( Options ), StringBinding);
 
  /* overestimate for each component for escaping of delimiters */
  if (ObjUuid && *ObjUuid) len += lstrlenW(ObjUuid) * 2 + 1;
  if (Protseq && *Protseq) len += lstrlenW(Protseq) * 2 + 1;
  if (NetworkAddr && *NetworkAddr) len += lstrlenW(NetworkAddr) * 2;
  if (Endpoint && *Endpoint) len += lstrlenW(Endpoint) * 2 + 2;
  if (Options && *Options) len += lstrlenW(Options) * 2 + 2;
 
  data = malloc(len * sizeof(WCHAR));
  *StringBinding = data;
 
  if (ObjUuid && *ObjUuid) {
    data = escape_string_binding_componentW(data, ObjUuid);
    *data++ = '@';
  }
  if (Protseq && *Protseq) {
    data = escape_string_binding_componentW(data, Protseq);
    *data++ = ':';
  }
  if (NetworkAddr && *NetworkAddr) {
    data = escape_string_binding_componentW(data, NetworkAddr);
  }
  if ((Endpoint && *Endpoint) ||
      (Options && *Options)) {
    *data++ = '[';
    if (Endpoint && *Endpoint) {
      data = escape_string_binding_componentW(data, Endpoint);
      if (Options && *Options) *data++ = ',';
    }
    if (Options && *Options) {
      data = escape_string_binding_componentW(data, Options);
    }
    *data++ = ']';
  }
  *data = 0;
 
  return RPC_S_OK;
}

Referenced by __wine_msi_call_dll_function(), ATSVC_HANDLE_bind(), BROWSER_IDENTIFY_HANDLE_bind(), CreateProcessWithLogonW(), DNSRSLVR_HANDLE_bind(), DsSetupBind(), EVENTLOG_HANDLE_W_bind(), get_irot_handle(), LOGONSRV_HANDLE_bind(), NetpBind(), PDHCP_SERVER_NAME_bind(), PLSAPR_SERVER_NAME_bind(), PnpBindRpc(), PREGISTRY_SERVER_NAME_bind(), PSAMPR_SERVER_NAME_bind(), RPC_CreateClientChannel(), ScCreateStatusBinding(), SRVSVC_HANDLE_bind(), SVCCTL_HANDLEW_bind(), WINSPOOL_HANDLE_bind(), WKSSVC_IDENTIFY_HANDLE_bind(), WKSSVC_IMPERSONATE_HANDLE_bind(), and WLANSVC_HANDLE_bind().

RpcStringBindingParseA()

RPC_STATUS WINAPI RpcStringBindingParseA	(	RPC_CSTR	StringBinding,
		RPC_CSTR *	ObjUuid,
		RPC_CSTR *	Protseq,
		RPC_CSTR *	NetworkAddr,
		RPC_CSTR *	Endpoint,
		RPC_CSTR *	Options
	)

Definition at line 547 of file rpc_binding.c.

{
  const unsigned char *data, *next;
  static const char ep_opt[] = "endpoint=";
  BOOL endpoint_already_found = FALSE;
 
  TRACE("(%s,%p,%p,%p,%p,%p)\n", debugstr_a((char*)StringBinding),
       ObjUuid, Protseq, NetworkAddr, Endpoint, Options);
 
  if (ObjUuid) *ObjUuid = NULL;
  if (Protseq) *Protseq = NULL;
  if (NetworkAddr) *NetworkAddr = NULL;
  if (Endpoint) *Endpoint = NULL;
  if (Options) *Options = NULL;
 
  data = StringBinding;
 
  next = string_binding_find_delimiter(data, '@');
  if (next) {
    UUID uuid;
    RPC_STATUS status;
    RPC_CSTR str_uuid = unescape_string_binding_component(data, next - data);
    status = UuidFromStringA(str_uuid, &uuid);
    if (status != RPC_S_OK) {
      free(str_uuid);
      return status;
    }
    if (ObjUuid)
      *ObjUuid = str_uuid;
    else
      free(str_uuid);
    data = next+1;
  }
 
  next = string_binding_find_delimiter(data, ':');
  if (next) {
    if (Protseq) *Protseq = unescape_string_binding_component(data, next - data);
    data = next+1;
  } else {
    goto fail;
  }
 
  next = string_binding_find_delimiter(data, '[');
  if (next) {
    const unsigned char *close;
    RPC_CSTR opt;
 
    if (NetworkAddr) *NetworkAddr = unescape_string_binding_component(data, next - data);
    data = next+1;
    close = string_binding_find_delimiter(data, ']');
    if (!close) goto fail;
 
    /* tokenize options */
    while (data < close) {
      next = string_binding_find_delimiter(data, ',');
      if (!next || next > close) next = close;
      /* FIXME: this is kind of inefficient */
      opt = unescape_string_binding_component(data, next - data);
      data = next+1;
 
      /* parse option */
      next = string_binding_find_delimiter(opt, '=');
      if (!next) {
        /* not an option, must be an endpoint */
        if (endpoint_already_found) goto fail;
        if (Endpoint) *Endpoint = opt;
        else free(opt);
        endpoint_already_found = TRUE;
      } else {
        if (strncmp((const char *)opt, ep_opt, strlen(ep_opt)) == 0) {
          /* endpoint option */
          if (endpoint_already_found) goto fail;
          if (Endpoint) *Endpoint = unescape_string_binding_component(next+1, -1);
          free(opt);
          endpoint_already_found = TRUE;
        } else {
          /* network option */
          if (Options) {
            if (*Options) {
              /* FIXME: this is kind of inefficient */
              *Options = (unsigned char*) RPCRT4_strconcatA( (char*)*Options, (char *)opt);
              free(opt);
            } else
              *Options = opt;
          } else
            free(opt);
        }
      }
    }
 
    data = close+1;
    if (*data) goto fail;
  }
  else if (NetworkAddr) 
    *NetworkAddr = unescape_string_binding_component(data, -1);
 
  return RPC_S_OK;
 
fail:
  if (ObjUuid) RpcStringFreeA(ObjUuid);
  if (Protseq) RpcStringFreeA(Protseq);
  if (NetworkAddr) RpcStringFreeA(NetworkAddr);
  if (Endpoint) RpcStringFreeA(Endpoint);
  if (Options) RpcStringFreeA(Options);
  return RPC_S_INVALID_STRING_BINDING;
}

Referenced by RpcBindingFromStringBindingA(), s_context_handle_test(), and test_RpcStringBindingParseA().

RpcStringBindingParseW()

RPC_STATUS WINAPI RpcStringBindingParseW	(	RPC_WSTR	StringBinding,
		RPC_WSTR *	ObjUuid,
		RPC_WSTR *	Protseq,
		RPC_WSTR *	NetworkAddr,
		RPC_WSTR *	Endpoint,
		RPC_WSTR *	Options
	)

Definition at line 659 of file rpc_binding.c.

{
  const WCHAR *data, *next;
  BOOL endpoint_already_found = FALSE;
 
  TRACE("(%s,%p,%p,%p,%p,%p)\n", debugstr_w(StringBinding),
       ObjUuid, Protseq, NetworkAddr, Endpoint, Options);
 
  if (ObjUuid) *ObjUuid = NULL;
  if (Protseq) *Protseq = NULL;
  if (NetworkAddr) *NetworkAddr = NULL;
  if (Endpoint) *Endpoint = NULL;
  if (Options) *Options = NULL;
 
  data = StringBinding;
 
  next = string_binding_find_delimiterW(data, '@');
  if (next) {
    UUID uuid;
    RPC_STATUS status;
    RPC_WSTR str_uuid = unescape_string_binding_componentW(data, next - data);
    status = UuidFromStringW(str_uuid, &uuid);
    if (status != RPC_S_OK) {
      free(str_uuid);
      return status;
    }
    if (ObjUuid)
      *ObjUuid = str_uuid;
    else
      free(str_uuid);
    data = next+1;
  }
 
  next = string_binding_find_delimiterW(data, ':');
  if (next) {
    if (Protseq) *Protseq = unescape_string_binding_componentW(data, next - data);
    data = next+1;
  } else {
    goto fail;
  }
 
  next = string_binding_find_delimiterW(data, '[');
  if (next) {
    const WCHAR *close;
    RPC_WSTR opt;
 
    if (NetworkAddr) *NetworkAddr = unescape_string_binding_componentW(data, next - data);
    data = next+1;
    close = string_binding_find_delimiterW(data, ']');
    if (!close) goto fail;
 
    /* tokenize options */
    while (data < close) {
      next = string_binding_find_delimiterW(data, ',');
      if (!next || next > close) next = close;
      /* FIXME: this is kind of inefficient */
      opt = unescape_string_binding_componentW(data, next - data);
      data = next+1;
 
      /* parse option */
      next = string_binding_find_delimiterW(opt, '=');
      if (!next) {
        /* not an option, must be an endpoint */
        if (endpoint_already_found) goto fail;
        if (Endpoint) *Endpoint = opt;
        else free(opt);
        endpoint_already_found = TRUE;
      } else {
        if (wcsncmp(opt, L"endpoint=", lstrlenW(L"endpoint=")) == 0) {
          /* endpoint option */
          if (endpoint_already_found) goto fail;
          if (Endpoint) *Endpoint = unescape_string_binding_componentW(next+1, -1);
          free(opt);
          endpoint_already_found = TRUE;
        } else {
          /* network option */
          if (Options) {
            if (*Options) {
              /* FIXME: this is kind of inefficient */
              *Options = RPCRT4_strconcatW(*Options, opt);
              free(opt);
            } else
              *Options = opt;
          } else
            free(opt);
        }
      }
    }
 
    data = close+1;
    if (*data) goto fail;
  } else if (NetworkAddr) 
    *NetworkAddr = unescape_string_binding_componentW(data, -1);
 
  return RPC_S_OK;
 
fail:
  if (ObjUuid) RpcStringFreeW(ObjUuid);
  if (Protseq) RpcStringFreeW(Protseq);
  if (NetworkAddr) RpcStringFreeW(NetworkAddr);
  if (Endpoint) RpcStringFreeW(Endpoint);
  if (Options) RpcStringFreeW(Options);
  return RPC_S_INVALID_STRING_BINDING;
}

Referenced by CreateJob(), and RpcBindingFromStringBindingW().

string_binding_find_delimiter()

static const unsigned char * string_binding_find_delimiter ( const unsigned char *  string_binding, unsigned char  delim  )

static

Definition at line 363 of file rpc_binding.c.

{
  const unsigned char *next;
  for (next = string_binding; *next; next++) {
    if (*next == '\\') {
      next++;
      continue;
    }
    if (*next == delim)
      return next;
  }
  return NULL;
}

Referenced by RpcStringBindingParseA().

string_binding_find_delimiterW()

static const WCHAR * string_binding_find_delimiterW ( const WCHAR *  string_binding, WCHAR  delim  )

static

Definition at line 378 of file rpc_binding.c.

{
  const WCHAR *next;
  for (next = string_binding; *next; next++) {
    if (*next == '\\') {
      next++;
      continue;
    }
    if (*next == delim)
      return next;
  }
  return NULL;
}

Referenced by RpcStringBindingParseW().

unescape_string_binding_component()

static RPC_CSTR unescape_string_binding_component ( const unsigned char *  string_binding, int  len  )

static

Definition at line 393 of file rpc_binding.c.

{
  RPC_CSTR component, p;
 
  if (len == -1) len = strlen((const char *)string_binding);
 
  component = malloc((len + 1) * sizeof(*component));
  if (!component) return NULL;
  for (p = component; len > 0; string_binding++, len--) {
    if (*string_binding == '\\') {
      string_binding++;
      len--;
      *p++ = *string_binding;
    } else {
      *p++ = *string_binding;
    }
  }
  *p = '\0';
  return component;
}

Referenced by RpcStringBindingParseA().

unescape_string_binding_componentW()

static RPC_WSTR unescape_string_binding_componentW ( const WCHAR *  string_binding, int  len  )

static

Definition at line 415 of file rpc_binding.c.

{
  RPC_WSTR component, p;
 
  if (len == -1) len = lstrlenW(string_binding);
 
  component = malloc((len + 1) * sizeof(*component));
  if (!component) return NULL;
  for (p = component; len > 0; string_binding++, len--) {
    if (*string_binding == '\\') {
      string_binding++;
      len--;
      *p++ = *string_binding;
    } else {
      *p++ = *string_binding;
    }
  }
  *p = '\0';
  return component;
}

Referenced by RpcStringBindingParseW().

WINE_DEFAULT_DEBUG_CHANNEL()

WINE_DEFAULT_DEBUG_CHANNEL

(

rpc

)