src/tests/kits/app/bmessagequeue/AddMessageTest1.cpp

78

assert(theMessageQueue->IsEmpty());

src/tests/kits/app/bmessagequeue/AddMessageTest1.cpp

79

assert(theMessageQueue->CountMessages() == 0);

src/tests/kits/app/bmessagequeue/AddMessageTest1.cpp

87

assert(!theMessageQueue->IsEmpty());

src/tests/kits/app/bmessagequeue/AddMessageTest1.cpp

88

assert(theMessageQueue->CountMessages() == i + 1);

src/tests/kits/app/bmessagequeue/AddMessageTest1.cpp

95

delete theMessageQueue;

src/tests/kits/app/bmessagequeue/AddMessageTest1.cpp

96

theMessageQueue = NULL;

src/tests/kits/app/bmessagequeue/AddMessageTest2.cpp

87

CPPUNIT_ASSERT(theMessageQueue->FindMessage((int32)0) == firstMessage);

src/tests/kits/app/bmessagequeue/AddMessageTest2.cpp

88

CPPUNIT_ASSERT(theMessageQueue->FindMessage((int32)1) == secondMessage);

src/tests/kits/app/bmessagequeue/AddMessageTest2.cpp

89

CPPUNIT_ASSERT(theMessageQueue->FindMessage((int32)2) == NULL);

src/tests/kits/app/bmessagequeue/AddMessageTest2.cpp

90

CPPUNIT_ASSERT(theMessageQueue->FindMessage((int32)3) == NULL);

src/tests/kits/app/bmessagequeue/AddMessageTest2.cpp

91

CPPUNIT_ASSERT(theMessageQueue->FindMessage((int32)4) == NULL);

src/tests/kits/app/bmessagequeue/ConcurrencyTest1.cpp

121

CPPUNIT_ASSERT(numMessages == theMessageQueue->CountMessages());

src/tests/kits/app/bmessagequeue/ConcurrencyTest1.cpp

124

delete theMessageQueue;

src/tests/kits/app/bmessagequeue/ConcurrencyTest1.cpp

125

theMessageQueue = NULL;

src/tests/kits/app/bmessagequeue/ConcurrencyTest1.cpp

152

theMessage = theMessageQueue->NextMessage();

src/tests/kits/app/bmessagequeue/ConcurrencyTest1.cpp

182

theMessageQueue->AddMessage(theMessage);

src/tests/kits/app/bmessagequeue/ConcurrencyTest1.cpp

189

theMessageQueue->RemoveMessage(theMessage);

src/tests/kits/app/bmessagequeue/ConcurrencyTest1.cpp

91

theMessageQueue->AddMessage(theMessage);

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

102

theMessageQueue->Unlock();

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

104

BMessageQueue *tmpMessageQueue = theMessageQueue;

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

105

theMessageQueue = NULL;

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

131

BMessage *theMessage = theMessageQueue->NextMessage();

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

172

theMessageQueue->RemoveMessage(removeMessage);

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

175

CPPUNIT_ASSERT(theMessageQueue->FindMessage(removeMessage->what, 0) == NULL);

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

200

theMessageQueue->AddMessage(new testMessageClass(numAddMessages));

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

203

CPPUNIT_ASSERT(theMessageQueue->FindMessage(numAddMessages, 0) != NULL);

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

220

SafetyLock mySafetyLock(theMessageQueue);

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

224

bool result = theMessageQueue->Lock();

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

228

theMessageQueue->Unlock();

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

78

theMessageQueue->AddMessage(theMessage);

src/tests/kits/app/bmessagequeue/ConcurrencyTest2.cpp

95

theMessageQueue->Lock();

src/tests/kits/app/bmessagequeue/FindMessageTest1.cpp

90

while ((theMessage = theMessageQueue->FindMessage(whatCode,

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

28

delete theMessageQueue;

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

29

theMessageQueue = NULL;

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

36

SafetyLock theSafetyLock(theMessageQueue);

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

38

if (theMessageQueue->Lock()) {

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

39

CPPUNIT_ASSERT(theMessageQueue->CountMessages() == messageList.CountItems());

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

41

for (i = 0; i < theMessageQueue->CountMessages(); i++) {

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

42

CPPUNIT_ASSERT(theMessageQueue->FindMessage((int32)i) ==

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

45

theMessageQueue->Unlock();

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

53

if (theMessageQueue->Lock()) {

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

54

theMessageQueue->AddMessage(message);

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

56

theMessageQueue->Unlock();

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

63

if (theMessageQueue->Lock()) {

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

64

theMessageQueue->RemoveMessage(message);

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

66

theMessageQueue->Unlock();

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

73

SafetyLock theSafetyLock(theMessageQueue);

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

76

if (theMessageQueue->Lock()) {

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

77

result = theMessageQueue->NextMessage();

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.cpp

79

theMessageQueue->Unlock();

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.h

37

BMessageQueue *theMessageQueue;

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.h

40

SafetyLock(BMessageQueue *aMessageQueue) {theMessageQueue = aMessageQueue;}

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.h

41

virtual ~SafetyLock() {if (theMessageQueue != NULL) theMessageQueue->Unlock(); };

src/tests/kits/app/bmessagequeue/MessageQueueTestCase.h

66

BMessageQueue *theMessageQueue;