Make main thread killable so that it can be canceled at any time.
Refine comment of makeThreadKillable(). This commit can be backported to 5.0, only if we also backport cf8a6e3. Co-authored-by: Oran Agra <oran@redislabs.com>
This commit is contained in:
parent
0bc59b46aa
commit
d229162730
@ -168,10 +168,7 @@ void *bioProcessBackgroundJobs(void *arg) {
|
|||||||
|
|
||||||
redisSetCpuAffinity(server.bio_cpulist);
|
redisSetCpuAffinity(server.bio_cpulist);
|
||||||
|
|
||||||
/* Make the thread killable at any time, so that bioKillThreads()
|
makeThreadKillable();
|
||||||
* can work reliably. */
|
|
||||||
pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
|
|
||||||
pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
|
|
||||||
|
|
||||||
pthread_mutex_lock(&bio_mutex[type]);
|
pthread_mutex_lock(&bio_mutex[type]);
|
||||||
/* Block SIGALRM so we are sure that only the main thread will
|
/* Block SIGALRM so we are sure that only the main thread will
|
||||||
|
@ -2870,12 +2870,21 @@ void resetServerStats(void) {
|
|||||||
server.blocked_last_cron = 0;
|
server.blocked_last_cron = 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/* Make the thread killable at any time, so that kill threads functions
|
||||||
|
* can work reliably (default cancelability type is PTHREAD_CANCEL_DEFERRED).
|
||||||
|
* Needed for pthread_cancel used by the fast memory test used by the crash report. */
|
||||||
|
void makeThreadKillable(void) {
|
||||||
|
pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
|
||||||
|
pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
|
||||||
|
}
|
||||||
|
|
||||||
void initServer(void) {
|
void initServer(void) {
|
||||||
int j;
|
int j;
|
||||||
|
|
||||||
signal(SIGHUP, SIG_IGN);
|
signal(SIGHUP, SIG_IGN);
|
||||||
signal(SIGPIPE, SIG_IGN);
|
signal(SIGPIPE, SIG_IGN);
|
||||||
setupSignalHandlers();
|
setupSignalHandlers();
|
||||||
|
makeThreadKillable();
|
||||||
|
|
||||||
if (server.syslog_enabled) {
|
if (server.syslog_enabled) {
|
||||||
openlog(server.syslog_ident, LOG_PID | LOG_NDELAY | LOG_NOWAIT,
|
openlog(server.syslog_ident, LOG_PID | LOG_NDELAY | LOG_NOWAIT,
|
||||||
|
@ -2492,6 +2492,7 @@ int populateCommandTableParseFlags(struct redisCommand *c, char *strflags);
|
|||||||
void debugDelay(int usec);
|
void debugDelay(int usec);
|
||||||
void killIOThreads(void);
|
void killIOThreads(void);
|
||||||
void killThreads(void);
|
void killThreads(void);
|
||||||
|
void makeThreadKillable(void);
|
||||||
|
|
||||||
/* TLS stuff */
|
/* TLS stuff */
|
||||||
void tlsInit(void);
|
void tlsInit(void);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user