queryqueuearray.h

Go to the documentation of this file.

/*
* Copyright 2016 Autodesk, Inc. All rights reserved.
* Use of this software is subject to the terms of the Autodesk license agreement and any attachments or Appendices thereto provided at the time of installation or download,
* or which otherwise accompanies this software in either electronic or hard copy form, or which is signed by you and accepted by Autodesk.
*/

#pragma once

#include "gwnavruntime/containers/kyarray.h"
#include "gwnavruntime/world/worldelement.h"

namespace Kaim
{

class QueryQueue;
class World;


enum QueryQueueArrayProcess
{
    QueryQueueArrayProcess_InWorldUpdate,
    QueryQueueArrayProcess_OutOfWorldUpdate,
};


class QueryQueueArray : public WorldElement
{
    KY_DEFINE_NEW_DELETE_OPERATORS(MemStat_QuerySystem)
    KY_CLASS_WITHOUT_COPY(QueryQueueArray)

public:
    static  WorldElementType GetStaticType()       { return TypeQueryQueueArray; }
    virtual WorldElementType GetType()       const { return TypeQueryQueueArray; }
    virtual const char*      GetTypeName()   const { return "QueryQueueArray";   }

    QueryQueueArray();
    virtual ~QueryQueueArray() {}

    void Init(World* world, KyUInt32 queueCount, QueryQueueArrayProcess queryQueueArrayProcessThread);

    void AddToWorld();
    void RemoveFromWorld();

    void ProcessQueues();

    void FlushQueries();

    void FlushCommands();

    KyUInt32 GetQueueCount() { return m_queues.GetCount(); }
    QueryQueue* GetQueue(KyUInt32 index) { return m_queues[index]; }

    KyUInt32 GetPendingOperationCount();

    bool IsProcessedInWorldUpdate() const { return m_queryQueueArrayProcessThread == QueryQueueArrayProcess_InWorldUpdate; }

    virtual void DoSendVisualDebug(VisualDebugServer& server, VisualDebugSendChangeEvent changeEvent); // Inherited from WorldElement

    void CancelAllQueriesAndClearCommands();

    void ForceClearWorkingMemory();
private:
    KyArray<Ptr<QueryQueue>, MemStat_QuerySystem> m_queues;
    QueryQueueArrayProcess m_queryQueueArrayProcessThread;
};

} // namespace Kaim