// Just enqueue the message
myMessageQueue.enqueue(message);
}
else {
jpvmSendConnection conn = getConnection(tid);
message.send(conn);
}
}
public synchronized void pvm_barrier(String host, int tag, int num) throws jpvmException,Exception {
Socket sock = new Socket(host,11111);