liboh/plugins/manual_query/ObjectQueryHandlerBase.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_OH_MQ_OBJECT_QUERY_HANDLER_BASE_HPP_
#define _SIRIKATA_OH_MQ_OBJECT_QUERY_HANDLER_BASE_HPP_

#include <sirikata/pintoloc/ReplicatedLocationServiceCache.hpp>
#include <sirikata/oh/ObjectHostContext.hpp>

namespace Sirikata {
namespace OH {
namespace Manual {

class ManualObjectQueryProcessor;

class ObjectQueryHandlerBase :
        public Service,
        public Liveness
{
public:
    ObjectQueryHandlerBase(ObjectHostContext* ctx, ManualObjectQueryProcessor* parent, const OHDP::SpaceNodeID& space, Network::IOStrandPtr prox_strand);
    ~ObjectQueryHandlerBase();

protected:

    // BOTH Threads: These are read-only.

    ObjectHostContext* mContext;
    const OHDP::SpaceNodeID mSpaceNodeID;


    // MAIN Thread: Utility methods that should only be called from the main
    // strand

    ManualObjectQueryProcessor* mParent;

    // Handle various events in the main thread that are triggered in the prox thread
    void handleAddObjectLocSubscription(Liveness::Token alive, const ObjectReference& subscriber, const ObjectReference& observed);
    void handleRemoveObjectLocSubscription(Liveness::Token alive, const ObjectReference& subscriber, const ObjectReference& observed);
    void handleRemoveAllObjectLocSubscription(Liveness::Token alive, const ObjectReference& subscriber);

    // PROX Thread - Should only be accessed in methods used by the prox thread
    Network::IOStrandPtr mProxStrand;

}; // class ObjectQueryHandlerBase

} // namespace Manual
} // namespace OH
} // namespace Sirikata

#endif //_SIRIKATA_OH_MQ_OBJECT_QUERY_HANDLER_BASE_HPP_