crash.software
Projects
Pull Requests
Issues
Builds
dolt
Code
Files
Commits
Branches
Tags
Pull Requests
Code Comments
Code Compare
Issues
List
Boards
Milestones
Builds
Statistics
Contributions
Source Lines
Child Projects
Projects
STRLCPY
dolt
Files
🤬
Sign In
1c3fcbe5
ROOT
/
go
/
store
/
datas
/
pull
/
puller.go
Search
History
569 lines
|
ISO-8859-1
|
13 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
ErrDBUpToDate
ErrIncompatibleSourceChunkStore
maxChunkWorkers
outstandingTableFiles
FilledWriters
wr
:
*nbs.CmpChunkTableWriter
CmpChnkAndRefs
cmpChnk
:
nbs.CompressedChunk
refs
:
map[hash.Hash]bool
Puller
waf
:
WalkAddrs
srcChunkStore
:
nbs.NBSCompressedChunkStore
sinkDBCS
:
chunks.ChunkStore
rootChunkHash
:
hash.Hash
downloaded
:
hash.HashSet
wr
:
*nbs.CmpChunkTableWriter
tablefileSema
:
*semaphore.Weighted
tempDir
:
string
chunksPerTF
:
int
pushLog
:
*log.Logger
statsCh
:
chan Stats
stats
:
*stats
NewPuller
(ctx context.Context, tempDir string, chunksPerTF int, srcCS, sinkCS chunks.ChunkStore, walkAddrs WalkAddrs, rootChunkHash hash.Hash, statsCh chan Stats)
:
(*Puller, error)
readable
Reader
()
:
(io.ReadCloser, error)
Remove
()
:
error
tempTblFile
id
:
string
read
:
readable
numChunks
:
int
chunksLen
:
uint64
contentLen
:
uint64
contentHash
:
[]byte
countingReader
io.ReadCloser
cnt
:
*uint64
Read
(p []byte)
:
(int, error)
emitStats
(s *stats, ch chan Stats)
:
(cancel func())
stats
finishedSendBytes
:
uint64
bufferedSendBytes
:
uint64
sendBytesPerSec
:
uint64
totalSourceChunks
:
uint64
fetchedSourceChunks
:
uint64
fetchedSourceBytes
:
uint64
fetchedSourceBytesPerSec
:
uint64
sendBytesPerSecF
:
float64
fetchedSourceBytesPerSecF
:
float64
Stats
FinishedSendBytes
:
uint64
BufferedSendBytes
:
uint64
SendBytesPerSec
:
float64
TotalSourceChunks
:
uint64
FetchedSourceChunks
:
uint64
FetchedSourceBytes
:
uint64
FetchedSourceBytesPerSec
:
float64
limitToNewChunks
(absent hash.HashSet, downloaded hash.HashSet)
*Puller
Logf
(fmt string, args ...interface{})
uploadTempTableFile
(ctx context.Context, tmpTblFile tempTblFile)
:
error
processCompletedTables
(ctx context.Context, completedTables <-chan FilledWriters)
:
error
Pull
(ctx context.Context)
:
error
getCmp
(ctx context.Context, leaves, batch hash.HashSet, completedTables chan FilledWriters)
:
(hash.HashSet, hash.HashSet, error)
*stats
read
()
:
Stats
All occurrences
Please wait...
Page is in error, reload to recover