MCPcopy Create free account

hub / github.com/Redundancy/go-sync / functions

Functions329 in github.com/Redundancy/go-sync

↓ 43 callersMethodWrite
([]byte)
comparer/comparer.go:26
↓ 25 callersMethodSize
the size of the hash output
filechecksum/filechecksum.go:42
↓ 24 callersMethodSum
Sum appends the current hash to b and returns the resulting slice. It does not change the underlying hash state. Note that this is to allow Sum() to r
rollsum/rollsum_32.go:70
↓ 22 callersFunctionNewFileChecksumGenerator
Uses all default hashes (MD5 & rollsum16)
filechecksum/filechecksum.go:30
↓ 22 callersMethodWrite
cannot be called concurrently
rollsum/rollsum_32.go:34
↓ 17 callersFunctionNewRollsum32
(blocksize uint)
rollsum/rollsum_32.go:16
↓ 17 callersMethodReset
()
filechecksum/filechecksum.go:56
↓ 16 callersFunctionMakeC2Buffer
(blockSize int)
circularbuffer/noalloc.go:38
↓ 15 callersFunctionMakeNullFixedSizeResolver
(blockSize uint64)
blocksources/helpers.go:113
↓ 14 callersMethodError
()
blocksources/blocksourcebase_test.go:16
↓ 13 callersMethodClose
()
rsync.go:54
↓ 13 callersMethodRead
(b []byte)
blocksources/readseeker_blocksource.go:12
↓ 12 callersFunctionMakeChecksumIndex
Builds an index in which chunks can be found, with their corresponding offsets We use this for the
index/index.go:52
↓ 11 callersMethodEvicted
get the data that was evicted by the last write
circularbuffer/noalloc.go:120
↓ 11 callersMethodGetMergedBlocks
Sorted list of blocks, based on StartBlock
comparer/merger.go:251
↓ 11 callersMethodGetMissingBlocks
Creates a list of spans that are missing. note that maxBlock is blockCount-1
comparer/merger.go:271
↓ 11 callersMethodStartMergeResultStream
Can be used on multiple streams of results simultaneously starts working asyncronously, call from the initiating goroutine
comparer/merger.go:127
↓ 10 callersMethodFindWeakChecksumInIndex
(weak []byte)
index/index.go:97
↓ 10 callersFunctioncompare
( original string, modified string, block_size uint, )
comparer/comparer_test.go:70
↓ 10 callersFunctionsplit
Splits successive strings into blocks of size n 2, ABCD -> AB, CD 2, ABCD, E, FG -> AB, CD, E, FG
comparer/comparer_test.go:103
↓ 9 callersFunctionCheckResults
( t *testing.T, original, modified string, results <-chan BlockMatchResult, block_size uint, expectedResu
comparer/comparer_test.go:14
↓ 9 callersMethodLen
()
circularbuffer/noalloc.go:86
↓ 8 callersMethodAddByte
Add a single byte into the rollsum
rollsum/rollsum_32_base.go:25
↓ 8 callersMethodGetBlock
get the current buffer contents of block
circularbuffer/noalloc.go:111
↓ 8 callersMethodGetStrongHash
Gets the Hash function for the strong hash used on each block defaults to md5, but can be overriden by the generator
filechecksum/filechecksum.go:95
↓ 8 callersMethodLen
()
comparer/merger.go:238
↓ 8 callersFunctionLoadChecksumsFromReader
Loads chunks from a reader, assuming alternating weak then strong hashes
chunks/chunks.go:38
↓ 8 callersFunctionNewBlockSourceBase
( requester BlockSourceRequester, resolver BlockSourceOffsetResolver, verifier BlockVerifier, concurrentRe
blocksources/blocksourcebase.go:39
↓ 8 callersFunctionNewNonRepeatingSequence
(i int)
util/readers/nonrepeating.go:17
↓ 8 callersFunctionOneReader
(length int)
util/readers/uniformreader.go:49
↓ 7 callersMethodGenerateChecksums
GenerateChecksums reads each block of the input file, and outputs first the weak, then the strong checksum to the output writer. It will return a chec
filechecksum/filechecksum.go:103
↓ 7 callersMethodGetResultChannel
()
patcher/blocksource.go:31
↓ 7 callersFunctionNewHttpBlockSource
( url string, concurrentRequests int, resolver BlockSourceOffsetResolver, verifier BlockVerifier, )
blocksources/httpblocksource.go:20
↓ 7 callersMethodRequestBlocks
(MissingBlockSpan)
patcher/blocksource.go:29
↓ 7 callersMethodRequestBlocks
(block patcher.MissingBlockSpan)
blocksources/blocksourcebase.go:99
↓ 7 callersMethodStartFindMatchingBlocks
( comparison io.Reader, baseOffset int64, generator *filechecksum.FileChecksumGenerator, referenceIndex In
comparer/comparer.go:64
↓ 6 callersMethodClose
()
blocksources/blocksourcebase.go:115
↓ 6 callersMethodFindStrongChecksum
(strong []byte)
index/index.go:142
↓ 5 callersMethodEncounteredError
If the block source encounters an unsurmountable problem
patcher/blocksource.go:34
↓ 5 callersMethodGetChecksumSizes
()
filechecksum/filechecksum.go:83
↓ 5 callersFunctionNewReadSeekerBlockSource
( r ReadSeeker, resolver BlockSourceOffsetResolver, )
blocksources/readseeker_blocksource.go:16
↓ 5 callersFunctionNewRollsum32Base
Rollsum32Base decouples the rollsum algorithm from the implementation of hash.Hash and the storage the rolling checksum window this allows us to write
rollsum/rollsum_32_base.go:13
↓ 5 callersFunctionNewSizedNonRepeatingSequence
(i int, s int64)
util/readers/nonrepeating.go:21
↓ 4 callersFunctionBuildChecksumIndex
Generates an index from a reader This is mostly a utility function to avoid being overly verbose in tests that need an index to work, but don't want t
indexbuilder/indexbuilder.go:21
↓ 4 callersMethodGetResultChannel
()
blocksources/blocksourcebase.go:104
↓ 4 callersMethodGetSum
Puts the sum into b. Avoids allocation. b must have length >= 4
rollsum/rollsum_32_base.go:83
↓ 4 callersMethodGetSum
(b []byte)
filechecksum/filechecksum.go:55
↓ 4 callersMethodRemoveByte
Remove a byte from the end of the rollsum Use the previous length (before removal)
rollsum/rollsum_32_base.go:39
↓ 4 callersFunctionSequentialPatcher
* This simple example currently doesn't do any pipelining of needed blocks, nor does it deal with blocks being delivered out of order. */
patcher/sequential/sequential.go:23
↓ 4 callersMethodSetBlock
(block []byte)
filechecksum/filechecksum.go:53
↓ 4 callersMethodStartChecksumGeneration
( inputFile io.Reader, blocksPerResult uint, compressionFunction CompressionFunction, )
filechecksum/filechecksum.go:134
↓ 4 callersMethodclear
()
blocksources/helpers.go:53
↓ 4 callersFunctionhandleFileError
(filename string, err error)
cmd/gosync/common.go:85
↓ 4 callersFunctionitemToBlockSpan
(in llrb.Item)
comparer/merger.go:95
↓ 4 callersMethodmaxWritten
the total written, up to the blocksize
circularbuffer/noalloc.go:78
↓ 4 callersMethodmerge
if merged, the block span remaining is the one with the lower start block
comparer/merger.go:106
↓ 3 callersMethodAddBytes
(bs []byte)
rollsum/rollsum_32_base.go:30
↓ 3 callersMethodErr
()
blocksources/helpers.go:28
↓ 3 callersMethodGetBlockSize
()
rsync.go:60
↓ 3 callersFunctionMakeFileSizedBlockResolver
(blockSize uint64, filesize int64)
blocksources/helpers.go:119
↓ 3 callersMethodMatch
compares a checksum to another based on the checksums, not the offset
chunks/chunks.go:26
↓ 3 callersMethodPatch
Patch the files
rsync.go:171
↓ 3 callersMethodPosition
()
comparer/merger.go:35
↓ 3 callersMethodReset
()
rollsum/rollsum_32.go:62
↓ 3 callersMethodSplitBlockRangeToDesiredSize
Split blocks into chunks of the desired size, or less. This implementation assumes a fixed block size at the source.
blocksources/fixed_size_block_resolver.go:26
↓ 3 callersMethodTruncate
Shortens the content of the circular buffer and returns the content removed
circularbuffer/noalloc.go:96
↓ 3 callersMethodVerifyBlockRange
(startBlockID uint, data []byte)
filechecksum/verifier.go:18
↓ 3 callersMethodsendIfSet
()
blocksources/helpers.go:32
↓ 3 callersMethodsetError
(e error)
blocksources/helpers.go:17
↓ 3 callersFunctionstringToReadSeeker
(input string)
patcher/sequential/sequential_test.go:47
↓ 2 callersMethodAddAndRemoveBytes
pairs up bytes to do remove/add in the right order
filechecksum/filechecksum.go:51
↓ 2 callersFunctionBuildIndexFromString
(generator *filechecksum.FileChecksumGenerator, reference string)
indexbuilder/indexbuilder.go:48
↓ 2 callersMethodChecksumSize
()
filechecksum/filechecksum.go:79
↓ 2 callersMethodEndOffset
(blockSize int64)
comparer/merger.go:73
↓ 2 callersMethodFindWeakChecksum2
(chk []byte)
index/index.go:107
↓ 2 callersMethodGetBlockSize
GetBlockSize gets the size of each block
rsync.go:78
↓ 2 callersMethodGetFileSize
()
rsync.go:62
↓ 2 callersMethodSeek
(offset int64, whence int)
blocksources/readseeker_blocksource.go:13
↓ 2 callersMethodSize
the number of bytes
rollsum/rollsum_32.go:58
↓ 2 callersMethodSplitBlockRangeToDesiredSize
(startBlockID, endBlockID uint)
blocksources/blocksourcebase.go:31
↓ 2 callersMethodgetBlockBuffer
()
circularbuffer/noalloc.go:68
↓ 2 callersFunctionopenFileAndHandleError
(filename string)
cmd/gosync/common.go:44
↓ 2 callersFunctionreadHeadersAndCheck
reads the file headers and checks the magic string, then the semantic versioning
cmd/gosync/common.go:164
↓ 2 callersFunctionreadIndex
(r io.Reader, blocksize uint)
cmd/gosync/common.go:211
↓ 2 callersMethodsetResponse
(r *patcher.BlockReponse)
blocksources/helpers.go:45
↓ 2 callersFunctiontoBlockSpan
(b BlockMatchResult)
comparer/merger.go:77
↓ 1 callersMethodAddAndRemoveBytes
(add []byte, remove []byte, length int)
rollsum/rollsum_32_base.go:52
↓ 1 callersMethodClose
Close - close open files, copy to the final location from a temporary one if neede
rsync.go:254
↓ 1 callersMethodDoRequest
This method is called on multiple goroutines, and must support simultaneous requests
blocksources/blocksourcebase.go:17
↓ 1 callersMethodEmpty
()
circularbuffer/noalloc.go:90
↓ 1 callersMethodEncounteredError
If the block source encounters an unsurmountable problem
blocksources/blocksourcebase.go:109
↓ 1 callersMethodFindStrongChecksum2
(chk []byte, weak interface{})
comparer/comparer.go:45
↓ 1 callersMethodFindWeakChecksum2
(bytes []byte)
rsync.go:63
↓ 1 callersMethodFindWeakChecksum2
(chk []byte)
comparer/comparer.go:44
↓ 1 callersMethodGetBlockCount
()
rsync.go:61
↓ 1 callersMethodGetBlockEndOffset
(blockID uint)
blocksources/fixed_size_block_resolver.go:17
↓ 1 callersMethodGetBlockEndOffset
(blockID uint)
blocksources/blocksourcebase.go:30
↓ 1 callersMethodGetBlockStartOffset
(blockID uint)
blocksources/blocksourcebase.go:29
↓ 1 callersMethodGetFileHash
Gets the Hash function for the overall file used on each block defaults to md5
filechecksum/filechecksum.go:89
↓ 1 callersMethodGetFileSize
GetFileSize gets the file size of the file
rsync.go:88
next →1–100 of 329, ranked by callers