[OMPI users] How to make a connection uninterruptible

[toufik hadjazi]

Hi Guys, 
I'm working on a client/server application on windows 7, where both the client 
and the server have a multithreaded architecture, more precisely, three threads 
per application, the first for receiving messages, the 2nd for analysing them 
and processing and the 3rd for sending answers. when I implemented this 
architecture, sometimes I have deadlocks, I don't know why? the code of the two 
threads that uses MPI is below, I think the problem is the the blocking callls, 
So, is there any alternatives? what I tried to do is make the whole connection 
session uninterruptible but i couldn't find a way to do it.
Receiver thread:forever {               // wait up for a new message
                emit WriteLine("waiting for connections on <" + 
QString::fromStdString(myPort) + ">\n");                MPI_Comm_accept( 
myPort, MPI_INFO_NULL, 0, MPI_COMM_WORLD, &client);                            
MPI_Recv(&message, 1, MessageType, MPI_ANY_SOURCE, MPI_ANY_TAG, client, 
&status);
                DIH.InFifo.Insert(message);    //insert the message into the 
fifo               emit WriteLine("A messaage 
"+QString::number(message.Command, 10)+" has been received from 
<"+QString::fromStdString(message.portSource)+">\n");
                //disconnect from the current client            
MPI_Barrier(client);            MPI_Comm_disconnect(&client);   }
Sender Thread:forever   {               message = DIH.OutFifo.Mov(); // to 
remove the message from the Fifo
                // send a new message           emit WriteLine("trying to 
connect to <" + QString::fromStdString(message.portDest) + ">\n");            
MPI_Comm_connect(message.portDest, MPI_INFO_NULL, 0, MPI_COMM_WORLD, &client);
                MPI_Send(&message, 1, MessageType, 0, 0, client);               
emit WriteLine("A messaage "+QString::number(message.Command, 10)+" has been 
sent to <"+QString::fromStdString(message.portDest)+">\n");
                //disconnect from the current client            
MPI_Barrier(client);            MPI_Comm_disconnect(&client);   }