Searched refs:readWork (Results 1 – 6 of 6) sorted by relevance
| /dports/devel/tbb/oneTBB-2020.3/examples/graph/fgbzip2/ |
| H A D | fgbzip2.cpp | 254 work_type readWork = { bufferMsg, msg }; in submitRead() local
255 m_readQueue.push(readWork); in submitRead()
274 work_type readWork; in readingLoop() local
275 m_readQueue.pop(readWork); in readingLoop()
281 readWork.bufferMsg.seqId = m_io.chunksRead(); in readingLoop()
282 m_io.readChunk(readWork.bufferMsg.inputBuffer); in readingLoop()
283 readWork.msg.set(readWork.bufferMsg); in readingLoop()
284 m_readQueue.pop(readWork); in readingLoop()
288 sendLastMessage(readWork); in readingLoop()
|
| /dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/examples/graph/fgbzip2/ |
| H A D | fgbzip2.cpp | 254 work_type readWork = { bufferMsg, msg }; in submitRead() local
255 m_readQueue.push(readWork); in submitRead()
274 work_type readWork; in readingLoop() local
275 m_readQueue.pop(readWork); in readingLoop()
281 readWork.bufferMsg.seqId = m_io.chunksRead(); in readingLoop()
282 m_io.readChunk(readWork.bufferMsg.inputBuffer); in readingLoop()
283 readWork.msg.set(readWork.bufferMsg); in readingLoop()
284 m_readQueue.pop(readWork); in readingLoop()
288 sendLastMessage(readWork); in readingLoop()
|
| /dports/net/rclone/rclone-1.57.0/vendor/github.com/pkg/sftp/ |
| H A D | client.go | 1263 type readWork struct {
1270 readCh := make(chan readWork)
1284 readWork := readWork{
1301 case readCh <- readWork:
1317 for readWork := range readCh {
1321 s := <-readWork.res
1322 resPool.Put(readWork.res)
1332 if readWork.id != sid {
1349 off: readWork.off,
1352 next: readWork.next,
[all …]
|
| /dports/sysutils/restic/restic-0.12.1/vendor/github.com/pkg/sftp/ |
| H A D | client.go | 1263 type readWork struct {
1270 readCh := make(chan readWork)
1284 readWork := readWork{
1301 case readCh <- readWork:
1317 for readWork := range readCh {
1321 s := <-readWork.res
1322 resPool.Put(readWork.res)
1332 if readWork.id != sid {
1349 off: readWork.off,
1352 next: readWork.next,
[all …]
|
| /dports/ftp/sftpgo/sftpgo-2.2.0/vendor/github.com/pkg/sftp/ |
| H A D | client.go | 1263 type readWork struct {
1270 readCh := make(chan readWork)
1284 readWork := readWork{
1301 case readCh <- readWork:
1317 for readWork := range readCh {
1321 s := <-readWork.res
1322 resPool.Put(readWork.res)
1332 if readWork.id != sid {
1349 off: readWork.off,
1352 next: readWork.next,
[all …]
|
| /dports/databases/litestream/litestream-0.3.6/vendor/github.com/pkg/sftp/ |
| H A D | client.go | 1202 type readWork struct {
1206 readCh := make(chan readWork)
1218 readWork := readWork{
1225 case readCh <- readWork:
1249 for readWork := range readCh {
1252 n, err := f.readChunkAt(ch, b, readWork.off)
1260 off: readWork.off,
1263 next: readWork.next,
1267 case readWork.cur <- writeWork:
|