replication: use fibers coio in SUBCRIBE/JOIN
Rewrite replication to use cooperative I/O. Propagate replication exceptions to the main thread. Introduce a function which stats a thread with a running event machine in it.
Showing
- src/box/recovery.cc 6 additions, 4 deletionssrc/box/recovery.cc
- src/box/recovery.h 1 addition, 14 deletionssrc/box/recovery.h
- src/box/replica.cc 0 additions, 3 deletionssrc/box/replica.cc
- src/box/replication.cc 66 additions, 85 deletionssrc/box/replication.cc
- src/fiber.cc 66 additions, 2 deletionssrc/fiber.cc
- src/fiber.h 11 additions, 1 deletionsrc/fiber.h
Loading
Please register or sign in to comment