char *app_id;
static const int MAX_MESSAGE_SIZE = 16 * 1024;
+static pthread_mutex_t _message_port_mutex = PTHREAD_MUTEX_INITIALIZER;
int write_socket(int fd,
const char *buffer,
return md5_interface;
}
+
+void message_port_lock_mutex()
+{
+ pthread_mutex_lock(&_message_port_mutex);
+}
+
+void message_port_unlock_mutex()
+{
+ pthread_mutex_unlock(&_message_port_mutex);
+}