db

Documentation

Index

• Variables
• type Event
• type FDescCache
• type FSControllerCache
  • func NewFSControllerCache(noRemove bool) *FSControllerCache
  • func (f *FSControllerCache) AcquireRead(path string, p []byte, off int64) (n int, err error)
  • func (f *FSControllerCache) RemoveFile(path string) (err error)
• type Node
• type OsFs
  • func (o *OsFs) Delete(name string) error
  • func (o *OsFs) Exists(name string) bool
  • func (o *OsFs) GetController() storage.FSController
  • func (o *OsFs) Open(name string, mode storage.OpenMode) (storage.FSFile, error)
• type Storage
  • func NewStorage(db *leveldb.DB, connector storage.NetConnector, forcePieceSize int, ...) (*Storage, error)
  • func (s *Storage) DetectFileRefs(path string) (rootPath string, dirName string, _ []storage.FileRef, _ error)
  • func (s *Storage) GetActiveFiles(bagId []byte) ([]uint32, error)
  • func (s *Storage) GetAll() []*storage.Torrent
  • func (s *Storage) GetAllFilesRefsInDir(path string) ([]storage.FileRef, error)
  • func (s *Storage) GetFS() storage.FS
  • func (s *Storage) GetForcedPieceSize() uint32
  • func (s *Storage) GetPiece(bagId []byte, id uint32) (*storage.PieceInfo, error)
  • func (s *Storage) GetSingleFileRef(path string) (storage.FileRef, error)
  • func (s *Storage) GetSpeedLimits() (download uint64, upload uint64, err error)
  • func (s *Storage) GetTorrent(hash []byte) *storage.Torrent
  • func (s *Storage) GetTorrentByOverlay(overlay []byte) *storage.Torrent
  • func (s *Storage) PiecesMask(bagId []byte, num uint32) []byte
  • func (s *Storage) RemovePiece(bagId []byte, id uint32) error
  • func (s *Storage) RemoveTorrent(t *storage.Torrent, withFiles bool) error
  • func (s *Storage) SetActiveFiles(bagId []byte, ids []uint32) error
  • func (s *Storage) SetPiece(bagId []byte, id uint32, p *storage.PieceInfo) error
  • func (s *Storage) SetSpeedLimits(download, upload uint64) error
  • func (s *Storage) SetTorrent(t *storage.Torrent) error
  • func (s *Storage) UpdateUploadStats(bagId []byte, val uint64) error
  • func (s *Storage) VerifyOnStartup() bool
• type TorrentStored

Variables

var CachedFDLimit = 800

Types

type Event

type Event int

const (
	EventTorrentUpdated Event = iota
	EventUploadUpdated
)

type FDescCache

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

type FSControllerCache

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

FSControllerCache caches file descriptors to avoid unnecessary open/close of most used files

func NewFSControllerCache

func NewFSControllerCache(noRemove bool) *FSControllerCache

func (*FSControllerCache) AcquireRead

func (f *FSControllerCache) AcquireRead(path string, p []byte, off int64) (n int, err error)

func (*FSControllerCache) RemoveFile

func (f *FSControllerCache) RemoveFile(path string) (err error)

type Node

type Node struct {
	Id       string
	Children []*Node
}

type OsFs

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

func (*OsFs) Delete

func (o *OsFs) Delete(name string) error

func (*OsFs) Exists

func (o *OsFs) Exists(name string) bool

func (*OsFs) GetController

func (o *OsFs) GetController() storage.FSController

func (*OsFs) Open

func (o *OsFs) Open(name string, mode storage.OpenMode) (storage.FSFile, error)

type Storage

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

func NewStorage

func NewStorage(db *leveldb.DB, connector storage.NetConnector, forcePieceSize int, startWithoutActiveFilesToo bool, skipVerify bool, noRemove bool, notifier chan Event) (*Storage, error)

func (*Storage) DetectFileRefs

func (s *Storage) DetectFileRefs(path string) (rootPath string, dirName string, _ []storage.FileRef, _ error)

func (*Storage) GetActiveFiles

func (s *Storage) GetActiveFiles(bagId []byte) ([]uint32, error)

func (*Storage) GetAll

func (s *Storage) GetAll() []*storage.Torrent

func (*Storage) GetAllFilesRefsInDir

func (s *Storage) GetAllFilesRefsInDir(path string) ([]storage.FileRef, error)

func (*Storage) GetFS

func (s *Storage) GetFS() storage.FS

func (*Storage) GetForcedPieceSize

func (s *Storage) GetForcedPieceSize() uint32

func (*Storage) GetPiece

func (s *Storage) GetPiece(bagId []byte, id uint32) (*storage.PieceInfo, error)

func (*Storage) GetSingleFileRef

func (s *Storage) GetSingleFileRef(path string) (storage.FileRef, error)

func (*Storage) GetSpeedLimits

func (s *Storage) GetSpeedLimits() (download uint64, upload uint64, err error)

func (*Storage) GetTorrent

func (s *Storage) GetTorrent(hash []byte) *storage.Torrent

func (*Storage) GetTorrentByOverlay

func (s *Storage) GetTorrentByOverlay(overlay []byte) *storage.Torrent

func (*Storage) PiecesMask

func (s *Storage) PiecesMask(bagId []byte, num uint32) []byte

func (*Storage) RemovePiece

func (s *Storage) RemovePiece(bagId []byte, id uint32) error

func (*Storage) RemoveTorrent

func (s *Storage) RemoveTorrent(t *storage.Torrent, withFiles bool) error

func (*Storage) SetActiveFiles

func (s *Storage) SetActiveFiles(bagId []byte, ids []uint32) error

func (*Storage) SetPiece

func (s *Storage) SetPiece(bagId []byte, id uint32, p *storage.PieceInfo) error

func (*Storage) SetSpeedLimits

func (s *Storage) SetSpeedLimits(download, upload uint64) error

func (*Storage) SetTorrent

func (s *Storage) SetTorrent(t *storage.Torrent) error

func (*Storage) UpdateUploadStats

func (s *Storage) UpdateUploadStats(bagId []byte, val uint64) error

func (*Storage) VerifyOnStartup

func (s *Storage) VerifyOnStartup() bool

type TorrentStored

type TorrentStored struct {
	BagID     []byte
	Path      string
	Info      *storage.TorrentInfo
	Header    *storage.TorrentHeader
	CreatedAt time.Time

	ActiveUpload    bool
	ActiveDownload  bool
	DownloadAll     bool
	DownloadOrdered bool
}