* Copyright 2009, Haiku, Inc.
* Distributed under the terms of the MIT License.
*
* Authors:
* Michael Lotz <mmlr@mlotz.ch>
*/
#ifndef NET_RECEIVER_H
#define NET_RECEIVER_H
#include <AutoDeleter.h>
#include <OS.h>
#include <SupportDefs.h>
class BNetEndpoint;
class StreamingRingBuffer;
typedef status_t (*NewConnectionCallback)(void *cookie, BNetEndpoint &endpoint);
class NetReceiver {
public:
NetReceiver(BNetEndpoint *endpoint,
StreamingRingBuffer *target,
NewConnectionCallback callback = NULL,
void *newConnectionCookie = NULL);
~NetReceiver();
BNetEndpoint * Endpoint() { return fEndpoint.Get(); }
private:
static int32 _NetworkReceiverEntry(void *data);
status_t _Listen();
status_t _Transfer();
BNetEndpoint * fListener;
StreamingRingBuffer * fTarget;
thread_id fReceiverThread;
bool fStopThread;
NewConnectionCallback fNewConnectionCallback;
void * fNewConnectionCookie;
ObjectDeleter<BNetEndpoint>
fEndpoint;
};
#endif
