Initialize rsocket in critical section

Author: knizhnik

src/common/pg_rsocket.c

@@ -20,6 +20,8 @@
 
 #ifdef WITH_RSOCKET
 
+#include <pthread.h>
+
 /*
  * Copy of defines from dynloader.h
  */
@@ -91,15 +93,22 @@ get_function(const char *name)
 	return func;
 }
 
+static pthread_mutex_t rsocket_init_mutex = PTHREAD_MUTEX_INITIALIZER;
+
 /*
  * Loads librdmacm and loads pointers to rsocket functions
  */
 void
 initialize_rsocket(void)
 {
+	pthread_mutex_lock(rsocket_init_mutex);
+
 	/* librdmacm was loaded already */
 	if (rdmacm_handle != NULL)
+	{
+		pthread_mutex_unlock(rsocket_init_mutex);
 		return;
+	}
 
 	rdmacm_handle = pg_dlopen(RDMACM_NAME);
 	if (rdmacm_handle == NULL)
@@ -159,6 +168,8 @@ initialize_rsocket(void)
 #if !defined(WIN32)
 	rcalls->fcntl = get_function("rfcntl");
 #endif
+
+	pthread_mutex_unlock(rsocket_init_mutex);
 }
 
 #endif   /* WITH_RSOCKET */