summaryrefslogtreecommitdiff
path: root/lib/top_block.cpp
diff options
context:
space:
mode:
authorJosh Blum2013-07-15 23:51:59 -0700
committerJosh Blum2013-07-15 23:51:59 -0700
commit6d07c50dafbe38049dbede7241e9e66eea0a699e (patch)
tree444d46efa7526a6ca0bebb4be95f878fc4f13d50 /lib/top_block.cpp
parent6f9ab7732da5731ee0db59d9623111b7af9b2e94 (diff)
downloadsandhi-6d07c50dafbe38049dbede7241e9e66eea0a699e.tar.gz
sandhi-6d07c50dafbe38049dbede7241e9e66eea0a699e.tar.bz2
sandhi-6d07c50dafbe38049dbede7241e9e66eea0a699e.zip
gras: make all start/commit messages high-prio
This makes doing live topology changes w/ commit instant, even if much buffering is backed up.
Diffstat (limited to 'lib/top_block.cpp')
-rw-r--r--lib/top_block.cpp14
1 files changed, 9 insertions, 5 deletions
diff --git a/lib/top_block.cpp b/lib/top_block.cpp
index 74d9523..0c8572d 100644
--- a/lib/top_block.cpp
+++ b/lib/top_block.cpp
@@ -50,22 +50,26 @@ void TopBlock::start(void)
{
(*this)->executor->commit();
{
- (*this)->executor->post_all((*this)->thread_group);
+ TopThreadMessage message;
+ message.thread_group = (*this)->thread_group;
+ (*this)->bcast_prio_msg(message);
}
{
TopTokenMessage message;
message.token = (*this)->token;
- (*this)->executor->post_all(message);
+ (*this)->bcast_prio_msg(message);
}
{
//send the global block config before alloc
- (*this)->executor->post_all((*this)->top_config);
+ TopConfigMessage message;
+ message.config = (*this)->top_config;
+ (*this)->bcast_prio_msg(message);
}
{
- (*this)->executor->post_all(TopAllocMessage());
+ (*this)->bcast_prio_msg(TopAllocMessage());
}
{
- (*this)->executor->post_all(TopActiveMessage());
+ (*this)->bcast_prio_msg(TopActiveMessage());
}
}