43 	Message (deUint16 threadId, deUint16 payload)  in Message()
44 		: data((threadId << 16) | payload)  in Message()
84 				deUint16 threadId = msg.getThreadId();  in run()  local
86 				if (threadId == 0xffff)  in run()
101 					DE_TEST_ASSERT(de::inBounds<int>(threadId, 0, (int)m_lastPayload.size()));  in run()
102 …DE_TEST_ASSERT((m_lastPayload[threadId] == 0 && msg.getPayload() == 0) || m_lastPayload[threadId] …  in run()
104 					m_lastPayload[threadId]	 = msg.getPayload();  in run()
105 					m_payloadSum[threadId]	+= (deUint32)msg.getPayload();  in run()
111 	deUint32 getPayloadSum (deUint16 threadId) const  in getPayloadSum()
113 		return m_payloadSum[threadId];  in getPayloadSum()
125 	Producer (MessageBuffer& buffer, deUint16 threadId, int numMessages)  in Producer()  argument
127 		, m_threadId	(threadId)  in Producer()