Loading...
Searching...
No Matches
resdb::MockGeoGlobalExecutor Class Reference

#include <mock_geo_global_executor.h>

Inheritance diagram for resdb::MockGeoGlobalExecutor:
resdb::GeoGlobalExecutor

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_
 

Detailed Description

Definition at line 27 of file mock_geo_global_executor.h.

Constructor & Destructor Documentation

◆ MockGeoGlobalExecutor()

resdb::MockGeoGlobalExecutor::MockGeoGlobalExecutor ( std::unique_ptr< TransactionExecutorImpl >  global_transaction_manager,
const ResDBConfig &  config 
)
inline

Definition at line 29 of file mock_geo_global_executor.h.

◆ ~MockGeoGlobalExecutor()

resdb::MockGeoGlobalExecutor::~MockGeoGlobalExecutor ( )
inline

Definition at line 34 of file mock_geo_global_executor.h.

Member Function Documentation

◆ MOCK_METHOD()

resdb::MockGeoGlobalExecutor::MOCK_METHOD ( void  ,
Execute  ,
(std::unique_ptr< Request >)  ,
(override)   
)