Distributed_key_value_store/utils.cpp 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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

#include "utils.h"

string
get_ipaddr() {
	string ipAddress;
	struct ifaddrs *interfaces = NULL;
	struct ifaddrs *temp_addr = NULL;
	int success = 0;
	// retrieve the current interfaces - returns 0 on success
	success = getifaddrs(&interfaces);
	if (success == 0) {
		// Loop through linked list of interfaces
		temp_addr = interfaces;
		while(temp_addr != NULL) {
			if(temp_addr->ifa_addr->sa_family == AF_INET) {
				if(strcmp(temp_addr->ifa_name, INTERFACE)==0){
					ipAddress=inet_ntoa(((struct sockaddr_in*)temp_addr->ifa_addr)->sin_addr);
#ifdef DEBUG_FLAG
					cout<<"\n IPaddress"<<ipAddress<<endl;
#endif
				}
			}
			temp_addr = temp_addr->ifa_next;
		}
	}
	// Free memory
	freeifaddrs(interfaces);
	return ipAddress+":";
}

request_type
get_c_request_type(KeyStoreRequest::RequestType type) {
	switch (type) {
		case KeyStoreRequest::READ:
			return READ;
		case KeyStoreRequest::READ_QUERY:
			return READ_QUERY;
		case KeyStoreRequest::WRITE:
			return WRITE;
		case KeyStoreRequest::WRITE_QUERY:
			return WRITE_QUERY;
		default:
			cout<<"get_ctype: wrong request type";
	}
	return READ;
}

string
getstring_grpc_request_type(KeyStoreRequest::RequestType type) {
	switch (type) {
		case KeyStoreRequest::READ:
			return "READ";
		case KeyStoreRequest::READ_QUERY:
			return "READ_QUERY"; break;
		case KeyStoreRequest::WRITE:
			return "WRITE"; break;
		case KeyStoreRequest::WRITE_QUERY:
			return "WRITE_QUERY"; break;
		default:
			return "Unknown";
	}
	return "Unknown";
}

string
getstring_c_request_type(request_type type) {
	switch (type) {
		case READ:
			return "READ"; break;
		case READ_QUERY:
			return "READ_QUERY"; break;
		case WRITE:
			 return"WRITE"; break;
		case WRITE_QUERY:
			return "WRITE_QUERY"; break;
		default:
			return "Unknown";
	}
	return "Unknown";
}

return_code
get_c_return_code(KeyStoreResponse::ReturnCode type) {
	switch (type) {
		case KeyStoreResponse::ACK:
			return ACK;
		case KeyStoreResponse::ERROR:
			return ERROR;
		case KeyStoreResponse::OK:
			return OK;
		default:
			cout<<"get_ctype: wrong return code";
	}
	return OK;
}

string
get_c_return_code_string(KeyStoreResponse::ReturnCode type) {
	switch (type) {
		case KeyStoreResponse::ACK:
			return "ACK";
		case KeyStoreResponse::ERROR:
			return "ERROR";
		case KeyStoreResponse::OK:
			return "OK";
		default:
			cout<<"get_ctype: wrong return code";
	}
	return "OK";
}

void
print_grpc_return_code(KeyStoreResponse::ReturnCode type) {
	switch (type) {
		case KeyStoreResponse::ACK:
			cout<< "ACK"; break;
		case KeyStoreResponse::ERROR:
			cout<< "ERROR"; break;
		case KeyStoreResponse::OK:
			cout<< "OK"; break;
		default:
			cout<<"Unknown return code";
	}
}