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 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 report a finished task to peer server.

func LaunchPeerServer

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

LaunchPeerServer launch 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 wait 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.