runc/v2/service.go

115 type service struct {  struct
116 	mu          sync.Mutex
117 	eventSendMu sync.Mutex
119 	context  context.Context
120 	events   chan interface{}
121 	platform stdio.Platform
122 	ec       chan runcC.Exit
123 	ep       oom.Watcher
126 	id string
128 	containers map[string]*runc.Container
130 	shimAddress string
131 	cancel      func()
174 func (s *service) StartShim(ctx context.Context, opts shim.StartOpts) (_ string, retErr error) {
291 func (s *service) Cleanup(ctx context.Context) (*taskAPI.DeleteResponse, error) {
331 …ate(ctx context.Context, r *taskAPI.CreateTaskRequest) (_ *taskAPI.CreateTaskResponse, err error) {
362 … (s *service) Start(ctx context.Context, r *taskAPI.StartRequest) (*taskAPI.StartResponse, error) {
419 … *service) Delete(ctx context.Context, r *taskAPI.DeleteRequest) (*taskAPI.DeleteResponse, error) {
448 func (s *service) Exec(ctx context.Context, r *taskAPI.ExecProcessRequest) (*ptypes.Empty, error) {
471 …c (s *service) ResizePty(ctx context.Context, r *taskAPI.ResizePtyRequest) (*ptypes.Empty, error) {
483 … (s *service) State(ctx context.Context, r *taskAPI.StateRequest) (*taskAPI.StateResponse, error) {
525 func (s *service) Pause(ctx context.Context, r *taskAPI.PauseRequest) (*ptypes.Empty, error) {
540 func (s *service) Resume(ctx context.Context, r *taskAPI.ResumeRequest) (*ptypes.Empty, error) {
555 func (s *service) Kill(ctx context.Context, r *taskAPI.KillRequest) (*ptypes.Empty, error) {
567 func (s *service) Pids(ctx context.Context, r *taskAPI.PidsRequest) (*taskAPI.PidsResponse, error) {
602 func (s *service) CloseIO(ctx context.Context, r *taskAPI.CloseIORequest) (*ptypes.Empty, error) {
614 …service) Checkpoint(ctx context.Context, r *taskAPI.CheckpointTaskRequest) (*ptypes.Empty, error) {
626 func (s *service) Update(ctx context.Context, r *taskAPI.UpdateTaskRequest) (*ptypes.Empty, error) {
638 func (s *service) Wait(ctx context.Context, r *taskAPI.WaitRequest) (*taskAPI.WaitResponse, error) {
656 …ervice) Connect(ctx context.Context, r *taskAPI.ConnectRequest) (*taskAPI.ConnectResponse, error) {
667 func (s *service) Shutdown(ctx context.Context, r *taskAPI.ShutdownRequest) (*ptypes.Empty, error) {
691 … (s *service) Stats(ctx context.Context, r *taskAPI.StatsRequest) (*taskAPI.StatsResponse, error) {
726 func (s *service) processExits() {
732 func (s *service) send(evt interface{}) {
736 func (s *service) sendL(evt interface{}) {
742 func (s *service) checkProcesses(e runcC.Exit) {
780 func (s *service) getContainerPids(ctx context.Context, id string) ([]uint32, error) {
800 func (s *service) forward(ctx context.Context, publisher shim.Publisher) {
812 func (s *service) getContainer(id string) (*runc.Container, error) {
824 func (s *service) initPlatform() error {