#include <mock_geo_global_executor.h>
Public Member Functions | |
| MockGeoGlobalExecutor (std::unique_ptr< TransactionExecutorImpl > global_transaction_manager, const ResDBConfig &config) | |
| MOCK_METHOD (void, Execute,(std::unique_ptr< Request >),(override)) | |
| ~MockGeoGlobalExecutor () | |
Public Member Functions inherited from resdb::GeoGlobalExecutor | |
| GeoGlobalExecutor (std::unique_ptr< TransactionManager > global_transaction_manager, const ResDBConfig &config) | |
| virtual | ~GeoGlobalExecutor () |
| virtual void | Execute (std::unique_ptr< Request > request) |
| virtual int | OrderGeoRequest (std::unique_ptr< Request > request) |
| void | Stop () |
| std::unique_ptr< BatchUserResponse > | GetResponseMsg () |
Additional Inherited Members | |
Protected Attributes inherited from resdb::GeoGlobalExecutor | |
| std::unique_ptr< TransactionManager > | global_transaction_manager_ |
| Stats * | global_stats_ |
| std::thread | execute_round_thread_ |
| std::thread | order_thread_ |
| ExecuteMap | execute_map_ |
| uint64_t | next_seq_ = 1 |
| int | next_region_ = 1 |
| size_t | region_size_ |
| ResDBConfig | config_ |
| std::atomic< bool > | is_stop_ |
| std::mutex | mutex_ |
| std::condition_variable | cv_ |
| LockFreeQueue< Request > | order_queue_ |
| LockFreeQueue< BatchUserResponse > | resp_queue_ |
| int | my_region_ |
Definition at line 27 of file mock_geo_global_executor.h.
|
inline |
Definition at line 29 of file mock_geo_global_executor.h.
|
inline |
Definition at line 34 of file mock_geo_global_executor.h.
| resdb::MockGeoGlobalExecutor::MOCK_METHOD | ( | void | , |
| Execute | , | ||
| (std::unique_ptr< Request >) | , | ||
| (override) | |||
| ) |