Searched refs:m_ReaderData (Results 1 – 4 of 4) sorted by relevance
325 return m_ReaderData.m_Jobs; } in GetJobs()344 m_ReaderData.m_WaitPort = port; } in SetWaitPort()348 return m_ReaderData.m_WaitPort; } in GetWaitPort()365 { SRemoteNodeData & data = m_ReaderData; in GetAndResetWaitPort()404 return m_ReaderData.m_PrefAffinities; in GetPreferredAffinities()409 return m_ReaderData.m_PrefAffinities.any(); } in HasPreferredAffinities()413 return m_ReaderData.m_WaitAffinities; } in GetWaitAffinities()417 return m_ReaderData.m_AffReset; } in GetAffinityReset()425 return m_ReaderData.m_WaitAffinities.any(); } in HasWaitAffinities()451 return m_ReaderData.AddPreferredAffinity(aff); in AddPreferredAffinity()[all …]
600 m_ReaderData(read_blacklist_timeout), in CNSClient()626 m_ReaderData.RegisterJob(job_id); in RegisterJob()649 m_ReaderData.AddToBlacklist(job_id, m_LastAccess); in RegisterBlacklistedJob()684 m_ReaderData.m_AffReset = false; in Touch()706 if (m_ReaderData.m_AffReset) buffer += "TRUE\n"; in Print()809 to_string(m_ReaderData.m_Jobs.count()) + "\n"; in Print()810 if (verbose && m_ReaderData.m_Jobs.any()) { in Print()819 to_string(m_ReaderData.m_NumberOfGiven) + "\n"; in Print()844 if (verbose && m_ReaderData.m_PrefAffinities.any()) { in Print()855 if (verbose && m_ReaderData.m_WaitAffinities.any()) { in Print()[all …]
1233 queue< CRef< CByteSource > > m_ReaderData; member1499 (m_MaxRawSize != 0 && m_ReaderData.empty() && !m_FuturesQueue.empty())) { in x_UpdateFuturesQueue()1553 while (m_ReaderData.empty()) { in x_GetNextData()1556 CRef< CByteSource > data = m_ReaderData.front(); in x_GetNextData()1557 m_ReaderData.pop(); in x_GetNextData()1593 m_ReaderData.push( data); in x_ReaderThread()1601 m_ReaderData.push( data); in x_ReaderThread()