cbus: code review for dynamic cbus routing
* move cbus declaration to cbus.c, since going forward it's a private singleton * rename cbus_item to cbus_endpoint. It represents the state of a single cord in the cbus (but in the future, a single cord may have more than one endpoint. * move declaration of cbus_endpoint to cbus.c * factor out cbus_find_endpoint() * add/update comments * move cbus_init()/cbus_free() to main.cc * replace pthread_cond_signal() with pthread_cond_broadcast(), since in theory there can be many waiters on an endpoint to join.
Showing
- src/box/box.cc 1 addition, 4 deletionssrc/box/box.cc
- src/box/iproto.cc 5 additions, 2 deletionssrc/box/iproto.cc
- src/box/wal.cc 4 additions, 2 deletionssrc/box/wal.cc
- src/cbus.c 88 additions, 39 deletionssrc/cbus.c
- src/cbus.h 18 additions, 40 deletionssrc/cbus.h
- src/main.cc 3 additions, 0 deletionssrc/main.cc
- src/tt_pthread.h 6 additions, 0 deletionssrc/tt_pthread.h
Loading
Please register or sign in to comment