Initialize rsocket in critical section

knizhnik · knizhnik · commit 10e71c96322b · 2018-05-24T16:58:55.000+03:00
diff --git a/src/common/pg_rsocket.c b/src/common/pg_rsocket.c
@@ -101,12 +101,12 @@ static pthread_mutex_t rsocket_init_mutex = PTHREAD_MUTEX_INITIALIZER;
 void
 initialize_rsocket(void)
 {
-	pthread_mutex_lock(rsocket_init_mutex);
+	pthread_mutex_lock(&rsocket_init_mutex);
 
 	/* librdmacm was loaded already */
 	if (rdmacm_handle != NULL)
 	{
-		pthread_mutex_unlock(rsocket_init_mutex);
+		pthread_mutex_unlock(&rsocket_init_mutex);
 		return;
 	}
 
@@ -169,7 +169,7 @@ initialize_rsocket(void)
 	rcalls->fcntl = get_function("rfcntl");
 #endif
 
-	pthread_mutex_unlock(rsocket_init_mutex);
+	pthread_mutex_unlock(&rsocket_init_mutex);
 }
 
 #endif   /* WITH_RSOCKET */

Original file line number	Diff line number	Diff line change
`@@ -101,12 +101,12 @@ static pthread_mutex_t rsocket_init_mutex = PTHREAD_MUTEX_INITIALIZER;`
`101`	`101`	`void`
`102`	`102`	`initialize_rsocket(void)`
`103`	`103`	`{`
`104`		`- pthread_mutex_lock(rsocket_init_mutex);`
	`104`	`+ pthread_mutex_lock(&rsocket_init_mutex);`
`105`	`105`
`106`	`106`	`/* librdmacm was loaded already */`
`107`	`107`	`if (rdmacm_handle != NULL)`
`108`	`108`	`{`
`109`		`- pthread_mutex_unlock(rsocket_init_mutex);`
	`109`	`+ pthread_mutex_unlock(&rsocket_init_mutex);`
`110`	`110`	`return;`
`111`	`111`	`}`
`112`	`112`
`@@ -169,7 +169,7 @@ initialize_rsocket(void)`
`169`	`169`	`rcalls->fcntl = get_function("rfcntl");`
`170`	`170`	`#endif`
`171`	`171`
`172`		`- pthread_mutex_unlock(rsocket_init_mutex);`
	`172`	`+ pthread_mutex_unlock(&rsocket_init_mutex);`
`173`	`173`	`}`
`174`	`174`
`175`	`175`	`#endif /* WITH_RSOCKET */`