Aren/haiku
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added tests for the missing SendMessage() version and also use remote targets.

Browse Source 
git-svn-id: file:///srv/svn/repos/haiku/trunk/current@370 a95241bf-73f2-0310-859d-f6bbb57e9c96
This commit is contained in:
Ingo Weinhold 2002-07-21 14:54:19 +00:00
parent 037c2e4631
commit a0ea8d5fd3
2 changed files with 122 additions and 104 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

222
src/tests/kits/app/bmessenger/SendMessageTester.cpp
View File

@ -31,105 +31,18 @@
// Globals --------------------------------------------------------------------- // Globals ---------------------------------------------------------------------
// procedure: // target flavors
// * init target (block/timeout), construct messenger
// (- uninitialized)
// - local
// - preferred
// - specific
// - remote
// - preferred
// - specific
// * init parameters
// - reply handler
// - reply messenger
// * invoke SM()
// * compare result
// * compare time
// * get + compare reply
// - no reply
// - reply handler
// - reply per reference
// SM() params:
//
// status_t SendMessage(uint32 command, BHandler *replyTo = NULL) const;
// * command
// * useReplyTo
//
// status_t SendMessage(BMessage *message, BHandler *replyTo = NULL,
// bigtime_t timeout = B_INFINITE_TIMEOUT) const;
// * message (command?)
// * useReplyTo
// * timeout
//
// status_t SendMessage(BMessage *message, BMessenger replyTo,
// bigtime_t timeout = B_INFINITE_TIMEOUT) const;
// * message (command?)
// * useReplyTo
// * timeout
//
// status_t SendMessage(uint32 command, BMessage *reply) const;
// * command
// * useReply
//
// status_t SendMessage(BMessage *message, BMessage *reply,
// bigtime_t deliveryTimeout = B_INFINITE_TIMEOUT,
// bigtime_t replyTimeout = B_INFINITE_TIMEOUT) const;
// * message (command?)
// * useReply
// * deliveryTimeout
// * replyTimeout
//
// Tester params:
//
// target:
// - invalid
// - local
// - preferred
// - specific
// - remote
// - preferred
// - specific
//
// target behavior:
// - unblock after ms
// - reply after ms
//
// SM() result
//
// delivery success
//
// SM() return time
enum target_kind { enum target_kind {
TARGET_UNINITIALIZED, TARGET_UNINITIALIZED,
TARGET_LOCAL_PREFERRED, TARGET_LOCAL_PREFERRED,
TARGET_LOCAL_SPECIFIC, TARGET_LOCAL_SPECIFIC,
// ... TARGET_REMOTE_PREFERRED,
TARGET_REMOTE_SPECIFIC,
}; };
// tester class
class SMTester { class SMTester {
public: public:
// target:
// - invalid
// - local
// - preferred
// - specific
// - remote
// - preferred
// - specific
//
// target behavior:
// - unblock after ms
// - reply after ms
//
// SM() result
//
// SM() return time
SMTester(target_kind targetKind) SMTester(target_kind targetKind)
: fTargetKind(targetKind) : fTargetKind(targetKind)
{ {
@ -143,9 +56,8 @@ public:
bigtime_t targetReply, status_t result, bool deliverySuccess, bigtime_t targetReply, status_t result, bool deliverySuccess,
bool replySuccess, bigtime_t duration) bool replySuccess, bigtime_t duration)
{ {
// NextSubTest(); //printf("SMTester::Run(%lld, %lld, %lx, %d, %d, %lld)\n", targetUnblock,
printf("SMTester::Run(%lld, %lld, %lx, %d, %d, %lld)\n", targetUnblock, //targetReply, result, deliverySuccess, replySuccess, duration);
targetReply, result, deliverySuccess, replySuccess, duration);
enum { JITTER = 10000 }; enum { JITTER = 10000 };
enum { SETUP_LATENCY = 100000 }; enum { SETUP_LATENCY = 100000 };
enum { DELIVERY_LATENCY = 10000 }; enum { DELIVERY_LATENCY = 10000 };
@ -164,6 +76,12 @@ targetReply, result, deliverySuccess, replySuccess, duration);
case TARGET_LOCAL_SPECIFIC: case TARGET_LOCAL_SPECIFIC:
target = new LocalSMTarget(false); target = new LocalSMTarget(false);
break; break;
case TARGET_REMOTE_PREFERRED:
target = new RemoteSMTarget(true);
break;
case TARGET_REMOTE_SPECIFIC:
target = new RemoteSMTarget(false);
break;
} }
AutoDeleter<SMTarget> deleter(target); AutoDeleter<SMTarget> deleter(target);
// create the reply target // create the reply target
@ -178,7 +96,7 @@ targetReply, result, deliverySuccess, replySuccess, duration);
status_t actualResult = invoker.Invoke(targetMessenger, replyHandler, status_t actualResult = invoker.Invoke(targetMessenger, replyHandler,
replyMessenger); replyMessenger);
bigtime_t actualDuration = system_time() - startTime; bigtime_t actualDuration = system_time() - startTime;
printf("duration: %lld vs %lld\n", actualDuration, duration); //printf("duration: %lld vs %lld\n", actualDuration, duration);
// We need to wait for the reply, if reply mode is asynchronous. // We need to wait for the reply, if reply mode is asynchronous.
snooze_until(startTime + targetUnblock + targetReply snooze_until(startTime + targetUnblock + targetReply
+ 2 * DELIVERY_LATENCY, B_SYSTEM_TIMEBASE); + 2 * DELIVERY_LATENCY, B_SYSTEM_TIMEBASE);
@ -232,12 +150,12 @@ SendMessageTester::~SendMessageTester()
} }
// TestUninitialized // TestUninitialized
static
void void
TestUninitialized() SendMessageTester::TestUninitialized()
{ {
SMTester tester(TARGET_UNINITIALIZED); SMTester tester(TARGET_UNINITIALIZED);
// status_t SendMessage(uint32 command, BHandler *replyTo) const // status_t SendMessage(uint32 command, BHandler *replyTo) const
NextSubTest();
{ {
SMInvoker1 invoker1(false); SMInvoker1 invoker1(false);
SMInvoker1 invoker2(true); SMInvoker1 invoker2(true);
@ -246,6 +164,7 @@ TestUninitialized()
} }
// status_t SendMessage(BMessage *message, BHandler *replyTo, // status_t SendMessage(BMessage *message, BHandler *replyTo,
// bigtime_t timeout) const // bigtime_t timeout) const
NextSubTest();
{ {
SMInvoker2 invoker1(true, false, B_INFINITE_TIMEOUT); SMInvoker2 invoker1(true, false, B_INFINITE_TIMEOUT);
SMInvoker2 invoker2(true, true, B_INFINITE_TIMEOUT); SMInvoker2 invoker2(true, true, B_INFINITE_TIMEOUT);
@ -254,6 +173,7 @@ TestUninitialized()
} }
// status_t SendMessage(BMessage *message, BMessenger replyTo, // status_t SendMessage(BMessage *message, BMessenger replyTo,
// bigtime_t timeout) const // bigtime_t timeout) const
NextSubTest();
{ {
SMInvoker3 invoker1(true, false, B_INFINITE_TIMEOUT); SMInvoker3 invoker1(true, false, B_INFINITE_TIMEOUT);
SMInvoker3 invoker2(true, true, B_INFINITE_TIMEOUT); SMInvoker3 invoker2(true, true, B_INFINITE_TIMEOUT);
@ -261,10 +181,27 @@ TestUninitialized()
tester.Run(invoker2, 0, 0, B_BAD_PORT_ID, false, false, 0); tester.Run(invoker2, 0, 0, B_BAD_PORT_ID, false, false, 0);
} }
// status_t SendMessage(uint32 command, BMessage *reply) const // status_t SendMessage(uint32 command, BMessage *reply) const
NextSubTest();
{ {
SMInvoker4 invoker1(false); SMInvoker4 invoker1(false);
SMInvoker4 invoker2(true); SMInvoker4 invoker2(true);
// We check the parameters first. // We check the parameters first.
#ifdef TEST_OBOS
tester.Run(invoker1, 0, 0, B_BAD_VALUE, false, false, 0);
#else
tester.Run(invoker1, 0, 0, B_BAD_PORT_ID, false, false, 0);
#endif
tester.Run(invoker2, 0, 0, B_BAD_PORT_ID, false, false, 0);
}
// status_t SendMessage(BMessage *message, BMessage *reply,
// bigtime_t deliveryTimeout,
// bigtime_t replyTimeout) const
NextSubTest();
{
SMInvoker5 invoker1(true, false, B_INFINITE_TIMEOUT,
B_INFINITE_TIMEOUT);
SMInvoker5 invoker2(true, true, B_INFINITE_TIMEOUT,
B_INFINITE_TIMEOUT);
#ifdef TEST_OBOS #ifdef TEST_OBOS
tester.Run(invoker1, 0, 0, B_BAD_VALUE, false, false, 0); tester.Run(invoker1, 0, 0, B_BAD_VALUE, false, false, 0);
#else #else
@ -275,11 +212,11 @@ TestUninitialized()
} }
// TestInitialized // TestInitialized
static
void void
TestInitialized(SMTester &tester) SendMessageTester::TestInitialized(SMTester &tester)
{ {
// status_t SendMessage(uint32 command, BHandler *replyTo) const // status_t SendMessage(uint32 command, BHandler *replyTo) const
NextSubTest();
{ {
SMInvoker1 invoker1(false); SMInvoker1 invoker1(false);
SMInvoker1 invoker2(true); SMInvoker1 invoker2(true);
@ -288,6 +225,7 @@ TestInitialized(SMTester &tester)
} }
// status_t SendMessage(BMessage *message, BHandler *replyTo, // status_t SendMessage(BMessage *message, BHandler *replyTo,
// bigtime_t timeout) const // bigtime_t timeout) const
NextSubTest();
{ {
// R5 crashes when passing a NULL message. // R5 crashes when passing a NULL message.
#ifndef TEST_R5 #ifndef TEST_R5
@ -295,12 +233,14 @@ TestInitialized(SMTester &tester)
tester.Run(invoker1, 0, 0, B_BAD_VALUE, false, false, 0); tester.Run(invoker1, 0, 0, B_BAD_VALUE, false, false, 0);
#endif #endif
} }
NextSubTest();
{ {
SMInvoker2 invoker1(true, false, B_INFINITE_TIMEOUT); SMInvoker2 invoker1(true, false, B_INFINITE_TIMEOUT);
SMInvoker2 invoker2(true, true, B_INFINITE_TIMEOUT); SMInvoker2 invoker2(true, true, B_INFINITE_TIMEOUT);
tester.Run(invoker1, 0, 0, B_OK, true, false, 0); tester.Run(invoker1, 0, 0, B_OK, true, false, 0);
tester.Run(invoker2, 0, 0, B_OK, true, true, 0); tester.Run(invoker2, 0, 0, B_OK, true, true, 0);
} }
NextSubTest();
{ {
SMInvoker2 invoker1(true, false, 0); SMInvoker2 invoker1(true, false, 0);
SMInvoker2 invoker2(true, true, 0); SMInvoker2 invoker2(true, true, 0);
@ -309,6 +249,7 @@ TestInitialized(SMTester &tester)
tester.Run(invoker1, 20000, 0, B_WOULD_BLOCK, false, false, 0); tester.Run(invoker1, 20000, 0, B_WOULD_BLOCK, false, false, 0);
tester.Run(invoker2, 20000, 0, B_WOULD_BLOCK, false, false, 0); tester.Run(invoker2, 20000, 0, B_WOULD_BLOCK, false, false, 0);
} }
NextSubTest();
{ {
SMInvoker2 invoker1(true, false, 20000); SMInvoker2 invoker1(true, false, 20000);
SMInvoker2 invoker2(true, true, 20000); SMInvoker2 invoker2(true, true, 20000);
@ -319,6 +260,7 @@ TestInitialized(SMTester &tester)
} }
// status_t SendMessage(BMessage *message, BMessenger replyTo, // status_t SendMessage(BMessage *message, BMessenger replyTo,
// bigtime_t timeout) const // bigtime_t timeout) const
NextSubTest();
{ {
// R5 crashes when passing a NULL message. // R5 crashes when passing a NULL message.
#ifndef TEST_R5 #ifndef TEST_R5
@ -326,12 +268,14 @@ TestInitialized(SMTester &tester)
tester.Run(invoker1, 0, 0, B_BAD_VALUE, false, false, 0); tester.Run(invoker1, 0, 0, B_BAD_VALUE, false, false, 0);
#endif #endif
} }
NextSubTest();
{ {
SMInvoker3 invoker1(true, false, B_INFINITE_TIMEOUT); SMInvoker3 invoker1(true, false, B_INFINITE_TIMEOUT);
SMInvoker3 invoker2(true, true, B_INFINITE_TIMEOUT); SMInvoker3 invoker2(true, true, B_INFINITE_TIMEOUT);
tester.Run(invoker1, 0, 0, B_OK, true, false, 0); tester.Run(invoker1, 0, 0, B_OK, true, false, 0);
tester.Run(invoker2, 0, 0, B_OK, true, true, 0); tester.Run(invoker2, 0, 0, B_OK, true, true, 0);
} }
NextSubTest();
{ {
SMInvoker3 invoker1(true, false, 0); SMInvoker3 invoker1(true, false, 0);
SMInvoker3 invoker2(true, true, 0); SMInvoker3 invoker2(true, true, 0);
@ -340,6 +284,7 @@ TestInitialized(SMTester &tester)
tester.Run(invoker1, 20000, 0, B_WOULD_BLOCK, false, false, 0); tester.Run(invoker1, 20000, 0, B_WOULD_BLOCK, false, false, 0);
tester.Run(invoker2, 20000, 0, B_WOULD_BLOCK, false, false, 0); tester.Run(invoker2, 20000, 0, B_WOULD_BLOCK, false, false, 0);
} }
NextSubTest();
{ {
SMInvoker3 invoker1(true, false, 20000); SMInvoker3 invoker1(true, false, 20000);
SMInvoker3 invoker2(true, true, 20000); SMInvoker3 invoker2(true, true, 20000);
@ -349,6 +294,7 @@ TestInitialized(SMTester &tester)
tester.Run(invoker2, 40000, 0, B_TIMED_OUT, false, false, 20000); tester.Run(invoker2, 40000, 0, B_TIMED_OUT, false, false, 20000);
} }
// status_t SendMessage(uint32 command, BMessage *reply) const // status_t SendMessage(uint32 command, BMessage *reply) const
NextSubTest();
{ {
// R5 crashes when passing a NULL reply message // R5 crashes when passing a NULL reply message
#ifndef TEST_R5 #ifndef TEST_R5
@ -360,20 +306,88 @@ TestInitialized(SMTester &tester)
#endif #endif
tester.Run(invoker2, 20000, 20000, B_OK, true, true, 40000); tester.Run(invoker2, 20000, 20000, B_OK, true, true, 40000);
} }
// status_t SendMessage(BMessage *message, BMessage *reply,
// bigtime_t deliveryTimeout,
// bigtime_t replyTimeout) const
NextSubTest();
{
// R5 crashes when passing a NULL message.
#ifndef TEST_R5
SMInvoker5 invoker1(false, true, B_INFINITE_TIMEOUT,
B_INFINITE_TIMEOUT);
tester.Run(invoker1, 0, 0, B_BAD_VALUE, false, false, 0);
#endif
}
NextSubTest();
{
SMInvoker5 invoker1(true, true, B_INFINITE_TIMEOUT,
B_INFINITE_TIMEOUT);
SMInvoker5 invoker2(true, true, B_INFINITE_TIMEOUT, 0);
SMInvoker5 invoker3(true, true, B_INFINITE_TIMEOUT, 20000);
tester.Run(invoker1, 0, 0, B_OK, true, true, 0);
tester.Run(invoker1, 10000, 0, B_OK, true, true, 10000);
tester.Run(invoker1, 0, 10000, B_OK, true, true, 10000);
// These two are race-conditional: The sending task must be pre-empted
// before reading from the reply port and the target must reply before
// the sending task gets another time slice.
// tester.Run(invoker2, 0, 0, B_OK, true, true, 0);
// tester.Run(invoker2, 10000, 0, B_OK, true, true, 10000);
tester.Run(invoker2, 0, 10000, B_WOULD_BLOCK, true, false, 0);
tester.Run(invoker3, 0, 10000, B_OK, true, true, 10000);
tester.Run(invoker3, 20000, 10000, B_OK, true, true, 30000);
tester.Run(invoker3, 0, 30000, B_TIMED_OUT, true, false, 20000);
}
NextSubTest();
{
SMInvoker5 invoker1(true, true, 0, B_INFINITE_TIMEOUT);
SMInvoker5 invoker2(true, true, 0, 0);
SMInvoker5 invoker3(true, true, 0, 20000);
tester.Run(invoker1, 0, 0, B_OK, true, true, 0);
tester.Run(invoker1, 10000, 0, B_WOULD_BLOCK, false, false, 0);
tester.Run(invoker1, 0, 10000, B_OK, true, true, 10000);
// This one is race-conditional: The sending task must be pre-empted
// before reading from the reply port and the target must reply before
// the sending task gets another time slice.
// tester.Run(invoker2, 0, 0, B_OK, true, true, 0);
tester.Run(invoker2, 10000, 0, B_WOULD_BLOCK, false, false, 0);
tester.Run(invoker2, 0, 10000, B_WOULD_BLOCK, true, false, 0);
tester.Run(invoker3, 0, 10000, B_OK, true, true, 10000);
tester.Run(invoker3, 10000, 10000, B_WOULD_BLOCK, false, false, 0);
tester.Run(invoker3, 0, 30000, B_TIMED_OUT, true, false, 20000);
}
NextSubTest();
{
SMInvoker5 invoker1(true, true, 20000, B_INFINITE_TIMEOUT);
SMInvoker5 invoker2(true, true, 20000, 0);
SMInvoker5 invoker3(true, true, 20000, 20000);
tester.Run(invoker1, 0, 0, B_OK, true, true, 0);
tester.Run(invoker1, 10000, 0, B_OK, true, true, 10000);
tester.Run(invoker1, 30000, 0, B_TIMED_OUT, false, false, 20000);
tester.Run(invoker1, 10000, 20000, B_OK, true, true, 30000);
// These two are race-conditional: The sending task must be pre-empted
// before reading from the reply port and the target must reply before
// the sending task gets another time slice.
// tester.Run(invoker2, 0, 0, B_OK, true, true, 0);
// tester.Run(invoker2, 10000, 0, B_OK, true, true, 0);
tester.Run(invoker2, 30000, 0, B_TIMED_OUT, false, false, 20000);
tester.Run(invoker2, 0, 10000, B_WOULD_BLOCK, true, false, 0);
tester.Run(invoker3, 10000, 10000, B_OK, true, true, 20000);
tester.Run(invoker3, 30000, 10000, B_TIMED_OUT, false, false, 20000);
tester.Run(invoker3, 10000, 30000, B_TIMED_OUT, true, false, 30000);
}
} }
/* /*
bool operator<(const BMessenger &a, const BMessenger &b) The different SendMessage() flavors.
@case 1 set fields of a and b manually
@results should return whatever the reference implementation
returns.
*/ */
void SendMessageTester::SendMessageTest1() void SendMessageTester::SendMessageTest1()
{ {
TestUninitialized(); TestUninitialized();
target_kind targetKinds[] = { target_kind targetKinds[] = {
TARGET_LOCAL_PREFERRED, TARGET_LOCAL_PREFERRED,
TARGET_LOCAL_SPECIFIC TARGET_LOCAL_SPECIFIC,
TARGET_REMOTE_PREFERRED,
TARGET_REMOTE_SPECIFIC
}; };
int32 targetKindCount = sizeof(targetKinds) / sizeof(target_kind); int32 targetKindCount = sizeof(targetKinds) / sizeof(target_kind);
for (int32 i = 0; i < targetKindCount; i++) { for (int32 i = 0; i < targetKindCount; i++) {

4
src/tests/kits/app/bmessenger/SendMessageTester.h
View File

@ -22,6 +22,7 @@
class BHandler; class BHandler;
class BLooper; class BLooper;
class SMTester;
class SendMessageTester : public BThreadedTestCase class SendMessageTester : public BThreadedTestCase
{ {
@ -30,6 +31,9 @@ public:
SendMessageTester(std::string name); SendMessageTester(std::string name);
virtual ~SendMessageTester(); virtual ~SendMessageTester();
void TestUninitialized();
void TestInitialized(SMTester &tester);
void SendMessageTest1(); void SendMessageTest1();
static Test* Suite(); static Test* Suite();