Refactor replica.cc code to support multiple instances
* Implement explicit API to create/start/stop/destroy remote clients * Merge re-connect loop && fiber code for JOIN and SUBSCRIBE * Re-use connection between JOIN and SUBSCRIBE * Split SUBSCRIBE code from pull_from_replica() * Improve logging and unify 'warning_said' logic * Fix fiber_cancel() on a replica fiber * Move the single instance of struct replica to cluster.h * Remove dependency on replica.h(cc) from recovery.h(cc) * Use enum replica_state for states instead of const char *
Showing
- src/box/box.cc 52 additions, 30 deletionssrc/box/box.cc
- src/box/cluster.cc 3 additions, 0 deletionssrc/box/cluster.cc
- src/box/cluster.h 2 additions, 0 deletionssrc/box/cluster.h
- src/box/lua/info.cc 17 additions, 4 deletionssrc/box/lua/info.cc
- src/box/recovery.cc 2 additions, 3 deletionssrc/box/recovery.cc
- src/box/recovery.h 0 additions, 2 deletionssrc/box/recovery.h
- src/box/relay.cc 1 addition, 2 deletionssrc/box/relay.cc
- src/box/replica.cc 185 additions, 137 deletionssrc/box/replica.cc
- src/box/replica.h 54 additions, 14 deletionssrc/box/replica.h
- src/coio.cc 3 additions, 4 deletionssrc/coio.cc
- src/coio.h 1 addition, 1 deletionsrc/coio.h
- test/replication/conflict.test.py 5 additions, 5 deletionstest/replication/conflict.test.py
Loading
Please register or sign in to comment