sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-03-09 08:58:35 +03:00
Code

s3-rpc_server: Let enpoint mapper listen on port 135.

Browse Source 
*** This is my commit #500 ***

Endpoint Mapper is disabled by default. The next steps are to setup a
tcpip and ncalrpc listener for each service and register it at epm.

Autobuild-User: Andreas Schneider <asn@cryptomilk.org>
Autobuild-Date: Tue Feb 22 00:07:45 CET 2011 on sn-devel-104
This commit is contained in:
Andreas Schneider 2011-02-21 09:58:26 +01:00 committed by Andreas Schneider
parent 0abe7c68c5
commit 8fce37331e
1 changed files with 88 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

89
source3/rpc_server/rpc_ep_setup.c
View File

@ -44,12 +44,76 @@
#include "librpc/rpc/dcerpc_ep.h"
#include "rpc_server/rpc_ep_setup.h"
#include "rpc_server/rpc_server.h"
struct dcesrv_ep_context {
struct tevent_context *ev_ctx;
struct messaging_context *msg_ctx;
};
static uint16_t _open_sockets(struct tevent_context *ev_ctx,
struct messaging_context *msg_ctx,
struct ndr_syntax_id syntax_id,
uint16_t port)
{
uint32_t num_ifs = iface_count();
uint32_t i;
uint16_t p = 0;
if (lp_interfaces() && lp_bind_interfaces_only()) {
/*
* We have been given an interfaces line, and been told to only
* bind to those interfaces. Create a socket per interface and
* bind to only these.
*/
/* Now open a listen socket for each of the interfaces. */
for(i = 0; i < num_ifs; i++) {
const struct sockaddr_storage *ifss =
iface_n_sockaddr_storage(i);
p = setup_dcerpc_ncacn_tcpip_socket(ev_ctx,
msg_ctx,
syntax_id,
ifss,
port);
if (p == 0) {
return 0;
}
port = p;
}
} else {
const char *sock_addr = lp_socket_address();
const char *sock_ptr;
char *sock_tok;
for (sock_ptr = sock_addr;
next_token_talloc(talloc_tos(), &sock_ptr, &sock_tok, " \t,");
) {
struct sockaddr_storage ss;
/* open an incoming socket */
if (!interpret_string_addr(&ss,
sock_tok,
AI_NUMERICHOST|AI_PASSIVE)) {
continue;
}
p = setup_dcerpc_ncacn_tcpip_socket(ev_ctx,
msg_ctx,
syntax_id,
&ss,
port);
if (p == 0) {
return 0;
}
port = p;
}
}
return p;
}
static NTSTATUS _rpc_ep_register(struct tevent_context *ev_ctx,
struct messaging_context *msg_ctx,
const struct ndr_interface_table *iface,
@ -117,6 +181,23 @@ static NTSTATUS _rpc_ep_unregister(const struct ndr_interface_table *iface)
return status;
}
static bool epmapper_init_cb(void *ptr)
{
struct dcesrv_ep_context *ep_ctx =
talloc_get_type_abort(ptr, struct dcesrv_ep_context);
uint16_t port;
port = _open_sockets(ep_ctx->ev_ctx,
ep_ctx->msg_ctx,
ndr_table_epmapper.syntax_id,
135);
if (port == 135) {
return true;
}
return false;
}
static bool winreg_init_cb(void *ptr)
{
struct dcesrv_ep_context *ep_ctx =
@ -392,6 +473,8 @@ bool dcesrv_ep_setup(struct tevent_context *ev_ctx,
{
struct dcesrv_ep_context *ep_ctx;
struct rpc_srv_callbacks epmapper_cb;
struct rpc_srv_callbacks winreg_cb;
struct rpc_srv_callbacks srvsvc_cb;
@ -426,7 +509,11 @@ bool dcesrv_ep_setup(struct tevent_context *ev_ctx,
"rpc_server", "epmapper",
"none");
if (StrCaseCmp(rpcsrv_type, "embedded") == 0) {
if (!NT_STATUS_IS_OK(rpc_epmapper_init(NULL))) {
epmapper_cb.init = epmapper_init_cb;
epmapper_cb.shutdown = NULL;
epmapper_cb.private_data = ep_ctx;
if (!NT_STATUS_IS_OK(rpc_epmapper_init(&epmapper_cb))) {
return false;
}
}