79 	fPrivateData(NULL),  in BSocketMessenger()
90 	fPrivateData(NULL),  in BSocketMessenger()
101 	fPrivateData(NULL),  in BSocketMessenger()
106 	if (fPrivateData == NULL)  in BSocketMessenger()
113 	fPrivateData->fReplyReader = spawn_thread(&_MessageReader,  in BSocketMessenger()
115 	if (fPrivateData->fReplyReader < 0)  in BSocketMessenger()
116 		fInitStatus = fPrivateData->fReplyReader;  in BSocketMessenger()
118 		exit_thread(fPrivateData->fReplyReader);  in BSocketMessenger()
119 		fPrivateData->fReplyReader = -1;  in BSocketMessenger()
123 	fInitStatus = resume_thread(fPrivateData->fReplyReader);  in BSocketMessenger()
131 	delete fPrivateData;  in ~BSocketMessenger()
138 	if (fPrivateData == NULL)  in Unset()
142 	wait_for_thread(fPrivateData->fReplyReader, NULL);  in Unset()
143 	fPrivateData->fReplyReader = -1;  in Unset()
144 	fPrivateData->ClearMessages();  in Unset()
146 	release_sem_etc(fPrivateData->fMessageWaiters, 1, B_RELEASE_ALL);  in Unset()
157 	if (fPrivateData == NULL)  in SetTo()
160 	fPrivateData->fReplyReader = spawn_thread(&_MessageReader,  in SetTo()
162 	if (fPrivateData->fReplyReader < 0)  in SetTo()
163 		return fPrivateData->fReplyReader;  in SetTo()
170 	return fInitStatus = resume_thread(fPrivateData->fReplyReader);  in SetTo()
192 	int64 replyID = atomic_add64(&fPrivateData->fReplyIDCounter, 1);  in SendMessage()
233 	AutoLocker<BMessageQueue> queueLocker(fPrivateData->fReceivedMessages);  in ReceiveMessage()
235 		if (!fPrivateData->fReceivedMessages.IsEmpty()) {  in ReceiveMessage()
237 				= fPrivateData->fReceivedMessages.NextMessage();  in ReceiveMessage()
261 	if (fPrivateData != NULL)  in _Init()
279 	fPrivateData = data;  in _Init()
287 		status_t error = acquire_sem_etc(fPrivateData->fMessageWaiters, 1,  in _WaitForMessage()
368 		if (fPrivateData->fReceivedReplies.ContainsKey(replyID)) {  in _ReadReply()
369 			reply = fPrivateData->fReceivedReplies.Remove(replyID);  in _ReadReply()
390 	BSocketMessenger::Private* data = messenger->fPrivateData;  in _MessageReader()