summaryrefslogtreecommitdiff
path: root/source4/lib/dcom/common
diff options
context:
space:
mode:
Diffstat (limited to 'source4/lib/dcom/common')
-rw-r--r--source4/lib/dcom/common/dcom.h60
-rw-r--r--source4/lib/dcom/common/main.c476
2 files changed, 0 insertions, 536 deletions
diff --git a/source4/lib/dcom/common/dcom.h b/source4/lib/dcom/common/dcom.h
deleted file mode 100644
index dd21bb9d29..0000000000
--- a/source4/lib/dcom/common/dcom.h
+++ /dev/null
@@ -1,60 +0,0 @@
-/*
- Unix SMB/CIFS implementation.
- DCOM standard objects
- Copyright (C) Jelmer Vernooij 2004-2005.
-
- This program is free software; you can redistribute it and/or modify
- it under the terms of the GNU General Public License as published by
- the Free Software Foundation; either version 2 of the License, or
- (at your option) any later version.
-
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU General Public License for more details.
-
- You should have received a copy of the GNU General Public License
- along with this program; if not, write to the Free Software
- Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
-*/
-
-#ifndef _DCOM_H /* _DCOM_H */
-#define _DCOM_H
-
-#include "librpc/ndr/ndr_dcom.h"
-
-struct dcom_context
-{
- struct dcom_object_exporter {
- struct dcom_object_exporter *prev, *next;
- struct STRINGARRAY resolver_address;
- struct DUALSTRINGARRAY bindings;
- uint64_t oxid;
- struct dcerpc_pipe *pipe;
- struct dcom_object
- {
- struct dcom_object *prev, *next;
- uint64_t oid;
- void *private_data;
- } *objects;
- } *oxids;
- const char *domain;
- const char *user;
- const char *password;
- uint32_t dcerpc_flags;
-};
-
-struct dcom_interface_p
-{
- struct com_context *ctx;
- const struct com_interface *interface;
- const void *vtable; /* Points to one of the available implementations */
- struct GUID ipid;
- struct com_object *object;
- int objref_flags;
- int orpc_flags;
- struct com_object_exporter *ox;
- uint32_t private_references;
-};
-
-#endif /* _DCOM_H */
diff --git a/source4/lib/dcom/common/main.c b/source4/lib/dcom/common/main.c
deleted file mode 100644
index 315912ba3c..0000000000
--- a/source4/lib/dcom/common/main.c
+++ /dev/null
@@ -1,476 +0,0 @@
-/*
- Unix SMB/CIFS implementation.
- Main DCOM functionality
- Copyright (C) 2004 Jelmer Vernooij <jelmer@samba.org>
-
- This program is free software; you can redistribute it and/or modify
- it under the terms of the GNU General Public License as published by
- the Free Software Foundation; either version 2 of the License, or
- (at your option) any later version.
-
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU General Public License for more details.
-
- You should have received a copy of the GNU General Public License
- along with this program; if not, write to the Free Software
- Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
-*/
-
-#include "includes.h"
-#include "system/filesys.h"
-#include "dlinklist.h"
-#include "librpc/gen_ndr/ndr_epmapper.h"
-#include "librpc/gen_ndr/ndr_remact.h"
-#include "librpc/gen_ndr/ndr_oxidresolver.h"
-#include "librpc/gen_ndr/ndr_dcom.h"
-
-#define DCOM_NEGOTIATED_PROTOCOLS { EPM_PROTOCOL_TCP, EPM_PROTOCOL_SMB, EPM_PROTOCOL_NCALRPC }
-
-static NTSTATUS dcerpc_binding_from_STRINGBINDING(TALLOC_CTX *mem_ctx, struct dcerpc_binding *b, struct STRINGBINDING *bd)
-{
- char *host, *endpoint;
-
- ZERO_STRUCTP(b);
-
- b->transport = dcerpc_transport_by_endpoint_protocol(bd->wTowerId);
-
- if (b->transport == -1) {
- DEBUG(1, ("Can't find transport match endpoint protocol %d\n", bd->wTowerId));
- return NT_STATUS_NOT_SUPPORTED;
- }
-
- host = talloc_strdup(mem_ctx, bd->NetworkAddr);
- endpoint = strchr(host, '[');
-
- if (endpoint) {
- *endpoint = '\0';
- endpoint++;
-
- endpoint[strlen(endpoint)-1] = '\0';
- }
-
- b->host = host;
- b->endpoint = endpoint;
-
- return NT_STATUS_OK;
-}
-
-static NTSTATUS dcom_connect_host(struct dcom_context *ctx, struct dcerpc_pipe **p, const char *server)
-{
- struct dcerpc_binding bd;
- enum dcerpc_transport_t available_transports[] = { NCACN_IP_TCP, NCACN_NP };
- int i;
- NTSTATUS status;
- TALLOC_CTX *mem_ctx = talloc_init("dcom_connect");
-
- /* Allow server name to contain a binding string */
- if (NT_STATUS_IS_OK(dcerpc_parse_binding(mem_ctx, server, &bd))) {
- status = dcerpc_pipe_connect_b(p, &bd,
- DCERPC_IREMOTEACTIVATION_UUID,
- DCERPC_IREMOTEACTIVATION_VERSION,
- ctx->domain, ctx->user, ctx->password);
-
- talloc_free(mem_ctx);
- return status;
- }
- talloc_free(mem_ctx);
-
- ZERO_STRUCT(bd);
- bd.host = server;
-
- if (server == NULL) {
- bd.transport = NCALRPC;
- return dcerpc_pipe_connect_b(p, &bd,
- DCERPC_IREMOTEACTIVATION_UUID,
- DCERPC_IREMOTEACTIVATION_VERSION,
- ctx->domain, ctx->user, ctx->password);
- }
-
- for (i = 0; i < ARRAY_SIZE(available_transports); i++)
- {
- bd.transport = available_transports[i];
-
- status = dcerpc_pipe_connect_b(p, &bd,
- DCERPC_IREMOTEACTIVATION_UUID,
- DCERPC_IREMOTEACTIVATION_VERSION,
- ctx->domain, ctx->user, ctx->password);
-
- if (NT_STATUS_IS_OK(status)) {
- return status;
- }
- }
-
- return status;
-}
-
-WERROR dcom_init(struct dcom_context **ctx, const char *domain, const char *user, const char *pass)
-{
- *ctx = talloc(NULL, struct dcom_context);
- (*ctx)->oxids = NULL;
- (*ctx)->domain = talloc_strdup(*ctx, domain);
- (*ctx)->user = talloc_strdup(*ctx, user);
- (*ctx)->password = talloc_strdup(*ctx, pass);
- (*ctx)->dcerpc_flags = 0;
-
- return WERR_OK;
-}
-
-struct dcom_object_exporter *oxid_mapping_by_oxid (struct dcom_context *ctx, uint64_t oxid)
-{
- struct dcom_object_exporter *m;
-
- for (m = ctx->oxids;m;m = m->next) {
- if (m->oxid == oxid) {
- break;
- }
- }
-
- /* Add oxid mapping if we couldn't find one */
- if (!m) {
- m = talloc_zero(ctx, struct dcom_object_exporter);
- m->oxid = oxid;
- DLIST_ADD(ctx->oxids, m);
- }
-
- return m;
-}
-
-WERROR dcom_ping(struct dcom_context *ctx)
-{
- /* FIXME: If OID's waiting in queue, do a ComplexPing call */
- /* FIXME: otherwise, do a SimplePing call */
- return WERR_OK;
-}
-
-static WERROR dcom_create_object(struct dcom_context *ctx, struct GUID *clsid, const char *server, int num_ifaces, struct GUID *iid, struct dcom_interface_p ***ip, WERROR *results)
-{
- uint16_t protseq[] = DCOM_NEGOTIATED_PROTOCOLS;
- struct dcerpc_pipe *p;
- struct dcom_object_exporter *m;
- NTSTATUS status;
- struct RemoteActivation r;
- struct DUALSTRINGARRAY dualstring;
- int i;
-
- if (!server) {
- return com_create_object(ctx, clsid, num_ifaces, iid, ip, results);
- }
-
- status = dcom_connect_host(ctx, &p, server);
- if (NT_STATUS_IS_ERR(status)) {
- DEBUG(1, ("Unable to connect to %s - %s\n", server, nt_errstr(status)));
- return ntstatus_to_werror(status);
- }
-
- ZERO_STRUCT(r.in);
- r.in.this.version.MajorVersion = COM_MAJOR_VERSION;
- r.in.this.version.MinorVersion = COM_MINOR_VERSION;
- r.in.this.cid = GUID_random();
- r.in.Clsid = *clsid;
- r.in.ClientImpLevel = RPC_C_IMP_LEVEL_IDENTIFY;
- r.in.num_protseqs = ARRAY_SIZE(protseq);
- r.in.protseq = protseq;
- r.in.Interfaces = num_ifaces;
- r.in.pIIDs = iid;
- r.out.ifaces = talloc_array(ctx, struct pMInterfacePointer, num_ifaces);
- r.out.pdsaOxidBindings = &dualstring;
-
- status = dcerpc_RemoteActivation(p, ctx, &r);
- if(NT_STATUS_IS_ERR(status)) {
- DEBUG(1, ("Error while running RemoteActivation %s\n", nt_errstr(status)));
- return ntstatus_to_werror(status);
- }
-
- if(!W_ERROR_IS_OK(r.out.result)) {
- return r.out.result;
- }
-
- if(!W_ERROR_IS_OK(r.out.hr)) {
- return r.out.hr;
- }
-
- *ip = talloc_array(ctx, struct dcom_interface_p *, num_ifaces);
- for (i = 0; i < num_ifaces; i++) {
- results[i] = r.out.results[i];
- (*ip)[i] = NULL;
- if (W_ERROR_IS_OK(results[i])) {
- status = dcom_ifacep_from_OBJREF(ctx, &(*ip)[i], &r.out.ifaces[i].p->obj);
- if (NT_STATUS_IS_OK(status)) {
- (*ip)[i]->private_references = 1;
- } else {
- results[i] = ntstatus_to_werror(status);
- }
- }
- }
-
- /* Add the OXID data for the returned oxid */
- m = oxid_mapping_by_oxid(ctx, r.out.pOxid);
- m->bindings = *r.out.pdsaOxidBindings;
-
- return WERR_OK;
-}
-
-WERROR dcom_get_class_object(struct dcom_context *ctx, struct GUID *clsid, const char *server, struct GUID *iid, struct dcom_interface_p **ip)
-{
- struct dcom_object_exporter *m;
- struct RemoteActivation r;
- struct dcerpc_pipe *p;
- struct DUALSTRINGARRAY dualstring;
- NTSTATUS status;
- struct pMInterfacePointer pm;
- uint16_t protseq[] = DCOM_NEGOTIATED_PROTOCOLS;
-
- if (!server) {
- return com_get_class_object(ctx, clsid, iid, ip);
- }
-
- status = dcom_connect_host(ctx, &p, server);
- if (NT_STATUS_IS_ERR(status)) {
- DEBUG(1, ("Unable to connect to %s - %s\n", server, nt_errstr(status)));
- return ntstatus_to_werror(status);
- }
-
- ZERO_STRUCT(r.in);
- r.in.this.version.MajorVersion = COM_MAJOR_VERSION;
- r.in.this.version.MinorVersion = COM_MINOR_VERSION;
- r.in.this.cid = GUID_random();
- r.in.Clsid = *clsid;
- r.in.ClientImpLevel = RPC_C_IMP_LEVEL_IDENTIFY;
- r.in.num_protseqs = ARRAY_SIZE(protseq);
- r.in.protseq = protseq;
- r.in.Interfaces = 1;
- r.in.pIIDs = iid;
- r.in.Mode = MODE_GET_CLASS_OBJECT;
- r.out.ifaces = &pm;
- r.out.pdsaOxidBindings = &dualstring;
-
- status = dcerpc_RemoteActivation(p, ctx, &r);
- if(NT_STATUS_IS_ERR(status)) {
- DEBUG(1, ("Error while running RemoteActivation - %s\n", nt_errstr(status)));
- return ntstatus_to_werror(status);
- }
-
- if(!W_ERROR_IS_OK(r.out.result)) { return r.out.result; }
- if(!W_ERROR_IS_OK(r.out.hr)) { return r.out.hr; }
- if(!W_ERROR_IS_OK(r.out.results[0])) { return r.out.results[0]; }
-
- /* Set up the interface data */
- dcom_ifacep_from_OBJREF(ctx, ip, &pm.p->obj);
- (*ip)->private_references = 1;
-
- /* Add the OXID data for the returned oxid */
- m = oxid_mapping_by_oxid(ctx, r.out.pOxid);
- m->bindings = *r.out.pdsaOxidBindings;
-
- return WERR_OK;
-}
-
-NTSTATUS dcom_get_pipe (struct dcom_interface_p *iface, struct dcerpc_pipe **pp)
-{
- struct dcerpc_binding binding;
- struct GUID iid;
- uint64_t oxid;
- NTSTATUS status;
- int i;
- struct dcerpc_pipe *p;
- TALLOC_CTX *tmp_ctx;
- const char *uuid;
-
- tmp_ctx = talloc_new(NULL);
-
- p = iface->ox->pipe;
-
- oxid = iface->ox->oxid;
- iid = iface->interface->iid;
-
- uuid = GUID_string(tmp_ctx, &iid);
-
- if (p) {
- if (!GUID_equal(&p->syntax.uuid, &iid)) {
- struct dcerpc_pipe *p2;
- iface->ox->pipe->syntax.uuid = iid;
- status = dcerpc_secondary_context(p, &p2, uuid, 0);
- if (NT_STATUS_IS_OK(status)) {
- p = p2;
- }
- } else {
- p = talloc_reference(NULL, p);
- }
- *pp = p;
- talloc_free(tmp_ctx);
- return status;
- }
-
- i = 0;
- do {
- status = dcerpc_binding_from_STRINGBINDING(iface->ctx, &binding,
- iface->ox->bindings.stringbindings[i]);
- if (!NT_STATUS_IS_OK(status)) {
- DEBUG(1, ("Error parsing string binding"));
- } else {
- binding.flags = iface->ctx->dcerpc_flags;
- status = dcerpc_pipe_connect_b(&p, &binding,
- uuid, 0.0,
- iface->ctx->domain, iface->ctx->user,
- iface->ctx->password);
- }
-
- i++;
- } while (NT_STATUS_IS_ERR(status) && iface->ox->bindings.stringbindings[i]);
-
- if (NT_STATUS_IS_ERR(status)) {
- DEBUG(0, ("Unable to connect to remote host - %s\n", nt_errstr(status)));
- talloc_free(tmp_ctx);
- return status;
- }
-
- DEBUG(2, ("Successfully connected to OXID %llx\n", oxid));
-
- *pp = p;
- talloc_free(tmp_ctx);
-
- return NT_STATUS_OK;
-}
-
-struct dcom_object *dcom_object_by_oid(struct dcom_object_exporter *ox, uint64_t oid)
-{
- struct dcom_object *o;
-
- for (o = ox->objects; o; o = o->next) {
- if (o->oid == oid) {
- break;
- }
- }
-
- if (o == NULL) {
- o = talloc_zero(ox, struct dcom_object);
- o->oid = oid;
- DLIST_ADD(ox->objects, o);
- }
-
- return o;
-}
-
-
-NTSTATUS dcom_OBJREF_from_ifacep(struct dcom_context *ctx, struct OBJREF *o, struct dcom_interface_p *_p)
-{
- return NT_STATUS_NOT_IMPLEMENTED;
-}
-
-NTSTATUS dcom_ifacep_from_OBJREF(struct dcom_context *ctx, struct dcom_interface_p **_p, struct OBJREF *o)
-{
- struct dcom_interface_p *p = talloc(ctx, struct dcom_interface_p);
-
- p->ctx = ctx;
- p->interface = dcom_interface_by_iid(&o->iid);
- if (!p->interface) {
- DEBUG(0, ("Unable to find interface with IID %s\n", GUID_string(ctx, &o->iid)));
- return NT_STATUS_NOT_SUPPORTED;
- }
-
- p->private_references = 0;
- p->objref_flags = o->flags;
-
- switch(p->objref_flags) {
- case OBJREF_NULL:
- p->object = NULL;
- p->ox = NULL;
- p->vtable = dcom_proxy_vtable_by_iid(&p->interface->iid);
- ZERO_STRUCT(p->ipid);
- *_p = p;
- return NT_STATUS_OK;
-
- case OBJREF_STANDARD:
- p->ox = oxid_mapping_by_oxid(ctx, o->u_objref.u_standard.std.oxid);
- p->ipid = o->u_objref.u_standard.std.ipid;
- p->object = dcom_object_by_oid(p->ox, o->u_objref.u_standard.std.oid);
- p->ox->resolver_address = o->u_objref.u_standard.saResAddr;
- p->vtable = dcom_proxy_vtable_by_iid(&p->interface->iid);
- *_p = p;
- return NT_STATUS_OK;
-
- case OBJREF_HANDLER:
- p->ox = oxid_mapping_by_oxid(ctx, o->u_objref.u_handler.std.oxid );
- p->ipid = o->u_objref.u_handler.std.ipid;
- p->object = dcom_object_by_oid(p->ox, o->u_objref.u_standard.std.oid);
- p->ox->resolver_address = o->u_objref.u_handler.saResAddr;
-/*FIXME p->vtable = dcom_vtable_by_clsid(&o->u_objref.u_handler.clsid);*/
- /* FIXME: Do the custom unmarshaling call */
-
- *_p = p;
- return NT_STATUS_OK;
-
- case OBJREF_CUSTOM:
- {
- p->vtable = NULL;
-
- /* FIXME: Do the actual custom unmarshaling call */
- p->ox = NULL;
- p->object = NULL;
- ZERO_STRUCT(p->ipid);
- *_p = p;
- return NT_STATUS_NOT_SUPPORTED;
- }
- }
-
- return NT_STATUS_NOT_SUPPORTED;
-
-
-#if 0
- struct dcom_oxid_mapping *m;
- /* Add OXID mapping if none present yet */
- if (!m) {
- struct dcerpc_pipe *po;
- struct ResolveOxid r;
- uint16_t protseq[] = DCOM_NEGOTIATED_PROTOCOLS;
-
- DEBUG(3, ("No binding data present yet, resolving OXID %llu\n", p->ox->oxid));
-
- m = talloc_zero(p->ctx, struct dcom_oxid_mapping);
- m->oxid = oxid;
-
- i = 0;
- do {
- status = dcerpc_binding_from_STRINGBINDING(p->ctx, &binding, p->client.objref->u_objref.u_standard.saResAddr.stringbindings[i]);
-
- if (NT_STATUS_IS_OK(status)) {
- binding.flags = iface->ctx->dcerpc_flags;
- status = dcerpc_pipe_connect_b(&po, &binding, DCERPC_IOXIDRESOLVER_UUID, DCERPC_IOXIDRESOLVER_VERSION, iface->ctx->domain, iface->ctx->user, iface->ctx->password);
- } else {
- DEBUG(1, ("Error parsing string binding - %s", nt_errstr(status)));
- }
-
- i++;
- } while (!NT_STATUS_IS_OK(status) && iface->client.objref->u_objref.u_standard.saResAddr.stringbindings[i]);
-
- if (NT_STATUS_IS_ERR(status)) {
- DEBUG(1, ("Error while connecting to OXID Resolver : %s\n", nt_errstr(status)));
- return status;
- }
-
- r.in.pOxid = oxid;
- r.in.cRequestedProtseqs = ARRAY_SIZE(protseq);
- r.in.arRequestedProtseqs = protseq;
- r.out.ppdsaOxidBindings = &m->bindings;
-
- status = dcerpc_ResolveOxid(po, iface->ctx, &r);
- if (NT_STATUS_IS_ERR(status)) {
- DEBUG(1, ("Error while resolving OXID: %s\n", nt_errstr(status)));
- return status;
- }
-
- dcerpc_pipe_close(po);
-
- DLIST_ADD(iface->ctx->oxids, m);
- }
-#endif
-
- return NT_STATUS_NOT_SUPPORTED;
-}
-
-uint64_t dcom_get_current_oxid(void)
-{
- return getpid();
-}
generated by cgit (git 2.34.1) at 2025-01-02 17:19:54 +0000