Skip to content

Commit

Permalink
Fix building errors in the tests
Browse files Browse the repository at this point in the history
  • Loading branch information
ellysh committed Feb 5, 2013
1 parent ac42350 commit 0191ac3
Show file tree
Hide file tree
Showing 7 changed files with 26 additions and 31 deletions.
9 changes: 4 additions & 5 deletions test/cross_test.cpp
Expand Up @@ -15,18 +15,17 @@ void* WriteOperation(void* args)
char* key = static_cast<char*>(args);
RegistrarClient client("write.log", "ipc:///var/run/zero-cache/0", kDealer);

client.WriteData(key, key, sizeof(key));
client.WriteData(key, Package(key, sizeof(key)));
}

void* ReadOperation(void* args)
{
const char* key = static_cast<char*>(args);
RegistrarClient client("read.log", "ipc:///var/run/zero-cache/0", kDealer);

char* result;
result = static_cast<char*>(client.ReadData(key));
assert( ! memcmp(result, key, sizeof(key)) );
free(result);
Package result = client.ReadData(key);
assert( ! memcmp(result.GetData(), key, sizeof(key)) );
free(result.GetData());

usleep(2 * 1000 * 1000);
exit(0);
Expand Down
21 changes: 10 additions & 11 deletions test/get_test.cpp
Expand Up @@ -19,23 +19,22 @@ static const string kKey3 = "key3";

void InitData(RegistrarClient& client)
{
client.WriteData(kKey1, kData1.c_str(), kData1.size());
client.WriteData(kKey2, &kData2, sizeof(kData2));
client.WriteData(kKey1, Package(kData1.c_str(), kData1.size()));
client.WriteData(kKey2, Package(&kData2, sizeof(kData2)));
}

void CheckData(RegistrarClient& client)
{
char* result;
result = static_cast<char*>(client.ReadData(kKey1));
assert( ! memcmp(result, kData1.c_str(), kData1.size()) );
free(result);
Package result = client.ReadData(kKey1);
assert( ! memcmp(result.GetData(), kData1.c_str(), kData1.size()) );
free(result.GetData());

result = static_cast<char*>(client.ReadData(kKey2));
assert( ! memcmp(result, kData2, sizeof(kData2)) );
free(result);
result = client.ReadData(kKey2);
assert( ! memcmp(result.GetData(), kData2, sizeof(kData2)) );
free(result.GetData());

result = static_cast<char*>(client.ReadData(kKey3));
assert( result == NULL );
result = client.ReadData(kKey3);
assert( result.GetData() == NULL );
}

int main()
Expand Down
4 changes: 2 additions & 2 deletions test/key_test.cpp
Expand Up @@ -16,8 +16,8 @@ static const string kData = "test data 1";

void InitData(RegistrarClient& client)
{
client.WriteData(kKey1, kData.c_str(), kData.size());
client.WriteData(kKey2, kData.c_str(), kData.size());
client.WriteData(kKey1, Package(kData.c_str(), kData.size()));
client.WriteData(kKey2, Package(kData.c_str(), kData.size()));
}

vector<string> ParseKeys(KeyArray& keys)
Expand Down
2 changes: 1 addition & 1 deletion test/memory_leak_test.cpp
Expand Up @@ -15,7 +15,7 @@ void* WriteLoop(void* args)

while (true)
{
client.WriteData(key, &kData, sizeof(kData));
client.WriteData(key, Package(&kData, sizeof(kData)));
usleep(100);
}
}
Expand Down
10 changes: 4 additions & 6 deletions test/read_test.cpp
Expand Up @@ -15,16 +15,14 @@ void* WriteLoop(void* args)
const char* key = static_cast<char*>(args);
RegistrarClient client(key, "ipc:///var/run/zero-cache/0", kDealer);

char* result;

while (true)
{
client.WriteData(key, args, sizeof(args));
client.WriteData(key, Package(args, sizeof(args)));
usleep(1000);

result = static_cast<char*>(client.ReadData(key));
assert( ! memcmp(result, key, sizeof(result)) );
free(result);
Package result = client.ReadData(key);
assert( ! memcmp(result.GetData(), key, sizeof(result)) );
free(result.GetData());
usleep(1000);
}
}
Expand Down
9 changes: 4 additions & 5 deletions test/tcp_test.cpp
Expand Up @@ -14,15 +14,14 @@ static char kData[10] = {0, 1, 2, 3, 4, 5, 6, 7, 8, 9};

void InitData(RegistrarClient& client)
{
client.WriteData(kKey, &kData, sizeof(kData));
client.WriteData(kKey, Package(&kData, sizeof(kData)));
}

void CheckData(RegistrarClient& client)
{
char* result;
result = static_cast<char*>(client.ReadData(kKey));
assert( ! memcmp(result, kData, sizeof(kData)) );
free(result);
Package result = client.ReadData(kKey);
assert( ! memcmp(result.GetData(), kData, sizeof(kData)) );
free(result.GetData());
}

int main()
Expand Down
2 changes: 1 addition & 1 deletion test/write_test.cpp
Expand Up @@ -13,7 +13,7 @@ void* WriteLoop(void* args)

while (true)
{
client.WriteData(key, args, 1);
client.WriteData(key, Package(args, 1));
usleep(500);
}
}
Expand Down

0 comments on commit 0191ac3

Please sign in to comment.