kits/app/Message.cpp

70 	bigtime_t timeout, BMessage* reply);
114 	BMessage* reply)
139 	result = reply->Unflatten(buffer);
211 	// Note, that BeOS R5 seems to keep the reply info.
405 		// still someone waiting for a reply to this message, we have to send
915 BMessage::SendReply(BMessage* reply, BHandler* replyTo, bigtime_t timeout)
919 	return SendReply(reply, messenger, timeout);
924 BMessage::SendReply(BMessage* reply, BMessenger replyTo, bigtime_t timeout)
935 		reply->fHeader->flags |= MESSAGE_FLAG_REPLY_AS_KMESSAGE;
942 		reply->fHeader->flags |= MESSAGE_FLAG_IS_REPLY;
943 		status_t result = messenger.SendMessage(reply, replyTo, timeout);
944 		reply->fHeader->flags &= ~MESSAGE_FLAG_IS_REPLY;
954 	// no reply required
958 	reply->AddMessage("_previous_", this);
959 	reply->fHeader->flags |= MESSAGE_FLAG_IS_REPLY;
960 	status_t result = messenger.SendMessage(reply, replyTo, timeout);
961 	reply->fHeader->flags &= ~MESSAGE_FLAG_IS_REPLY;
962 	reply->RemoveName("_previous_");
977 BMessage::SendReply(BMessage* reply, BMessage* replyToReply,
994 		reply->fHeader->flags |= MESSAGE_FLAG_IS_REPLY;
995 		status_t result = messenger.SendMessage(reply, replyToReply,
997 		reply->fHeader->flags &= ~MESSAGE_FLAG_IS_REPLY;
1009 	// no reply required
1013 	reply->AddMessage("_previous_", this);
1014 	reply->fHeader->flags |= MESSAGE_FLAG_IS_REPLY
1016 	status_t result = messenger.SendMessage(reply, replyToReply, sendTimeout,
1018 	reply->fHeader->flags &= ~MESSAGE_FLAG_IS_REPLY;
1019 	reply->RemoveName("_previous_");
2242 		// the forwarded message will handle the reply - we must not do
2271 // Sends a message and waits synchronously for a reply.
2274 	BMessage* reply, bigtime_t sendTimeout, bigtime_t replyTimeout) const
2278 		// waiting for a reply
2288 		// All the cached reply ports are in use; create a new one
2315 	// tests if the queue of the reply port is really empty
2320 		debugger("reply port not empty!");
2321 		printf("  reply port not empty! %ld message(s) in queue\n",
2330 				printf("failed to read message from reply port\n");
2334 				printf("message from reply port too big\n");
2339 			BMessage reply;
2340 			if (reply.Unflatten(&stream) != B_OK) {
2341 				printf("failed to unflatten message from reply port\n");
2345 			printf("message %ld from reply port:\n", i);
2346 			reply.PrintToStream();
2365 	result = handle_reply(replyPort, &code, replyTimeout, reply);