files

package
v0.10.19 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 11, 2015 License: GPL-3.0 Imports: 19 Imported by: 0

Documentation

Overview

Package files provides a set type to track local/remote files with newness checks. We must do a certain amount of normalization in here. We will get fed paths with either native or wire-format separators and encodings depending on who calls us. We transform paths to wire-format (NFC and slashes) on the way to the database, and transform to native format (varying separator and encoding) on the way back out.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BlocksToSize added in v0.10.19 

func BlocksToSize(num uint32) int64

func DropFolder added in v0.10.0 

func DropFolder(db *leveldb.DB, folder string)

DropFolder clears out all information related to the given folder from the database.

func ListFolders added in v0.10.0 

func ListFolders(db *leveldb.DB) []string

ListFolders returns the folder IDs seen in the database.

Types

type BlockFinder added in v0.10.2 

type BlockFinder struct {
	// contains filtered or unexported fields
}

func NewBlockFinder added in v0.10.2 

func NewBlockFinder(db *leveldb.DB, cfg *config.Wrapper) *BlockFinder

func (*BlockFinder) Changed added in v0.10.2 

func (f *BlockFinder) Changed(cfg config.Configuration) error

Implements config.Handler interface

func (*BlockFinder) Fix added in v0.10.4 

func (f *BlockFinder) Fix(folder, file string, index uint32, oldHash, newHash []byte) error

A method for repairing incorrect blockmap entries, removes the old entry and replaces it with a new entry for the given block

func (*BlockFinder) Iterate added in v0.10.2 

func (f *BlockFinder) Iterate(hash []byte, iterFn func(string, string, uint32) bool) bool

An iterator function which iterates over all matching blocks for the given hash. The iterator function has to return either true (if they are happy with the block) or false to continue iterating for whatever reason. The iterator finally returns the result, whether or not a satisfying block was eventually found.

type BlockMap added in v0.10.2 

type BlockMap struct {
	// contains filtered or unexported fields
}

func NewBlockMap added in v0.10.2 

func NewBlockMap(db *leveldb.DB, folder string) *BlockMap

func (*BlockMap) Add added in v0.10.2 

func (m *BlockMap) Add(files []protocol.FileInfo) error

Add files to the block map, ignoring any deleted or invalid files.

func (*BlockMap) Discard added in v0.10.3 

func (m *BlockMap) Discard(files []protocol.FileInfo) error

Discard block map state, removing the given files

func (*BlockMap) Drop added in v0.10.2 

func (m *BlockMap) Drop() error

Drop block map, removing all entries related to this block map from the db.

func (*BlockMap) Update added in v0.10.2 

func (m *BlockMap) Update(files []protocol.FileInfo) error

Update block map state, removing any deleted or invalid files.

type FileInfoTruncated added in v0.10.19 

type FileInfoTruncated struct {
	Name         string // max:8192
	Flags        uint32
	Modified     int64
	Version      uint64
	LocalVersion uint64
	NumBlocks    uint32
}

Used for unmarshalling a FileInfo structure but skipping the block list.

func (FileInfoTruncated) AppendXDR added in v0.10.19 

func (o FileInfoTruncated) AppendXDR(bs []byte) ([]byte, error)

func (*FileInfoTruncated) DecodeXDR added in v0.10.19 

func (o *FileInfoTruncated) DecodeXDR(r io.Reader) error

func (FileInfoTruncated) EncodeXDR added in v0.10.19 

func (o FileInfoTruncated) EncodeXDR(w io.Writer) (int, error)

func (FileInfoTruncated) HasPermissionBits added in v0.10.19 

func (f FileInfoTruncated) HasPermissionBits() bool

func (FileInfoTruncated) IsDeleted added in v0.10.19 

func (f FileInfoTruncated) IsDeleted() bool

func (FileInfoTruncated) IsDirectory added in v0.10.19 

func (f FileInfoTruncated) IsDirectory() bool

func (FileInfoTruncated) IsInvalid added in v0.10.19 

func (f FileInfoTruncated) IsInvalid() bool
func (f FileInfoTruncated) IsSymlink() bool

func (FileInfoTruncated) MarshalXDR added in v0.10.19 

func (o FileInfoTruncated) MarshalXDR() ([]byte, error)

func (FileInfoTruncated) MustMarshalXDR added in v0.10.19 

func (o FileInfoTruncated) MustMarshalXDR() []byte

func (FileInfoTruncated) Size added in v0.10.19 

func (f FileInfoTruncated) Size() int64

Returns a statistical guess on the size, not the exact figure

func (FileInfoTruncated) String added in v0.10.19 

func (f FileInfoTruncated) String() string

func (*FileInfoTruncated) UnmarshalXDR added in v0.10.19 

func (o *FileInfoTruncated) UnmarshalXDR(bs []byte) error

type FileIntf added in v0.10.19 

type FileIntf interface {
	Size() int64
	IsDeleted() bool
	IsInvalid() bool
	IsDirectory() bool
	IsSymlink() bool
	HasPermissionBits() bool
}

FileIntf is the set of methods implemented by both protocol.FileInfo and protocol.FileInfoTruncated.

type Iterator added in v0.10.19 

type Iterator func(f FileIntf) bool

The Iterator is called with either a protocol.FileInfo or a protocol.FileInfoTruncated (depending on the method) and returns true to continue iteration, false to stop.

type Set 

type Set struct {
	// contains filtered or unexported fields
}

func NewSet 

func NewSet(folder string, db *leveldb.DB) *Set

func (*Set) Availability 

func (s *Set) Availability(file string) []protocol.DeviceID

func (*Set) Get 

func (s *Set) Get(device protocol.DeviceID, file string) (protocol.FileInfo, bool)

func (*Set) GetGlobal 

func (s *Set) GetGlobal(file string) (protocol.FileInfo, bool)

func (*Set) GetGlobalTruncated added in v0.10.19 

func (s *Set) GetGlobalTruncated(file string) (FileInfoTruncated, bool)

func (*Set) LocalVersion 

func (s *Set) LocalVersion(device protocol.DeviceID) uint64

func (*Set) Replace 

func (s *Set) Replace(device protocol.DeviceID, fs []protocol.FileInfo)

func (*Set) ReplaceWithDelete 

func (s *Set) ReplaceWithDelete(device protocol.DeviceID, fs []protocol.FileInfo)

func (*Set) Update 

func (s *Set) Update(device protocol.DeviceID, fs []protocol.FileInfo)

func (*Set) WithGlobal 

func (s *Set) WithGlobal(fn Iterator)

func (*Set) WithGlobalTruncated 

func (s *Set) WithGlobalTruncated(fn Iterator)

func (*Set) WithHave 

func (s *Set) WithHave(device protocol.DeviceID, fn Iterator)

func (*Set) WithHaveTruncated 

func (s *Set) WithHaveTruncated(device protocol.DeviceID, fn Iterator)

func (*Set) WithNeed 

func (s *Set) WithNeed(device protocol.DeviceID, fn Iterator)

func (*Set) WithNeedTruncated 

func (s *Set) WithNeedTruncated(device protocol.DeviceID, fn Iterator)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.