}
}
- msg_ctx = server_messaging_context();
+ msg_ctx = global_messaging_context();
if (msg_ctx == NULL) {
return NULL;
}
/* The following definitions come from lib/server_contexts.c */
struct tevent_context *global_event_context(void);
void global_event_context_free(void);
-struct messaging_context *server_messaging_context(void);
-void server_messaging_context_free(void);
+struct messaging_context *global_messaging_context(void);
+void global_messaging_context_free(void);
/* The following definitions come from lib/sessionid_tdb.c */
struct sessionid;
exit(1);
}
- msg_ctx = server_messaging_context();
+ msg_ctx = global_messaging_context();
if (msg_ctx == NULL) {
if (geteuid() == 0) {
fprintf(stderr,
void cmdline_messaging_context_free(void)
{
- server_messaging_context_free();
+ global_messaging_context_free();
}
errno = EIO;
return NULL;
}
- msg_ctx = server_messaging_context();
+ msg_ctx = global_messaging_context();
result = db_open_ctdb(mem_ctx, msg_ctx, base,
hash_size,
static struct messaging_context *server_msg_ctx = NULL;
-struct messaging_context *server_messaging_context(void)
+struct messaging_context *global_messaging_context(void)
{
if (server_msg_ctx == NULL) {
/*
return server_msg_ctx;
}
-void server_messaging_context_free(void)
+void global_messaging_context_free(void)
{
TALLOC_FREE(server_msg_ctx);
}
return False;
}
- lock_db = db_open_watched(NULL, &backend, server_messaging_context());
+ lock_db = db_open_watched(NULL, &backend, global_messaging_context());
if (lock_db == NULL) {
DBG_ERR("db_open_watched failed\n");
TALLOC_FREE(backend);
* just return */
return status;
}
- messaging_send_all(server_messaging_context(),
+ messaging_send_all(global_messaging_context(),
ID_CACHE_DELETE,
msg_data,
strlen(msg_data) + 1);
driver_directory);
}
- nt_status = create_conn_struct_tos_cwd(server_messaging_context(),
+ nt_status = create_conn_struct_tos_cwd(global_messaging_context(),
printdollar_snum,
working_dir,
session_info,
return WERR_BAD_NET_NAME;
}
- nt_status = create_conn_struct_tos_cwd(server_messaging_context(),
+ nt_status = create_conn_struct_tos_cwd(global_messaging_context(),
printdollar_snum,
lp_path(frame, printdollar_snum),
session_info,
return false;
}
- nt_status = create_conn_struct_tos_cwd(server_messaging_context(),
+ nt_status = create_conn_struct_tos_cwd(global_messaging_context(),
printdollar_snum,
lp_path(frame, printdollar_snum),
session_info,
{
NTSTATUS status;
struct rpc_srv_callbacks spoolss_cb;
- struct messaging_context *msg_ctx = server_messaging_context();
+ struct messaging_context *msg_ctx = global_messaging_context();
bool ok;
status = reinit_after_fork(msg_ctx, ev_ctx, true, "spoolssd-child");
struct pf_worker_data *pf)
{
NTSTATUS status;
- struct messaging_context *msg_ctx = server_messaging_context();
+ struct messaging_context *msg_ctx = global_messaging_context();
bool ok;
status = reinit_after_fork(msg_ctx, ev_ctx,
struct pf_worker_data *pf)
{
NTSTATUS status;
- struct messaging_context *msg_ctx = server_messaging_context();
+ struct messaging_context *msg_ctx = global_messaging_context();
bool ok;
status = reinit_after_fork(msg_ctx, ev_ctx,
goto error_exit;
}
- nt_status = create_conn_struct_tos_cwd(server_messaging_context(),
+ nt_status = create_conn_struct_tos_cwd(global_messaging_context(),
snum,
lp_path(frame, snum),
p->session_info,
goto error_exit;
}
- nt_status = create_conn_struct_tos_cwd(server_messaging_context(),
+ nt_status = create_conn_struct_tos_cwd(global_messaging_context(),
snum,
lp_path(frame, snum),
p->session_info,
return NT_STATUS_OK;
}
- status = create_conn_struct_tos_cwd(server_messaging_context(),
+ status = create_conn_struct_tos_cwd(global_messaging_context(),
snum,
lp_path(frame, snum),
NULL,
if(snum < 0) {
return False;
}
- status = create_conn_struct_tos_cwd(server_messaging_context(),
+ status = create_conn_struct_tos_cwd(global_messaging_context(),
snum,
lp_path(talloc_tos(), snum),
NULL,
* Fake up a connection struct for the VFS layer.
*/
- status = create_conn_struct_tos_cwd(server_messaging_context(),
+ status = create_conn_struct_tos_cwd(global_messaging_context(),
snum,
connect_path,
NULL,
* Fake up a connection struct for the VFS layer.
*/
- status = create_conn_struct_tos_cwd(server_messaging_context(),
+ status = create_conn_struct_tos_cwd(global_messaging_context(),
snum,
connect_path,
NULL,
return NT_STATUS_NO_MEMORY;
}
- status = create_conn_struct_tos(server_messaging_context(),
+ status = create_conn_struct_tos(global_messaging_context(),
-1,
"/",
NULL,
* Init the messaging context
* FIXME: This should only call messaging_init()
*/
- msg_ctx = server_messaging_context();
+ msg_ctx = global_messaging_context();
if (msg_ctx == NULL) {
exit(1);
}
struct smbXsrv_connection *xconn = NULL;
struct smbXsrv_connection *xconn_next = NULL;
struct smbd_server_connection *sconn = NULL;
- struct messaging_context *msg_ctx = server_messaging_context();
+ struct messaging_context *msg_ctx = global_messaging_context();
if (client != NULL) {
sconn = client->sconn;
netlogon_creds_cli_close_global_db();
TALLOC_FREE(global_smbXsrv_client);
smbprofile_dump();
- server_messaging_context_free();
+ global_messaging_context_free();
global_event_context_free();
TALLOC_FREE(smbd_memcache_ctx);
return status;
}
- db_ctx = db_open_watched(NULL, &backend, server_messaging_context());
+ db_ctx = db_open_watched(NULL, &backend, global_messaging_context());
if (db_ctx == NULL) {
TALLOC_FREE(backend);
return NT_STATUS_NO_MEMORY;
uint32_t val;
struct messaging_context *msg_ctx;
- msg_ctx = server_messaging_context();
+ msg_ctx = global_messaging_context();
db = db_open_ctdb(talloc_tos(), msg_ctx, "torture.tdb",
0, TDB_DEFAULT,
fprintf(stderr, "global_event_context() failed\n");
return false;
}
- msg = server_messaging_context();
+ msg = global_messaging_context();
if (msg == NULL) {
- fprintf(stderr, "server_messaging_context() failed\n");
+ fprintf(stderr, "global_messaging_context() failed\n");
return false;
}
fprintf(stderr, "tevent_context_init failed\n");
return false;
}
- *msg = server_messaging_context();
+ *msg = global_messaging_context();
if (*msg == NULL) {
fprintf(stderr, "messaging_init failed\n");
TALLOC_FREE(*ev);
return 1;
}
- status = create_conn_struct_tos(server_messaging_context(),
+ status = create_conn_struct_tos(global_messaging_context(),
-1,
getcwd(cwd, sizeof(cwd)),
session_info,
return msg;
}
- msg_ctx = server_messaging_context();
+ msg_ctx = global_messaging_context();
if (msg_ctx == NULL) {
- smb_panic("server_messaging_context failed\n");
+ smb_panic("global_messaging_context failed\n");
}
myself = messaging_server_id(msg_ctx);
MSG_WINBIND_ONLINESTATUS, winbind_msg_onlinestatus);
/* Handle domain online/offline messages for domains */
- messaging_register(server_messaging_context(), NULL,
+ messaging_register(global_messaging_context(), NULL,
MSG_WINBIND_DOMAIN_OFFLINE, winbind_msg_domain_offline);
- messaging_register(server_messaging_context(), NULL,
+ messaging_register(global_messaging_context(), NULL,
MSG_WINBIND_DOMAIN_ONLINE, winbind_msg_domain_online);
messaging_register(msg_ctx, NULL,
/* Initialise messaging system */
- if (server_messaging_context() == NULL) {
+ if (global_messaging_context() == NULL) {
exit(1);
}
* winbindd-specific resources we must free yet. JRA.
*/
- status = reinit_after_fork(server_messaging_context(),
+ status = reinit_after_fork(global_messaging_context(),
global_event_context(),
false, NULL);
if (!NT_STATUS_IS_OK(status)) {
exit_daemon(nt_errstr(status), map_errno_from_nt_status(status));
}
- winbindd_register_handlers(server_messaging_context(), !Fork);
+ winbindd_register_handlers(global_messaging_context(), !Fork);
- if (!messaging_parent_dgm_cleanup_init(server_messaging_context())) {
+ if (!messaging_parent_dgm_cleanup_init(global_messaging_context())) {
exit(1);
}
rpc_samr_init(NULL);
winbindd_init_addrchange(NULL, global_event_context(),
- server_messaging_context());
+ global_messaging_context());
/* setup listen sockets */
if (domain->dc_probe_pid != (pid_t)0) {
/* Parent */
- messaging_register(server_messaging_context(), NULL,
+ messaging_register(global_messaging_context(), NULL,
MSG_WINBIND_TRY_TO_GO_ONLINE,
msg_try_to_go_online);
- messaging_register(server_messaging_context(), NULL,
+ messaging_register(global_messaging_context(), NULL,
MSG_WINBIND_FAILED_TO_GO_ONLINE,
msg_failed_to_go_online);
return True;
if (!NT_STATUS_IS_OK(status)) {
DEBUG(1, ("winbindd_reinit_after_fork failed: %s\n",
nt_errstr(status)));
- messaging_send_buf(server_messaging_context(),
+ messaging_send_buf(global_messaging_context(),
pid_to_procid(parent_pid),
MSG_WINBIND_FAILED_TO_GO_ONLINE,
(const uint8_t *)domain->name,
mem_ctx = talloc_init("fork_child_dc_connect");
if (!mem_ctx) {
DEBUG(0,("talloc_init failed.\n"));
- messaging_send_buf(server_messaging_context(),
+ messaging_send_buf(global_messaging_context(),
pid_to_procid(parent_pid),
MSG_WINBIND_FAILED_TO_GO_ONLINE,
(const uint8_t *)domain->name,
TALLOC_FREE(mem_ctx);
if (!ok || (num_dcs == 0)) {
/* Still offline ? Can't find DC's. */
- messaging_send_buf(server_messaging_context(),
+ messaging_send_buf(global_messaging_context(),
pid_to_procid(parent_pid),
MSG_WINBIND_FAILED_TO_GO_ONLINE,
(const uint8_t *)domain->name,
/* We got a DC. Send a message to our parent to get it to
try and do the same. */
- messaging_send_buf(server_messaging_context(),
+ messaging_send_buf(global_messaging_context(),
pid_to_procid(parent_pid),
MSG_WINBIND_TRY_TO_GO_ONLINE,
(const uint8_t *)domain->name,
/* Send a message to the parent that the domain is offline. */
if (parent_pid > 1 && !domain->internal) {
- messaging_send_buf(server_messaging_context(),
+ messaging_send_buf(global_messaging_context(),
pid_to_procid(parent_pid),
MSG_WINBIND_DOMAIN_OFFLINE,
(uint8_t *)domain->name,
struct winbindd_child *idmap = idmap_child();
if ( idmap->pid != 0 ) {
- messaging_send_buf(server_messaging_context(),
+ messaging_send_buf(global_messaging_context(),
pid_to_procid(idmap->pid),
MSG_WINBIND_OFFLINE,
(const uint8_t *)domain->name,
TALLOC_FREE(domain->check_online_event);
/* Ensure we ignore any pending child messages. */
- messaging_deregister(server_messaging_context(),
+ messaging_deregister(global_messaging_context(),
MSG_WINBIND_TRY_TO_GO_ONLINE, NULL);
- messaging_deregister(server_messaging_context(),
+ messaging_deregister(global_messaging_context(),
MSG_WINBIND_FAILED_TO_GO_ONLINE, NULL);
domain->online = True;
/* Send a message to the parent that the domain is online. */
if (parent_pid > 1 && !domain->internal) {
- messaging_send_buf(server_messaging_context(),
+ messaging_send_buf(global_messaging_context(),
pid_to_procid(parent_pid),
MSG_WINBIND_DOMAIN_ONLINE,
(uint8_t *)domain->name,
struct winbindd_child *idmap = idmap_child();
if ( idmap->pid != 0 ) {
- messaging_send_buf(server_messaging_context(),
+ messaging_send_buf(global_messaging_context(),
pid_to_procid(idmap->pid),
MSG_WINBIND_ONLINE,
(const uint8_t *)domain->name,
"%s$",
lp_netbios_name());
- status = nbt_getdc(server_messaging_context(), 10, pss,
+ status = nbt_getdc(global_messaging_context(), 10, pss,
domain->name, &domain->sid,
my_acct_name, ACB_WSTRUST,
nt_version, mem_ctx, &nt_version,
session_info,
NULL,
NULL,
- server_messaging_context(),
+ global_messaging_context(),
&cli);
} else {
status = rpc_pipe_open_internal(mem_ctx,
session_info,
NULL,
NULL,
- server_messaging_context(),
+ global_messaging_context(),
&cli);
}
if (!NT_STATUS_IS_OK(status)) {
enum dcerpc_transport_t transport,
struct rpc_pipe_client **cli)
{
- struct messaging_context *msg_ctx = server_messaging_context();
+ struct messaging_context *msg_ctx = global_messaging_context();
struct winbindd_cm_conn *conn;
NTSTATUS result;
enum netr_SchannelType sec_chan_type;
struct timeval now,
void *private_data)
{
- struct messaging_context *msg_ctx = server_messaging_context();
+ struct messaging_context *msg_ctx = global_messaging_context();
struct winbindd_child *child =
(struct winbindd_child *)private_data;
struct rpc_pipe_client *netlogon_pipe = NULL;
NTSTATUS status;
status = reinit_after_fork(
- server_messaging_context(),
+ global_messaging_context(),
global_event_context(),
true, NULL);
if (!NT_STATUS_IS_OK(status)) {
CatchChild();
/* Don't handle the same messages as our parent. */
- messaging_deregister(server_messaging_context(),
+ messaging_deregister(global_messaging_context(),
MSG_SMB_CONF_UPDATED, NULL);
- messaging_deregister(server_messaging_context(),
+ messaging_deregister(global_messaging_context(),
MSG_SHUTDOWN, NULL);
- messaging_deregister(server_messaging_context(),
+ messaging_deregister(global_messaging_context(),
MSG_WINBIND_OFFLINE, NULL);
- messaging_deregister(server_messaging_context(),
+ messaging_deregister(global_messaging_context(),
MSG_WINBIND_ONLINE, NULL);
- messaging_deregister(server_messaging_context(),
+ messaging_deregister(global_messaging_context(),
MSG_WINBIND_ONLINESTATUS, NULL);
- messaging_deregister(server_messaging_context(),
+ messaging_deregister(global_messaging_context(),
MSG_WINBIND_DUMP_DOMAIN_LIST, NULL);
- messaging_deregister(server_messaging_context(),
+ messaging_deregister(global_messaging_context(),
MSG_DEBUG, NULL);
- messaging_deregister(server_messaging_context(),
+ messaging_deregister(global_messaging_context(),
MSG_WINBIND_DOMAIN_OFFLINE, NULL);
- messaging_deregister(server_messaging_context(),
+ messaging_deregister(global_messaging_context(),
MSG_WINBIND_DOMAIN_ONLINE, NULL);
/* We have destroyed all events in the winbindd_event_context
}
/* Handle online/offline messages. */
- messaging_register(server_messaging_context(), NULL,
+ messaging_register(global_messaging_context(), NULL,
MSG_WINBIND_OFFLINE, child_msg_offline);
- messaging_register(server_messaging_context(), NULL,
+ messaging_register(global_messaging_context(), NULL,
MSG_WINBIND_ONLINE, child_msg_online);
- messaging_register(server_messaging_context(), NULL,
+ messaging_register(global_messaging_context(), NULL,
MSG_DEBUG, debug_message);
- messaging_register(server_messaging_context(), NULL,
+ messaging_register(global_messaging_context(), NULL,
MSG_WINBIND_IP_DROPPED,
winbind_msg_ip_dropped);
- messaging_register(server_messaging_context(), NULL,
+ messaging_register(global_messaging_context(), NULL,
MSG_WINBIND_DISCONNECT_DC,
winbind_msg_disconnect_dc);
bool try_dsrgetdcname = false;
if (domain == NULL) {
- return dsgetdcname(p->mem_ctx, server_messaging_context(),
+ return dsgetdcname(p->mem_ctx, global_messaging_context(),
r->in.domain_name, r->in.domain_guid,
r->in.site_name ? r->in.site_name : "",
r->in.flags,
NTSTATUS _wbint_ChangeMachineAccount(struct pipes_struct *p,
struct wbint_ChangeMachineAccount *r)
{
- struct messaging_context *msg_ctx = server_messaging_context();
+ struct messaging_context *msg_ctx = global_messaging_context();
struct winbindd_domain *domain;
NTSTATUS status;
struct rpc_pipe_client *netlogon_pipe = NULL;
struct winbindd_domain *domain,
struct winbind_LogonControl *r)
{
- struct messaging_context *msg_ctx = server_messaging_context();
+ struct messaging_context *msg_ctx = global_messaging_context();
NTSTATUS status;
struct rpc_pipe_client *netlogon_pipe = NULL;
struct netlogon_creds_cli_context *netlogon_creds_ctx = NULL;