summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--source3/rpc_server/srv_epmapper.c254
1 files changed, 210 insertions, 44 deletions
diff --git a/source3/rpc_server/srv_epmapper.c b/source3/rpc_server/srv_epmapper.c
index 07097e4bad..028cadfb14 100644
--- a/source3/rpc_server/srv_epmapper.c
+++ b/source3/rpc_server/srv_epmapper.c
@@ -57,6 +57,11 @@ struct dcesrv_endpoint {
struct dcesrv_iface_list *iface_list;
};
+struct rpc_eps {
+ struct dcesrv_ep_iface *e;
+ uint32_t count;
+};
+
struct dcesrv_endpoint *endpoint_table;
/*
@@ -397,6 +402,7 @@ error_status_t _epm_Lookup(struct pipes_struct *p,
struct epm_Lookup *r)
{
struct policy_handle *entry_handle;
+ struct rpc_eps *eps;
TALLOC_CTX *tmp_ctx;
error_status_t rc;
uint32_t count = 0;
@@ -405,11 +411,6 @@ error_status_t _epm_Lookup(struct pipes_struct *p,
bool match = false;
bool ok;
- struct rpc_eps {
- struct dcesrv_ep_iface *e;
- uint32_t count;
- } *eps;
-
*r->out.num_ents = 0;
r->out.entries = NULL;
@@ -724,74 +725,239 @@ done:
error_status_t _epm_Map(struct pipes_struct *p,
struct epm_Map *r)
{
+ struct policy_handle *entry_handle;
enum dcerpc_transport_t transport;
- struct ndr_syntax_id ndr_syntax;
- struct dcesrv_ep_iface *eps;
+ struct ndr_syntax_id ifid;
struct epm_floor *floors;
- uint32_t count, i;
-
- count = build_ep_list(p->mem_ctx, endpoint_table, NULL, &eps);
+ struct rpc_eps *eps;
+ TALLOC_CTX *tmp_ctx;
+ error_status_t rc;
+ uint32_t count = 0;
+ uint32_t num_towers = 0;
+ uint32_t num_floors = 0;
+ uint32_t i;
+ bool ok;
- ZERO_STRUCT(*r->out.entry_handle);
- r->out.num_towers = talloc(p->mem_ctx, uint32_t);
- if (r->out.num_towers == NULL) {
- return EPMAPPER_STATUS_NO_MEMORY;
- }
+ *r->out.num_towers = 0;
+ r->out.towers = NULL;
- *r->out.num_towers = 1;
- r->out.towers = talloc(p->mem_ctx, struct epm_twr_p_t);
- if (r->out.towers == NULL) {
- return EPMAPPER_STATUS_NO_MEMORY;
+ if (r->in.map_tower == NULL || r->in.max_towers == 0 ||
+ r->in.map_tower->tower.num_floors < 3) {
+ return EPMAPPER_STATUS_NO_MORE_ENTRIES;
}
- r->out.towers->twr = talloc(p->mem_ctx, struct epm_twr_t);
- if (r->out.towers->twr == NULL) {
+ tmp_ctx = talloc_stackframe();
+ if (tmp_ctx == NULL) {
return EPMAPPER_STATUS_NO_MEMORY;
}
- if (r->in.map_tower == NULL || r->in.max_towers == 0 ||
- r->in.map_tower->tower.num_floors < 3) {
- goto failed;
- }
-
+ ZERO_STRUCTP(r->out.entry_handle);
+
+ DEBUG(3, ("_epm_Map: Trying to map max. %u towers.\n",
+ r->in.max_towers));
+
+ /*
+ * A tower has normally up to 6 floors
+ *
+ * +-----------------------------------------------------------------+
+ * | Floor 1 | Provides the RPC interface identifier. (e.g. UUID for |
+ * | | netlogon) |
+ * +---------+-------------------------------------------------------+
+ * | Floor 2 | Transfer syntax (NDR endcoded) |
+ * +---------+-------------------------------------------------------+
+ * | Floor 3 | RPC protocol identifier (ncacn_tcp_ip, ncacn_np, ...) |
+ * +---------+-------------------------------------------------------+
+ * | Floor 4 | Port address (e.g. TCP Port: 49156) |
+ * +---------+-------------------------------------------------------+
+ * | Floor 5 | Transport (e.g. IP:192.168.51.10) |
+ * +---------+-------------------------------------------------------+
+ * | Floor 6 | Routing |
+ * +---------+-------------------------------------------------------+
+ */
+ num_floors = r->in.map_tower->tower.num_floors;
floors = r->in.map_tower->tower.floors;
- dcerpc_floor_get_lhs_data(&r->in.map_tower->tower.floors[1], &ndr_syntax);
+ /* We accept NDR as the transfer syntax */
+ dcerpc_floor_get_lhs_data(&floors[1], &ifid);
if (floors[1].lhs.protocol != EPM_PROTOCOL_UUID ||
- !GUID_equal(&ndr_syntax.uuid, &ndr_transfer_syntax.uuid) ||
- ndr_syntax.if_version != ndr_transfer_syntax.if_version) {
- goto failed;
+ !GUID_equal(&ifid.uuid, &ndr_transfer_syntax.uuid) ||
+ ifid.if_version != ndr_transfer_syntax.if_version) {
+ rc = EPMAPPER_STATUS_NO_MORE_ENTRIES;
+ goto done;
}
+ /* We only talk to sane transports */
transport = dcerpc_transport_by_tower(&r->in.map_tower->tower);
- if (transport == -1) {
- DEBUG(2, ("epm_Insert: Client requested unknown transport with levels: "));
+ if (transport == NCA_UNKNOWN) {
+ DEBUG(2, ("epm_Map: Client requested unknown transport with"
+ "levels: "));
for (i = 2; i < r->in.map_tower->tower.num_floors; i++) {
DEBUG(2, ("%d, ", r->in.map_tower->tower.floors[i].lhs.protocol));
}
DEBUG(2, ("\n"));
- goto failed;
+ rc = EPMAPPER_STATUS_NO_MORE_ENTRIES;
+ goto done;
+ }
+
+ if (r->in.entry_handle == NULL ||
+ policy_handle_empty(r->in.entry_handle)) {
+ struct GUID *obj;
+
+ DEBUG(5, ("_epm_Map: No entry_handle found, creating it.\n"));
+
+ eps = talloc_zero(tmp_ctx, struct rpc_eps);
+ if (eps == NULL) {
+ rc = EPMAPPER_STATUS_NO_MEMORY;
+ goto done;
+ }
+
+ /*
+ * *** ATTENTION ***
+ * CDE 1.1 states:
+ *
+ * ept_map()
+ * Apply some algorithm (using the fields in the map_tower)
+ * to an endpoint map to produce a list of protocol towers.
+ *
+ * The following code is the mysterious "some algorithm"!
+ */
+
+ /* Filter by object id if one was given. */
+ if (r->in.object == NULL || GUID_all_zero(r->in.object)) {
+ obj = NULL;
+ } else {
+ obj = r->in.object;
+ }
+
+ eps->count = build_ep_list(eps,
+ endpoint_table,
+ obj,
+ &eps->e);
+ if (eps->count == 0) {
+ rc = EPMAPPER_STATUS_NO_MORE_ENTRIES;
+ goto done;
+ }
+
+ /* Filter out endpoints which match the interface. */
+ {
+ struct rpc_eps *teps;
+ uint32_t total = 0;
+
+ teps = talloc_zero(tmp_ctx, struct rpc_eps);
+ if (teps == NULL) {
+ rc = EPMAPPER_STATUS_NO_MEMORY;
+ goto done;
+ }
+
+ for (i = 0; i < eps->count; i++) {
+ if (data_blob_cmp(&r->in.map_tower->tower.floors[0].lhs.lhs_data,
+ &eps->e[i].ep.floors[0].lhs.lhs_data) != 0 ||
+ transport != dcerpc_transport_by_tower(&eps->e[i].ep)) {
+ continue;
+ }
+
+ teps->e = talloc_realloc(tmp_ctx,
+ teps->e,
+ struct dcesrv_ep_iface,
+ total + 1);
+ if (teps->e == NULL) {
+ return 0;
+ }
+
+ teps->e[total].ep.floors = talloc_move(teps, &eps->e[i].ep.floors);
+ teps->e[total].ep.num_floors = eps->e[i].ep.num_floors;
+ teps->e[total].name = talloc_move(teps, &eps->e[i].name);
+ teps->e[total].syntax_id = eps->e[i].syntax_id;
+
+ total++;
+ }
+
+ teps->count = total;
+ talloc_free(eps);
+ eps = teps;
+ }
+ /* end of "some algorithm" */
+
+ ok = create_policy_hnd(p, r->out.entry_handle, eps);
+ if (!ok) {
+ rc = EPMAPPER_STATUS_NO_MEMORY;
+ goto done;
+ }
+
+ ok = find_policy_by_hnd(p, r->out.entry_handle, (void **)(void*) &eps);
+ if (!ok) {
+ rc = EPMAPPER_STATUS_NO_MEMORY;
+ goto done;
+ }
+ entry_handle = r->out.entry_handle;
+ } else {
+ DEBUG(5, ("_epm_Map: Trying to find entry_handle.\n"));
+
+ ok = find_policy_by_hnd(p, r->in.entry_handle, (void **)(void*) &eps);
+ if (!ok) {
+ rc = EPMAPPER_STATUS_NO_MEMORY;
+ goto done;
+ }
+ entry_handle = r->in.entry_handle;
+ }
+
+ if (eps == NULL || eps->e == NULL) {
+ rc = EPMAPPER_STATUS_NO_MORE_ENTRIES;
+ goto done;
+ }
+
+ /* return the next N elements */
+ count = r->in.max_towers;
+ if (count > eps->count) {
+ count = eps->count;
+ }
+
+ if (count == 0) {
+ close_policy_hnd(p, entry_handle);
+ ZERO_STRUCTP(r->out.entry_handle);
+
+ rc = EPMAPPER_STATUS_NO_MORE_ENTRIES;
+ goto done;
+ }
+
+ r->out.towers = talloc_array(p->mem_ctx, struct epm_twr_p_t, count);
+ if (r->out.towers == NULL) {
+ rc = EPMAPPER_STATUS_NO_MEMORY;
+ goto done;
}
for (i = 0; i < count; i++) {
- if (data_blob_cmp(&r->in.map_tower->tower.floors[0].lhs.lhs_data,
- &eps[i].ep.floors[0].lhs.lhs_data) != 0 ||
- transport != dcerpc_transport_by_tower(&eps[i].ep)) {
- continue;
+ DEBUG(5, ("_epm_Map: Map tower for '%s'\n",
+ eps->e[i].name));
+
+ r->out.towers[num_towers].twr = talloc(r->out.towers,
+ struct epm_twr_t);
+ if (r->out.towers[num_towers].twr == NULL) {
+ rc = EPMAPPER_STATUS_NO_MEMORY;
+ goto done;
}
+ r->out.towers[num_towers].twr->tower.floors = talloc_move(r->out.towers[num_towers].twr, &eps->e[i].ep.floors);
+ r->out.towers[num_towers].twr->tower.num_floors = eps->e[i].ep.num_floors;
+ r->out.towers[num_towers].twr->tower_length = 0;
- r->out.towers->twr->tower = eps[i].ep;
- r->out.towers->twr->tower_length = 0;
+ num_towers++;
+ }
- return EPMAPPER_STATUS_OK;
+ *r->out.num_towers = num_towers;
+
+ eps->count -= count;
+ eps->e += count;
+ if (eps->count == 0) {
+ close_policy_hnd(p, entry_handle);
+ ZERO_STRUCTP(r->out.entry_handle);
}
-failed:
- *r->out.num_towers = 0;
- r->out.towers->twr = NULL;
+ rc = EPMAPPER_STATUS_OK;
+done:
+ talloc_free(tmp_ctx);
- return EPMAPPER_STATUS_NO_MORE_ENTRIES;
+ return rc;
}
/*
generated by cgit (git 2.34.1) at 2024-12-21 00:28:54 +0000