pinto/src/PintoManager.hpp

Go to the documentation of this file.

// Copyright (c) 2012 Sirikata Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can
// be found in the LICENSE file.

#ifndef _SIRIKATA_PINTO_MANAGER_HPP_
#define _SIRIKATA_PINTO_MANAGER_HPP_

#include "PintoManagerBase.hpp"

#include <prox/geom/QueryHandler.hpp>
#include <prox/base/QueryEventListener.hpp>
#include <prox/base/LocationUpdateListener.hpp>

#include "PintoManagerLocationServiceCache.hpp"

namespace Sirikata {

class PintoManager
    : public PintoManagerBase,
      public Prox::QueryEventListener<ServerProxSimulationTraits, Prox::Query<ServerProxSimulationTraits> >
{
public:
    PintoManager(PintoContext* ctx);
    virtual ~PintoManager();

private:
    typedef Prox::QueryHandler<ServerProxSimulationTraits> ProxQueryHandler;
    typedef Prox::Query<ServerProxSimulationTraits> Query;
    typedef Prox::QueryEvent<ServerProxSimulationTraits> QueryEvent;

    // PintoManagerBase overrides
    virtual void onConnected(Sirikata::Network::Stream* newStream);
    virtual void onInitialMessage(Sirikata::Network::Stream* stream);
    virtual void onRegionUpdate(Sirikata::Network::Stream* stream, BoundingSphere3f bounds);
    virtual void onMaxSizeUpdate(Sirikata::Network::Stream* stream, float32 ms);
    virtual void onQueryUpdate(Sirikata::Network::Stream* stream, const String& update);
    virtual void onDisconnected(Sirikata::Network::Stream* stream);


    // QueryEventListener Interface
    virtual void queryHasEvents(Query* query);

    // Command handlers
    virtual void commandProperties(const Command::Command& cmd, Command::Commander* cmdr, Command::CommandID cmdid);
    virtual void commandListHandlers(const Command::Command& cmd, Command::Commander* cmdr, Command::CommandID cmdid);
    virtual void commandForceRebuild(const Command::Command& cmd, Command::Commander* cmdr, Command::CommandID cmdid);
    virtual void commandListNodes(const Command::Command& cmd, Command::Commander* cmdr, Command::CommandID cmdid);
    virtual void commandListQueriers(const Command::Command& cmd, Command::Commander* cmdr, Command::CommandID cmdid);
    virtual void commandStats(const Command::Command& cmd, Command::Commander* cmdr, Command::CommandID cmdid);


    // Tick the QueryHandler. We don't actually care about time since Servers
    // won't be in motion. Should only be called when the server data or query
    // data is updated.
    void tick();

    struct ClientData {
        ClientData()
         : query(NULL)
        {}

        Query* query;
    };
    typedef std::tr1::unordered_map<Sirikata::Network::Stream*, ClientData> ClientDataMap;
    ClientDataMap mClients;
    // Reverse index for queryHasEvents callbacks
    typedef std::tr1::unordered_map<Query*, Sirikata::Network::Stream*> ClientsByQuery;
    ClientsByQuery mClientsByQuery;

    ProxQueryHandler* mQueryHandler;
    Time mLastTime;
    Duration mDt;
};

} // namespace Sirikata

#endif //_SIRIKATA_PINTO_MANAGER_HPP_