summaryrefslogtreecommitdiff
path: root/Mainline.hs
diff options
context:
space:
mode:
authorjoe <joe@jerkface.net>2017-07-23 18:24:08 -0400
committerjoe <joe@jerkface.net>2017-07-23 18:24:08 -0400
commitcced8596d2fe2b35e373853382551756281d4602 (patch)
tree9893ce4cc5ad73c52c6c613cebfd1b2e075738f4 /Mainline.hs
parent77f6b96492223e7d7b147dac8d026e0b6f6a651b (diff)
Rewrite: new bootstrap function.
Diffstat (limited to 'Mainline.hs')
-rw-r--r--Mainline.hs10
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)