controller

Documentation

Index

• Constants
• func GetAvailableCPU(ctx context.Context) (cpuid int, err error)
• func Ping(ctx context.Context) (err error)
• type Daemon
  • func (d *Daemon) AddTask(ctx context.Context, jinfo config.JudgeInfo, dir string, img string) (err error)
  • func (d *Daemon) Run(ctx context.Context)
• type RunResult
• type Worker

Constants

const (
	ExitAC = 42
	ExitWA = 43
)

const (
	FilePerm    = 0644
	DirPerm     = 0755
	SandboxRoot = "/sandbox"
)

const (
	ErrMaxWorkerExceed = "max worker exceed"
)

Functions

func GetAvailableCPU

func GetAvailableCPU(ctx context.Context) (cpuid int, err error)

func Ping

func Ping(ctx context.Context) (err error)

Types

type Daemon

type Daemon struct {
	MaxWorker     int
	CurrentWorker int
	WorkerState   []string
	// contains filtered or unexported fields
}

func (*Daemon) AddTask

func (d *Daemon) AddTask(ctx context.Context, jinfo config.JudgeInfo, dir string, img string) (err error)

func (*Daemon) Run

func (d *Daemon) Run(ctx context.Context)

type RunResult

type RunResult struct {
	Stage string
	RunID int
	// contains filtered or unexported fields
}

type Worker

type Worker struct {
	JudgeInfo    config.JudgeInfo
	WorkDir      string
	DockerImage  string
	RunUser      string
	CPUID        int
	MaxRetryTime int
	// contains filtered or unexported fields
}