uploader

Documentation

Overview

Package uploader implements an uploader server. It is the important role - peer - in P2P pattern that will wait for other P2PDownloader to download its downloaded files.

Index

• func FinishTask(ip string, port int, taskFileName, cid, taskID, node string) error
• func FuzzParseParams(data []byte) int
• func LaunchPeerServer(cfg *config.Config) (int, error)
• func SetupPeerServerExecutor(executor PeerServerExecutor)
• func StartPeerServerProcess(cfg *config.Config) (port int, err error)
• func WaitForShutdown()
• type PeerServerExecutor
  • func GetPeerServerExecutor() PeerServerExecutor

Functions

func FinishTask

func FinishTask(ip string, port int, taskFileName, cid, taskID, node string) error

FinishTask reports a finished task to peer server.

func FuzzParseParams

func FuzzParseParams(data []byte) int

func LaunchPeerServer

func LaunchPeerServer(cfg *config.Config) (int, error)

LaunchPeerServer launches a server to send piece data.

func SetupPeerServerExecutor

func SetupPeerServerExecutor(executor PeerServerExecutor)

SetupPeerServerExecutor setup a giving executor instance instead of default implementation.

func StartPeerServerProcess

func StartPeerServerProcess(cfg *config.Config) (port int, err error)

StartPeerServerProcess starts an independent peer server process for uploading downloaded files if it doesn't exist. This function is invoked when dfget starts to download files in p2p pattern.

func WaitForShutdown

func WaitForShutdown()

WaitForShutdown waits for peer server shutdown.

Types

type PeerServerExecutor

type PeerServerExecutor interface {
	StartPeerServerProcess(cfg *config.Config) (port int, err error)
}

PeerServerExecutor starts an independent peer server process for uploading downloaded files.

func GetPeerServerExecutor

func GetPeerServerExecutor() PeerServerExecutor

GetPeerServerExecutor returns the current executor instance.