Searched refs:blocksThisRead (Results 1 – 4 of 4) sorted by relevance
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/testbc/ |
| H A D | iomanager.cpp | 96 uint32_t dlen = 0, acc, readSize, blocksThisRead, j; in thr_popper() local
161 blocksThisRead = std::min(dlen, iom->blocksPerRead); in thr_popper()
162 readSize = blocksThisRead * BLOCK_SIZE; in thr_popper()
202 blocksRead += blocksThisRead; in thr_popper()
204 for (i = 0; (unsigned)i < blocksThisRead; ++i) in thr_popper()
210 dlen -= blocksThisRead; in thr_popper()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/testbc/ |
| H A D | iomanager.cpp | 96 uint32_t dlen = 0, acc, readSize, blocksThisRead, j; in thr_popper() local
161 blocksThisRead = std::min(dlen, iom->blocksPerRead); in thr_popper()
162 readSize = blocksThisRead * BLOCK_SIZE; in thr_popper()
202 blocksRead += blocksThisRead; in thr_popper()
204 for (i = 0; (unsigned)i < blocksThisRead; ++i) in thr_popper()
210 dlen -= blocksThisRead; in thr_popper()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/primitives/blockcache/ |
| H A D | iomanager.cpp | 432 uint32_t dlen = 0, acc, readSize, blocksThisRead, j; in thr_popper() local
822 blocksThisRead = std::min(dlen, iom->blocksPerRead); in thr_popper()
823 readSize = blocksThisRead * BLOCK_SIZE; in thr_popper()
1026 blocksRead += blocksThisRead; in thr_popper()
1037 for (i = 0; (uint32_t) i < blocksThisRead; i++) in thr_popper()
1050 if (blocksThisRead > 0 && fdit->second->isCompressed()) in thr_popper()
1074 blocksRead -= blocksThisRead; in thr_popper()
1108 memcpy(ptr, &uCmpBuf[cmpOffFact.rem], blocksThisRead * BLOCK_SIZE); in thr_popper()
1183 dlen -= blocksThisRead; in thr_popper()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/primitives/blockcache/ |
| H A D | iomanager.cpp | 432 uint32_t dlen = 0, acc, readSize, blocksThisRead, j; in thr_popper() local
822 blocksThisRead = std::min(dlen, iom->blocksPerRead); in thr_popper()
823 readSize = blocksThisRead * BLOCK_SIZE; in thr_popper()
1026 blocksRead += blocksThisRead; in thr_popper()
1037 for (i = 0; (uint32_t) i < blocksThisRead; i++) in thr_popper()
1050 if (blocksThisRead > 0 && fdit->second->isCompressed()) in thr_popper()
1074 blocksRead -= blocksThisRead; in thr_popper()
1108 memcpy(ptr, &uCmpBuf[cmpOffFact.rem], blocksThisRead * BLOCK_SIZE); in thr_popper()
1183 dlen -= blocksThisRead; in thr_popper()
|