]> AND Private Git Repository - loba.git/commit
Logo AND Algorithmique Numérique Distribuée

Private GIT Repository
Use a separate thread to handle incoming messages.
authorArnaud Giersch <arnaud.giersch@iut-bm.univ-fcomte.fr>
Thu, 6 Jan 2011 15:59:57 +0000 (16:59 +0100)
committerArnaud Giersch <arnaud.giersch@iut-bm.univ-fcomte.fr>
Thu, 6 Jan 2011 15:59:57 +0000 (16:59 +0100)
commitafd307b9711af19f9053bad1aec0b8e60c3ea467
tree85ef0030572cb4929dc6c071426d39f3ff06f4ec
parent3969d4ebdc78d21108c2d9e38875d5717eb36f53
Use a separate thread to handle incoming messages.

Incoming messages were taken into account very late,
because of the following scheme:

  ...
* do something (compute, load-balance, ...)
  ...
* receive some message
* create a new asynchronous receive communication

Here, we cannot have received any new message, even
if the sender was ready a long time ago, since the
transfer only started when we created the new communication.
Thus, we start a new iteration.

The solution is to implement a separate thread to handle incoming
messages asynchronously.  Those messages are put in a queue to be
consumed later.
communicator.cpp
communicator.h
process.cpp