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