link

Documentation

Index

• Constants
• Variables
• type TaskLink
  • func NewTaskLink() *TaskLink
  • func (l *TaskLink) CanExecuteWithLocalIdleResource(command []string) bool
  • func (l *TaskLink) FinalExecute([]string)
  • func (l *TaskLink) GetFilterRules() ([]dcSDK.FilterRuleItem, error)
  • func (l *TaskLink) GetPreloadConfig(config dcType.BoosterConfig) (*dcSDK.PreloadConfig, error)
  • func (l *TaskLink) InitExtra(extra []byte)
  • func (l *TaskLink) InitSandbox(sandbox *dcSyscall.Sandbox)
  • func (l *TaskLink) LocalExecute(command []string) dcType.BKDistCommonError
  • func (l *TaskLink) LocalExecuteNeed(command []string) bool
  • func (l *TaskLink) LocalLockWeight(command []string) int32
  • func (l *TaskLink) NeedRemoteResource(command []string) bool
  • func (l *TaskLink) NeedRetryOnRemoteFail(command []string) bool
  • func (l *TaskLink) OnRemoteFail(command []string) (*dcSDK.BKDistCommand, dcType.BKDistCommonError)
  • func (l *TaskLink) PostExecute(r *dcSDK.BKDistResult) dcType.BKDistCommonError
  • func (l *TaskLink) PostExecuteNeedLock(result *dcSDK.BKDistResult) bool
  • func (l *TaskLink) PostLockWeight(result *dcSDK.BKDistResult) int32
  • func (l *TaskLink) PostWork(config *dcType.BoosterConfig) error
  • func (l *TaskLink) PreExecute(command []string) (*dcSDK.BKDistCommand, dcType.BKDistCommonError)
  • func (l *TaskLink) PreExecuteNeedLock(command []string) bool
  • func (l *TaskLink) PreLockWeight(command []string) int32
  • func (l *TaskLink) PreWork(config *dcType.BoosterConfig) error
  • func (l *TaskLink) RemoteRetryTimes() int
  • func (l *TaskLink) RenderArgs(config dcType.BoosterConfig, originArgs string) string
  • func (l *TaskLink) ResultExtra() []byte

Constants

const (
	// do not distribute if over this
	MaxInputFileSize = 1024 * 1024 * 50
)

Variables

var (
	ErrorMissingOption      = fmt.Errorf("missing option/operand")
	ErrorInvalidOption      = fmt.Errorf("invalid option/operand")
	ErrorUnrecognizedOption = fmt.Errorf("unrecognized option")
	ErrorNoAvailable4Remote = fmt.Errorf("no available for remote")
	ErrorFileNotExist       = fmt.Errorf("file/path not exist")
	ErrorFileInvalid        = fmt.Errorf("file/path invalid")
	ErrorInvalidParam       = fmt.Errorf("param is invalid")
)

errors for link.exe

var (
	// ForceLocalFileKeys force some module to compile locally
	// mscoree.lib missed for SwarmInterface
	ForceLocalFileKeys = []string{"UE4Editor-SwarmInterface"}
)

Types

type TaskLink

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

TaskLink 定义了link.exe链接的描述处理对象, 一般用来处理ue4-win下的link链接

func NewTaskLink

func NewTaskLink() *TaskLink

NewTaskLink get a new link handler

func (*TaskLink) CanExecuteWithLocalIdleResource

func (l *TaskLink) CanExecuteWithLocalIdleResource(command []string) bool

func (*TaskLink) FinalExecute

func (l *TaskLink) FinalExecute([]string)

FinalExecute no need

func (*TaskLink) GetFilterRules

func (l *TaskLink) GetFilterRules() ([]dcSDK.FilterRuleItem, error)

GetFilterRules add file send filter

func (*TaskLink) GetPreloadConfig

func (l *TaskLink) GetPreloadConfig(config dcType.BoosterConfig) (*dcSDK.PreloadConfig, error)

GetPreloadConfig no preload config need

func (*TaskLink) InitExtra

func (l *TaskLink) InitExtra(extra []byte)

InitExtra no need

func (*TaskLink) InitSandbox

func (l *TaskLink) InitSandbox(sandbox *dcSyscall.Sandbox)

InitSandbox set sandbox to task-link

func (*TaskLink) LocalExecute

func (l *TaskLink) LocalExecute(command []string) dcType.BKDistCommonError

LocalExecute no need

func (*TaskLink) LocalExecuteNeed

func (l *TaskLink) LocalExecuteNeed(command []string) bool

LocalExecuteNeed no need

func (*TaskLink) LocalLockWeight

func (l *TaskLink) LocalLockWeight(command []string) int32

LocalLockWeight decide local-execute lock weight, default 1

func (*TaskLink) NeedRemoteResource

func (l *TaskLink) NeedRemoteResource(command []string) bool

NeedRemoteResource check whether this command need remote resource

func (*TaskLink) NeedRetryOnRemoteFail

func (l *TaskLink) NeedRetryOnRemoteFail(command []string) bool

NeedRetryOnRemoteFail check whether need retry on remote fail

func (*TaskLink) OnRemoteFail

func (l *TaskLink) OnRemoteFail(command []string) (*dcSDK.BKDistCommand, dcType.BKDistCommonError)

OnRemoteFail give chance to try other way if failed to remote execute

func (*TaskLink) PostExecute

func (l *TaskLink) PostExecute(r *dcSDK.BKDistResult) dcType.BKDistCommonError

PostExecute 后置处理

func (*TaskLink) PostExecuteNeedLock

func (l *TaskLink) PostExecuteNeedLock(result *dcSDK.BKDistResult) bool

PostExecuteNeedLock 防止回传的文件读写跑满本机磁盘

func (*TaskLink) PostLockWeight

func (l *TaskLink) PostLockWeight(result *dcSDK.BKDistResult) int32

PostLockWeight decide post-execute lock weight, default 1

func (*TaskLink) PostWork

func (l *TaskLink) PostWork(config *dcType.BoosterConfig) error

PostWork no need

func (*TaskLink) PreExecute

func (l *TaskLink) PreExecute(command []string) (*dcSDK.BKDistCommand, dcType.BKDistCommonError)

PreExecute 预处理

func (*TaskLink) PreExecuteNeedLock

func (l *TaskLink) PreExecuteNeedLock(command []string) bool

PreExecuteNeedLock 没有在本地执行的预处理步骤, 无需pre-lock

func (*TaskLink) PreLockWeight

func (l *TaskLink) PreLockWeight(command []string) int32

PreLockWeight decide pre-execute lock weight, default 1

func (*TaskLink) PreWork

func (l *TaskLink) PreWork(config *dcType.BoosterConfig) error

PreWork no need

func (*TaskLink) RemoteRetryTimes

func (l *TaskLink) RemoteRetryTimes() int

RemoteRetryTimes will return the remote retry times

func (*TaskLink) RenderArgs

func (l *TaskLink) RenderArgs(config dcType.BoosterConfig, originArgs string) string

RenderArgs no need change

func (*TaskLink) ResultExtra

func (l *TaskLink) ResultExtra() []byte

ResultExtra no need