Changeset 740 for vendor/current/librpc/rpc/binding.c

Timestamp:

Nov 14, 2012, 12:59:34 PM (13 years ago)

Author:

Silvan Scherrer

Message:

Samba Server: update vendor to 3.6.0

File:

• vendor/current/librpc/rpc/binding.c (modified) (18 diffs)

vendor/current/librpc/rpc/binding.c

@@ -24 +24 @@
 
 #include "includes.h"
+#include "../../lib/util/util_net.h"
 #include "librpc/gen_ndr/ndr_epmapper.h"
 #include "librpc/gen_ndr/ndr_misc.h"
 #include "librpc/rpc/dcerpc.h"
+#include "rpc_common.h"
+
 #undef strcasecmp
+#undef strncasecmp
 
 #define MAX_PROTSEQ             10
@@ -86 +90 @@
         {"smb2", DCERPC_SMB2},
         {"hdrsign", DCERPC_HEADER_SIGNING},
-        {"ndr64", DCERPC_NDR64}
+        {"ndr64", DCERPC_NDR64},
+        {"localaddress", DCERPC_LOCALADDRESS}
 };
 
@@ -114 +119 @@
                         } else { /* IPX */
                                 return talloc_asprintf(mem_ctx, "IPX:%s", 
-                                                data_blob_hex_string(mem_ctx, &epm_floor->rhs.uuid.unknown));
+                                                data_blob_hex_string_upper(mem_ctx, &epm_floor->rhs.uuid.unknown));
                         }
 
@@ -220 +225 @@
         for (i=0;i<ARRAY_SIZE(ncacn_options);i++) {
                 if (b->flags & ncacn_options[i].flag) {
-                        s = talloc_asprintf_append_buffer(s, ",%s", ncacn_options[i].name);
+                        if (ncacn_options[i].flag == DCERPC_LOCALADDRESS && b->localaddress) {
+                                s = talloc_asprintf_append_buffer(s, ",%s=%s", ncacn_options[i].name,
+                                                                  b->localaddress);
+                        } else {
+                                s = talloc_asprintf_append_buffer(s, ",%s", ncacn_options[i].name);
+                        }
                         if (!s) return NULL;
                 }
@@ -240 +250 @@
         int i, j, comma_count;
 
-        b = talloc(mem_ctx, struct dcerpc_binding);
+        b = talloc_zero(mem_ctx, struct dcerpc_binding);
         if (!b) {
                 return NT_STATUS_NO_MEMORY;
@@ -313 +323 @@
         b->assoc_group_id = 0;
         b->endpoint = NULL;
+        b->localaddress = NULL;
 
         if (!options) {
@@ -339 +350 @@
         for (i=0;b->options[i];i++) {
                 for (j=0;j<ARRAY_SIZE(ncacn_options);j++) {
-                        if (strcasecmp(ncacn_options[j].name, b->options[i]) == 0) {
+                        size_t opt_len = strlen(ncacn_options[j].name);
+                        if (strncasecmp(ncacn_options[j].name, b->options[i], opt_len) == 0) {
                                 int k;
+                                char c = b->options[i][opt_len];
+
+                                if (ncacn_options[j].flag == DCERPC_LOCALADDRESS && c == '=') {
+                                        b->localaddress = talloc_strdup(b, &b->options[i][opt_len+1]);
+                                } else if (c != 0) {
+                                        continue;
+                                }
+
                                 b->flags |= ncacn_options[j].flag;
                                 for (k=i;b->options[k];k++) {
@@ -376 +396 @@
         uint16_t if_version=0;
 
-        ndr = ndr_pull_init_blob(&epm_floor->lhs.lhs_data, mem_ctx, NULL);
+        ndr = ndr_pull_init_blob(&epm_floor->lhs.lhs_data, mem_ctx);
         if (ndr == NULL) {
                 talloc_free(mem_ctx);
@@ -404 +424 @@
 static DATA_BLOB dcerpc_floor_pack_lhs_data(TALLOC_CTX *mem_ctx, const struct ndr_syntax_id *syntax)
 {
-        struct ndr_push *ndr = ndr_push_init_ctx(mem_ctx, NULL);
+        DATA_BLOB blob;
+        struct ndr_push *ndr = ndr_push_init_ctx(mem_ctx);
 
         ndr->flags |= LIBNDR_FLAG_NOALIGN;
@@ -411 +432 @@
         ndr_push_uint16(ndr, NDR_SCALARS, syntax->if_version);
 
-        return ndr_push_blob(ndr);
+        blob = ndr_push_blob(ndr);
+        talloc_steal(mem_ctx, blob.data);
+        talloc_free(ndr);
+        return blob;
+}
+
+static bool dcerpc_floor_pack_rhs_if_version_data(
+        TALLOC_CTX *mem_ctx, const struct ndr_syntax_id *syntax,
+        DATA_BLOB *pblob)
+{
+        DATA_BLOB blob;
+        struct ndr_push *ndr = ndr_push_init_ctx(mem_ctx);
+        enum ndr_err_code ndr_err;
+
+        if (ndr == NULL) {
+                return false;
+        }
+
+        ndr->flags |= LIBNDR_FLAG_NOALIGN;
+
+        ndr_err = ndr_push_uint16(ndr, NDR_SCALARS, syntax->if_version >> 16);
+        if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
+                return false;
+        }
+
+        blob = ndr_push_blob(ndr);
+        talloc_steal(mem_ctx, blob.data);
+        talloc_free(ndr);
+        *pblob = blob;
+        return true;
 }
 
@@ -608 +658 @@
 }
 
-_PUBLIC_ NTSTATUS dcerpc_binding_from_tower(TALLOC_CTX *mem_ctx, 
-                                   struct epm_tower *tower, 
-                                   struct dcerpc_binding **b_out)
+_PUBLIC_ NTSTATUS dcerpc_binding_from_tower(TALLOC_CTX *mem_ctx,
+                                            struct epm_tower *tower,
+                                            struct dcerpc_binding **b_out)
 {
         NTSTATUS status;
         struct dcerpc_binding *binding;
 
-        binding = talloc(mem_ctx, struct dcerpc_binding);
+        /*
+         * A tower needs to have at least 4 floors to carry useful
+         * information. Floor 3 is the transport identifier which defines
+         * how many floors are required at least.
+         */
+        if (tower->num_floors < 4) {
+                return NT_STATUS_INVALID_PARAMETER;
+        }
+
+        binding = talloc_zero(mem_ctx, struct dcerpc_binding);
         NT_STATUS_HAVE_NO_MEMORY(binding);
 
@@ -631 +690 @@
         }
 
-        if (tower->num_floors < 1) {
-                return NT_STATUS_OK;
-        }
-
         /* Set object uuid */
         status = dcerpc_floor_get_lhs_data(&tower->floors[0], &binding->object);
 
         if (!NT_STATUS_IS_OK(status)) {
-                DEBUG(1, ("Error pulling object uuid and version: %s", nt_errstr(status)));     
+                DEBUG(1, ("Error pulling object uuid and version: %s", nt_errstr(status)));
                 return status;
         }
@@ -649 +704 @@
         /* Set endpoint */
         if (tower->num_floors >= 4) {
-                binding->endpoint = dcerpc_floor_get_rhs_data(mem_ctx, &tower->floors[3]);
+                binding->endpoint = dcerpc_floor_get_rhs_data(binding, &tower->floors[3]);
         } else {
                 binding->endpoint = NULL;
@@ -656 +711 @@
         /* Set network address */
         if (tower->num_floors >= 5) {
-                binding->host = dcerpc_floor_get_rhs_data(mem_ctx, &tower->floors[4]);
+                binding->host = dcerpc_floor_get_rhs_data(binding, &tower->floors[4]);
                 NT_STATUS_HAVE_NO_MEMORY(binding->host);
                 binding->target_hostname = binding->host;
@@ -662 +717 @@
         *b_out = binding;
         return NT_STATUS_OK;
+}
+
+_PUBLIC_ struct dcerpc_binding *dcerpc_binding_dup(TALLOC_CTX *mem_ctx,
+                                                   const struct dcerpc_binding *b)
+{
+        struct dcerpc_binding *n;
+        uint32_t count;
+
+        n = talloc_zero(mem_ctx, struct dcerpc_binding);
+        if (n == NULL) {
+                return NULL;
+        }
+
+        n->transport = b->transport;
+        n->object = b->object;
+        n->flags = b->flags;
+        n->assoc_group_id = b->assoc_group_id;
+
+        if (b->host != NULL) {
+                n->host = talloc_strdup(n, b->host);
+                if (n->host == NULL) {
+                        talloc_free(n);
+                        return NULL;
+                }
+        }
+
+        if (b->target_hostname != NULL) {
+                n->target_hostname = talloc_strdup(n, b->target_hostname);
+                if (n->target_hostname == NULL) {
+                        talloc_free(n);
+                        return NULL;
+                }
+        }
+
+        if (b->target_principal != NULL) {
+                n->target_principal = talloc_strdup(n, b->target_principal);
+                if (n->target_principal == NULL) {
+                        talloc_free(n);
+                        return NULL;
+                }
+        }
+
+        if (b->localaddress != NULL) {
+                n->localaddress = talloc_strdup(n, b->localaddress);
+                if (n->localaddress == NULL) {
+                        talloc_free(n);
+                        return NULL;
+                }
+        }
+
+        if (b->endpoint != NULL) {
+                n->endpoint = talloc_strdup(n, b->endpoint);
+                if (n->endpoint == NULL) {
+                        talloc_free(n);
+                        return NULL;
+                }
+        }
+
+        for (count = 0; b->options && b->options[count]; count++);
+
+        if (count > 0) {
+                uint32_t i;
+
+                n->options = talloc_array(n, const char *, count + 1);
+                if (n->options == NULL) {
+                        talloc_free(n);
+                        return NULL;
+                }
+
+                for (i = 0; i < count; i++) {
+                        n->options[i] = talloc_strdup(n->options, b->options[i]);
+                        if (n->options[i] == NULL) {
+                                talloc_free(n);
+                                return NULL;
+                        }
+                }
+                n->options[count] = NULL;
+        }
+
+        return n;
 }
 
@@ -692 +827 @@
         tower->floors[0].lhs.protocol = EPM_PROTOCOL_UUID;
 
-        tower->floors[0].lhs.lhs_data = dcerpc_floor_pack_lhs_data(mem_ctx, &binding->object);
-
-        tower->floors[0].rhs.uuid.unknown = data_blob_talloc_zero(mem_ctx, 2);
+        tower->floors[0].lhs.lhs_data = dcerpc_floor_pack_lhs_data(tower->floors, &binding->object);
+
+        if (!dcerpc_floor_pack_rhs_if_version_data(
+                    tower->floors, &binding->object,
+                    &tower->floors[0].rhs.uuid.unknown)) {
+                return NT_STATUS_NO_MEMORY;
+        }
 
         /* Floor 1 */
         tower->floors[1].lhs.protocol = EPM_PROTOCOL_UUID;
 
-        tower->floors[1].lhs.lhs_data = dcerpc_floor_pack_lhs_data(mem_ctx, 
+        tower->floors[1].lhs.lhs_data = dcerpc_floor_pack_lhs_data(tower->floors, 
                                                                 &ndr_transfer_syntax);
 
-        tower->floors[1].rhs.uuid.unknown = data_blob_talloc_zero(mem_ctx, 2);
+        tower->floors[1].rhs.uuid.unknown = data_blob_talloc_zero(tower->floors, 2);
 
         /* Floor 2 to num_protocols */
         for (i = 0; i < num_protocols; i++) {
                 tower->floors[2 + i].lhs.protocol = protseq[i];
-                tower->floors[2 + i].lhs.lhs_data = data_blob_talloc(mem_ctx, NULL, 0);
+                tower->floors[2 + i].lhs.lhs_data = data_blob_talloc(tower->floors, NULL, 0);
                 ZERO_STRUCT(tower->floors[2 + i].rhs);
-                dcerpc_floor_set_rhs_data(mem_ctx, &tower->floors[2 + i], "");
+                dcerpc_floor_set_rhs_data(tower->floors, &tower->floors[2 + i], "");
         }
 
         /* The 4th floor contains the endpoint */
         if (num_protocols >= 2 && binding->endpoint) {
-                status = dcerpc_floor_set_rhs_data(mem_ctx, &tower->floors[3], binding->endpoint);
+                status = dcerpc_floor_set_rhs_data(tower->floors, &tower->floors[3], binding->endpoint);
                 if (NT_STATUS_IS_ERR(status)) {
                         return status;
@@ -722 +861 @@
         /* The 5th contains the network address */
         if (num_protocols >= 3 && binding->host) {
-                if (is_ipaddress(binding->host)) {
-                        status = dcerpc_floor_set_rhs_data(mem_ctx, &tower->floors[4], 
+                if (is_ipaddress(binding->host) ||
+                    (binding->host[0] == '\\' && binding->host[1] == '\\')) {
+                        status = dcerpc_floor_set_rhs_data(tower->floors, &tower->floors[4], 
                                                            binding->host);
                 } else {
@@ -731 +871 @@
                            a wildcard all-zeros IP for the server to
                            fill in */
-                        status = dcerpc_floor_set_rhs_data(mem_ctx, &tower->floors[4], 
+                        status = dcerpc_floor_set_rhs_data(tower->floors, &tower->floors[4], 
                                                            "0.0.0.0");
                 }