// ServerManager.h

#ifndef NET_FS_SERVER_MANAGER_H
#define NET_FS_SERVER_MANAGER_H

#include "Locker.h"

class ExtendedServerInfo;
class NetAddress;

// ServerManager
class ServerManager {
public:
                        class Listener;

public:
                                                                ServerManager(Listener* listener);
                                                                ~ServerManager();

                        status_t                        Init();
                        void                            Uninit();

                        void                            Run();

                        ExtendedServerInfo*     GetServerInfo(const NetAddress& address);
                        status_t                        AddServer(const NetAddress& address);
                        void                            RemoveServer(const NetAddress& address);

private:
                        struct ServerInfoMap;
                        class ServerInfoTask;
                        friend class ServerInfoTask;

        static  int32                           _BroadcastListenerEntry(void* data);
                        int32                           _BroadcastListener();
                        status_t                        _InitBroadcastListener();
                        void                            _TerminateBroadcastListener();

                        void                            _ServerAdded(ExtendedServerInfo* serverInfo);
                        void                            _ServerUpdated(ExtendedServerInfo* serverInfo);
                        void                            _AddingServerFailed(
                                                                        ExtendedServerInfo* serverInfo);
                        void                            _UpdatingServerFailed(
                                                                        ExtendedServerInfo* serverInfo);
                        void                            _RemoveServer(ExtendedServerInfo* serverInfo);

private:
                        Locker                          fLock;
                        ServerInfoMap*          fServerInfos;
                        thread_id                       fBroadcastListener;
                        int32                           fBroadcastListenerSocket;
                        Listener*                       fListener;
                        volatile bool           fTerminating;
};

// Listener
class ServerManager::Listener {
public:
                                                                Listener()      {}
        virtual                                         ~Listener();

        virtual void                            ServerAdded(ExtendedServerInfo* serverInfo) = 0;
        virtual void                            ServerUpdated(ExtendedServerInfo* oldInfo,
                                                                        ExtendedServerInfo* newInfo) = 0;
        virtual void                            ServerRemoved(
                                                                        ExtendedServerInfo* serverInfo) = 0;
};


#endif  // NET_FS_SERVER_MANAGER_H