| /dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/netsync/ |
| H A D | manager.go | 147 requestedBlocks map[chainhash.Hash]struct{} member
170 requestedBlocks map[chainhash.Hash]struct{} member
410 requestedBlocks: make(map[chainhash.Hash]struct{}),
511 for blockHash := range state.requestedBlocks {
512 delete(sm.requestedBlocks, blockHash)
680 delete(state.requestedBlocks, *blockHash)
681 delete(sm.requestedBlocks, *blockHash)
793 len(state.requestedBlocks) < minInFlightBlocks {
866 sm.requestedBlocks[*node.hash] = struct{}{}
1205 sm.requestedBlocks[iv.Hash] = struct{}{}
[all …]
|
| /dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/netsync/ |
| H A D | manager.go | 147 requestedBlocks map[chainhash.Hash]struct{} member
170 requestedBlocks map[chainhash.Hash]struct{} member
410 requestedBlocks: make(map[chainhash.Hash]struct{}),
511 for blockHash := range state.requestedBlocks {
512 delete(sm.requestedBlocks, blockHash)
680 delete(state.requestedBlocks, *blockHash)
681 delete(sm.requestedBlocks, *blockHash)
793 len(state.requestedBlocks) < minInFlightBlocks {
866 sm.requestedBlocks[*node.hash] = struct{}{}
1205 sm.requestedBlocks[iv.Hash] = struct{}{}
[all …]
|
| /dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/netsync/ |
| H A D | manager.go | 147 requestedBlocks map[chainhash.Hash]struct{} member
170 requestedBlocks map[chainhash.Hash]struct{} member
410 requestedBlocks: make(map[chainhash.Hash]struct{}),
511 for blockHash := range state.requestedBlocks {
512 delete(sm.requestedBlocks, blockHash)
680 delete(state.requestedBlocks, *blockHash)
681 delete(sm.requestedBlocks, *blockHash)
793 len(state.requestedBlocks) < minInFlightBlocks {
866 sm.requestedBlocks[*node.hash] = struct{}{}
1205 sm.requestedBlocks[iv.Hash] = struct{}{}
[all …]
|
| /dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/netsync/ |
| H A D | manager.go | 147 requestedBlocks map[chainhash.Hash]struct{} member
170 requestedBlocks map[chainhash.Hash]struct{} member
410 requestedBlocks: make(map[chainhash.Hash]struct{}),
511 for blockHash := range state.requestedBlocks {
512 delete(sm.requestedBlocks, blockHash)
680 delete(state.requestedBlocks, *blockHash)
681 delete(sm.requestedBlocks, *blockHash)
793 len(state.requestedBlocks) < minInFlightBlocks {
866 sm.requestedBlocks[*node.hash] = struct{}{}
1205 sm.requestedBlocks[iv.Hash] = struct{}{}
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/btcsuite/btcd/netsync/ |
| H A D | manager.go | 147 requestedBlocks map[chainhash.Hash]struct{} member
170 requestedBlocks map[chainhash.Hash]struct{} member
410 requestedBlocks: make(map[chainhash.Hash]struct{}),
511 for blockHash := range state.requestedBlocks {
512 delete(sm.requestedBlocks, blockHash)
680 delete(state.requestedBlocks, *blockHash)
681 delete(sm.requestedBlocks, *blockHash)
793 len(state.requestedBlocks) < minInFlightBlocks {
866 sm.requestedBlocks[*node.hash] = struct{}{}
1205 sm.requestedBlocks[iv.Hash] = struct{}{}
[all …]
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/btcsuite/btcd/netsync/ |
| H A D | manager.go | 147 requestedBlocks map[chainhash.Hash]struct{} member
170 requestedBlocks map[chainhash.Hash]struct{} member
410 requestedBlocks: make(map[chainhash.Hash]struct{}),
511 for blockHash := range state.requestedBlocks {
512 delete(sm.requestedBlocks, blockHash)
680 delete(state.requestedBlocks, *blockHash)
681 delete(sm.requestedBlocks, *blockHash)
793 len(state.requestedBlocks) < minInFlightBlocks {
866 sm.requestedBlocks[*node.hash] = struct{}{}
1205 sm.requestedBlocks[iv.Hash] = struct{}{}
[all …]
|
| /dports/games/spring/spring_98.0/rts/System/Sync/ |
| H A D | SyncDebugger.cpp | 338 requestedBlocks = pendingBlocksToRequest; in ServerQueueBlockRequests()
356 …equest(pendingBlocksToRequest.front(), requestedBlocks.size() - pendingBlocksToRequest.size() + 1,… in ServerHandlePendingBlockRequests()
408 …for (; virtualBlockNr < requestedBlocks.size() && requestedBlocks[virtualBlockNr] != blockNr; ++vi… in ServerDumpStack()
411 if (virtualBlockNr >= requestedBlocks.size()) in ServerDumpStack()
430 blockNr = requestedBlocks[virtualBlockNr]; in ServerDumpStack()
|
| H A D | SyncDebugger.h | 111 std::deque<unsigned> requestedBlocks; ///< We are processing these blocks. variable
|
| /dports/converters/wkhtmltopdf/qt-5db36ec/examples/network/torrent/ |
| H A D | torrentclient.cpp | 72 QBitArray requestedBlocks; member in TorrentPiece
317 piece->requestedBlocks.resize(completed.size()); in setDumpedState()
608 piece->requestedBlocks.fill(false); in pieceVerified()
870 piece->requestedBlocks.fill(false); in removeClient()
949 inProgress += it.value()->requestedBlocks.count(true); in peerPiecesAvailable()
1018 piece->requestedBlocks.clearBit(blockBit); in blockReceived()
1308 piece->requestedBlocks.resize(numBlocks); in schedulePieceForClient()
1366 if (!piece->completedBlocks.testBit(i) && !piece->requestedBlocks.testBit(i)) in requestBlocks()
1405 piece->requestedBlocks.setBit(bits.at(i)); in requestBlocks()
1423 it.value()->requestedBlocks.fill(false); in peerChoked()
|
| /dports/misc/qt5-examples/qt-everywhere-src-5.15.2/qtbase/examples/network/torrent/ |
| H A D | torrentclient.cpp | 80 QBitArray requestedBlocks; member
327 piece->requestedBlocks.resize(completed.size()); in setDumpedState()
618 piece->requestedBlocks.fill(false); in pieceVerified()
879 piece->requestedBlocks.fill(false); in removeClient()
962 inProgress += it.value()->requestedBlocks.count(true); in peerPiecesAvailable()
1031 piece->requestedBlocks.clearBit(blockBit); in blockReceived()
1321 piece->requestedBlocks.resize(numBlocks); in schedulePieceForClient()
1379 if (!piece->completedBlocks.testBit(i) && !piece->requestedBlocks.testBit(i)) in requestBlocks()
1418 piece->requestedBlocks.setBit(bits.at(i)); in requestBlocks()
1436 it.value()->requestedBlocks.fill(false); in peerChoked()
|