diff options
author | Josh Blum | 2013-07-15 23:51:59 -0700 |
---|---|---|
committer | Josh Blum | 2013-07-15 23:51:59 -0700 |
commit | 6d07c50dafbe38049dbede7241e9e66eea0a699e (patch) | |
tree | 444d46efa7526a6ca0bebb4be95f878fc4f13d50 /lib/top_block.cpp | |
parent | 6f9ab7732da5731ee0db59d9623111b7af9b2e94 (diff) | |
download | sandhi-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.cpp | 14 |
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()); } } |