|
 |
b69e47 |
From a00917eec0bcef75180eaf4dd9b360519b9e2644 Mon Sep 17 00:00:00 2001
|
|
|
b69e47 |
From: Mark Reynolds <mreynolds@redhat.com>
|
|
|
b69e47 |
Date: Tue, 14 Mar 2017 14:35:05 -0400
|
|
|
b69e47 |
Subject: [PATCH 2/5] Issue 49170 - sync plugin thread count not handled
|
|
|
b69e47 |
correctly
|
|
|
b69e47 |
|
|
|
b69e47 |
Bug Description: If sync repl connections get aborted the thread_count is
|
|
|
b69e47 |
not properly updated which leads to the server hanging
|
|
|
b69e47 |
on shutdown.
|
|
|
b69e47 |
|
|
|
b69e47 |
Fix Description: When connections get aborted we still need to shutdown
|
|
|
b69e47 |
the result thread cleanly: remove the req, update thread
|
|
|
b69e47 |
count, etc.
|
|
|
b69e47 |
|
|
|
b69e47 |
https://pagure.io/389-ds-base/issue/49170
|
|
|
b69e47 |
|
|
|
b69e47 |
Reviewed by: nhosoi(Thanks!)
|
|
|
b69e47 |
|
|
|
b69e47 |
(cherry picked from commit 770fcf4349ccf9e07ff0e1cf0d6991927ec9ba75)
|
|
|
b69e47 |
---
|
|
|
b69e47 |
ldap/servers/plugins/sync/sync_persist.c | 17 ++++++++---------
|
|
|
b69e47 |
1 file changed, 8 insertions(+), 9 deletions(-)
|
|
|
b69e47 |
|
|
|
b69e47 |
diff --git a/ldap/servers/plugins/sync/sync_persist.c b/ldap/servers/plugins/sync/sync_persist.c
|
|
|
b69e47 |
index d0c8da2..667a529 100644
|
|
|
b69e47 |
--- a/ldap/servers/plugins/sync/sync_persist.c
|
|
|
b69e47 |
+++ b/ldap/servers/plugins/sync/sync_persist.c
|
|
|
b69e47 |
@@ -548,16 +548,16 @@ sync_send_results( void *arg )
|
|
|
b69e47 |
slapi_pblock_get(req->req_pblock, SLAPI_CONNECTION, &conn;;
|
|
|
b69e47 |
if (NULL == conn) {
|
|
|
b69e47 |
slapi_log_err(SLAPI_LOG_ERR, SYNC_PLUGIN_SUBSYSTEM,
|
|
|
b69e47 |
- "sync_send_results - conn=%" NSPRIu64 " op=%d Null connection - aborted\n",
|
|
|
b69e47 |
- connid, opid);
|
|
|
b69e47 |
- return;
|
|
|
b69e47 |
+ "sync_send_results - conn=%" NSPRIu64 " op=%d Null connection - aborted\n",
|
|
|
b69e47 |
+ connid, opid);
|
|
|
b69e47 |
+ goto done;
|
|
|
b69e47 |
}
|
|
|
b69e47 |
conn_acq_flag = sync_acquire_connection (conn);
|
|
|
b69e47 |
if (conn_acq_flag) {
|
|
|
b69e47 |
slapi_log_err(SLAPI_LOG_ERR, SYNC_PLUGIN_SUBSYSTEM,
|
|
|
b69e47 |
- "sync_send_results - conn=%" NSPRIu64 " op=%d Could not acquire the connection - aborted\n",
|
|
|
b69e47 |
- connid, opid);
|
|
|
b69e47 |
- return;
|
|
|
b69e47 |
+ "sync_send_results - conn=%" NSPRIu64 " op=%d Could not acquire the connection - aborted\n",
|
|
|
b69e47 |
+ connid, opid);
|
|
|
b69e47 |
+ goto done;
|
|
|
b69e47 |
}
|
|
|
b69e47 |
|
|
|
b69e47 |
PR_Lock( sync_request_list->sync_req_cvarlock );
|
|
|
b69e47 |
@@ -658,15 +658,14 @@ sync_send_results( void *arg )
|
|
|
b69e47 |
}
|
|
|
b69e47 |
}
|
|
|
b69e47 |
PR_Unlock( sync_request_list->sync_req_cvarlock );
|
|
|
b69e47 |
- sync_remove_request( req );
|
|
|
b69e47 |
|
|
|
b69e47 |
/* indicate the end of search */
|
|
|
b69e47 |
-
|
|
|
b69e47 |
sync_release_connection(req->req_pblock, conn, op, conn_acq_flag == 0);
|
|
|
b69e47 |
|
|
|
b69e47 |
+done:
|
|
|
b69e47 |
+ sync_remove_request( req );
|
|
|
b69e47 |
PR_DestroyLock ( req->req_lock );
|
|
|
b69e47 |
req->req_lock = NULL;
|
|
|
b69e47 |
-
|
|
|
b69e47 |
slapi_ch_free((void **) &req->req_pblock );
|
|
|
b69e47 |
slapi_ch_free((void **) &req->req_orig_base );
|
|
|
b69e47 |
slapi_filter_free(req->req_filter, 1);
|
|
|
b69e47 |
--
|
|
|
b69e47 |
2.9.3
|
|
|
b69e47 |
|