Searched refs:curPos (Results 1 – 6 of 6) sorted by relevance
1515 job->curPos = 0; in JobExec() 1804 nRead = read(job->inPipe, &job->outBuf[job->curPos],1805 JOB_BUFSIZE - job->curPos);1823 if (nr == 0 && job->curPos != 0) { in CollectOutput() 1824 job->outBuf[job->curPos] = '\n'; in CollectOutput() 1828 max = job->curPos + nr; in CollectOutput() 1829 for (i = job->curPos; i < max; i++) in CollectOutput() 1834 for (i = job->curPos + nr - 1; in CollectOutput() 1835 i >= job->curPos && i != (size_t)-1; i--) { in CollectOutput() 1843 job->curPos in CollectOutput() [all...]
175 size_t curPos; /* Current position in outBuf. */ member
2673 size_t curPos = 0; in reduce() local2680 task._args[3] = min(len, curPos + workUnitSize); // upper bound. in reduce()2682 task._args[2] = curPos; // lower bound. in reduce()2684 curPos += workUnitSize; in reduce()
2779 size_t curPos = 0; in reduce() local2791 curPos, // lower bound. in reduce()2792 cast() min(len, curPos + workUnitSize) // upper bound. in reduce()2797 curPos += workUnitSize; in reduce()
3721 sizediff_t curPos = 0; variable3725 ++curPos;3729 minPos = curPos;
4020 ptrdiff_t curPos = 0; variable4024 ++curPos;4028 minPos = curPos;