@ -122,10 +122,12 @@ static inline int __sxmsg_send(chnl_t *channel, const char *data, size_t datalen
pthread_mutex_unlock(&co->write_pending_lock);
}
//pthread_mutex_lock(&msg->wait); /* we will sleep here */
pthread_mutex_lock(&msg->wait); /* we will sleep here */
#if 0
while(pthread_mutex_trylock(&msg->wait)) {
//printf("here opcode = %d\n", head->opcode);
#endif
if(head->payload_length) {
*omsg = msg;