// RequestConnection.h

#ifndef NET_FS_REQUEST_CONNECTION_H
#define NET_FS_REQUEST_CONNECTION_H

#include <SupportDefs.h>

class Connection;
class Request;
class RequestHandler;

class RequestConnection {
public:
                                                                RequestConnection(Connection* connection,
                                                                        RequestHandler* requestHandler,
                                                                        bool ownsRequestHandler = false);
                                                                ~RequestConnection();

                        status_t                        Init();

                        void                            Close();

                        status_t                        SendRequest(Request* request,
                                                                        Request** reply = NULL);
                        status_t                        SendRequest(Request* request,
                                                                        RequestHandler* replyHandler);
private:
                        class DownStreamThread;
                        friend class DownStreamThread;

private:
                        bool                            DownStreamChannelError(DownStreamThread* thread,
                                                                        status_t error);

                        status_t                        _SendRequest(Request* request, Request** reply,
                                                                        RequestHandler* replyHandler);

private:
                        Connection*                     fConnection;
                        RequestHandler*         fRequestHandler;
                        bool                            fOwnsRequestHandler;
                        DownStreamThread*       fThreads;
                        int32                           fThreadCount;
                        int32                           fTerminationCount;
};

#endif  // NET_FS_REQUEST_CONNECTION_H