goed2k

package module

Go to main page

Versions in this module

v0

v0.1.3

Aug 2, 2026

Changes in this version

+ const PeerWeb

+ func AllocEmuleTempPartSlot(tempDir string) (slot int, partPath string, err error)

+ func ApplyEmulePreferences(settings *Settings, prefs EmulePreferences)

+ func EmuleTempPartPath(tempDir string, slot int) string

+ func ResolveEmuleDownloadPath(settings Settings, outDir, filename string) (path string, cleanup func(), err error)

type AddTransferParams

+ HttpSources []string

type Client

+ func (c *Client) AddHttpSource(hash protocol.Hash, sourceURL string) error

+ func (c *Client) ImportEmulePreferences(path string) error

+ func (c *Client) ImportPartMet(path string) (PartMetInfo, error)

type ClientTransferState

+ HttpSources []string

+ type EmulePreferences struct

+ AllocFull bool

+ ClientName string

+ EnableDHT bool

+ EnableKad bool

+ IncomingDir string

+ ListenPort int

+ MaxDownloadRateKB int

+ MaxUploadRateKB int

+ ModName string

+ NickName string

+ ServerHost string

+ ServerPort int

+ SparseFiles bool

+ TempDir string

+ UDPPort int

+ func LoadEmulePreferences(path string) (EmulePreferences, error)

+ func ParseEmulePreferencesINI(text string) (EmulePreferences, error)

type IPFilter

+ func ParseEmuleIPFilter(text string, filterLevel int) (*IPFilter, error)

+ func ParseIPFilterBytes(raw []byte) (*IPFilter, error)

+ func (f *IPFilter) FilterLevel() int

+ func (f *IPFilter) Ranges() []IPFilterRange

+ func (f *IPFilter) SetFilterLevel(level int)

+ type IPFilterRange struct

+ AccessLevel int

+ Description string

+ End net.IP

+ Start net.IP

type PartMetDocument

+ FileHash protocol.Hash

+ FileSize int64

+ HttpSources []string

+ type PartMetInfo struct

+ FileSize int64

+ Filename string

+ Hash protocol.Hash

+ HttpSources []string

+ Resume *protocol.TransferResumeData

+ func ImportEmulePartMetFromSlot(partPath string) (PartMetInfo, error)

+ func ImportPartMet(path string) (PartMetInfo, error)

+ func ParsePartMetBytes(raw []byte) (PartMetInfo, error)

type Peer

+ func (p Peer) ToSourceExchangeEntry(sx1Ver int, sx2Version byte, cryptOptions uint8) (clientproto.SourceExchangeEntry, bool)

type PeerConnection

+ func (p *PeerConnection) FlushOutgoing() error

+ func (p *PeerConnection) HandleAnswerSources(ans *clientproto.AnswerSources)

+ func (p *PeerConnection) HandleClientRequestPreview(req *clientproto.RequestPreview)

+ func (p *PeerConnection) HandlePreviewAnswer(ans *clientproto.PreviewAnswer)

+ func (p *PeerConnection) HandleRequestSources(req *clientproto.RequestSources)

+ func (p *PeerConnection) SendRequestPreview(hash protocol.Hash, pieceIndex uint16)

+ func (p *PeerConnection) SendRequestSources(hash protocol.Hash) error

type RemotePeerInfo

+ SourceExchange2Ver byte

type ServerConnection

+ func (s *ServerConnection) SendFileSourcesObfuRequest(hash protocol.Hash, size int64)

type Session

+ func (s *Session) IsUDPReachable() bool

+ func (s *Session) SendUDPReaskPing(addr *net.UDPAddr) error

type Settings

+ EnableWebDownload bool

+ HttpRequestTimeoutSec int

+ MaxConcurrentHttpBlocks int

+ MaxHttpSources int

+ PartialKadPublish bool

+ PreallocateDiskSpace bool

+ UseEmuleTempLayout bool

+ UseSparseFiles bool

+ WebCacheDir string

type Transfer

+ func (t *Transfer) AddHttpSource(rawURL string) error

+ func (t *Transfer) HttpSources() []string

+ func (t *Transfer) PreviewPiece(index uint16) ([]byte, bool)

+ func (t *Transfer) StorePreviewPiece(index uint16, data []byte)

v0.1.2

Jul 29, 2026

Changes in this version

+ func DefaultIdentityKeyPath() string

+ func EnsureIdentityKeyForSecIdent(settings *Settings) string

+ func FormatCategoriesConfig(categories []Category) string

type AddTransferParams

+ FileComment string

type Category

+ func ParseCategoriesConfig(raw string) ([]Category, error)

type Client

+ func (c *Client) LoadIdentity(path string) error

+ func (c *Client) SettingsSnapshot() PublicSettings

+ func (c *Client) SharedFileSnapshots() []SharedFileSnapshot

+ type ClientCategoryState struct

+ AutoExtension string

+ Name string

+ OutputDir string

type ClientState

+ Categories []ClientCategoryState

+ type PublicSettings struct

+ CategoryCount int

+ CreditsOnlyVerified bool

+ CryptLayerRequired bool

+ EnableCryptLayer bool

+ EnableDHT bool

+ EnableDHTv6 bool

+ EnableSecIdent bool

+ EnableUPnP bool

+ IdentityKeyPath string

+ ListenPort int

+ MaxDownloadRateKB int

+ MaxUploadRateKB int

+ SecIdentRequired bool

+ UDPPort int

+ UDPPortV6 int

+ type SharedFileSnapshot struct

+ Completed bool

+ Hash string

+ Name string

+ Path string

+ Size int64

type Transfer

+ func (t *Transfer) FileComment() string

v0.1.0

Jul 29, 2026

Changes in this version

+ const AICHBlockSize

+ const AICHBlocksPerPiece

+ const AICHLastBlockSize

+ const AICHPieceSize

+ const PeerKADV6

+ const SecIdentStateKeyAndSigNeeded

+ const SecIdentStateSignatureNeeded

+ const SecIdentStateUnavailable

+ const SecIdentWireVersion

+ func AICHBlockCount(size int64) int

+ func AICHRequestMarker(pieceIndex, blockIndex int) protocol.AICHHash

+ func BuildAICHBlockHashes(data []byte) []protocol.AICHHash

+ func BuildAICHPieceRoot(pieceData []byte) protocol.AICHHash

+ func BuildAICHRootFromData(data []byte) protocol.AICHHash

+ func BuildAICHRootFromFile(path string) (protocol.AICHHash, error)

+ func BuildAICHRootFromReader(r io.Reader, size int64) (protocol.AICHHash, error)

+ func BuildAICHTreeRoot(leaves []protocol.AICHHash) protocol.AICHHash

+ func ComputeAICHHash(data []byte) protocol.AICHHash

+ func DecodeAICHRequestMarker(h protocol.AICHHash) (pieceIndex, blockIndex int, ok bool)

+ func ExportPartMet(path string, resume *protocol.TransferResumeData) error

+ func LocateCorruptAICHBlocks(pieceData []byte, blockHashes []protocol.AICHHash) []int

+ func NewOutgoingClientObfuscatedConn(conn net.Conn, peerUserHash protocol.Hash) (net.Conn, error)

+ func NewOutgoingServerObfuscatedConn(conn net.Conn) (net.Conn, error)

+ func PublicKeyFingerprint(pubDER []byte) uint32

+ func ResolveCategoryOutputDir(categories []Category, filename, defaultDir string) string

+ func SHA1Sum(data []byte) [sha1.Size]byte

+ func UserHashFromPublicKey(pubDER []byte) (protocol.Hash, error)

+ func VerifyAICHBlock(pieceData []byte, expected protocol.AICHHash) bool

+ func VerifySecIdentSignature(senderPubKey []byte, localPubKey []byte, challenge uint32, signature []byte) error

+ func WrapIncomingObfuscatedConn(conn net.Conn, localUserHash protocol.Hash, forceObfuscated, required bool) net.Conn

+ type AICHHasher struct

+ func NewAICHHasher() *AICHHasher

+ func (h *AICHHasher) Sum() protocol.AICHHash

+ func (h *AICHHasher) Write(p []byte) (int, error)

type AddTransferParams

+ AICHRootHash protocol.AICHHash

+ PieceHashes []protocol.Hash

+ type Category struct

+ AutoExtension string

+ Name string

+ OutputDir string

+ func MatchCategory(categories []Category, filename string) *Category

type Client

+ func (c *Client) AddCollectionLink(linkValue, outputDir string) (CollectionAddResult, error)

+ func (c *Client) AddDHTv6BootstrapNodes(nodes ...string) error

+ func (c *Client) BanPeer(endpoint protocol.Endpoint) error

+ func (c *Client) DHTv6Status() KADV6Status

+ func (c *Client) EnableDHTv6() *KADV6Tracker

+ func (c *Client) ExportPartMetForTransfer(hash protocol.Hash) error

+ func (c *Client) GetDHTv6Tracker() *KADV6Tracker

+ func (c *Client) LoadDHTv6NodesDat(path ...string) error

+ func (c *Client) LoadIPFilter(path string) error

+ func (c *Client) PublishDHTv6Keyword(keywordHash protocol.Hash, entries ...kadv6proto.SearchEntry) bool

+ func (c *Client) PublishDHTv6Notes(fileHash protocol.Hash, entries ...kadv6proto.SearchEntry) bool

+ func (c *Client) PublishDHTv6Source(hash protocol.Hash, tcpAddr *net.TCPAddr, size int64) bool

+ func (c *Client) SearchDHTNotes(fileHash protocol.Hash, cb func([]kadproto.SearchEntry)) bool

+ func (c *Client) SearchDHTv6Keywords(keywordHash protocol.Hash, cb func([]kadv6proto.SearchEntry)) bool

+ func (c *Client) SearchDHTv6Notes(fileHash protocol.Hash, cb func([]kadv6proto.SearchEntry)) bool

+ func (c *Client) SearchDHTv6Sources(hash protocol.Hash, size int64, cb func([]kadv6proto.SearchEntry)) bool

+ func (c *Client) SetDHTv6StoragePoint(address string) error

+ func (c *Client) SetDHTv6Tracker(tracker *KADV6Tracker)

+ func (c *Client) SetIPFilter(filter *IPFilter)

+ func (c *Client) SetTransferPriority(hash protocol.Hash, priority TransferPriority) error

+ type ClientDHTv6NodeState struct

+ Addr string

+ FailCount int

+ FirstSeen int64

+ HelloSent bool

+ ID protocol.Hash

+ LastSeen int64

+ Pinged bool

+ Seed bool

+ TCPPort uint16

+ Version byte

+ type ClientDHTv6State struct

+ LastBootstrap int64

+ LastRefresh int64

+ Nodes []ClientDHTv6NodeState

+ RouterNodes []string

+ SelfID protocol.Hash

+ StoragePoint string

type ClientState

+ BannedPeers []protocol.Endpoint

+ DHTv6 *ClientDHTv6State

+ IdentityKeyPath string

+ IdentityVersion int

type ClientTransferState

+ DownloadPrio TransferPriority

+ type CollectionAddResult struct

+ Handles []TransferHandle

+ TargetPath []string

type DHTTracker

+ func (t *DHTTracker) SearchNotes(hash protocol.Hash, cb func([]kadproto.SearchEntry)) bool

+ func (t *DHTTracker) SetED2KUDPHandler(h func(*net.UDPAddr, []byte))

+ func (t *DHTTracker) UDPConn() *net.UDPConn

type EMuleLink

+ AICHRootHash protocol.AICHHash

+ FileLinks []EMuleLink

+ PartHashes []protocol.Hash

+ func ParseEMuleCollectionContent(content string) ([]EMuleLink, error)

+ func ParseEMuleCollectionFile(path string) ([]EMuleLink, error)

+ type IPFilter struct

+ func LoadIPFilter(path string) (*IPFilter, error)

+ func NewIPFilter() *IPFilter

+ func ParseIPFilter(text string) (*IPFilter, error)

+ func (f *IPFilter) Contains(ip net.IP) bool

+ func (f *IPFilter) IsEmpty() bool

+ type IdentityState struct

+ Version int

+ func GenerateIdentityKeyPair(path string) (*IdentityState, error)

+ func LoadIdentityState(path string) (*IdentityState, error)

+ func NewIdentityState() *IdentityState

+ func (id *IdentityState) Available() bool

+ func (id *IdentityState) Fingerprint() uint32

+ func (id *IdentityState) KeyPath() string

+ func (id *IdentityState) LinkUserHash(hash protocol.Hash)

+ func (id *IdentityState) PublicKeyDER() []byte

+ func (id *IdentityState) SignChallenge(remotePubKey []byte, challenge uint32) ([]byte, error)

+ func (id *IdentityState) UserHash() protocol.Hash

+ type KADV6RoutingNode struct

+ Addr *net.UDPAddr

+ FailCount int

+ FirstSeen time.Time

+ HelloSent bool

+ ID kadv6proto.ID

+ LastSeen time.Time

+ Pinged bool

+ Seed bool

+ TCPPort uint16

+ Version byte

+ func (n *KADV6RoutingNode) Key() string

+ func (n *KADV6RoutingNode) KnownID() bool

+ type KADV6Status struct

+ Bootstrapped bool

+ InitialBootstrap bool

+ KnownNodes int

+ ListenPort int

+ LiveNodes int

+ ReplacementNodes int

+ RouterNodes int

+ RunningTraversals int

+ StoragePoint string

+ type KADV6Tracker struct

+ func NewKADV6Tracker(listenPort int, timeout time.Duration) *KADV6Tracker

+ func (t *KADV6Tracker) AddNode(addr *net.UDPAddr)

+ func (t *KADV6Tracker) AddNodes(addrs ...*net.UDPAddr)

+ func (t *KADV6Tracker) ApplyNodesDat(nodes *kadv6proto.NodesDat) error

+ func (t *KADV6Tracker) ApplyState(state *ClientDHTv6State) error

+ func (t *KADV6Tracker) Close()

+ func (t *KADV6Tracker) ListenPort() int

+ func (t *KADV6Tracker) LoadNodesDat(path string) error

+ func (t *KADV6Tracker) PublishKeyword(keywordHash protocol.Hash, entries ...kadv6proto.SearchEntry) bool

+ func (t *KADV6Tracker) PublishNotes(fileHash protocol.Hash, entries ...kadv6proto.SearchEntry) bool

+ func (t *KADV6Tracker) PublishSource(hash protocol.Hash, tcpAddr *net.TCPAddr, size int64) bool

+ func (t *KADV6Tracker) SearchKeywords(hash protocol.Hash, cb func([]kadv6proto.SearchEntry)) bool

+ func (t *KADV6Tracker) SearchNotes(hash protocol.Hash, cb func([]kadv6proto.SearchEntry)) bool

+ func (t *KADV6Tracker) SearchSources(hash protocol.Hash, size int64, cb func([]kadv6proto.SearchEntry)) bool

+ func (t *KADV6Tracker) SetStoragePoint(addr *net.UDPAddr)

+ func (t *KADV6Tracker) SnapshotState() *ClientDHTv6State

+ func (t *KADV6Tracker) Start() error

+ func (t *KADV6Tracker) Status() KADV6Status

+ func (t *KADV6Tracker) UDPConn() *net.UDPConn

type LinkType

+ const LinkCollection

+ type ObfuscatedConn struct

+ func (o *ObfuscatedConn) Read(p []byte) (int, error)

+ func (o *ObfuscatedConn) Write(p []byte) (int, error)

+ type PartMetDocument struct

+ CompletedPieces []bool

+ DownloadedBlocks []partMetBlock

+ Format string

+ KnownPeers []string

+ PieceHashes []protocol.Hash

+ Version int

type Peer

+ CryptOptions uint8

+ ServerClientID int32

+ UserHash protocol.Hash

type PeerConnection

+ func (p *PeerConnection) HandleAICHAnswer(value *clientproto.AICHAnswer)

+ func (p *PeerConnection) HandleAICHFileHashAnswer(value *clientproto.AICHFileHashAnswer)

+ func (p *PeerConnection) HandleClientAICHFileHashRequest(value *clientproto.AICHFileHashRequest)

+ func (p *PeerConnection) HandleClientAICHRequest(value *clientproto.AICHRequest)

+ func (p *PeerConnection) HandleExtHelloAnswer(value *clientproto.ExtHelloAnswer)

+ func (p *PeerConnection) HandleFileComment(value *clientproto.FileComment)

+ func (p *PeerConnection) HandlePublicKey(value *clientproto.PublicKey)

+ func (p *PeerConnection) HandleSecIdentState(value *clientproto.SecIdentState)

+ func (p *PeerConnection) HandleSignature(value *clientproto.Signature)

+ func (p *PeerConnection) IdentityVerified() bool

+ func (p *PeerConnection) SendAICHAnswer(res UploadableResource, requested []protocol.AICHHash)

+ func (p *PeerConnection) SendAICHFileHashAnswer(res UploadableResource)

+ func (p *PeerConnection) SendAICHRequest(hash protocol.Hash, requested []protocol.AICHHash)

+ func (p *PeerConnection) SendAICHRequestForPiece(t *Transfer, pieceIndex int)

+ func (p *PeerConnection) SendCompressedPart(begin, compressedTotalLen int64, payload []byte) error

+ func (p *PeerConnection) SendExtHello()

+ func (p *PeerConnection) SendPublicKey()

+ func (p *PeerConnection) SendSecIdentState()

+ func (p *PeerConnection) SendSignature()

type PeerCreditManager

+ func (m *PeerCreditManager) CreditsOnlyVerified() bool

+ func (m *PeerCreditManager) SetCreditsOnlyVerified(v bool)

type RemotePeerInfo

+ SecIdentKeyFP uint32

+ SecIdentVersion int

type SearchResult

+ Note string

type ServerConnectionPolicy

+ func (p *ServerConnectionPolicy) SetPingResult(rttMs, ttlMs, now int64)

+ func (p ServerConnectionPolicy) EffectivePingRTT(now int64) int64

type ServerSnapshot

+ Description string

+ HardFilesLimit uint32

+ MaxUsers uint32

+ Name string

+ ObfuscationTCPPort uint32

+ ReportedIP uint32

+ SoftFilesLimit uint32

+ StatusFiles int32

+ StatusUsers int32

+ UDPFiles uint32

+ UDPStatsValid bool

+ UDPUsers uint32

type Session

+ func (s *Session) BanPeer(endpoint protocol.Endpoint)

+ func (s *Session) BannedPeers() []protocol.Endpoint

+ func (s *Session) EnsureServerStatUDPListener() error

+ func (s *Session) GetDHTv6Tracker() *KADV6Tracker

+ func (s *Session) IPFilter() *IPFilter

+ func (s *Session) Identity() *IdentityState

+ func (s *Session) LoadIdentity(path string) error

+ func (s *Session) OnCallbackRequestIncoming(point protocol.Endpoint)

+ func (s *Session) ProbeServerPing(identifier string, address *net.TCPAddr)

+ func (s *Session) PublishTransferToKADV6(t *Transfer)

+ func (s *Session) RequestServerCallback(t *Transfer, clientID int32) bool

+ func (s *Session) SendDHTv6SourcesRequest(hash protocol.Hash, size int64, transfer *Transfer) bool

+ func (s *Session) SetDHTv6Tracker(tracker *KADV6Tracker)

+ func (s *Session) SetIPFilter(filter *IPFilter)

+ func (s *Session) SetIdentity(id *IdentityState)

+ func (s *Session) SetServerMetadata(identifier, name, description string)

+ func (s *Session) SyncDHTv6ListenPort()

+ func (s *Session) ThrottleDownload(bytes int)

+ func (s *Session) UnbanPeer(endpoint protocol.Endpoint)

type Settings

+ Categories []Category

+ CreditsOnlyVerified bool

+ CryptLayerRequired bool

+ DHTv6SearchTimeout int

+ EnableCryptLayer bool

+ EnableDHTv6 bool

+ EnableSecIdent bool

+ IdentityKeyPath string

+ MaxDownloadRateKB int

+ ObfuscationTCPPort int

+ SecIdentRequired bool

+ UDPPortV6 int

type SharedFile

+ func (s *SharedFile) AICHRootHash() (protocol.AICHHash, bool)

+ func (s *SharedFile) SetAICHRootHash(root protocol.AICHHash)

+ func (s *SharedFile) UploadAICHHashes(requested []protocol.AICHHash) []protocol.AICHHash

type Transfer

+ func (t *Transfer) AICHPieceBlocks(pieceIndex int) []protocol.AICHHash

+ func (t *Transfer) AICHRootHash() (protocol.AICHHash, bool)

+ func (t *Transfer) DownloadPriority() TransferPriority

+ func (t *Transfer) SetAICHRootHash(root protocol.AICHHash)

+ func (t *Transfer) SetDownloadPriority(priority TransferPriority)

+ func (t *Transfer) StoreAICHPieceBlocks(pieceIndex int, hashes []protocol.AICHHash)

+ func (t *Transfer) UploadAICHHashes(requested []protocol.AICHHash) []protocol.AICHHash

type TransferHandle

+ func (h TransferHandle) DownloadPriority() TransferPriority

+ type TransferPriority int

+ const TransferPriorityHigh

+ const TransferPriorityLow

+ const TransferPriorityNormal

+ const TransferPriorityVeryHigh

+ const TransferPriorityVeryLow

+ func (p TransferPriority) Label() string

+ func (p TransferPriority) SortKey() int

+ func (p TransferPriority) TextLabel() string

type TransferSnapshot

+ DownloadPriority TransferPriority

type UploadableResource

+ AICHRootHash func() (protocol.AICHHash, bool)

+ UploadAICHHashes func(requested []protocol.AICHHash) []protocol.AICHHash

v0.0.2

Apr 10, 2026

Changes in this version

type PeerCreditManager

+ func (m *PeerCreditManager) TotalsForPeer(hash protocol.Hash) (uploaded, downloaded uint64)

type PeerInfo

+ Connected bool

+ HelloMisc1 int

+ HelloMisc2 int

+ NickName string

+ TotalDownloaded uint64

+ TotalUploaded uint64

+ UserHash protocol.Hash

type RemotePeerInfo

+ NickName string

v0.0.1

Apr 9, 2026

Changes in this version

+ const BlockSize

+ const BlockSizeInt

+ const BlocksPerPiece

+ const EndGameDPLimit

+ const HighestLowIDED2K

+ const InvalidETA

+ const InvalidSpeed

+ const MaxOutgoingBufferSize

+ const MaxPeerListSize

+ const MinReconnectTimeout

+ const PartsInRequest

+ const PeerDHT

+ const PeerIncoming

+ const PeerResume

+ const PeerServer

+ const PeerSourceExchange

+ const PieceSize

+ const RequestQueueSize

+ const SourceExchangePeerLimit

+ var ErrClientStopped = errors.New("client stopped")

+ func Byte2String(value []byte) string

+ func ComputeEd2kFileMeta(path string) (root protocol.Hash, size int64, pieceHashes []protocol.Hash, err error)

+ func CurrentTime() int64

+ func CurrentTimeHiRes() int64

+ func CurrentTimeMillis() int64

+ func CurrentTimeToDeadline(nsFromNow int64) time.Time

+ func DivCeil(a, b int64) int64

+ func FormatLink(fileName string, fileSize int64, hash fmt.Stringer) string

+ func HTONL(ip int32) int32

+ func HTONLBytes(order []byte) int32

+ func HiPart(value int64) int32

+ func Hours(value int64) int64

+ func IP2String(ip int32) string

+ func Int2Address(ip int32) net.IP

+ func IsBit(value, mask int32) bool

+ func IsLocalAddress(ip int32) bool

+ func IsLowID(v int32) bool

+ func LowPart(value int64) int32

+ func MakeFullED2KVersion(clientID, a, b, c int64) int64

+ func Minutes(value int64) int64

+ func NTOHL(ip int32) int32

+ func PackToNetworkByteOrder(order []byte) int32

+ func PeerSourceLabels(sourceFlag int) []string

+ func Seconds(value int64) int64

+ func String2IP(s string) (int32, error)

+ func UpdateCachedTime()

+ type AddTransferParams struct

+ CreateTime int64

+ FilePath string

+ Handler disk.FileHandler

+ Hash protocol.Hash

+ Paused bool

+ ResumeData *protocol.TransferResumeData

+ Size int64

+ func NewAddTransferParamsFromFile(h protocol.Hash, createTime int64, size int64, file *os.File, paused bool) AddTransferParams

+ func NewAddTransferParamsFromHandler(h protocol.Hash, createTime int64, size int64, handler disk.FileHandler, ...) AddTransferParams

+ func (a *AddTransferParams) SetExternalFileHandler(handler disk.FileHandler)

+ type AsyncHash struct

+ PieceIndex int

+ func NewAsyncHash(transfer *Transfer, pieceIndex int) *AsyncHash

+ func (a *AsyncHash) Call() AsyncOperationResult

+ func (t AsyncHash) Transfer() *Transfer

+ type AsyncHashResult struct

+ Hash protocol.Hash

+ PieceIndex int

+ Transfer *Transfer

+ func (a *AsyncHashResult) Code() BaseErrorCode

+ func (a *AsyncHashResult) OnCompleted()

+ type AsyncOperationResult interface

+ Code func() BaseErrorCode

+ OnCompleted func()

+ type AsyncRelease struct

+ DeleteFile bool

+ func NewAsyncRelease(transfer *Transfer, deleteFile bool) *AsyncRelease

+ func (a *AsyncRelease) Call() AsyncOperationResult

+ func (t AsyncRelease) Transfer() *Transfer

+ type AsyncReleaseResult struct

+ Buffers [][]byte

+ DeleteFile bool

+ EC BaseErrorCode

+ Transfer *Transfer

+ func (a *AsyncReleaseResult) Code() BaseErrorCode

+ func (a *AsyncReleaseResult) OnCompleted()

+ type AsyncRestore struct

+ Block data.PieceBlock

+ FileSize int64

+ func NewAsyncRestore(transfer *Transfer, block data.PieceBlock, fileSize int64) *AsyncRestore

+ func (a *AsyncRestore) Call() AsyncOperationResult

+ func (t AsyncRestore) Transfer() *Transfer

+ type AsyncRestoreResult struct

+ Block data.PieceBlock

+ Buffers [][]byte

+ EC BaseErrorCode

+ Transfer *Transfer

+ func (a *AsyncRestoreResult) Code() BaseErrorCode

+ func (a *AsyncRestoreResult) OnCompleted()

+ type AsyncWrite struct

+ Block data.PieceBlock

+ Buffer []byte

+ func NewAsyncWrite(block data.PieceBlock, buffer []byte, transfer *Transfer) *AsyncWrite

+ func (a *AsyncWrite) Call() AsyncOperationResult

+ func (t AsyncWrite) Transfer() *Transfer

+ type AsyncWriteResult struct

+ Block data.PieceBlock

+ Buffers [][]byte

+ EC BaseErrorCode

+ Transfer *Transfer

+ func (a *AsyncWriteResult) Code() BaseErrorCode

+ func (a *AsyncWriteResult) OnCompleted()

+ type BaseErrorCode interface

+ Code func() int

+ Description func() string

+ type BlockManager struct

+ func NewBlockManager(piece, buffersCount int) *BlockManager

+ func (b *BlockManager) Buffers() [][]byte

+ func (b *BlockManager) ByteBuffersCount() int

+ func (b *BlockManager) HashedSize() int

+ func (b *BlockManager) PieceHash() protocol.Hash

+ func (b *BlockManager) PieceIndex() int

+ func (b *BlockManager) RegisterBlock(blockIndex int, buffer []byte) [][]byte

+ type BlockState byte

+ const StateFinished

+ const StateNone

+ const StateRequested

+ const StateWriting

+ type BlocksEnumerator struct

+ func NewBlocksEnumerator(pieceCount, blocksInLastPiece int) BlocksEnumerator

+ func (b BlocksEnumerator) BlocksInPiece(pieceIndex int) int

+ type Client struct

+ func NewClient(settings Settings) *Client

+ func (c *Client) AddDHTBootstrapNodes(nodes ...string) error

+ func (c *Client) AddLink(linkValue, outputDir string) (TransferHandle, string, error)

+ func (c *Client) AddSharedDir(path string) error

+ func (c *Client) AddTransfer(atp AddTransferParams) (TransferHandle, error)

+ func (c *Client) Close()

+ func (c *Client) Connect(serverAddr string) error

+ func (c *Client) ConnectSavedServer() error

+ func (c *Client) ConnectServerLink(linkValue string) error

+ func (c *Client) ConnectServerMet(path string) error

+ func (c *Client) ConnectServers(serverAddrs ...string) error

+ func (c *Client) DHTStatus() DHTStatus

+ func (c *Client) EnableDHT() *DHTTracker

+ func (c *Client) FindTransfer(hash protocol.Hash) TransferHandle

+ func (c *Client) GetDHTTracker() *DHTTracker

+ func (c *Client) ImportSharedFile(path string) error

+ func (c *Client) ListSharedDirs() []string

+ func (c *Client) LoadDHTNodesDat(path ...string) error

+ func (c *Client) LoadServerMet(path string) ([]serverproto.ServerMetEntry, error)

+ func (c *Client) LoadState(path string) error

+ func (c *Client) PauseTransfer(hash protocol.Hash) error

+ func (c *Client) PeerStatuses() []ClientPeerSnapshot

+ func (c *Client) PublishDHTKeyword(keywordHash protocol.Hash, entries ...kadproto.SearchEntry) bool

+ func (c *Client) PublishDHTNotes(fileHash protocol.Hash, entries ...kadproto.SearchEntry) bool

+ func (c *Client) PublishDHTSource(hash protocol.Hash, endpoint protocol.Endpoint, size int64) bool

+ func (c *Client) RemoveSharedDir(path string) error

+ func (c *Client) RemoveSharedFile(hash protocol.Hash) bool

+ func (c *Client) RemoveTransfer(hash protocol.Hash, deleteFile bool) error

+ func (c *Client) RescanSharedDirs() error

+ func (c *Client) ResumeTransfer(hash protocol.Hash) error

+ func (c *Client) ResumeUpload(hash protocol.Hash)

+ func (c *Client) SaveState(path string) error

+ func (c *Client) SearchDHTKeywords(keywordHash protocol.Hash, cb func([]kadproto.SearchEntry)) bool

+ func (c *Client) SearchSnapshot() SearchSnapshot

+ func (c *Client) ServerAddress() string

+ func (c *Client) ServerStatuses() []ServerSnapshot

+ func (c *Client) Session() *Session

+ func (c *Client) SetAutoSaveInterval(interval time.Duration)

+ func (c *Client) SetDHTStoragePoint(address string) error

+ func (c *Client) SetDHTTracker(tracker *DHTTracker)

+ func (c *Client) SetFriendSlot(hash protocol.Hash, enabled bool)

+ func (c *Client) SetStatePath(path string)

+ func (c *Client) SetStateStore(store ClientStateStore)

+ func (c *Client) SetTransferUploadPriority(hash protocol.Hash, priority UploadPriority) error

+ func (c *Client) SharedFiles() []*SharedFile

+ func (c *Client) Start() error

+ func (c *Client) StartSearch(params SearchParams) (SearchHandle, error)

+ func (c *Client) StatePath() string

+ func (c *Client) StateStore() ClientStateStore

+ func (c *Client) Status() ClientStatus

+ func (c *Client) Stop() error

+ func (c *Client) StopSearch() error

+ func (c *Client) SubscribeStatus() (<-chan ClientStatusEvent, func())

+ func (c *Client) SubscribeStatusBuffered(buffer int) (<-chan ClientStatusEvent, func())

+ func (c *Client) SubscribeTransferProgress() (<-chan TransferProgressEvent, func())

+ func (c *Client) SubscribeTransferProgressBuffered(buffer int) (<-chan TransferProgressEvent, func())

+ func (c *Client) SuspendUpload(hash protocol.Hash, terminate bool) uint16

+ func (c *Client) TransferSnapshots() []TransferSnapshot

+ func (c *Client) Transfers() []TransferHandle

+ func (c *Client) Wait() error

+ type ClientCreditState struct

+ Downloaded uint64

+ PeerHash protocol.Hash

+ Uploaded uint64

+ type ClientDHTNodeState struct

+ Addr string

+ FailCount int

+ FirstSeen int64

+ HelloSent bool

+ ID protocol.Hash

+ LastSeen int64

+ Pinged bool

+ Seed bool

+ TCPPort uint16

+ Version byte

+ type ClientDHTState struct

+ Firewalled bool

+ LastBootstrap int64

+ LastFirewalledCheck int64

+ LastRefresh int64

+ Nodes []ClientDHTNodeState

+ RouterNodes []string

+ SelfID protocol.Hash

+ StoragePoint string

+ type ClientPeerSnapshot struct

+ FileName string

+ FilePath string

+ Peer PeerInfo

+ TransferHash protocol.Hash

+ type ClientSharedFileState struct

+ Completed bool

+ Hash protocol.Hash

+ LastHashAt int64

+ Name string

+ Origin SharedOrigin

+ Path string

+ PieceHashes []protocol.Hash

+ Size int64

+ type ClientState struct

+ Credits []ClientCreditState

+ DHT *ClientDHTState

+ FriendSlots []protocol.Hash

+ ServerAddress string

+ SharedDirs []string

+ SharedFiles []ClientSharedFileState

+ Transfers []ClientTransferState

+ Version int

+ type ClientStateStore interface

+ Load func() (*ClientState, error)

+ Save func(state *ClientState) error

+ type ClientStatus struct

+ DownloadRate int

+ Peers []ClientPeerSnapshot

+ Servers []ServerSnapshot

+ TotalDone int64

+ TotalReceived int64

+ TotalWanted int64

+ Transfers []TransferSnapshot

+ Upload int64

+ UploadRate int

+ type ClientStatusEvent struct

+ At time.Time

+ DHT DHTStatus

+ Status ClientStatus

+ func (e ClientStatusEvent) TransferSnapshots() []TransferSnapshot

+ func (e ClientStatusEvent) TransferState(hash protocol.Hash) (TransferState, bool)

+ func (e ClientStatusEvent) TransferStates() map[protocol.Hash]TransferState

+ type ClientTransferState struct

+ CreateTime int64

+ Hash protocol.Hash

+ Paused bool

+ ResumeData *protocol.TransferResumeData

+ Size int64

+ TargetPath string

+ UploadPrio UploadPriority

+ type Connection struct

+ func NewConnection(session *Session) Connection

+ func (c *Connection) AppendIncoming(chunk []byte)

+ func (c *Connection) Close(ec BaseErrorCode)

+ func (c *Connection) Connect(address net.Addr) error

+ func (c *Connection) ConsumeIncoming(limit int) []byte

+ func (c *Connection) DecodeFrames(combiner *protocol.PacketCombiner) ([]protocol.PacketHeader, []protocol.Serializable, error)

+ func (c *Connection) DisconnectCode() BaseErrorCode

+ func (c *Connection) DoRead() error

+ func (c *Connection) DrainIncoming() []byte

+ func (c *Connection) Endpoint() protocol.Endpoint

+ func (c *Connection) FlushOutgoing() error

+ func (c *Connection) IncomingBytes() int

+ func (c *Connection) IncomingChunks() [][]byte

+ func (c *Connection) IsDisconnectHandled() bool

+ func (c *Connection) IsDisconnecting() bool

+ func (c *Connection) MarkDisconnectHandled()

+ func (c *Connection) MillisecondsSinceLastReceive() int64

+ func (c *Connection) PendingPackets() [][]byte

+ func (c *Connection) PopOutgoing() []byte

+ func (c *Connection) QueuePacket(packet []byte)

+ func (c *Connection) QueuePacketWithStats(packet []byte, protocolBytes, payloadBytes int64)

+ func (c *Connection) ReadFrames() ([]protocol.PacketHeader, [][]byte, error)

+ func (c *Connection) ReadFramesWithCombiner(combiner *protocol.PacketCombiner) ([]protocol.PacketHeader, [][]byte, error)

+ func (c *Connection) SecondTick(tickIntervalMS int64)

+ func (c *Connection) Statistics() Statistics

+ type DHTStatus struct

+ Bootstrapped bool

+ Firewalled bool

+ InitialBootstrap bool

+ KnownNodes int

+ ListenPort int

+ LiveNodes int

+ ReplacementNodes int

+ RouterNodes int

+ RunningTraversals int

+ StoragePoint string

+ type DHTTracker struct

+ func NewDHTTracker(listenPort int, timeout time.Duration) *DHTTracker

+ func (t *DHTTracker) AddNode(addr *net.UDPAddr)

+ func (t *DHTTracker) AddNodes(addrs ...*net.UDPAddr)

+ func (t *DHTTracker) ApplyNodesDat(nodes *kadproto.NodesDat) error

+ func (t *DHTTracker) ApplyState(state *ClientDHTState) error

+ func (t *DHTTracker) Close()

+ func (t *DHTTracker) IsFirewalled() bool

+ func (t *DHTTracker) ListenPort() int

+ func (t *DHTTracker) LoadNodesDat(path string) error

+ func (t *DHTTracker) PublishKeyword(keywordHash protocol.Hash, entries ...kadproto.SearchEntry) bool

+ func (t *DHTTracker) PublishNotes(fileHash protocol.Hash, entries ...kadproto.SearchEntry) bool

+ func (t *DHTTracker) PublishSource(hash protocol.Hash, endpoint protocol.Endpoint, size int64) bool

+ func (t *DHTTracker) SearchKeywords(hash protocol.Hash, cb func([]kadproto.SearchEntry)) bool

+ func (t *DHTTracker) SearchSources(hash protocol.Hash, size int64, cb func([]kadproto.SearchEntry)) bool

+ func (t *DHTTracker) SetStoragePoint(addr *net.UDPAddr)

+ func (t *DHTTracker) SnapshotState() *ClientDHTState

+ func (t *DHTTracker) Start() error

+ func (t *DHTTracker) Status() DHTStatus

+ type DownloadingBlock struct

+ func (b *DownloadingBlock) Abort(p *Peer)

+ func (b *DownloadingBlock) Finish()

+ func (b *DownloadingBlock) Request(p *Peer, speed PeerSpeed)

+ func (b *DownloadingBlock) Write()

+ func (b DownloadingBlock) IsFinished() bool

+ func (b DownloadingBlock) IsFree() bool

+ func (b DownloadingBlock) IsRequested() bool

+ func (b DownloadingBlock) IsWriting() bool

+ type DownloadingPiece struct

+ Blocks []DownloadingBlock

+ PieceIndex int

+ func NewDownloadingPiece(pieceIndex, blocksCount int) DownloadingPiece

+ func (d *DownloadingPiece) AbortDownloading(blockIndex int, p *Peer)

+ func (d *DownloadingPiece) FinishBlock(blockIndex int)

+ func (d *DownloadingPiece) PickBlocks(rq *[]data.PieceBlock, orderLength int, peer *Peer, speed PeerSpeed, ...) int

+ func (d *DownloadingPiece) RequestBlock(blockIndex int, p *Peer, speed PeerSpeed)

+ func (d *DownloadingPiece) WriteBlock(blockIndex int) bool

+ func (d DownloadingPiece) BlocksCount() int

+ func (d DownloadingPiece) DownloadedCount() int

+ func (d DownloadingPiece) DownloadingBlocksCount() int

+ func (d DownloadingPiece) FinishedBlocksCount() int

+ func (d DownloadingPiece) IsDownloaded(blockIndex int) bool

+ func (d DownloadingPiece) IsFinished(blockIndex int) bool

+ func (d DownloadingPiece) TotalBlocks() int

+ func (d DownloadingPiece) WritingBlocksCount() int

+ type EMuleLink struct

+ Hash protocol.Hash

+ NumberValue int64

+ StringValue string

+ Type LinkType

+ func ParseEMuleLink(uri string) (EMuleLink, error)

+ type ErrorCode int

+ const BufferGetException

+ const BufferTooLarge

+ const BufferUnderflowException

+ const ChannelClosed

+ const ConnectionTimeout

+ const DHTRequestAlreadyRunning

+ const DHTTrackerAborted

+ const DuplicatePeer

+ const DuplicatePeerConnection

+ const EndOfStream

+ const Fail

+ const FileIOError

+ const FileNotFound

+ const GenericIllegalAccess

+ const GenericInstantiationError

+ const GithubCfgIPIsNull

+ const GithubCfgPortsAreEmpty

+ const GithubCfgPortsAreNull

+ const HashMismatch

+ const IOException

+ const IllegalArgument

+ const IncomingDirInaccessible

+ const InflateError

+ const InternalError

+ const Interrupted

+ const InvalidPRParameter

+ const LinkMailformed

+ const NoError

+ const NoMemory

+ const NoTransfer

+ const NonWriteableChannel

+ const NotConnected

+ const NumberFormatError

+ const OutOfParts

+ const PacketHeaderUndefined

+ const PacketSizeIncorrect

+ const PacketSizeOverflow

+ const PeerConnUnsupportedPacket

+ const PeerLimitExceeded

+ const PeerRequestOverflow

+ const PortMappingAlreadyMapped

+ const PortMappingCommandRejected

+ const PortMappingConfigError

+ const PortMappingError

+ const PortMappingException

+ const PortMappingIOError

+ const PortMappingNoDevice

+ const PortMappingSAXError

+ const QueueRanking

+ const SecurityException

+ const ServerConnUnsupportedPacket

+ const ServerMetHeaderIncorrect

+ const SessionStopping

+ const TagFromStringInvalidCP

+ const TagToBSOBInvalid

+ const TagToBlobInvalid

+ const TagToFloatInvalid

+ const TagToHashInvalid

+ const TagToIntInvalid

+ const TagToLongInvalid

+ const TagToStringInvalid

+ const TagTypeUnknown

+ const TransferAborted

+ const TransferFinished

+ const TransferPaused

+ const URISyntaxError

+ const UnableToDeleteFile

+ const UnknownLinkType

+ const UnsupportedEncoding

+ const WrongHashSet

+ func (e ErrorCode) Code() int

+ func (e ErrorCode) Description() string

+ func (e ErrorCode) String() string

+ type FileClientStateStore struct

+ func NewFileClientStateStore(path string) *FileClientStateStore

+ func (s *FileClientStateStore) Load() (*ClientState, error)

+ func (s *FileClientStateStore) Path() string

+ func (s *FileClientStateStore) Save(state *ClientState) error

+ type JED2KError struct

+ Cause error

+ EC BaseErrorCode

+ func NewError(ec BaseErrorCode) *JED2KError

+ func WrapError(cause error, ec BaseErrorCode) *JED2KError

+ func (e *JED2KError) Error() string

+ func (e *JED2KError) ErrorCode() BaseErrorCode

+ func (e *JED2KError) Unwrap() error

+ type KadRoutingNode struct

+ Addr *net.UDPAddr

+ FailCount int

+ FirstSeen time.Time

+ HelloSent bool

+ ID kadproto.ID

+ LastSeen time.Time

+ Pinged bool

+ Seed bool

+ TCPPort uint16

+ Version byte

+ func (n *KadRoutingNode) Key() string

+ func (n *KadRoutingNode) KnownID() bool

+ type LinkType string

+ const LinkFile

+ const LinkNodes

+ const LinkServer

+ const LinkServers

+ type MiscOptions struct

+ AICHVersion int

+ AcceptCommentVer int

+ DataCompVer int

+ ExtendedRequestsVer int

+ MultiPacket int

+ NoViewSharedFiles int

+ SourceExchange1Ver int

+ SupportSecIdent int

+ SupportsPreview int

+ UDPVer int

+ UnicodeSupport int

+ func (m *MiscOptions) Assign(value int)

+ func (m MiscOptions) IntValue() int

+ type MiscOptions2 struct

+ Value int

+ func (m *MiscOptions2) Assign(value int)

+ func (m *MiscOptions2) SetCaptcha()

+ func (m *MiscOptions2) SetExtMultipacket()

+ func (m *MiscOptions2) SetLargeFiles()

+ func (m *MiscOptions2) SetSourceExt2()

+ func (m MiscOptions2) SupportCaptcha() bool

+ func (m MiscOptions2) SupportExtMultipacket() bool

+ func (m MiscOptions2) SupportLargeFiles() bool

+ func (m MiscOptions2) SupportSourceExt2() bool

+ type Peer struct

+ Connectable bool

+ Connection any

+ DialAddr *net.TCPAddr

+ Endpoint protocol.Endpoint

+ FailCount int

+ LastConnected int64

+ NextConnection int64

+ SourceFlag int

+ func NewPeer(ep protocol.Endpoint) Peer

+ func NewPeerFromTCPAddr(addr *net.TCPAddr, connectable bool, sourceFlag int) Peer

+ func NewPeerWithSource(ep protocol.Endpoint, conn bool, sourceFlag int) Peer

+ func PeerFromKADV6SearchEntry(se kadv6.SearchEntry, sourceFlag int) (Peer, bool)

+ func (p Peer) CanEncodeAnswerSources2() bool

+ func (p Peer) Compare(other Peer) int

+ func (p Peer) EffectiveEndpointForSX() (protocol.Endpoint, bool)

+ func (p Peer) Equal(other Peer) bool

+ func (p Peer) HasDialableAddress() bool

+ type PeerConnection struct

+ func NewIncomingPeerConnection(session *Session, conn net.Conn) *PeerConnection

+ func NewPeerConnection(session *Session, point protocol.Endpoint, transfer *Transfer, peerInfo *Peer) *PeerConnection

+ func (p *PeerConnection) AbortAllRequests()

+ func (p *PeerConnection) ActiveUploadSource() UploadableResource

+ func (p *PeerConnection) AddUploadRequest(req data.PeerRequest)

+ func (p *PeerConnection) ClearUploadBlockRequests()

+ func (p *PeerConnection) ClearUploadWaitStart()

+ func (p *PeerConnection) CompleteBlock(pb *PendingBlock) bool

+ func (p *PeerConnection) Connect() error

+ func (p *PeerConnection) Endpoint() protocol.Endpoint

+ func (p *PeerConnection) FriendSlot() bool

+ func (p *PeerConnection) GetDownloading(block data.PieceBlock) *PendingBlock

+ func (p *PeerConnection) GetInfo() PeerInfo

+ func (p *PeerConnection) GetPeer() *Peer

+ func (p *PeerConnection) HandleAnswerSources2(ans *clientproto.AnswerSources2)

+ func (p *PeerConnection) HandleClientCancelTransfer()

+ func (p *PeerConnection) HandleClientFileRequest(value *clientproto.FileRequest)

+ func (p *PeerConnection) HandleClientFileStatusRequest(value *clientproto.FileStatusRequest)

+ func (p *PeerConnection) HandleClientHashSetRequest(value *clientproto.HashSetRequest)

+ func (p *PeerConnection) HandleClientHello(value *clientproto.Hello)

+ func (p *PeerConnection) HandleClientRequestParts32(value *clientproto.RequestParts32) error

+ func (p *PeerConnection) HandleClientRequestParts64(value *clientproto.RequestParts64) error

+ func (p *PeerConnection) HandleClientStartUpload(value *clientproto.StartUpload)

+ func (p *PeerConnection) HandleExtHello(_ *clientproto.ExtHello)

+ func (p *PeerConnection) HandleFileAnswer(value *clientproto.FileAnswer)

+ func (p *PeerConnection) HandleFileStatusAnswer(value *clientproto.FileStatusAnswer)

+ func (p *PeerConnection) HandleHelloAnswer(value *clientproto.HelloAnswer)

+ func (p *PeerConnection) HandleRequestSources2(req *clientproto.RequestSources2)

+ func (p *PeerConnection) HasEndpoint() bool

+ func (p *PeerConnection) IsRequesting(block data.PieceBlock) bool

+ func (p *PeerConnection) IsUploadConnected() bool

+ func (p *PeerConnection) IsUploadLowID() bool

+ func (p *PeerConnection) OnConnect()

+ func (p *PeerConnection) OnDisconnect(ec BaseErrorCode)

+ func (p *PeerConnection) PrepareHello() clientproto.Hello

+ func (p *PeerConnection) PrepareHelloAnswer() clientproto.HelloAnswer

+ func (p *PeerConnection) ProcessIncoming() error

+ func (p *PeerConnection) ReceiveCompressedData(header protocol.PacketHeader, offset, compressedLength int64, payloadSize int)

+ func (p *PeerConnection) ReceiveData(req data.PeerRequest, compressed bool)

+ func (p *PeerConnection) ReceivePendingData()

+ func (p *PeerConnection) RequestBlocks()

+ func (p *PeerConnection) ResetUploadSession()

+ func (p *PeerConnection) SecondTick(tickIntervalMS int64)

+ func (p *PeerConnection) SendAcceptUpload()

+ func (p *PeerConnection) SendBlockData()

+ func (p *PeerConnection) SendCancelTransfer()

+ func (p *PeerConnection) SendExtHelloAnswer()

+ func (p *PeerConnection) SendFileAnswer(res UploadableResource)

+ func (p *PeerConnection) SendFileRequest(hash protocol.Hash)

+ func (p *PeerConnection) SendFileStatusAnswer(res UploadableResource)

+ func (p *PeerConnection) SendFileStatusRequest(hash protocol.Hash)

+ func (p *PeerConnection) SendHashSetAnswer(res UploadableResource)

+ func (p *PeerConnection) SendHashSetRequest(hash protocol.Hash)

+ func (p *PeerConnection) SendOutOfPartReqsAndAddToWaitingQueue()

+ func (p *PeerConnection) SendOutOfParts()

+ func (p *PeerConnection) SendPart(begin, end int64, payload []byte) error

+ func (p *PeerConnection) SendQueueRanking(rank uint16)

+ func (p *PeerConnection) SendRequestParts32(packet *clientproto.RequestParts32)

+ func (p *PeerConnection) SendRequestParts64(packet *clientproto.RequestParts64)

+ func (p *PeerConnection) SendRequestSources2(hash protocol.Hash) error

+ func (p *PeerConnection) SendStartUpload(hash protocol.Hash)

+ func (p *PeerConnection) SetFriendSlot(v bool)

+ func (p *PeerConnection) SetPeer(peer *Peer)

+ func (p *PeerConnection) SetTransfer(transfer *Transfer)

+ func (p *PeerConnection) SetUploadAddNextConnect(v bool)

+ func (p *PeerConnection) SetUploadQueueRank(rank uint16)

+ func (p *PeerConnection) SetUploadResource(res UploadableResource)

+ func (p *PeerConnection) SetUploadStartTime(ts int64)

+ func (p *PeerConnection) SetUploadState(state UploadState)

+ func (p *PeerConnection) SetUploadWaitStart(ts int64)

+ func (p *PeerConnection) Speed() PeerSpeed

+ func (p *PeerConnection) UploadAddNextConnect() bool

+ func (p *PeerConnection) UploadQueueRank() uint16

+ func (p *PeerConnection) UploadScore() uint32

+ func (p *PeerConnection) UploadSession() int64

+ func (p *PeerConnection) UploadStartDelay() int64

+ func (p *PeerConnection) UploadState() UploadState

+ func (p *PeerConnection) UploadWaitStart() int64

+ type PeerCredit struct

+ Downloaded uint64

+ PeerHash protocol.Hash

+ Uploaded uint64

+ type PeerCreditManager struct

+ func NewPeerCreditManager() *PeerCreditManager

+ func (m *PeerCreditManager) AddDownloaded(hash protocol.Hash, bytes int64)

+ func (m *PeerCreditManager) AddUploaded(hash protocol.Hash, bytes int64)

+ func (m *PeerCreditManager) ApplySnapshot(states []ClientCreditState)

+ func (m *PeerCreditManager) ScoreRatio(hash protocol.Hash) float64

+ func (m *PeerCreditManager) Snapshot() []ClientCreditState

+ type PeerInfo struct

+ DownloadSpeed int

+ Endpoint protocol.Endpoint

+ FailCount int

+ ModName string

+ ModVersion int

+ PayloadDownloadSpeed int

+ PayloadUploadSpeed int

+ RemotePieces protocol.BitField

+ SourceFlag int

+ StrModVersion string

+ UploadSpeed int

+ Version int

+ func (p PeerInfo) HasSource(source byte) bool

+ func (p PeerInfo) SourceLabels() []string

+ func (p PeerInfo) SourceString() string

+ type PeerSpeed int

+ const PeerSpeedFast

+ const PeerSpeedMedium

+ const PeerSpeedSlow

+ type PendingBlock struct

+ Block data.PieceBlock

+ Buffer []byte

+ CreateTime int64

+ DataSize int64

+ Received int64

+ func NewPendingBlock(block data.PieceBlock, totalSize int64) PendingBlock

+ type PieceManager struct

+ func NewPieceManager(handler disk.FileHandler, pieceCount, blocksInLastPiece int) *PieceManager

+ func (p *PieceManager) Abort() [][]byte

+ func (p *PieceManager) DeleteFile() error

+ func (p *PieceManager) GetFile() *os.File

+ func (p *PieceManager) HashPiece(pieceIndex int) protocol.Hash

+ func (p *PieceManager) ReadRange(begin, end int64) ([]byte, error)

+ func (p *PieceManager) ReleaseFile(deleteFile bool) ([][]byte, error)

+ func (p *PieceManager) RestoreBlock(block data.PieceBlock, fileSize int64) ([][]byte, []byte, error)

+ func (p *PieceManager) WriteBlock(block data.PieceBlock, buffer []byte) ([][]byte, error)

+ type PiecePicker struct

+ func NewPiecePicker(pieceCount, blocksInLastPiece int) PiecePicker

+ func (p *PiecePicker) AbortDownload(b data.PieceBlock, peer *Peer)

+ func (p *PiecePicker) ChooseNextPiece() bool

+ func (p *PiecePicker) ChooseNextPieceWithAvailability(available *protocol.BitField) bool

+ func (p *PiecePicker) DownloadPiece(pieceIndex int)

+ func (p *PiecePicker) GetDownloadingPiece(index int) *DownloadingPiece

+ func (p *PiecePicker) IsBlockDownloaded(b data.PieceBlock) bool

+ func (p *PiecePicker) MarkAsDownloading(b data.PieceBlock, peer *Peer) bool

+ func (p *PiecePicker) MarkAsFinished(b data.PieceBlock) bool

+ func (p *PiecePicker) MarkAsWriting(b data.PieceBlock) bool

+ func (p *PiecePicker) PickPieces(rq *[]data.PieceBlock, orderLength int, peer *Peer, speed PeerSpeed)

+ func (p *PiecePicker) PickPiecesWithAvailability(rq *[]data.PieceBlock, orderLength int, peer *Peer, speed PeerSpeed, ...)

+ func (p *PiecePicker) RestoreHave(pieceIndex int)

+ func (p *PiecePicker) RestorePiece(pieceIndex int)

+ func (p *PiecePicker) WeHave(pieceIndex int)

+ func (p *PiecePicker) WeHaveBlock(b data.PieceBlock)

+ func (p PiecePicker) GetDownloadingQueue() []DownloadingPiece

+ func (p PiecePicker) GetPieceCount() int

+ func (p PiecePicker) HavePiece(pieceIndex int) bool

+ func (p PiecePicker) IsEndGame() bool

+ func (p PiecePicker) IsPieceFinished(pieceIndex int) bool

+ func (p PiecePicker) NumDownloadingPieces() int

+ func (p PiecePicker) NumHave() int

+ func (p PiecePicker) NumPieces() int

+ func (p PiecePicker) TotalPieces() int

+ type PieceSnapshot struct

+ BlocksDone int

+ BlocksPending int

+ BlocksTotal int

+ BlocksWriting int

+ DoneBytes int64

+ Index int

+ ReceivedBytes int64

+ State PieceSnapshotState

+ TotalBytes int64

+ type PieceSnapshotState string

+ const PieceSnapshotDownloading

+ const PieceSnapshotFinished

+ const PieceSnapshotMissing

+ type PieceState byte

+ const PieceDownloading

+ const PieceHave

+ const PieceNone

+ type Policy struct

+ func NewPolicy(t *Transfer) Policy

+ func (p *Policy) AddPeer(peer Peer) (bool, error)

+ func (p *Policy) ConnectOnePeer(sessionTime int64) (bool, error)

+ func (p *Policy) ConnectionClosed(c *PeerConnection, sessionTime int64)

+ func (p *Policy) ErasePeers()

+ func (p *Policy) FindConnectCandidate(sessionTime int64) *Peer

+ func (p *Policy) MergeSourceExchangePeers(peers []Peer) int

+ func (p *Policy) NewConnection(c *PeerConnection) error

+ func (p *Policy) PeersForSourceExchange(exclude protocol.Endpoint, limit int) []Peer

+ func (p *Policy) SetConnection(peer *Peer, c *PeerConnection)

+ func (p Policy) ComparePeerErase(lhs, rhs Peer) bool

+ func (p Policy) ComparePeers(lhs, rhs Peer) bool

+ func (p Policy) FindPeer(ep protocol.Endpoint) *Peer

+ func (p Policy) Get(endpoint protocol.Endpoint) *Peer

+ func (p Policy) GetSourceRank(sourceBitmask int) int

+ func (p Policy) IsConnectCandidate(pe Peer) bool

+ func (p Policy) IsEraseCandidate(pe Peer) bool

+ func (p Policy) NumConnectCandidates() int

+ func (p Policy) Size() int

+ type RemotePeerInfo struct

+ Misc1 MiscOptions

+ Misc2 MiscOptions2

+ ModName string

+ ModNumber int

+ ModVersion string

+ Point protocol.Endpoint

+ Version int

+ type RequestedUploadBlock struct

+ Begin int64

+ End int64

+ Transferred int64

+ type SearchHandle struct

+ func (h SearchHandle) ID() uint32

+ func (h SearchHandle) IsValid() bool

+ func (h SearchHandle) Snapshot() SearchSnapshot

+ func (h SearchHandle) Stop() error

+ type SearchParams struct

+ Extension string

+ FileType string

+ MaxSize int64

+ MinCompleteSources int

+ MinSize int64

+ MinSources int

+ Query string

+ Scope SearchScope

+ type SearchResult struct

+ CompleteSources int

+ Extension string

+ FileName string

+ FileSize int64

+ FileType string

+ Hash protocol.Hash

+ MediaBitrate int

+ MediaCodec string

+ MediaLength int

+ Source SearchResultSource

+ Sources int

+ func (r SearchResult) ED2KLink() string

+ type SearchResultSource uint8

+ const SearchResultKAD

+ const SearchResultServer

+ type SearchScope uint8

+ const SearchScopeAll

+ const SearchScopeDHT

+ const SearchScopeServer

+ type SearchSnapshot struct

+ DHTBusy bool

+ Error string

+ ID uint32

+ KadKeyword string

+ Params SearchParams

+ Results []SearchResult

+ ServerBusy bool

+ StartedAt int64

+ State SearchState

+ UpdatedAt int64

+ type SearchState string

+ const SearchStateFailed

+ const SearchStateFinished

+ const SearchStateIdle

+ const SearchStateRunning

+ const SearchStateStopped

+ type ServerConnection struct

+ func NewServerConnection(identifier string, address *net.TCPAddr, session *Session) *ServerConnection

+ func (s *ServerConnection) AuxPort() int32

+ func (s *ServerConnection) ClientID() int32

+ func (s *ServerConnection) Connect() error

+ func (s *ServerConnection) Endpoint() protocol.Endpoint

+ func (s *ServerConnection) GetAddress() *net.TCPAddr

+ func (s *ServerConnection) GetIdentifier() string

+ func (s *ServerConnection) IsHandshakeCompleted() bool

+ func (s *ServerConnection) OnDisconnect(ec BaseErrorCode)

+ func (s *ServerConnection) OnServerIDChange(clientID, tcpFlags, auxPort int32)

+ func (s *ServerConnection) ProcessIncoming() error

+ func (s *ServerConnection) SecondTick(currentSessionTime int64)

+ func (s *ServerConnection) SendCallbackRequest(clientID int32)

+ func (s *ServerConnection) SendFileSourcesRequest(hash protocol.Hash, size int64)

+ func (s *ServerConnection) SendGetList()

+ func (s *ServerConnection) SendLoginRequest()

+ func (s *ServerConnection) SendOfferFiles(packet *serverproto.OfferFiles)

+ func (s *ServerConnection) SendSearchMore()

+ func (s *ServerConnection) SendSearchRequest(packet *serverproto.SearchRequest)

+ func (s *ServerConnection) TCPFlags() int32

+ type ServerConnectionCandidate struct

+ Address *net.TCPAddr

+ Identifier string

+ type ServerConnectionPolicy struct

+ func NewServerConnectionPolicy(reconnectSecondsTimeout int64, maxReconnects int) ServerConnectionPolicy

+ func (p *ServerConnectionPolicy) RemoveConnectCandidates()

+ func (p *ServerConnectionPolicy) SetConnectCandidate(identifier string, address *net.TCPAddr, currentSessionTime int64)

+ func (p *ServerConnectionPolicy) SetServerConnectionFailed(identifier string, address *net.TCPAddr, currentSessionTime int64)

+ func (p ServerConnectionPolicy) GetConnectCandidate(currentSessionTime int64) *ServerConnectionCandidate

+ func (p ServerConnectionPolicy) HasCandidate() bool

+ func (p ServerConnectionPolicy) HasIterations() bool

+ type ServerSnapshot struct

+ Address string

+ AuxPort int32

+ ClientID int32

+ Configured bool

+ Connected bool

+ Disconnecting bool

+ DownloadRate int

+ HandshakeCompleted bool

+ Identifier string

+ MillisecondsSinceLastReceive int64

+ Primary bool

+ TCPFlags int32

+ UploadRate int

+ func (s ServerSnapshot) IDClass() string

+ type Session struct

+ func NewSession(st Settings) *Session

+ func (s *Session) AddSharedDir(path string) error

+ func (s *Session) AddTransfer(hash protocol.Hash, size int64, file *os.File) (TransferHandle, error)

+ func (s *Session) AddTransferParams(atp AddTransferParams) (TransferHandle, error)

+ func (s *Session) AddTransferWithHandler(hash protocol.Hash, size int64, handler disk.FileHandler) (TransferHandle, error)

+ func (s *Session) CloseConnection(connection *PeerConnection)

+ func (s *Session) CloseListener()

+ func (s *Session) ConfigureSession(st Settings)

+ func (s *Session) ConnectNewPeers()

+ func (s *Session) ConnectTo(identifier string, address *net.TCPAddr) error

+ func (s *Session) ConnectedServerID() string

+ func (s *Session) ConnectedServerIDs() []string

+ func (s *Session) Credits() *PeerCreditManager

+ func (s *Session) DisconnectFrom()

+ func (s *Session) FindTransfer(hash protocol.Hash) TransferHandle

+ func (s *Session) GetAppVersion() int

+ func (s *Session) GetClientID() int32

+ func (s *Session) GetClientName() string

+ func (s *Session) GetCompressionVersion() int

+ func (s *Session) GetCurrentTime() int64

+ func (s *Session) GetDHTTracker() *DHTTracker

+ func (s *Session) GetListenPort() int

+ func (s *Session) GetModBuildVersion() int

+ func (s *Session) GetModMajorVersion() int

+ func (s *Session) GetModMinorVersion() int

+ func (s *Session) GetModName() string

+ func (s *Session) GetTransfers() []TransferHandle

+ func (s *Session) GetUDPPort() int

+ func (s *Session) GetUserAgent() protocol.Hash

+ func (s *Session) ImportSharedFile(path string) error

+ func (s *Session) IsFriendSlot(hash protocol.Hash) bool

+ func (s *Session) ListSharedDirs() []string

+ func (s *Session) Listen() error

+ func (s *Session) LookupTransfer(hash protocol.Hash) *Transfer

+ func (s *Session) OnServerConnectionClosed(sc *ServerConnection, ec BaseErrorCode)

+ func (s *Session) OnServerIDChange(sc *ServerConnection, clientID, tcpFlags, auxPort int32)

+ func (s *Session) OnServerSearchResult(sc *ServerConnection, result *serverproto.SearchResult)

+ func (s *Session) PublishTransferToKAD(t *Transfer)

+ func (s *Session) PublishTransferToServer(t *Transfer)

+ func (s *Session) PumpIO()

+ func (s *Session) RefreshUPnPMapping()

+ func (s *Session) RemoveDiskTask(transfer *Transfer)

+ func (s *Session) RemoveSharedDir(path string) error

+ func (s *Session) RemoveSharedFile(hash protocol.Hash) bool

+ func (s *Session) RemoveTransfer(hash protocol.Hash, deleteFile bool) error

+ func (s *Session) RequestSourcesNow(transfer *Transfer) bool

+ func (s *Session) RescanSharedDirs() error

+ func (s *Session) SearchSnapshot() SearchSnapshot

+ func (s *Session) SecondTick(currentSessionTime, tickIntervalMS int64)

+ func (s *Session) SendDHTSourcesRequest(hash protocol.Hash, size int64, transfer *Transfer) bool

+ func (s *Session) SendSourcesRequest(hash protocol.Hash, size int64) bool

+ func (s *Session) ServerSnapshots() []ServerSnapshot

+ func (s *Session) SetDHTTracker(tracker *DHTTracker)

+ func (s *Session) SetFriendSlot(hash protocol.Hash, enabled bool)

+ func (s *Session) SharedFiles() []*SharedFile

+ func (s *Session) SharedStore() *SharedStore

+ func (s *Session) StartSearch(params SearchParams) (SearchHandle, error)

+ func (s *Session) StopSearch(id uint32) error

+ func (s *Session) SubmitDiskTask(task TransferCallable)

+ func (s *Session) SyncDHTListenPort()

+ func (s *Session) UploadQueue() *UploadQueue

+ type Settings struct

+ BufferPoolSize int

+ ClientName string

+ CompressionVersion int

+ DHTSearchTimeout int

+ EnableDHT bool

+ EnableUPnP bool

+ ListenPort int

+ Logger *slog.Logger

+ MaxConnectionsPerSecond int

+ MaxFailCount int

+ MaxPeerListSize int

+ MaxUploadRateKB int

+ MinPeerReconnectTime int

+ ModBuild int

+ ModMajor int

+ ModMinor int

+ ModName string

+ PeerConnectionTimeout int

+ ReconnectToServer bool

+ ServerPingTimeout int64

+ ServerSearchTimeout int

+ SessionConnectionsLimit int

+ SlotAllocationKB int

+ UDPPort int

+ UploadQueueSize int

+ UploadSlots int

+ UserAgent protocol.Hash

+ Version int

+ func NewSettings() Settings

+ func (s Settings) String() string

+ type SharedFile struct

+ Completed bool

+ FileSize int64

+ Hash protocol.Hash

+ LastHashAt int64

+ Name string

+ Origin SharedOrigin

+ Path string

+ PieceHashes []protocol.Hash

+ func (s *SharedFile) AvailablePieces() protocol.BitField

+ func (s *SharedFile) CanUpload() bool

+ func (s *SharedFile) CanUploadRange(begin, end int64) bool

+ func (s *SharedFile) FileLabel() string

+ func (s *SharedFile) GetHash() protocol.Hash

+ func (s *SharedFile) ReadRange(begin, end int64) ([]byte, error)

+ func (s *SharedFile) Size() int64

+ func (s *SharedFile) UploadHashSet() []protocol.Hash

+ func (s *SharedFile) UploadPriority() UploadPriority

+ type SharedOrigin int

+ const SharedOriginDownloaded

+ const SharedOriginImported

+ type SharedStore struct

+ func NewSharedStore() *SharedStore

+ func (st *SharedStore) Add(f *SharedFile) bool

+ func (st *SharedStore) Get(hash protocol.Hash) *SharedFile

+ func (st *SharedStore) Len() int

+ func (st *SharedStore) List() []*SharedFile

+ func (st *SharedStore) Remove(hash protocol.Hash) bool

+ func (st *SharedStore) ReplaceAll(files []*SharedFile)

+ type SpeedMonitor struct

+ func NewSpeedMonitor(samplesLimit int) SpeedMonitor

+ func (s *SpeedMonitor) AddSample(speedSample int64)

+ func (s *SpeedMonitor) Clear()

+ func (s SpeedMonitor) AverageSpeed() int64

+ func (s SpeedMonitor) NumSamples() int

+ type StatChannel struct

+ func NewStatChannel() StatChannel

+ func (s *StatChannel) Add(count int64)

+ func (s *StatChannel) AddChannel(other StatChannel)

+ func (s *StatChannel) Clear()

+ func (s *StatChannel) Counter() int64

+ func (s *StatChannel) LowPassRate() int64

+ func (s *StatChannel) MergeChannel(other StatChannel)

+ func (s *StatChannel) Rate() int64

+ func (s *StatChannel) SecondTick(timeIntervalMS int64)

+ func (s *StatChannel) Total() int64

+ type Statistics struct

+ func NewStatistics() Statistics

+ func (s *Statistics) Add(other Statistics) *Statistics

+ func (s *Statistics) Clear()

+ func (s *Statistics) Merge(other Statistics) *Statistics

+ func (s *Statistics) ReceiveBytes(protocolBytes, payloadBytes int64)

+ func (s *Statistics) SecondTick(timeIntervalMS int64)

+ func (s *Statistics) SendBytes(protocolBytes, payloadBytes int64)

+ func (s Statistics) DownloadPayloadRate() int64

+ func (s Statistics) DownloadRate() int64

+ func (s Statistics) LastDownload() int64

+ func (s Statistics) LastUpload() int64

+ func (s Statistics) LowPassDownloadRate() int64

+ func (s Statistics) LowPassUploadRate() int64

+ func (s Statistics) TotalPayloadDownload() int64

+ func (s Statistics) TotalPayloadUpload() int64

+ func (s Statistics) TotalProtocolDownload() int64

+ func (s Statistics) TotalProtocolUpload() int64

+ func (s Statistics) TotalUpload() int64

+ func (s Statistics) UploadPayloadRate() int64

+ func (s Statistics) UploadRate() int64

+ type Transfer struct

+ func NewTransfer(s *Session, atp AddTransferParams) (*Transfer, error)

+ func (t *Transfer) Abort(deleteFile bool) error

+ func (t *Transfer) ActiveConnections() int

+ func (t *Transfer) AddPeer(endpoint protocol.Endpoint, sourceFlag int) error

+ func (t *Transfer) AddPeerFromKADV6Search(entry kadv6.SearchEntry) (bool, error)

+ func (t *Transfer) AddStats(s Statistics)

+ func (t *Transfer) AsyncRestoreBlock(block data.PieceBlock)

+ func (t *Transfer) AttachIncomingPeer(c *PeerConnection) error

+ func (t *Transfer) AttachPeer(c *PeerConnection) error

+ func (t *Transfer) AvailablePieces() protocol.BitField

+ func (t *Transfer) CanUpload() bool

+ func (t *Transfer) CanUploadRange(begin, end int64) bool

+ func (t *Transfer) ConnectToPeer(peerInfo *Peer) (*PeerConnection, error)

+ func (t *Transfer) FileLabel() string

+ func (t *Transfer) FileName() string

+ func (t *Transfer) ForceSourceDiscoveryNow()

+ func (t *Transfer) GetCreateTime() int64

+ func (t *Transfer) GetFile() *os.File

+ func (t *Transfer) GetFilePath() string

+ func (t *Transfer) GetHash() protocol.Hash

+ func (t *Transfer) GetPeersInfo() []PeerInfo

+ func (t *Transfer) GetPieceManager() *PieceManager

+ func (t *Transfer) GetStatus() TransferStatus

+ func (t *Transfer) IsAborted() bool

+ func (t *Transfer) IsFinished() bool

+ func (t *Transfer) IsPaused() bool

+ func (t *Transfer) NeedMoreSources() bool

+ func (t *Transfer) NeedResumeDataSave() bool

+ func (t *Transfer) OnBlockRestoreCompleted(block data.PieceBlock, ec BaseErrorCode)

+ func (t *Transfer) OnBlockWriteCompleted(block data.PieceBlock, _ [][]byte, ec BaseErrorCode)

+ func (t *Transfer) OnPieceHashCompleted(pieceIndex int, hash protocol.Hash)

+ func (t *Transfer) OnReleaseFile(_ BaseErrorCode, _ [][]byte, _ bool)

+ func (t *Transfer) Pause()

+ func (t *Transfer) PauseWithDisconnect()

+ func (t *Transfer) PieceSnapshots() []PieceSnapshot

+ func (t *Transfer) QueuePieceHash(pieceIndex int) bool

+ func (t *Transfer) ReadRange(begin, end int64) ([]byte, error)

+ func (t *Transfer) RemovePeerConnection(c *PeerConnection)

+ func (t *Transfer) Resume()

+ func (t *Transfer) ResumeData() *protocol.TransferResumeData

+ func (t *Transfer) ResumeWithState()

+ func (t *Transfer) SecondTick(accumulator *Statistics, tickIntervalMS int64)

+ func (t *Transfer) SetHashSet(hash protocol.Hash, hashes []protocol.Hash)

+ func (t *Transfer) SetUploadPriority(priority UploadPriority)

+ func (t *Transfer) Size() int64

+ func (t *Transfer) TryConnectPeer(sessionTime int64) (bool, error)

+ func (t *Transfer) UploadHashSet() []protocol.Hash

+ func (t *Transfer) UploadPriority() UploadPriority

+ func (t *Transfer) WantMorePeers() bool

+ func (t *Transfer) WeHave(pieceIndex int)

+ type TransferCallable interface

+ Call func() AsyncOperationResult

+ Transfer func() *Transfer

+ type TransferHandle struct

+ func NewTransferHandle(s *Session) TransferHandle

+ func NewTransferHandleWithTransfer(s *Session, t *Transfer) TransferHandle

+ func (h TransferHandle) ActiveConnections() int

+ func (h TransferHandle) GetCreateTime() int64

+ func (h TransferHandle) GetFile() *os.File

+ func (h TransferHandle) GetFilePath() string

+ func (h TransferHandle) GetHash() protocol.Hash

+ func (h TransferHandle) GetPeersInfo() []PeerInfo

+ func (h TransferHandle) GetResumeData() *protocol.TransferResumeData

+ func (h TransferHandle) GetSize() int64

+ func (h TransferHandle) GetStatus() TransferStatus

+ func (h TransferHandle) IsFinished() bool

+ func (h TransferHandle) IsPaused() bool

+ func (h TransferHandle) IsResumed() bool

+ func (h TransferHandle) IsValid() bool

+ func (h TransferHandle) NeedResumeDataSave() bool

+ func (h TransferHandle) Pause()

+ func (h TransferHandle) PieceSnapshots() []PieceSnapshot

+ func (h TransferHandle) Resume()

+ type TransferProgressEvent struct

+ At time.Time

+ Transfers []TransferProgressSnapshot

+ type TransferProgressSnapshot struct

+ ActivePeers int

+ DownloadingPieces int

+ FileName string

+ FilePath string

+ Hash protocol.Hash

+ NumPeers int

+ Paused bool

+ Removed bool

+ State TransferState

+ TotalDone int64

+ TotalReceived int64

+ TotalWanted int64

+ type TransferSnapshot struct

+ ActivePeers int

+ CreateTime int64

+ FileName string

+ FilePath string

+ Hash protocol.Hash

+ Peers []PeerInfo

+ Pieces []PieceSnapshot

+ Size int64

+ Status TransferStatus

+ func (t TransferSnapshot) ED2KLink() string

+ type TransferState string

+ const Downloading

+ const Finished

+ const LoadingResumeData

+ const PausedState

+ const Verifying

+ type TransferStatus struct

+ DownloadRate int

+ DownloadingPieces int

+ ETA int64

+ NumPeers int

+ NumPieces int

+ Paused bool

+ Pieces protocol.BitField

+ State TransferState

+ TotalDone int64

+ TotalReceived int64

+ TotalWanted int64

+ Upload int64

+ UploadRate int

+ func (s TransferStatus) String() string

+ type UploadPriority int

+ const UploadPriorityHigh

+ const UploadPriorityLow

+ const UploadPriorityNormal

+ const UploadPriorityPowerShare

+ const UploadPriorityVeryHigh

+ const UploadPriorityVeryLow

+ func (p UploadPriority) ScoreFactor() float64

+ type UploadQueue struct

+ func NewUploadQueue(session *Session) *UploadQueue

+ func (q *UploadQueue) AddClientToQueue(client *PeerConnection)

+ func (q *UploadQueue) CheckForTimeOver(client *PeerConnection) bool

+ func (q *UploadQueue) IsOnUploadQueue(client *PeerConnection) bool

+ func (q *UploadQueue) IsUploading(client *PeerConnection) bool

+ func (q *UploadQueue) Process()

+ func (q *UploadQueue) RemoveFromUploadQueue(client *PeerConnection) bool

+ func (q *UploadQueue) RemoveFromWaitingQueue(client *PeerConnection) bool

+ func (q *UploadQueue) ResumeUpload(hash protocol.Hash)

+ func (q *UploadQueue) SuspendUpload(hash protocol.Hash, terminate bool) uint16

+ type UploadState int

+ const UploadStateConnecting

+ const UploadStateNone

+ const UploadStateOnQueue

+ const UploadStateUploading

+ type UploadableResource interface

+ AvailablePieces func() protocol.BitField

+ CanUpload func() bool

+ CanUploadRange func(begin, end int64) bool

+ FileLabel func() string

+ GetHash func() protocol.Hash

+ ReadRange func(begin, end int64) ([]byte, error)

+ Size func() int64

+ UploadHashSet func() []protocol.Hash

+ UploadPriority func() UploadPriority

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL