2 Unix SMB/CIFS implementation.
4 dcerpc utility functions
6 Copyright (C) Andrew Tridgell 2003
7 Copyright (C) Jelmer Vernooij 2004
8 Copyright (C) Andrew Bartlett <abartlet@samba.org> 2005
9 Copyright (C) Rafal Szczesniak 2006
10 Copyright (C) Stefan Metzmacher 2014
12 This program is free software; you can redistribute it and/or modify
13 it under the terms of the GNU General Public License as published by
14 the Free Software Foundation; either version 3 of the License, or
15 (at your option) any later version.
17 This program is distributed in the hope that it will be useful,
18 but WITHOUT ANY WARRANTY; without even the implied warranty of
19 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
20 GNU General Public License for more details.
22 You should have received a copy of the GNU General Public License
23 along with this program. If not, see <http://www.gnu.org/licenses/>.
27 #include "../../lib/util/util_net.h"
28 #include "librpc/gen_ndr/ndr_epmapper.h"
29 #include "librpc/gen_ndr/ndr_misc.h"
30 #include "librpc/rpc/dcerpc.h"
31 #include "rpc_common.h"
36 #define MAX_PROTSEQ 10
38 struct dcerpc_binding
{
39 enum dcerpc_transport_t transport
;
41 const char *object_string
;
43 const char *target_hostname
;
44 const char *target_principal
;
48 uint32_t assoc_group_id
;
49 char assoc_group_string
[11]; /* 0x3456789a + '\0' */
54 enum dcerpc_transport_t transport
;
56 enum epm_protocol protseq
[MAX_PROTSEQ
];
58 { "ncacn_np", NCACN_NP
, 3,
59 { EPM_PROTOCOL_NCACN
, EPM_PROTOCOL_SMB
, EPM_PROTOCOL_NETBIOS
}},
60 { "ncacn_ip_tcp", NCACN_IP_TCP
, 3,
61 { EPM_PROTOCOL_NCACN
, EPM_PROTOCOL_TCP
, EPM_PROTOCOL_IP
} },
62 { "ncacn_http", NCACN_HTTP
, 3,
63 { EPM_PROTOCOL_NCACN
, EPM_PROTOCOL_HTTP
, EPM_PROTOCOL_IP
} },
64 { "ncadg_ip_udp", NCACN_IP_UDP
, 3,
65 { EPM_PROTOCOL_NCADG
, EPM_PROTOCOL_UDP
, EPM_PROTOCOL_IP
} },
66 { "ncalrpc", NCALRPC
, 2,
67 { EPM_PROTOCOL_NCALRPC
, EPM_PROTOCOL_NAMED_PIPE
} },
68 { "ncacn_unix_stream", NCACN_UNIX_STREAM
, 2,
69 { EPM_PROTOCOL_NCACN
, EPM_PROTOCOL_UNIX_DS
} },
70 { "ncadg_unix_dgram", NCADG_UNIX_DGRAM
, 2,
71 { EPM_PROTOCOL_NCADG
, EPM_PROTOCOL_UNIX_DS
} },
72 { "ncacn_at_dsp", NCACN_AT_DSP
, 3,
73 { EPM_PROTOCOL_NCACN
, EPM_PROTOCOL_APPLETALK
, EPM_PROTOCOL_DSP
} },
74 { "ncadg_at_ddp", NCADG_AT_DDP
, 3,
75 { EPM_PROTOCOL_NCADG
, EPM_PROTOCOL_APPLETALK
, EPM_PROTOCOL_DDP
} },
76 { "ncacn_vns_ssp", NCACN_VNS_SPP
, 3,
77 { EPM_PROTOCOL_NCACN
, EPM_PROTOCOL_STREETTALK
, EPM_PROTOCOL_VINES_SPP
} },
78 { "ncacn_vns_ipc", NCACN_VNS_IPC
, 3,
79 { EPM_PROTOCOL_NCACN
, EPM_PROTOCOL_STREETTALK
, EPM_PROTOCOL_VINES_IPC
}, },
80 { "ncadg_ipx", NCADG_IPX
, 2,
81 { EPM_PROTOCOL_NCADG
, EPM_PROTOCOL_IPX
},
83 { "ncacn_spx", NCACN_SPX
, 3,
84 /* I guess some MS programmer confused the identifier for
85 * EPM_PROTOCOL_UUID (0x0D or 13) with the one for
86 * EPM_PROTOCOL_SPX (0x13) here. -- jelmer*/
87 { EPM_PROTOCOL_NCACN
, EPM_PROTOCOL_NCALRPC
, EPM_PROTOCOL_UUID
},
91 static const struct ncacn_option
{
95 {"sign", DCERPC_SIGN
},
96 {"seal", DCERPC_SEAL
},
97 {"connect", DCERPC_CONNECT
},
98 {"spnego", DCERPC_AUTH_SPNEGO
},
99 {"ntlm", DCERPC_AUTH_NTLM
},
100 {"krb5", DCERPC_AUTH_KRB5
},
101 {"schannel", DCERPC_SCHANNEL
| DCERPC_SCHANNEL_AUTO
},
102 {"validate", DCERPC_DEBUG_VALIDATE_BOTH
},
103 {"print", DCERPC_DEBUG_PRINT_BOTH
},
104 {"padcheck", DCERPC_DEBUG_PAD_CHECK
},
105 {"bigendian", DCERPC_PUSH_BIGENDIAN
},
106 {"smb2", DCERPC_SMB2
},
107 {"ndr64", DCERPC_NDR64
},
108 {"packet", DCERPC_PACKET
},
111 static const struct ncacn_option
*ncacn_option_by_name(const char *name
)
115 for (i
=0; i
<ARRAY_SIZE(ncacn_options
); i
++) {
118 ret
= strcasecmp(ncacn_options
[i
].name
, name
);
123 return &ncacn_options
[i
];
129 const char *epm_floor_string(TALLOC_CTX
*mem_ctx
, struct epm_floor
*epm_floor
)
131 struct ndr_syntax_id syntax
;
134 switch(epm_floor
->lhs
.protocol
) {
135 case EPM_PROTOCOL_UUID
:
136 status
= dcerpc_floor_get_lhs_data(epm_floor
, &syntax
);
137 if (NT_STATUS_IS_OK(status
)) {
138 /* lhs is used: UUID */
141 if (GUID_equal(&syntax
.uuid
, &ndr_transfer_syntax_ndr
.uuid
)) {
145 if (GUID_equal(&syntax
.uuid
, &ndr_transfer_syntax_ndr64
.uuid
)) {
149 uuidstr
= GUID_string(mem_ctx
, &syntax
.uuid
);
151 return talloc_asprintf(mem_ctx
, " uuid %s/0x%02x", uuidstr
, syntax
.if_version
);
153 return talloc_asprintf(mem_ctx
, "IPX:%s",
154 data_blob_hex_string_upper(mem_ctx
, &epm_floor
->rhs
.uuid
.unknown
));
157 case EPM_PROTOCOL_NCACN
:
160 case EPM_PROTOCOL_NCADG
:
163 case EPM_PROTOCOL_NCALRPC
:
166 case EPM_PROTOCOL_DNET_NSP
:
169 case EPM_PROTOCOL_IP
:
170 return talloc_asprintf(mem_ctx
, "IP:%s", epm_floor
->rhs
.ip
.ipaddr
);
172 case EPM_PROTOCOL_NAMED_PIPE
:
173 return talloc_asprintf(mem_ctx
, "NAMED-PIPE:%s", epm_floor
->rhs
.named_pipe
.path
);
175 case EPM_PROTOCOL_SMB
:
176 return talloc_asprintf(mem_ctx
, "SMB:%s", epm_floor
->rhs
.smb
.unc
);
178 case EPM_PROTOCOL_UNIX_DS
:
179 return talloc_asprintf(mem_ctx
, "Unix:%s", epm_floor
->rhs
.unix_ds
.path
);
181 case EPM_PROTOCOL_NETBIOS
:
182 return talloc_asprintf(mem_ctx
, "NetBIOS:%s", epm_floor
->rhs
.netbios
.name
);
184 case EPM_PROTOCOL_NETBEUI
:
187 case EPM_PROTOCOL_SPX
:
190 case EPM_PROTOCOL_NB_IPX
:
193 case EPM_PROTOCOL_HTTP
:
194 return talloc_asprintf(mem_ctx
, "HTTP:%d", epm_floor
->rhs
.http
.port
);
196 case EPM_PROTOCOL_TCP
:
197 return talloc_asprintf(mem_ctx
, "TCP:%d", epm_floor
->rhs
.tcp
.port
);
199 case EPM_PROTOCOL_UDP
:
200 return talloc_asprintf(mem_ctx
, "UDP:%d", epm_floor
->rhs
.udp
.port
);
203 return talloc_asprintf(mem_ctx
, "UNK(%02x):", epm_floor
->lhs
.protocol
);
209 form a binding string from a binding structure
211 _PUBLIC_
char *dcerpc_binding_string(TALLOC_CTX
*mem_ctx
, const struct dcerpc_binding
*b
)
213 char *s
= talloc_strdup(mem_ctx
, "");
216 const char *t_name
= NULL
;
217 bool option_section
= false;
218 const char *target_hostname
= NULL
;
220 if (b
->transport
!= NCA_UNKNOWN
) {
221 t_name
= derpc_transport_string_by_transport(b
->transport
);
228 if (!GUID_all_zero(&b
->object
)) {
230 s
= talloc_asprintf_append_buffer(s
, "%s@",
231 GUID_string(mem_ctx
, &b
->object
));
238 if (t_name
!= NULL
) {
240 s
= talloc_asprintf_append_buffer(s
, "%s:", t_name
);
249 s
= talloc_asprintf_append_buffer(s
, "%s", b
->host
);
256 target_hostname
= b
->target_hostname
;
257 if (target_hostname
!= NULL
&& b
->host
!= NULL
) {
258 if (strcmp(target_hostname
, b
->host
) == 0) {
259 target_hostname
= NULL
;
264 option_section
= true;
265 } else if (target_hostname
) {
266 option_section
= true;
267 } else if (b
->target_principal
) {
268 option_section
= true;
269 } else if (b
->assoc_group_id
!= 0) {
270 option_section
= true;
271 } else if (b
->options
) {
272 option_section
= true;
273 } else if (b
->flags
) {
274 option_section
= true;
277 if (!option_section
) {
282 s
= talloc_asprintf_append_buffer(s
, "[");
290 s
= talloc_asprintf_append_buffer(s
, "%s", b
->endpoint
);
297 for (i
=0;i
<ARRAY_SIZE(ncacn_options
);i
++) {
298 if (!(b
->flags
& ncacn_options
[i
].flag
)) {
303 s
= talloc_asprintf_append_buffer(s
, ",%s", ncacn_options
[i
].name
);
310 if (target_hostname
) {
312 s
= talloc_asprintf_append_buffer(s
, ",target_hostname=%s",
320 if (b
->target_principal
) {
322 s
= talloc_asprintf_append_buffer(s
, ",target_principal=%s",
323 b
->target_principal
);
330 if (b
->assoc_group_id
!= 0) {
332 s
= talloc_asprintf_append_buffer(s
, ",assoc_group_id=0x%08x",
340 for (i
=0;b
->options
&& b
->options
[i
];i
++) {
342 s
= talloc_asprintf_append_buffer(s
, ",%s", b
->options
[i
]);
350 s
= talloc_asprintf_append_buffer(s
, "]");
360 parse a binding string into a dcerpc_binding structure
362 _PUBLIC_ NTSTATUS
dcerpc_parse_binding(TALLOC_CTX
*mem_ctx
, const char *_s
, struct dcerpc_binding
**b_out
)
365 struct dcerpc_binding
*b
;
367 char *options
= NULL
;
372 b
= talloc_zero(mem_ctx
, struct dcerpc_binding
);
374 return NT_STATUS_NO_MEMORY
;
377 _t
= talloc_strdup(b
, _s
);
380 return NT_STATUS_NO_MEMORY
;
389 if (options
[strlen(options
)-1] != ']') {
391 return NT_STATUS_INVALID_PARAMETER_MIX
;
393 options
[strlen(options
)-1] = 0;
398 if (p
&& PTR_DIFF(p
, s
) == 36) { /* 36 is the length of a UUID */
401 status
= dcerpc_binding_set_string_option(b
, "object", s
);
402 if (!NT_STATUS_IS_OK(status
)) {
413 b
->transport
= NCA_UNKNOWN
;
414 } else if (is_ipaddress_v6(s
)) {
415 b
->transport
= NCA_UNKNOWN
;
419 status
= dcerpc_binding_set_string_option(b
, "transport", s
);
420 if (!NT_STATUS_IS_OK(status
)) {
429 status
= dcerpc_binding_set_string_option(b
, "host", s
);
430 if (!NT_STATUS_IS_OK(status
)) {
435 b
->target_hostname
= talloc_strdup(b
, b
->host
);
436 if (b
->target_hostname
== NULL
) {
438 return NT_STATUS_NO_MEMORY
;
442 for (i
=0; options
!= NULL
; i
++) {
443 const char *name
= options
;
444 const char *value
= NULL
;
446 p
= strchr(options
, ',');
454 p
= strchr(name
, '=');
462 * If it's not a key=value pair
463 * it might be a ncacn_option
464 * or if it's the first option
467 const struct ncacn_option
*no
= NULL
;
471 no
= ncacn_option_by_name(name
);
475 * we don't allow unknown options
477 return NT_STATUS_INVALID_PARAMETER_MIX
;
481 * This is the endpoint
484 if (strlen(value
) == 0) {
490 status
= dcerpc_binding_set_string_option(b
, name
, value
);
491 if (!NT_STATUS_IS_OK(status
)) {
502 _PUBLIC_
struct GUID
dcerpc_binding_get_object(const struct dcerpc_binding
*b
)
507 _PUBLIC_ NTSTATUS
dcerpc_binding_set_object(struct dcerpc_binding
*b
,
510 char *tmp
= discard_const_p(char, b
->object_string
);
512 if (GUID_all_zero(&object
)) {
514 b
->object_string
= NULL
;
515 ZERO_STRUCT(b
->object
);
519 b
->object_string
= GUID_string(b
, &object
);
520 if (b
->object_string
== NULL
) {
521 b
->object_string
= tmp
;
522 return NT_STATUS_NO_MEMORY
;
530 _PUBLIC_
enum dcerpc_transport_t
dcerpc_binding_get_transport(const struct dcerpc_binding
*b
)
535 _PUBLIC_ NTSTATUS
dcerpc_binding_set_transport(struct dcerpc_binding
*b
,
536 enum dcerpc_transport_t transport
)
541 * TODO: we may want to check the transport value is
544 if (b
->transport
== transport
) {
549 * This implicitly resets the endpoint
550 * as the endpoint is transport specific.
552 * It also resets the assoc group as it's
553 * also endpoint specific.
555 * TODO: in future we may reset more options
558 status
= dcerpc_binding_set_string_option(b
, "endpoint", NULL
);
559 if (!NT_STATUS_IS_OK(status
)) {
563 b
->assoc_group_id
= 0;
565 b
->transport
= transport
;
569 _PUBLIC_
void dcerpc_binding_get_auth_info(const struct dcerpc_binding
*b
,
570 enum dcerpc_AuthType
*_auth_type
,
571 enum dcerpc_AuthLevel
*_auth_level
)
573 enum dcerpc_AuthType auth_type
;
574 enum dcerpc_AuthLevel auth_level
;
576 if (b
->flags
& DCERPC_AUTH_SPNEGO
) {
577 auth_type
= DCERPC_AUTH_TYPE_SPNEGO
;
578 } else if (b
->flags
& DCERPC_AUTH_KRB5
) {
579 auth_type
= DCERPC_AUTH_TYPE_KRB5
;
580 } else if (b
->flags
& DCERPC_SCHANNEL
) {
581 auth_type
= DCERPC_AUTH_TYPE_SCHANNEL
;
582 } else if (b
->flags
& DCERPC_AUTH_NTLM
) {
583 auth_type
= DCERPC_AUTH_TYPE_NTLMSSP
;
585 auth_type
= DCERPC_AUTH_TYPE_NONE
;
588 if (b
->flags
& DCERPC_SEAL
) {
589 auth_level
= DCERPC_AUTH_LEVEL_PRIVACY
;
590 } else if (b
->flags
& DCERPC_SIGN
) {
591 auth_level
= DCERPC_AUTH_LEVEL_INTEGRITY
;
592 } else if (b
->flags
& DCERPC_CONNECT
) {
593 auth_level
= DCERPC_AUTH_LEVEL_CONNECT
;
594 } else if (b
->flags
& DCERPC_PACKET
) {
595 auth_level
= DCERPC_AUTH_LEVEL_PACKET
;
596 } else if (auth_type
!= DCERPC_AUTH_TYPE_NONE
) {
597 auth_level
= DCERPC_AUTH_LEVEL_INTEGRITY
;
599 auth_level
= DCERPC_AUTH_LEVEL_NONE
;
602 if (_auth_type
!= NULL
) {
603 *_auth_type
= auth_type
;
606 if (_auth_level
!= NULL
) {
607 *_auth_level
= auth_level
;
611 _PUBLIC_
uint32_t dcerpc_binding_get_assoc_group_id(const struct dcerpc_binding
*b
)
613 return b
->assoc_group_id
;
616 _PUBLIC_ NTSTATUS
dcerpc_binding_set_assoc_group_id(struct dcerpc_binding
*b
,
617 uint32_t assoc_group_id
)
619 b
->assoc_group_id
= assoc_group_id
;
623 _PUBLIC_
struct ndr_syntax_id
dcerpc_binding_get_abstract_syntax(const struct dcerpc_binding
*b
)
625 const char *s
= dcerpc_binding_get_string_option(b
, "abstract_syntax");
627 struct ndr_syntax_id id
;
630 return ndr_syntax_id_null
;
633 ok
= ndr_syntax_id_from_string(s
, &id
);
635 return ndr_syntax_id_null
;
641 _PUBLIC_ NTSTATUS
dcerpc_binding_set_abstract_syntax(struct dcerpc_binding
*b
,
642 const struct ndr_syntax_id
*syntax
)
647 if (syntax
== NULL
) {
648 status
= dcerpc_binding_set_string_option(b
, "abstract_syntax", NULL
);
649 if (!NT_STATUS_IS_OK(status
)) {
656 if (ndr_syntax_id_equal(&ndr_syntax_id_null
, syntax
)) {
657 status
= dcerpc_binding_set_string_option(b
, "abstract_syntax", NULL
);
658 if (!NT_STATUS_IS_OK(status
)) {
665 s
= ndr_syntax_id_to_string(b
, syntax
);
667 return NT_STATUS_NO_MEMORY
;
670 status
= dcerpc_binding_set_string_option(b
, "abstract_syntax", s
);
672 if (!NT_STATUS_IS_OK(status
)) {
679 _PUBLIC_
const char *dcerpc_binding_get_string_option(const struct dcerpc_binding
*b
,
685 #define _SPECIAL(x) { .name = #x, .value = b->x, }
687 { .name
= "object", .value
= b
->object_string
, },
690 _SPECIAL(target_hostname
),
691 _SPECIAL(target_principal
),
694 const struct ncacn_option
*no
= NULL
;
695 size_t name_len
= strlen(name
);
699 ret
= strcmp(name
, "transport");
701 return derpc_transport_string_by_transport(b
->transport
);
704 ret
= strcmp(name
, "assoc_group_id");
706 char *tmp
= discard_const_p(char, b
->assoc_group_string
);
708 if (b
->assoc_group_id
== 0) {
712 snprintf(tmp
, sizeof(b
->assoc_group_string
),
713 "0x%08x", b
->assoc_group_id
);
714 return (const char *)b
->assoc_group_string
;
717 for (i
=0; i
< ARRAY_SIZE(specials
); i
++) {
718 ret
= strcmp(specials
[i
].name
, name
);
723 return specials
[i
].value
;
726 no
= ncacn_option_by_name(name
);
728 if (b
->flags
& no
->flag
) {
735 if (b
->options
== NULL
) {
739 for (i
=0; b
->options
[i
]; i
++) {
740 const char *o
= b
->options
[i
];
741 const char *vs
= NULL
;
743 ret
= strncmp(name
, o
, name_len
);
748 if (o
[name_len
] != '=') {
752 vs
= &o
[name_len
+ 1];
760 _PUBLIC_
char *dcerpc_binding_copy_string_option(TALLOC_CTX
*mem_ctx
,
761 const struct dcerpc_binding
*b
,
764 const char *c
= dcerpc_binding_get_string_option(b
, name
);
772 v
= talloc_strdup(mem_ctx
, c
);
781 _PUBLIC_ NTSTATUS
dcerpc_binding_set_string_option(struct dcerpc_binding
*b
,
788 #define _SPECIAL(x) { .name = #x, .ptr = &b->x, }
792 _SPECIAL(target_hostname
),
793 _SPECIAL(target_principal
),
796 const struct ncacn_option
*no
= NULL
;
797 size_t name_len
= strlen(name
);
798 const char *opt
= NULL
;
804 * Note: value == NULL, means delete it.
805 * value != NULL means add or reset.
808 ret
= strcmp(name
, "transport");
810 enum dcerpc_transport_t t
= dcerpc_transport_by_name(value
);
812 if (t
== NCA_UNKNOWN
&& value
!= NULL
) {
813 return NT_STATUS_INVALID_PARAMETER_MIX
;
816 return dcerpc_binding_set_transport(b
, t
);
819 ret
= strcmp(name
, "object");
822 struct GUID uuid
= GUID_zero();
826 blob
= data_blob_string_const(value
);
827 if (blob
.length
!= 36) {
828 return NT_STATUS_INVALID_PARAMETER_MIX
;
831 status
= GUID_from_data_blob(&blob
, &uuid
);
832 if (!NT_STATUS_IS_OK(status
)) {
837 return dcerpc_binding_set_object(b
, uuid
);
840 ret
= strcmp(name
, "assoc_group_id");
842 uint32_t assoc_group_id
= 0;
847 ret
= sscanf(value
, "0x%08x%c", &assoc_group_id
, &c
);
849 return NT_STATUS_INVALID_PARAMETER_MIX
;
853 return dcerpc_binding_set_assoc_group_id(b
, assoc_group_id
);
856 for (i
=0; i
< ARRAY_SIZE(specials
); i
++) {
857 ret
= strcmp(specials
[i
].name
, name
);
862 tmp
= discard_const_p(char, *specials
[i
].ptr
);
866 *specials
[i
].ptr
= NULL
;
870 if (value
[0] == '\0') {
871 return NT_STATUS_INVALID_PARAMETER_MIX
;
874 *specials
[i
].ptr
= talloc_strdup(b
, value
);
875 if (*specials
[i
].ptr
== NULL
) {
876 *specials
[i
].ptr
= tmp
;
877 return NT_STATUS_NO_MEMORY
;
884 no
= ncacn_option_by_name(name
);
887 b
->flags
&= ~no
->flag
;
891 ret
= strcasecmp(no
->name
, value
);
893 return NT_STATUS_INVALID_PARAMETER_MIX
;
896 b
->flags
|= no
->flag
;
900 for (i
=0; b
->options
&& b
->options
[i
]; i
++) {
901 const char *o
= b
->options
[i
];
903 ret
= strncmp(name
, o
, name_len
);
908 if (o
[name_len
] != '=') {
923 n
= talloc_realloc(b
, b
->options
, const char *, i
+ 2);
925 return NT_STATUS_NO_MEMORY
;
932 tmp
= discard_const_p(char, opt
);
935 for (;b
->options
[i
];i
++) {
936 b
->options
[i
] = b
->options
[i
+1];
942 b
->options
[i
] = talloc_asprintf(b
->options
, "%s=%s",
944 if (b
->options
[i
] == NULL
) {
946 return NT_STATUS_NO_MEMORY
;
952 _PUBLIC_
uint32_t dcerpc_binding_get_flags(const struct dcerpc_binding
*b
)
957 _PUBLIC_ NTSTATUS
dcerpc_binding_set_flags(struct dcerpc_binding
*b
,
962 * TODO: in future we may want to reject invalid combinations
965 b
->flags
|= additional
;
970 _PUBLIC_ NTSTATUS
dcerpc_floor_get_lhs_data(const struct epm_floor
*epm_floor
,
971 struct ndr_syntax_id
*syntax
)
973 TALLOC_CTX
*mem_ctx
= talloc_init("floor_get_lhs_data");
974 struct ndr_pull
*ndr
;
975 enum ndr_err_code ndr_err
;
976 uint16_t if_version
=0;
978 ndr
= ndr_pull_init_blob(&epm_floor
->lhs
.lhs_data
, mem_ctx
);
980 talloc_free(mem_ctx
);
981 return NT_STATUS_NO_MEMORY
;
983 ndr
->flags
|= LIBNDR_FLAG_NOALIGN
;
985 ndr_err
= ndr_pull_GUID(ndr
, NDR_SCALARS
| NDR_BUFFERS
, &syntax
->uuid
);
986 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err
)) {
987 talloc_free(mem_ctx
);
988 return ndr_map_error2ntstatus(ndr_err
);
991 ndr_err
= ndr_pull_uint16(ndr
, NDR_SCALARS
, &if_version
);
992 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err
)) {
993 talloc_free(mem_ctx
);
994 return ndr_map_error2ntstatus(ndr_err
);
997 syntax
->if_version
= if_version
;
999 talloc_free(mem_ctx
);
1001 return NT_STATUS_OK
;
1004 static DATA_BLOB
dcerpc_floor_pack_lhs_data(TALLOC_CTX
*mem_ctx
, const struct ndr_syntax_id
*syntax
)
1007 enum ndr_err_code ndr_err
;
1008 struct ndr_push
*ndr
;
1010 ndr
= ndr_push_init_ctx(mem_ctx
);
1012 return data_blob_null
;
1015 ndr
->flags
|= LIBNDR_FLAG_NOALIGN
;
1017 ndr_err
= ndr_push_GUID(ndr
, NDR_SCALARS
| NDR_BUFFERS
, &syntax
->uuid
);
1018 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err
)) {
1019 return data_blob_null
;
1021 ndr_err
= ndr_push_uint16(ndr
, NDR_SCALARS
, syntax
->if_version
);
1022 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err
)) {
1023 return data_blob_null
;
1026 blob
= ndr_push_blob(ndr
);
1027 talloc_steal(mem_ctx
, blob
.data
);
1032 static bool dcerpc_floor_pack_rhs_if_version_data(
1033 TALLOC_CTX
*mem_ctx
, const struct ndr_syntax_id
*syntax
,
1037 struct ndr_push
*ndr
= ndr_push_init_ctx(mem_ctx
);
1038 enum ndr_err_code ndr_err
;
1044 ndr
->flags
|= LIBNDR_FLAG_NOALIGN
;
1046 ndr_err
= ndr_push_uint16(ndr
, NDR_SCALARS
, syntax
->if_version
>> 16);
1047 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err
)) {
1051 blob
= ndr_push_blob(ndr
);
1052 talloc_steal(mem_ctx
, blob
.data
);
1058 char *dcerpc_floor_get_rhs_data(TALLOC_CTX
*mem_ctx
, struct epm_floor
*epm_floor
)
1060 switch (epm_floor
->lhs
.protocol
) {
1061 case EPM_PROTOCOL_TCP
:
1062 if (epm_floor
->rhs
.tcp
.port
== 0) return NULL
;
1063 return talloc_asprintf(mem_ctx
, "%d", epm_floor
->rhs
.tcp
.port
);
1065 case EPM_PROTOCOL_UDP
:
1066 if (epm_floor
->rhs
.udp
.port
== 0) return NULL
;
1067 return talloc_asprintf(mem_ctx
, "%d", epm_floor
->rhs
.udp
.port
);
1069 case EPM_PROTOCOL_HTTP
:
1070 if (epm_floor
->rhs
.http
.port
== 0) return NULL
;
1071 return talloc_asprintf(mem_ctx
, "%d", epm_floor
->rhs
.http
.port
);
1073 case EPM_PROTOCOL_IP
:
1074 return talloc_strdup(mem_ctx
, epm_floor
->rhs
.ip
.ipaddr
);
1076 case EPM_PROTOCOL_NCACN
:
1079 case EPM_PROTOCOL_NCADG
:
1082 case EPM_PROTOCOL_SMB
:
1083 if (strlen(epm_floor
->rhs
.smb
.unc
) == 0) return NULL
;
1084 return talloc_strdup(mem_ctx
, epm_floor
->rhs
.smb
.unc
);
1086 case EPM_PROTOCOL_NAMED_PIPE
:
1087 if (strlen(epm_floor
->rhs
.named_pipe
.path
) == 0) return NULL
;
1088 return talloc_strdup(mem_ctx
, epm_floor
->rhs
.named_pipe
.path
);
1090 case EPM_PROTOCOL_NETBIOS
:
1091 if (strlen(epm_floor
->rhs
.netbios
.name
) == 0) return NULL
;
1092 return talloc_strdup(mem_ctx
, epm_floor
->rhs
.netbios
.name
);
1094 case EPM_PROTOCOL_NCALRPC
:
1097 case EPM_PROTOCOL_VINES_SPP
:
1098 return talloc_asprintf(mem_ctx
, "%d", epm_floor
->rhs
.vines_spp
.port
);
1100 case EPM_PROTOCOL_VINES_IPC
:
1101 return talloc_asprintf(mem_ctx
, "%d", epm_floor
->rhs
.vines_ipc
.port
);
1103 case EPM_PROTOCOL_STREETTALK
:
1104 return talloc_strdup(mem_ctx
, epm_floor
->rhs
.streettalk
.streettalk
);
1106 case EPM_PROTOCOL_UNIX_DS
:
1107 if (strlen(epm_floor
->rhs
.unix_ds
.path
) == 0) return NULL
;
1108 return talloc_strdup(mem_ctx
, epm_floor
->rhs
.unix_ds
.path
);
1110 case EPM_PROTOCOL_NULL
:
1114 DEBUG(0,("Unsupported lhs protocol %d\n", epm_floor
->lhs
.protocol
));
1121 static NTSTATUS
dcerpc_floor_set_rhs_data(TALLOC_CTX
*mem_ctx
,
1122 struct epm_floor
*epm_floor
,
1129 switch (epm_floor
->lhs
.protocol
) {
1130 case EPM_PROTOCOL_TCP
:
1131 epm_floor
->rhs
.tcp
.port
= atoi(data
);
1132 return NT_STATUS_OK
;
1134 case EPM_PROTOCOL_UDP
:
1135 epm_floor
->rhs
.udp
.port
= atoi(data
);
1136 return NT_STATUS_OK
;
1138 case EPM_PROTOCOL_HTTP
:
1139 epm_floor
->rhs
.http
.port
= atoi(data
);
1140 return NT_STATUS_OK
;
1142 case EPM_PROTOCOL_IP
:
1143 if (!is_ipaddress_v4(data
)) {
1146 epm_floor
->rhs
.ip
.ipaddr
= talloc_strdup(mem_ctx
, data
);
1147 NT_STATUS_HAVE_NO_MEMORY(epm_floor
->rhs
.ip
.ipaddr
);
1148 return NT_STATUS_OK
;
1150 case EPM_PROTOCOL_NCACN
:
1151 epm_floor
->rhs
.ncacn
.minor_version
= 0;
1152 return NT_STATUS_OK
;
1154 case EPM_PROTOCOL_NCADG
:
1155 epm_floor
->rhs
.ncadg
.minor_version
= 0;
1156 return NT_STATUS_OK
;
1158 case EPM_PROTOCOL_SMB
:
1159 epm_floor
->rhs
.smb
.unc
= talloc_strdup(mem_ctx
, data
);
1160 NT_STATUS_HAVE_NO_MEMORY(epm_floor
->rhs
.smb
.unc
);
1161 return NT_STATUS_OK
;
1163 case EPM_PROTOCOL_NAMED_PIPE
:
1164 epm_floor
->rhs
.named_pipe
.path
= talloc_strdup(mem_ctx
, data
);
1165 NT_STATUS_HAVE_NO_MEMORY(epm_floor
->rhs
.named_pipe
.path
);
1166 return NT_STATUS_OK
;
1168 case EPM_PROTOCOL_NETBIOS
:
1169 epm_floor
->rhs
.netbios
.name
= talloc_strdup(mem_ctx
, data
);
1170 NT_STATUS_HAVE_NO_MEMORY(epm_floor
->rhs
.netbios
.name
);
1171 return NT_STATUS_OK
;
1173 case EPM_PROTOCOL_NCALRPC
:
1174 return NT_STATUS_OK
;
1176 case EPM_PROTOCOL_VINES_SPP
:
1177 epm_floor
->rhs
.vines_spp
.port
= atoi(data
);
1178 return NT_STATUS_OK
;
1180 case EPM_PROTOCOL_VINES_IPC
:
1181 epm_floor
->rhs
.vines_ipc
.port
= atoi(data
);
1182 return NT_STATUS_OK
;
1184 case EPM_PROTOCOL_STREETTALK
:
1185 epm_floor
->rhs
.streettalk
.streettalk
= talloc_strdup(mem_ctx
, data
);
1186 NT_STATUS_HAVE_NO_MEMORY(epm_floor
->rhs
.streettalk
.streettalk
);
1187 return NT_STATUS_OK
;
1189 case EPM_PROTOCOL_UNIX_DS
:
1190 epm_floor
->rhs
.unix_ds
.path
= talloc_strdup(mem_ctx
, data
);
1191 NT_STATUS_HAVE_NO_MEMORY(epm_floor
->rhs
.unix_ds
.path
);
1192 return NT_STATUS_OK
;
1194 case EPM_PROTOCOL_NULL
:
1195 return NT_STATUS_OK
;
1198 DEBUG(0,("Unsupported lhs protocol %d\n", epm_floor
->lhs
.protocol
));
1202 return NT_STATUS_NOT_SUPPORTED
;
1205 enum dcerpc_transport_t
dcerpc_transport_by_endpoint_protocol(int prot
)
1209 /* Find a transport that has 'prot' as 4th protocol */
1210 for (i
=0;i
<ARRAY_SIZE(transports
);i
++) {
1211 if (transports
[i
].num_protocols
>= 2 &&
1212 transports
[i
].protseq
[1] == prot
) {
1213 return transports
[i
].transport
;
1217 /* Unknown transport */
1218 return (unsigned int)-1;
1221 _PUBLIC_
enum dcerpc_transport_t
dcerpc_transport_by_tower(const struct epm_tower
*tower
)
1225 /* Find a transport that matches this tower */
1226 for (i
=0;i
<ARRAY_SIZE(transports
);i
++) {
1228 if (transports
[i
].num_protocols
!= tower
->num_floors
- 2) {
1232 for (j
= 0; j
< transports
[i
].num_protocols
&& j
< MAX_PROTSEQ
; j
++) {
1233 if (transports
[i
].protseq
[j
] != tower
->floors
[j
+2].lhs
.protocol
) {
1238 if (j
== transports
[i
].num_protocols
) {
1239 return transports
[i
].transport
;
1243 /* Unknown transport */
1244 return (unsigned int)-1;
1247 _PUBLIC_
const char *derpc_transport_string_by_transport(enum dcerpc_transport_t t
)
1251 for (i
=0; i
<ARRAY_SIZE(transports
); i
++) {
1252 if (t
== transports
[i
].transport
) {
1253 return transports
[i
].name
;
1259 _PUBLIC_
enum dcerpc_transport_t
dcerpc_transport_by_name(const char *name
)
1267 for (i
=0; i
<ARRAY_SIZE(transports
);i
++) {
1268 if (strcasecmp(name
, transports
[i
].name
) == 0) {
1269 return transports
[i
].transport
;
1276 _PUBLIC_ NTSTATUS
dcerpc_binding_from_tower(TALLOC_CTX
*mem_ctx
,
1277 struct epm_tower
*tower
,
1278 struct dcerpc_binding
**b_out
)
1281 struct dcerpc_binding
*b
;
1282 enum dcerpc_transport_t transport
;
1283 struct ndr_syntax_id abstract_syntax
;
1284 char *endpoint
= NULL
;
1288 * A tower needs to have at least 4 floors to carry useful
1289 * information. Floor 3 is the transport identifier which defines
1290 * how many floors are required at least.
1292 if (tower
->num_floors
< 4) {
1293 return NT_STATUS_INVALID_PARAMETER
;
1296 status
= dcerpc_parse_binding(mem_ctx
, "", &b
);
1297 if (!NT_STATUS_IS_OK(status
)) {
1301 transport
= dcerpc_transport_by_tower(tower
);
1302 if (transport
== NCA_UNKNOWN
) {
1304 return NT_STATUS_NOT_SUPPORTED
;
1307 status
= dcerpc_binding_set_transport(b
, transport
);
1308 if (!NT_STATUS_IS_OK(status
)) {
1313 /* Set abstract syntax */
1314 status
= dcerpc_floor_get_lhs_data(&tower
->floors
[0], &abstract_syntax
);
1315 if (!NT_STATUS_IS_OK(status
)) {
1320 status
= dcerpc_binding_set_abstract_syntax(b
, &abstract_syntax
);
1321 if (!NT_STATUS_IS_OK(status
)) {
1326 /* Ignore floor 1, it contains the NDR version info */
1330 if (tower
->num_floors
>= 4) {
1331 endpoint
= dcerpc_floor_get_rhs_data(b
, &tower
->floors
[3]);
1334 int saved_errno
= errno
;
1336 return map_nt_error_from_unix_common(saved_errno
);
1339 status
= dcerpc_binding_set_string_option(b
, "endpoint", endpoint
);
1340 if (!NT_STATUS_IS_OK(status
)) {
1344 TALLOC_FREE(endpoint
);
1346 /* Set network address */
1348 if (tower
->num_floors
>= 5) {
1349 host
= dcerpc_floor_get_rhs_data(b
, &tower
->floors
[4]);
1352 int saved_errno
= errno
;
1354 return map_nt_error_from_unix_common(saved_errno
);
1357 status
= dcerpc_binding_set_string_option(b
, "host", host
);
1358 if (!NT_STATUS_IS_OK(status
)) {
1362 status
= dcerpc_binding_set_string_option(b
, "target_hostname", host
);
1363 if (!NT_STATUS_IS_OK(status
)) {
1370 return NT_STATUS_OK
;
1373 _PUBLIC_
struct dcerpc_binding
*dcerpc_binding_dup(TALLOC_CTX
*mem_ctx
,
1374 const struct dcerpc_binding
*b
)
1376 struct dcerpc_binding
*n
;
1379 n
= talloc_zero(mem_ctx
, struct dcerpc_binding
);
1384 n
->transport
= b
->transport
;
1385 n
->object
= b
->object
;
1386 n
->flags
= b
->flags
;
1387 n
->assoc_group_id
= b
->assoc_group_id
;
1389 if (b
->object_string
!= NULL
) {
1390 n
->object_string
= talloc_strdup(n
, b
->object_string
);
1391 if (n
->object_string
== NULL
) {
1396 if (b
->host
!= NULL
) {
1397 n
->host
= talloc_strdup(n
, b
->host
);
1398 if (n
->host
== NULL
) {
1404 if (b
->target_hostname
!= NULL
) {
1405 n
->target_hostname
= talloc_strdup(n
, b
->target_hostname
);
1406 if (n
->target_hostname
== NULL
) {
1412 if (b
->target_principal
!= NULL
) {
1413 n
->target_principal
= talloc_strdup(n
, b
->target_principal
);
1414 if (n
->target_principal
== NULL
) {
1420 if (b
->endpoint
!= NULL
) {
1421 n
->endpoint
= talloc_strdup(n
, b
->endpoint
);
1422 if (n
->endpoint
== NULL
) {
1428 for (count
= 0; b
->options
&& b
->options
[count
]; count
++);
1433 n
->options
= talloc_array(n
, const char *, count
+ 1);
1434 if (n
->options
== NULL
) {
1439 for (i
= 0; i
< count
; i
++) {
1440 n
->options
[i
] = talloc_strdup(n
->options
, b
->options
[i
]);
1441 if (n
->options
[i
] == NULL
) {
1446 n
->options
[count
] = NULL
;
1452 _PUBLIC_ NTSTATUS
dcerpc_binding_build_tower(TALLOC_CTX
*mem_ctx
,
1453 const struct dcerpc_binding
*binding
,
1454 struct epm_tower
*tower
)
1456 const enum epm_protocol
*protseq
= NULL
;
1457 int num_protocols
= -1, i
;
1458 struct ndr_syntax_id abstract_syntax
;
1461 /* Find transport */
1462 for (i
=0;i
<ARRAY_SIZE(transports
);i
++) {
1463 if (transports
[i
].transport
== binding
->transport
) {
1464 protseq
= transports
[i
].protseq
;
1465 num_protocols
= transports
[i
].num_protocols
;
1470 if (num_protocols
== -1) {
1471 DEBUG(0, ("Unable to find transport with id '%d'\n", binding
->transport
));
1472 return NT_STATUS_UNSUCCESSFUL
;
1475 tower
->num_floors
= 2 + num_protocols
;
1476 tower
->floors
= talloc_array(mem_ctx
, struct epm_floor
, tower
->num_floors
);
1479 tower
->floors
[0].lhs
.protocol
= EPM_PROTOCOL_UUID
;
1481 abstract_syntax
= dcerpc_binding_get_abstract_syntax(binding
);
1482 tower
->floors
[0].lhs
.lhs_data
= dcerpc_floor_pack_lhs_data(tower
->floors
,
1485 if (!dcerpc_floor_pack_rhs_if_version_data(
1486 tower
->floors
, &abstract_syntax
,
1487 &tower
->floors
[0].rhs
.uuid
.unknown
)) {
1488 return NT_STATUS_NO_MEMORY
;
1492 tower
->floors
[1].lhs
.protocol
= EPM_PROTOCOL_UUID
;
1494 tower
->floors
[1].lhs
.lhs_data
= dcerpc_floor_pack_lhs_data(tower
->floors
,
1495 &ndr_transfer_syntax_ndr
);
1497 tower
->floors
[1].rhs
.uuid
.unknown
= data_blob_talloc_zero(tower
->floors
, 2);
1499 /* Floor 2 to num_protocols */
1500 for (i
= 0; i
< num_protocols
; i
++) {
1501 tower
->floors
[2 + i
].lhs
.protocol
= protseq
[i
];
1502 tower
->floors
[2 + i
].lhs
.lhs_data
= data_blob_null
;
1503 ZERO_STRUCT(tower
->floors
[2 + i
].rhs
);
1504 status
= dcerpc_floor_set_rhs_data(tower
->floors
,
1505 &tower
->floors
[2 + i
],
1507 if (!NT_STATUS_IS_OK(status
)) {
1512 /* The 4th floor contains the endpoint */
1513 if (num_protocols
>= 2 && binding
->endpoint
) {
1514 status
= dcerpc_floor_set_rhs_data(tower
->floors
,
1517 if (!NT_STATUS_IS_OK(status
)) {
1522 /* The 5th contains the network address */
1523 if (num_protocols
>= 3 && binding
->host
) {
1524 status
= dcerpc_floor_set_rhs_data(tower
->floors
,
1527 if (!NT_STATUS_IS_OK(status
)) {
1532 return NT_STATUS_OK
;