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

Private GIT Repository
Improve documentation, move open questions in QUESTIONS file.
[loba.git] / NOTES
1 Process parameters
2 ==================
3
4 The process parameters are: initial_load [neighbors...]
5
6 Communications
7 ==============
8
9 There are two receiving channels per host: control for information
10 messages, and data for load transfers.
11
12 Process model
13 =============
14
15 Each process is made of 3 threads: a receiver thread, a computing
16 thread, and a load-balancer thread.
17
18 * Receiver thread
19   ---------------
20
21     Loop
22     | wait for a message to come, either on data channel, or on ctrl channel
23     | push received message in a buffer of received messages
24     | -> ctrl messages on the one side
25     | -> data messages on the other side
26     +-
27
28    The loop terminates when a "finalize" message is received on each
29    channel.
30
31 * Computing thread
32   ----------------
33
34     Loop
35     | if we received some real load, get it (data messages)
36     | if there is some real load to send, send it
37     | if we own some load, simulate some computing on it
38     | sleep a bit if we are looping too fast
39     +-
40     send CLOSE on data for all neighbors
41     wait for CLOSE on data from all neighbors
42
43   The loop terminates when process::still_running() returns false.
44   (read the source for full details...)
45
46 * Load-balancing thread
47   ---------------------
48
49     Loop
50     | call load-balancing algorithm
51     | send ctrl messages
52     | sleep (min_lb_iter_duration)
53     | receive ctrl messages
54     +-
55     send CLOSE on ctrl for all neighbors
56     wait for CLOSE on ctrl from all neighbors
57
58   The loop terminates when process::still_running() returns false.
59   (read the source for full details...)