84 lines
2.3 KiB
C
84 lines
2.3 KiB
C
#include <../../src/apps/cht/cht.h>
|
|
#include <assert.h>
|
|
int main(int argc, char ** argv) {
|
|
char * conf = "client.conf";
|
|
|
|
if(argc == 2) {
|
|
conf = argv[1];
|
|
} else if(argc > 2) {
|
|
printf("Usage: %s [client.conf]\n", argv[0]);
|
|
exit(-1);
|
|
}
|
|
|
|
Tinit();
|
|
|
|
DfaSet * cht_client = cHtClientInit(conf);
|
|
// pthread_t main_worker_loop =
|
|
spawn_main_thread(cht_client);
|
|
|
|
// cht_evals go here...
|
|
|
|
int xid = 1;//NULL_MACHINE; // What's the deal with this? ;)
|
|
clusterHashTable_t new_ht;
|
|
cHtCreate(xid, cht_client, &new_ht);
|
|
int i;
|
|
for(i = 0; i < 10000; i++) {
|
|
int one = i; int two = i+1;
|
|
cHtInsert(xid, cht_client, &new_ht, &one, sizeof(int), &two, sizeof(int));
|
|
int newOne, newTwo;
|
|
newOne = i;
|
|
newTwo = 0;
|
|
size_t newLen = sizeof(int);
|
|
int ret = cHtLookup(xid, cht_client, &new_ht, &newOne, sizeof(int), &newTwo, &newLen);
|
|
// xid++;
|
|
//printf("lookup returned %d (%d->%d)\n", ret, newOne, newTwo);
|
|
assert(ret);
|
|
assert(newOne == one);
|
|
assert(newTwo == two);
|
|
assert(newLen == sizeof(int));
|
|
}
|
|
cHtCommit(xid, cht_client);
|
|
|
|
for(i = 0; i < 10000; i+=10) {
|
|
int one = i; int two = -1;
|
|
size_t size = sizeof(int);
|
|
int removed = cHtRemove(xid, cht_client, &new_ht, &one, sizeof(int), &two, &size);
|
|
assert(removed);
|
|
|
|
size = sizeof(int);
|
|
two = -1;
|
|
removed = cHtRemove(xid, cht_client, &new_ht, &one, sizeof(int), &two, &size);
|
|
assert(!removed);
|
|
|
|
int newOne, newTwo;
|
|
newOne = i;
|
|
newTwo = 0;
|
|
size_t newLen = sizeof(int);
|
|
int ret = cHtLookup(xid, cht_client, &new_ht, &newOne, sizeof(int), &newTwo, &newLen);
|
|
|
|
assert(!ret);
|
|
|
|
}
|
|
cHtAbort(xid, cht_client);
|
|
exit(0); // @todo this test case should continue on...
|
|
for(i = 0; i < 10000; i++) {
|
|
int one = i; int two = i+1;
|
|
// cHtInsert(xid, cht_client, new_ht, &one, sizeof(int), &two, sizeof(int));
|
|
int newOne, newTwo;
|
|
newOne = i;
|
|
newTwo = 0;
|
|
size_t newLen = sizeof(int);
|
|
int ret = cHtLookup(xid, cht_client, &new_ht, &newOne, sizeof(int), &newTwo, &newLen);
|
|
// xid++;
|
|
//printf("lookup returned %d (%d->%d)\n", ret, newOne, newTwo);
|
|
assert(ret);
|
|
assert(newOne == one);
|
|
assert(newTwo == two);
|
|
assert(newLen == sizeof(int));
|
|
}
|
|
cHtCommit(xid, cht_client);
|
|
|
|
/** @todo devise a way to cleanly shut a CHT down. */
|
|
|
|
// dfa_free(cht_client);
|
|
}
|