space hacks
[iotcloud.git] / version2 / src / C / Test.C
1 #include "Table.h"
2 #include "IoTString.h"
3 #include "TimingSingleton.h"
4 #include "TransactionStatus.h"
5
6 #define NUMBER_OF_TESTS 2
7
8 int main(int numargs, char ** args) {
9         TimingSingleton * timer = TimingSingleton_getInstance();
10
11         bool foundError = false;
12         Vector<TransactionStatus *> * transStatusList = new Vector<TransactionStatus *>();
13
14         // Setup the 2 clients
15         IoTString *baseurl = new IoTString("http://dc-6.calit2.uci.edu/test.iotcloud/");
16         IoTString * password = new IoTString("reallysecret");
17         Table * t1 = new Table(baseurl, password, 321, -1);
18         t1->initTable();
19         printf("T1 Ready\n");
20
21         Table * t2 = new Table(baseurl, password, 351, -1);
22         t2->update();
23         printf("T2 Ready\n");
24
25         baseurl->releaseRef();
26         password->releaseRef();
27         
28         // Make the Keys
29         printf("Setting up keys\n");
30         for (int i = 0; i < NUMBER_OF_TESTS; i++) {
31                 printf("%d\n",i);
32                 char buffer[80];
33                 sprintf(buffer, "a%d", i);
34                 IoTString *ia = new IoTString(buffer);
35                 sprintf(buffer, "b%d", i);
36                 IoTString *ib = new IoTString(buffer);
37                 sprintf(buffer, "c%d", i);
38                 IoTString *ic = new IoTString(buffer);
39                 sprintf(buffer, "d%d", i);
40                 IoTString *id = new IoTString(buffer);
41                 t1->createNewKey(ia, 321);
42                 t1->createNewKey(ib, 351);
43                 t2->createNewKey(ic, 321);
44                 t2->createNewKey(id, 351);
45                 ia->releaseRef();
46                 ib->releaseRef();
47                 ic->releaseRef();
48                 id->releaseRef();
49         }
50         
51         // Do Updates for the keys
52         printf("Setting Key-Values...\n");
53         for (int i = 0; i < NUMBER_OF_TESTS; i++) {
54                 printf("%d\n", i);
55                 char buffer[80];
56                 sprintf(buffer, "a%d", i);
57                 IoTString * iKeyA = new IoTString(buffer);
58                 IoTString * iValueA = new IoTString(buffer);
59
60                 sprintf(buffer, "b%d", i);
61                 IoTString * iKeyB = new IoTString(buffer);
62                 IoTString * iValueB = new IoTString(buffer);
63                 
64                 sprintf(buffer, "c%d", i);
65                 IoTString * iKeyC = new IoTString(buffer);
66                 IoTString * iValueC = new IoTString(buffer);
67                 
68                 sprintf(buffer, "d%d", i);
69                 IoTString * iKeyD = new IoTString(buffer);
70                 IoTString * iValueD = new IoTString(buffer);
71
72                 t1->startTransaction();
73                 t1->put(iKeyA, iValueA);
74                 transStatusList->add(t1->commitTransaction());
75                 iKeyA->releaseRef();
76                 iValueA->releaseRef();
77                 
78                 t1->startTransaction();
79                 t1->put(iKeyB, iValueB);
80                 transStatusList->add(t1->commitTransaction());
81                 iKeyB->releaseRef();
82                 iValueB->releaseRef();
83                 
84                 t2->startTransaction();
85                 t2->put(iKeyC, iValueC);
86                 transStatusList->add(t2->commitTransaction());
87                 iKeyC->releaseRef();
88                 iValueC->releaseRef();
89                 
90                 t2->startTransaction();
91                 t2->put(iKeyD, iValueD);
92                 transStatusList->add(t2->commitTransaction());
93                 iKeyD->releaseRef();
94                 iValueD->releaseRef();
95         }
96         
97         printf("Updating Clients...\n");
98         t1->update();
99         t2->update();
100         
101         printf("Checking Key-Values...\n");
102         for (int i = 0; i < NUMBER_OF_TESTS; i++) {
103                 char buffer[80];
104                 sprintf(buffer, "a%d", i);
105                 IoTString * iKeyA = new IoTString(buffer);
106                 IoTString * iValueA = new IoTString(buffer);
107
108                 sprintf(buffer, "b%d", i);
109                 IoTString * iKeyB = new IoTString(buffer);
110                 IoTString * iValueB = new IoTString(buffer);
111                 
112                 sprintf(buffer, "c%d", i);
113                 IoTString * iKeyC = new IoTString(buffer);
114                 IoTString * iValueC = new IoTString(buffer);
115                 
116                 sprintf(buffer, "d%d", i);
117                 IoTString * iKeyD = new IoTString(buffer);
118                 IoTString * iValueD = new IoTString(buffer);
119                 
120                 IoTString *testValA1 = t1->getCommitted(iKeyA);
121                 IoTString *testValB1 = t1->getCommitted(iKeyB);
122                 IoTString *testValC1 = t1->getCommitted(iKeyC);
123                 IoTString *testValD1 = t1->getCommitted(iKeyD);
124                 
125                 IoTString *testValA2 = t2->getCommitted(iKeyA);
126                 IoTString *testValB2 = t2->getCommitted(iKeyB);
127                 IoTString *testValC2 = t2->getCommitted(iKeyC);
128                 IoTString *testValD2 = t2->getCommitted(iKeyD);
129                 
130                 if ((testValA1 == NULL) || (testValA1->equals(iValueA) == false)) {
131                         printf("Key-Value t1 incorrect: keyA\n");
132                         foundError = true;
133                 }
134                 
135                 if ((testValB1 == NULL) || (testValB1->equals(iValueB) == false)) {
136                         printf("Key-Value t1 incorrect: keyB\n");
137                         foundError = true;
138                 }
139
140                 if ((testValC1 == NULL) || (testValC1->equals(iValueC) == false)) {
141                         printf("Key-Value t1 incorrect: keyC\n");
142                         foundError = true;
143                 }
144                 
145                 if ((testValD1 == NULL) || (testValD1->equals(iValueD) == false)) {
146                         printf("Key-Value t1 incorrect: keyD\n");
147                         foundError = true;
148                 }
149                 
150                 if ((testValA2 == NULL) || (testValA2->equals(iValueA) == false)) {
151                         printf("Key-Value t2 incorrect: keyA     testValA2\n");
152                         foundError = true;
153                 }
154                 
155                 if ((testValB2 == NULL) || (testValB2->equals(iValueB) == false)) {
156                         printf("Key-Value t2 incorrect: keyB     testValB2\n");
157                         foundError = true;
158                 }
159                 
160                 if ((testValC2 == NULL) || (testValC2->equals(iValueC) == false)) {
161                         printf("Key-Value t2 incorrect: keyC     testValC2\n");
162                         foundError = true;
163                 }
164                 
165                 if ((testValD2 == NULL) || (testValD2->equals(iValueD) == false)) {
166                         printf("Key-Value t2 incorrect: keyD     testValD2\n");
167                         foundError = true;
168                 }
169                 iKeyA->releaseRef();
170                 iValueA->releaseRef();
171                 iKeyB->releaseRef();
172                 iValueB->releaseRef();
173                 iKeyC->releaseRef();
174                 iValueC->releaseRef();
175                 iKeyD->releaseRef();
176                 iValueD->releaseRef();
177                 testValA1->releaseRef();
178                 testValA2->releaseRef();
179                 testValB1->releaseRef();
180                 testValB2->releaseRef();
181                 testValC1->releaseRef();
182                 testValC2->releaseRef();
183                 testValD1->releaseRef();
184                 testValD2->releaseRef();
185         }
186
187         for (uint i = 0; i < transStatusList->size(); i++) {
188                 TransactionStatus * status = transStatusList->get(i);
189                 if (status->getStatus() != TransactionStatus_StatusCommitted) {
190                         foundError = true;
191                         printf("Status error\n");
192                 }
193                 delete status;
194         }
195         
196         if (foundError) {
197                 printf("Found Errors...\n");
198         } else {
199                 printf("No Errors Found...\n");
200         }
201
202         delete transStatusList;
203         delete t1;
204 }
205