// AbstractConnection.h

#ifndef NET_FS_ABSTRACT_CONNECTION_H
#define NET_FS_ABSTRACT_CONNECTION_H

#include "Connection.h"
#include "Locker.h"
#include "Vector.h"

class AbstractConnection : public Connection {
protected:
                                                                AbstractConnection();

public:
        virtual                                         ~AbstractConnection();

        virtual status_t                        Init(const char* parameters) = 0;
                        status_t                        Init();
        virtual void                            Close();

//      virtual User*                           GetAuthorizedUser();

                        status_t                        AddDownStreamChannel(Channel* channel);
                        status_t                        AddUpStreamChannel(Channel* channel);

        virtual int32                           CountDownStreamChannels() const;
        virtual Channel*                        DownStreamChannelAt(int32 index) const;

        virtual status_t                        GetUpStreamChannel(Channel** channel,
                                                                        bigtime_t timeout = B_INFINITE_TIMEOUT);
        virtual status_t                        PutUpStreamChannel(Channel* channel);

protected:
                        typedef Vector<Channel*>        ChannelVector;

                        status_t                        fInitStatus;
                        ChannelVector           fDownStreamChannels;
                        sem_id                          fUpStreamChannelSemaphore;
                        Locker                          fUpStreamChannelLock;
                        ChannelVector           fUpStreamChannels;
                        int32                           fFreeUpStreamChannels;
};

#endif  // NET_FS_ABSTRACT_CONNECTION_H