diff options
author | joe <joe@jerkface.net> | 2017-07-23 18:24:08 -0400 |
---|---|---|
committer | joe <joe@jerkface.net> | 2017-07-23 18:24:08 -0400 |
commit | cced8596d2fe2b35e373853382551756281d4602 (patch) | |
tree | 9893ce4cc5ad73c52c6c613cebfd1b2e075738f4 /Mainline.hs | |
parent | 77f6b96492223e7d7b147dac8d026e0b6f6a651b (diff) |
Rewrite: new bootstrap function.
Diffstat (limited to 'Mainline.hs')
-rw-r--r-- | Mainline.hs | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/Mainline.hs b/Mainline.hs index 1e30b718..fdb77b4d 100644 --- a/Mainline.hs +++ b/Mainline.hs | |||
@@ -308,8 +308,14 @@ newClient addr = do | |||
308 | sched6 <- newTVar Int.empty | 308 | sched6 <- newTVar Int.empty |
309 | return $ Routing tenative_info sched4 tbl4 committee4 sched6 tbl6 committee6 | 309 | return $ Routing tenative_info sched4 tbl4 committee4 sched6 tbl6 committee6 |
310 | -- TODO: Provide some means of shutting down these two auxillary threads: | 310 | -- TODO: Provide some means of shutting down these two auxillary threads: |
311 | refresh_thread4 <- pollForRefresh (15*60) (sched4 routing) (refreshBucket nodeSearch (routing4 routing) (nodeId tenative_info)) | 311 | refresh_thread4 <- forkPollForRefresh |
312 | refresh_thread6 <- pollForRefresh (15*60) (sched6 routing) (refreshBucket nodeSearch (routing6 routing) (nodeId tenative_info)) | 312 | (15*60) |
313 | (sched4 routing) | ||
314 | (refreshBucket nodeSearch (routing4 routing) (nodeId tenative_info)) | ||
315 | refresh_thread6 <- forkPollForRefresh | ||
316 | (15*60) | ||
317 | (sched6 routing) | ||
318 | (refreshBucket nodeSearch (routing6 routing) (nodeId tenative_info)) | ||
313 | swarms <- newSwarmsDatabase | 319 | swarms <- newSwarmsDatabase |
314 | map_var <- atomically $ newTVar (0, mempty) | 320 | map_var <- atomically $ newTVar (0, mempty) |
315 | let net = onInbound (updateRouting outgoingClient routing) | 321 | let net = onInbound (updateRouting outgoingClient routing) |