第10讲 DRQ与CAM SYNC 第1部分

ChiContext::Initialize()
{
    ThreadManager::Create(&m_pThreadManager, "SoloThreadManager", numThreads);
    //线程池handler会传递给session, pipeline, node, drq, metapool等进行共同使用
}

Session::Initialize()
{
    m_pDeferredRequestQueue = DeferredRequestQueue::Create(&pDeferredCreateData);
}

class DeferredRequestQueue : public IPropertyPoolObserver
{
    Hashmap*                    m_pDependencyMap;       ///< Hashmap to store pending dependencies
    ThreadManager*              m_pThreadManager;       ///< 指向一个线程池
    Session*                    m_pSession;             ///< pointer to Session to which this DRQ belongs
    JobHandle                   m_hDeferredWorker;      ///< 通过这个worker handle执行异步操作
    LightweightDoublyLinkedList m_deferredNodes;        ///< List of deferred nodes
    LightweightDoublyLinkedList m_readyNodes;           ///< List of ready nodes
    MetadataPool*               m_pMainPools[MaxPipelinesPerSession];  ///< 保存了每个pipeline的result metadata pool
}

struct DependencyUnit
{
    PropertyDependency propertyDependency;
    bufferDependency;// input buffer fence
    chiFenceDependency;// non buffer fence
}

struct DependencyKey
{
    UINT64 requestId;      ///< Request ID
    UINT64 pipelineId;     ///< pipeline id for the data
    UINT32 dataId;         ///< Property/Metadata/Data identifier
    VOID*  pFence;         ///< Fence pointer
    VOID*  pChiFence;      ///< Chi Fence pointer
}；

DependencyKey mapKey  = {request, pDependency->pipelineIds[i], pDependency->properties[i], NULL, NULL};

DependencyKey mapKey = {0, 0, PropertyIDInvalid, pDependency->phFences[i], NULL};

DependencyKey mapKey = {0, 0, PropertyIDInvalid, NULL, pDependency->pChiFences[i]};