summaryrefslogtreecommitdiff
path: root/source4/smbd
diff options
context:
space:
mode:
Diffstat (limited to 'source4/smbd')
-rw-r--r--source4/smbd/process_single.c7
-rw-r--r--source4/smbd/process_standard.c9
-rw-r--r--source4/smbd/process_thread.c10
3 files changed, 26 insertions, 0 deletions
diff --git a/source4/smbd/process_single.c b/source4/smbd/process_single.c
index a19577b3cf..8f1362bed3 100644
--- a/source4/smbd/process_single.c
+++ b/source4/smbd/process_single.c
@@ -81,6 +81,12 @@ static void terminate_connection(struct server_context *server, const char *reas
server_terminate(server);
}
+/* called when a rpc connection goes down */
+static void terminate_rpc_connection(void *r, const char *reason)
+{
+ rpc_server_terminate(r);
+}
+
static int get_id(struct request_context *req)
{
return (int)req->smb->pid;
@@ -100,6 +106,7 @@ void process_model_single_init(void)
ops.accept_connection = accept_connection;
ops.accept_rpc_connection = accept_rpc_connection;
ops.terminate_connection = terminate_connection;
+ ops.terminate_rpc_connection = terminate_rpc_connection;
ops.exit_server = NULL;
ops.get_id = get_id;
diff --git a/source4/smbd/process_standard.c b/source4/smbd/process_standard.c
index 507c179a26..505c2aafbf 100644
--- a/source4/smbd/process_standard.c
+++ b/source4/smbd/process_standard.c
@@ -121,6 +121,14 @@ static void terminate_connection(struct server_context *server, const char *reas
exit(0);
}
+/* called when a rpc connection goes down */
+static void terminate_rpc_connection(void *r, const char *reason)
+{
+ rpc_server_terminate(r);
+ /* terminate this process */
+ exit(0);
+}
+
static int get_id(struct request_context *req)
{
return (int)req->smb->pid;
@@ -140,6 +148,7 @@ void process_model_standard_init(void)
ops.accept_connection = accept_connection;
ops.accept_rpc_connection = accept_rpc_connection;
ops.terminate_connection = terminate_connection;
+ ops.terminate_rpc_connection = terminate_rpc_connection;
ops.get_id = get_id;
/* register ourselves with the process model subsystem. We register under the name 'standard'. */
diff --git a/source4/smbd/process_thread.c b/source4/smbd/process_thread.c
index 634e826395..d02238c840 100644
--- a/source4/smbd/process_thread.c
+++ b/source4/smbd/process_thread.c
@@ -134,6 +134,15 @@ static void terminate_connection(struct server_context *server, const char *reas
pthread_exit(NULL); /* thread cleanup routine will do actual cleanup */
}
+/* called when a rpc connection goes down */
+static void terminate_rpc_connection(void *r, const char *reason)
+{
+ rpc_server_terminate(r);
+
+ /* terminate this thread */
+ pthread_exit(NULL); /* thread cleanup routine will do actual cleanup */
+}
+
/*
mutex init function for thread model
*/
@@ -457,6 +466,7 @@ void process_model_thread_init(void)
ops.accept_connection = accept_connection;
ops.accept_rpc_connection = accept_rpc_connection;
ops.terminate_connection = terminate_connection;
+ ops.terminate_rpc_connection = terminate_rpc_connection;
ops.exit_server = NULL;
ops.get_id = get_id;