runc/v2/service.go

103 type service struct {  struct
104 	mu          sync.Mutex
105 	eventSendMu sync.Mutex
107 	context  context.Context
108 	events   chan interface{}
109 	platform stdio.Platform
110 	ec       chan runcC.Exit
111 	ep       *oom.Epoller
114 	id string
116 	containers map[string]*runc.Container
118 	cancel func()
161 ….Context, id, containerdBinary, containerdAddress, containerdTTRPCAddress string) (string, error) {
244 func (s *service) Cleanup(ctx context.Context) (*taskAPI.DeleteResponse, error) {
275 …ate(ctx context.Context, r *taskAPI.CreateTaskRequest) (_ *taskAPI.CreateTaskResponse, err error) {
306 … (s *service) Start(ctx context.Context, r *taskAPI.StartRequest) (*taskAPI.StartResponse, error) {
342 … *service) Delete(ctx context.Context, r *taskAPI.DeleteRequest) (*taskAPI.DeleteResponse, error) {
375 func (s *service) Exec(ctx context.Context, r *taskAPI.ExecProcessRequest) (*ptypes.Empty, error) {
398 …c (s *service) ResizePty(ctx context.Context, r *taskAPI.ResizePtyRequest) (*ptypes.Empty, error) {
410 … (s *service) State(ctx context.Context, r *taskAPI.StateRequest) (*taskAPI.StateResponse, error) {
452 func (s *service) Pause(ctx context.Context, r *taskAPI.PauseRequest) (*ptypes.Empty, error) {
467 func (s *service) Resume(ctx context.Context, r *taskAPI.ResumeRequest) (*ptypes.Empty, error) {
482 func (s *service) Kill(ctx context.Context, r *taskAPI.KillRequest) (*ptypes.Empty, error) {
494 func (s *service) Pids(ctx context.Context, r *taskAPI.PidsRequest) (*taskAPI.PidsResponse, error) {
529 func (s *service) CloseIO(ctx context.Context, r *taskAPI.CloseIORequest) (*ptypes.Empty, error) {
541 …service) Checkpoint(ctx context.Context, r *taskAPI.CheckpointTaskRequest) (*ptypes.Empty, error) {
553 func (s *service) Update(ctx context.Context, r *taskAPI.UpdateTaskRequest) (*ptypes.Empty, error) {
565 func (s *service) Wait(ctx context.Context, r *taskAPI.WaitRequest) (*taskAPI.WaitResponse, error) {
583 …ervice) Connect(ctx context.Context, r *taskAPI.ConnectRequest) (*taskAPI.ConnectResponse, error) {
594 func (s *service) Shutdown(ctx context.Context, r *taskAPI.ShutdownRequest) (*ptypes.Empty, error) {
606 … (s *service) Stats(ctx context.Context, r *taskAPI.StatsRequest) (*taskAPI.StatsResponse, error) {
628 func (s *service) processExits() {
634 func (s *service) send(evt interface{}) {
638 func (s *service) sendL(evt interface{}) {
644 func (s *service) checkProcesses(e runcC.Exit) {
706 func (s *service) getContainerPids(ctx context.Context, id string) ([]uint32, error) {
726 func (s *service) forward(ctx context.Context, publisher shim.Publisher) {
740 func (s *service) getContainer(id string) (*runc.Container, error) {
752 func (s *service) initPlatform() error {