* Copyright 2011-2016, Haiku, Inc. All Rights Reserved.
* Distributed under the terms of the MIT License.
*/
#ifndef SOCKET_MESSENGER_H
#define SOCKET_MESSENGER_H
#include <Socket.h>
class BMessage;
class BMessenger;
class BSocketMessenger {
public:
BSocketMessenger();
BSocketMessenger(
const BNetworkAddress& address,
bigtime_t timeout = B_INFINITE_TIMEOUT);
BSocketMessenger(const BSocket& socket);
virtual ~BSocketMessenger();
void Unset();
status_t SetTo(const BNetworkAddress& address,
bigtime_t timeout = B_INFINITE_TIMEOUT);
status_t SetTo(const BSocketMessenger& target,
bigtime_t timeout = B_INFINITE_TIMEOUT);
status_t InitCheck() const { return fInitStatus; }
const BNetworkAddress& Address() const { return fSocket.Peer(); }
virtual status_t SendMessage(const BMessage& message);
virtual status_t SendMessage(const BMessage& message,
BMessage& _reply,
bigtime_t timeout = B_INFINITE_TIMEOUT);
virtual status_t SendMessage(const BMessage& message,
BMessenger& replyTarget,
bigtime_t timeout = B_INFINITE_TIMEOUT);
virtual status_t SendReply(const BMessage& message,
const BMessage& reply);
virtual status_t ReceiveMessage(BMessage& _message,
bigtime_t timeout = B_INFINITE_TIMEOUT);
private:
struct Private;
private:
BSocketMessenger(const BSocketMessenger&);
BSocketMessenger& operator=(const BSocketMessenger&);
void _Init();
status_t _WaitForMessage(bigtime_t timeout);
status_t _SendMessage(const BMessage& message);
status_t _ReadMessage(BMessage& _message);
status_t _ReadReply(int64 replyID,
BMessage& _reply, bigtime_t timeout);
static status_t _MessageReader(void* arg);
private:
Private* fPrivateData;
BSocket fSocket;
status_t fInitStatus;
};
#endif
