Distributed_key_value_store/server.h at main · veerkumar/Distributed_key_value_store · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
#include "key_store_services.grpc.pb.h"
using grpc::Server;
using grpc::ServerBuilder;
using grpc::ServerContext;
using grpc::Status;

using KeyStore::KeyStoreRequest;
using KeyStore::KeyStoreResponse;
using KeyStore::KeyStoreService;


void
delete_cm_request_t(cm_message_request_t* cm_req);
uint32_t insert_command(const KeyStoreRequest  *req);


extern mutex abd_ks_map_mutex;
extern map<string,value_t*> abd_ks_map;

extern mutex cm_ks_map_mutex;
extern map<string,value_t*> cm_ks_map;

extern mutex cm_pq_mutex;
extern priority_queue <cm_message_request_t*, vector<cm_message_request_t*>, vectclk_comparator > cm_message_pq;

extern mutex cm_outque_mutex;
extern std::queue<cm_message_request_t* > cm_message_outqueue;

extern mutex cm_t_mutex;
extern int *t;
extern int serverlist_size;

extern int mynodenumber;

extern cm_server_connections *cm_connection_obj;


extern mutex mp_ks_map_mutex;
extern map<string,value_t*> mp_ks_map;

extern mp_server_connections *mp_connection_obj;