70 lines
2.0 KiB
C++
70 lines
2.0 KiB
C++
/*
|
|
* 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);
|
|
// adopt an existing already connected socket.
|
|
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);
|
|
|
|
// wait for unsolicited message on socket
|
|
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 // SOCKET_MESSENGER_H
|