Searched refs:thrIdx (Results 1 – 10 of 10) sorted by relevance
| /dports/biology/mmseqs2/MMseqs2-13-45111/src/commons/ |
| H A D | DBWriter.cpp | 250 if (thrIdx >= threads) { in writeStart()
254 starts[thrIdx] = offsets[thrIdx]; in writeStart()
270 if (thrIdx >= threads) { in writeAdd()
279 if(isCompressedDB && (state[thrIdx] == INIT_STATE || state[thrIdx] == COMPRESSED) ) { in writeAdd()
284 ZSTD_outBuffer output = {compressedBuffers[thrIdx], compressedBufferSizes[thrIdx], 0}; in writeAdd()
343 compressedLength = offsets[thrIdx] - starts[thrIdx]; in writeEnd()
369 offsets[thrIdx] += 1; in writeEnd()
373 size_t length = offsets[thrIdx] - starts[thrIdx]; in writeEnd()
382 writeIndexEntry(key, starts[thrIdx], length, thrIdx); in writeEnd()
398 writeStart(thrIdx); in writeData()
[all …]
|
| H A D | DBWriter.h | 28 void writeStart(unsigned int thrIdx = 0);
29 size_t writeAdd(const char* data, size_t dataSize, unsigned int thrIdx = 0);
30 …void writeEnd(unsigned int key, unsigned int thrIdx = 0, bool addNullByte = true, bool addIndexEnt…
36 void alignToPageSize(int thrIdx = 0);
44 void writeIndexEntry(unsigned int key, size_t offset, size_t length, unsigned int thrIdx);
|
| H A D | DBReader.cpp | 516 template <typename T> char* DBReader<T>::getDataCompressed(size_t id, int thrIdx) { in getDataCompressed() argument
528 ZSTD_outBuffer output = {compressedBuffers[thrIdx], compressedBufferSizes[thrIdx], 0}; in getDataCompressed()
530 size_t toRead = ZSTD_decompressStream(dstream[thrIdx], &output, &input); in getDataCompressed()
537 compressedBuffers[thrIdx][totalSize] = '\0'; in getDataCompressed()
539 memcpy(compressedBuffers[thrIdx], cBuff, cSize); in getDataCompressed()
540 compressedBuffers[thrIdx][cSize] = '\0'; in getDataCompressed()
542 return compressedBuffers[thrIdx]; in getDataCompressed()
556 template <typename T> char* DBReader<T>::getData(size_t id, int thrIdx){ in getData() argument
558 return getDataCompressed(id, thrIdx); in getData()
610 template <typename T> char* DBReader<T>::getDataByDBKey(T dbKey, int thrIdx) { in getDataByDBKey() argument
[all …]
|
| H A D | DBReader.h | 156 char* getData(size_t id, int thrIdx);
158 char* getDataCompressed(size_t id, int thrIdx);
164 char* getDataByDBKey(T key, int thrIdx);
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
| H A D | largehashjoin.cpp | 189 const uint32_t thrIdx = params->thrIdx; in HashJoinByBucket_thr() local
203 cout << "\tJoinByBucket() thr " << dec << thrIdx in HashJoinByBucket_thr()
225 hjPtr->setHashResult(hjPtr->Result2(), thrIdx); in HashJoinByBucket_thr()
233 hjPtr->setHashResult(hjPtr->Result1(), thrIdx); in HashJoinByBucket_thr()
242 hjPtr->createHash(hjPtr->HashSet(thrIdx), in HashJoinByBucket_thr()
243 hjPtr->HashTable(thrIdx), in HashJoinByBucket_thr()
246 hjPtr->HashResult(thrIdx), in HashJoinByBucket_thr()
260 cout << "\t\tJoinByBucket() thr " << dec << thrIdx in HashJoinByBucket_thr()
307 hjPtr->SearchResult(thrIdx)->insert(e); in HashJoinByBucket_thr()
406 hjPtr->SearchResult(thrIdx)->insert(vec1); in HashJoinByBucket_thr()
[all …]
|
| H A D | largehashjoin.h | 162 uint32_t thrIdx;
377 params[idx].thrIdx = idx;
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
| H A D | largehashjoin.cpp | 189 const uint32_t thrIdx = params->thrIdx; in HashJoinByBucket_thr() local
203 cout << "\tJoinByBucket() thr " << dec << thrIdx in HashJoinByBucket_thr()
225 hjPtr->setHashResult(hjPtr->Result2(), thrIdx); in HashJoinByBucket_thr()
233 hjPtr->setHashResult(hjPtr->Result1(), thrIdx); in HashJoinByBucket_thr()
242 hjPtr->createHash(hjPtr->HashSet(thrIdx), in HashJoinByBucket_thr()
243 hjPtr->HashTable(thrIdx), in HashJoinByBucket_thr()
246 hjPtr->HashResult(thrIdx), in HashJoinByBucket_thr()
260 cout << "\t\tJoinByBucket() thr " << dec << thrIdx in HashJoinByBucket_thr()
307 hjPtr->SearchResult(thrIdx)->insert(e); in HashJoinByBucket_thr()
406 hjPtr->SearchResult(thrIdx)->insert(vec1); in HashJoinByBucket_thr()
[all …]
|
| H A D | largehashjoin.h | 162 uint32_t thrIdx;
377 params[idx].thrIdx = idx;
|
| /dports/databases/cego/cego-2.47.11/src/ |
| H A D | CegoTableManager.h | 299 void setPoolSyncInfo(CegoDbThreadPool *pPool, int thrIdx);
|
| H A D | CegoTableManager.cc | 89 void CegoTableManager::setPoolSyncInfo(CegoDbThreadPool *pPool, int thrIdx) in setPoolSyncInfo() argument
92 _thrIdx = thrIdx; in setPoolSyncInfo()
|