Merge pull request #9538 from containerd/dependabot/go_modules/github.com/Microsoft/hcsshim-0.12.0-rc.1
build(deps): bump github.com/Microsoft/hcsshim from 0.12.0-rc.0 to 0.12.0-rc.1
This commit is contained in:
commit
14e851ecc7
2
go.mod
2
go.mod
@ -7,7 +7,7 @@ require (
|
|||||||
github.com/AdaLogics/go-fuzz-headers v0.0.0-20230811130428-ced1acdcaa24
|
github.com/AdaLogics/go-fuzz-headers v0.0.0-20230811130428-ced1acdcaa24
|
||||||
github.com/AdamKorcz/go-118-fuzz-build v0.0.0-20230306123547-8075edf89bb0
|
github.com/AdamKorcz/go-118-fuzz-build v0.0.0-20230306123547-8075edf89bb0
|
||||||
github.com/Microsoft/go-winio v0.6.1
|
github.com/Microsoft/go-winio v0.6.1
|
||||||
github.com/Microsoft/hcsshim v0.12.0-rc.0
|
github.com/Microsoft/hcsshim v0.12.0-rc.1
|
||||||
github.com/Microsoft/hcsshim/test v0.0.0-20210227013316-43a75bb4edd3
|
github.com/Microsoft/hcsshim/test v0.0.0-20210227013316-43a75bb4edd3
|
||||||
github.com/container-orchestrated-devices/container-device-interface v0.6.1
|
github.com/container-orchestrated-devices/container-device-interface v0.6.1
|
||||||
github.com/containerd/btrfs/v2 v2.0.0
|
github.com/containerd/btrfs/v2 v2.0.0
|
||||||
|
4
go.sum
4
go.sum
@ -59,8 +59,8 @@ github.com/Microsoft/hcsshim v0.8.7-0.20190325164909-8abdbb8205e4/go.mod h1:Op3h
|
|||||||
github.com/Microsoft/hcsshim v0.8.7/go.mod h1:OHd7sQqRFrYd3RmSgbgji+ctCwkbq2wbEYNSzOYtcBQ=
|
github.com/Microsoft/hcsshim v0.8.7/go.mod h1:OHd7sQqRFrYd3RmSgbgji+ctCwkbq2wbEYNSzOYtcBQ=
|
||||||
github.com/Microsoft/hcsshim v0.8.9/go.mod h1:5692vkUqntj1idxauYlpoINNKeqCiG6Sg38RRsjT5y8=
|
github.com/Microsoft/hcsshim v0.8.9/go.mod h1:5692vkUqntj1idxauYlpoINNKeqCiG6Sg38RRsjT5y8=
|
||||||
github.com/Microsoft/hcsshim v0.8.14/go.mod h1:NtVKoYxQuTLx6gEq0L96c9Ju4JbRJ4nY2ow3VK6a9Lg=
|
github.com/Microsoft/hcsshim v0.8.14/go.mod h1:NtVKoYxQuTLx6gEq0L96c9Ju4JbRJ4nY2ow3VK6a9Lg=
|
||||||
github.com/Microsoft/hcsshim v0.12.0-rc.0 h1:wX/F5huJxH9APBkhKSEAqaiZsuBvbbDnyBROZAqsSaY=
|
github.com/Microsoft/hcsshim v0.12.0-rc.1 h1:Hy+xzYujv7urO5wrgcG58SPMOXNLrj4WCJbySs2XX/A=
|
||||||
github.com/Microsoft/hcsshim v0.12.0-rc.0/go.mod h1:rvOnw3YlfoNnEp45wReUngvsXbwRW+AFQ10GVjG1kMU=
|
github.com/Microsoft/hcsshim v0.12.0-rc.1/go.mod h1:Y1a1S0QlYp1mBpyvGiuEdOfZqnao+0uX5AWHXQ5NhZU=
|
||||||
github.com/Microsoft/hcsshim/test v0.0.0-20201218223536-d3e5debf77da/go.mod h1:5hlzMzRKMLyo42nCZ9oml8AdTlq/0cvIaBv6tK1RehU=
|
github.com/Microsoft/hcsshim/test v0.0.0-20201218223536-d3e5debf77da/go.mod h1:5hlzMzRKMLyo42nCZ9oml8AdTlq/0cvIaBv6tK1RehU=
|
||||||
github.com/Microsoft/hcsshim/test v0.0.0-20210227013316-43a75bb4edd3 h1:4FA+QBaydEHlwxg0lMN3rhwoDaQy6LKhVWR4qvq4BuA=
|
github.com/Microsoft/hcsshim/test v0.0.0-20210227013316-43a75bb4edd3 h1:4FA+QBaydEHlwxg0lMN3rhwoDaQy6LKhVWR4qvq4BuA=
|
||||||
github.com/Microsoft/hcsshim/test v0.0.0-20210227013316-43a75bb4edd3/go.mod h1:mw7qgWloBUl75W/gVH3cQszUg1+gUITj7D6NY7ywVnY=
|
github.com/Microsoft/hcsshim/test v0.0.0-20210227013316-43a75bb4edd3/go.mod h1:mw7qgWloBUl75W/gVH3cQszUg1+gUITj7D6NY7ywVnY=
|
||||||
|
12
vendor/github.com/Microsoft/hcsshim/hcn/hcn.go
generated
vendored
12
vendor/github.com/Microsoft/hcsshim/hcn/hcn.go
generated
vendored
@ -312,6 +312,18 @@ func NestedIpSetSupported() error {
|
|||||||
return platformDoesNotSupportError("NestedIpSet")
|
return platformDoesNotSupportError("NestedIpSet")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// DisableHostPortSupported returns an error if the HCN version does not support DisableHostPort flag
|
||||||
|
func DisableHostPortSupported() error {
|
||||||
|
supported, err := GetCachedSupportedFeatures()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
if supported.DisableHostPort {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
return platformDoesNotSupportError("DisableHostPort")
|
||||||
|
}
|
||||||
|
|
||||||
// RequestType are the different operations performed to settings.
|
// RequestType are the different operations performed to settings.
|
||||||
// Used to update the settings of Endpoint/Namespace objects.
|
// Used to update the settings of Endpoint/Namespace objects.
|
||||||
type RequestType string
|
type RequestType string
|
||||||
|
3
vendor/github.com/Microsoft/hcsshim/hcn/hcnglobals.go
generated
vendored
3
vendor/github.com/Microsoft/hcsshim/hcn/hcnglobals.go
generated
vendored
@ -84,6 +84,9 @@ var (
|
|||||||
|
|
||||||
//HNS 15.0 allows for NestedIpSet support
|
//HNS 15.0 allows for NestedIpSet support
|
||||||
NestedIpSetVersion = VersionRanges{VersionRange{MinVersion: Version{Major: 15, Minor: 0}, MaxVersion: Version{Major: math.MaxInt32, Minor: math.MaxInt32}}}
|
NestedIpSetVersion = VersionRanges{VersionRange{MinVersion: Version{Major: 15, Minor: 0}, MaxVersion: Version{Major: math.MaxInt32, Minor: math.MaxInt32}}}
|
||||||
|
|
||||||
|
//HNS 15.1 allows support for DisableHostPort flag.
|
||||||
|
DisableHostPortVersion = VersionRanges{VersionRange{MinVersion: Version{Major: 15, Minor: 1}, MaxVersion: Version{Major: math.MaxInt32, Minor: math.MaxInt32}}}
|
||||||
)
|
)
|
||||||
|
|
||||||
// GetGlobals returns the global properties of the HCN Service.
|
// GetGlobals returns the global properties of the HCN Service.
|
||||||
|
1
vendor/github.com/Microsoft/hcsshim/hcn/hcnnetwork.go
generated
vendored
1
vendor/github.com/Microsoft/hcsshim/hcn/hcnnetwork.go
generated
vendored
@ -72,6 +72,7 @@ type NetworkFlags uint32
|
|||||||
const (
|
const (
|
||||||
None NetworkFlags = 0
|
None NetworkFlags = 0
|
||||||
EnableNonPersistent NetworkFlags = 8
|
EnableNonPersistent NetworkFlags = 8
|
||||||
|
DisableHostPort NetworkFlags = 1024
|
||||||
)
|
)
|
||||||
|
|
||||||
// HostComputeNetwork represents a network
|
// HostComputeNetwork represents a network
|
||||||
|
2
vendor/github.com/Microsoft/hcsshim/hcn/hcnsupport.go
generated
vendored
2
vendor/github.com/Microsoft/hcsshim/hcn/hcnsupport.go
generated
vendored
@ -37,6 +37,7 @@ type SupportedFeatures struct {
|
|||||||
TierAcl bool `json:"TierAcl"`
|
TierAcl bool `json:"TierAcl"`
|
||||||
NetworkACL bool `json:"NetworkACL"`
|
NetworkACL bool `json:"NetworkACL"`
|
||||||
NestedIpSet bool `json:"NestedIpSet"`
|
NestedIpSet bool `json:"NestedIpSet"`
|
||||||
|
DisableHostPort bool `json:"DisableHostPort"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// AclFeatures are the supported ACL possibilities.
|
// AclFeatures are the supported ACL possibilities.
|
||||||
@ -114,6 +115,7 @@ func getSupportedFeatures() (SupportedFeatures, error) {
|
|||||||
features.TierAcl = isFeatureSupported(globals.Version, TierAclPolicyVersion)
|
features.TierAcl = isFeatureSupported(globals.Version, TierAclPolicyVersion)
|
||||||
features.NetworkACL = isFeatureSupported(globals.Version, NetworkACLPolicyVersion)
|
features.NetworkACL = isFeatureSupported(globals.Version, NetworkACLPolicyVersion)
|
||||||
features.NestedIpSet = isFeatureSupported(globals.Version, NestedIpSetVersion)
|
features.NestedIpSet = isFeatureSupported(globals.Version, NestedIpSetVersion)
|
||||||
|
features.DisableHostPort = isFeatureSupported(globals.Version, DisableHostPortVersion)
|
||||||
|
|
||||||
log.L.WithFields(logrus.Fields{
|
log.L.WithFields(logrus.Fields{
|
||||||
"version": globals.Version,
|
"version": globals.Version,
|
||||||
|
68
vendor/github.com/Microsoft/hcsshim/internal/hcs/process.go
generated
vendored
68
vendor/github.com/Microsoft/hcsshim/internal/hcs/process.go
generated
vendored
@ -12,14 +12,16 @@ import (
|
|||||||
"syscall"
|
"syscall"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"go.opencensus.io/trace"
|
||||||
|
|
||||||
"github.com/Microsoft/hcsshim/internal/cow"
|
"github.com/Microsoft/hcsshim/internal/cow"
|
||||||
|
hcsschema "github.com/Microsoft/hcsshim/internal/hcs/schema2"
|
||||||
"github.com/Microsoft/hcsshim/internal/log"
|
"github.com/Microsoft/hcsshim/internal/log"
|
||||||
"github.com/Microsoft/hcsshim/internal/oc"
|
"github.com/Microsoft/hcsshim/internal/oc"
|
||||||
|
"github.com/Microsoft/hcsshim/internal/protocol/guestrequest"
|
||||||
"github.com/Microsoft/hcsshim/internal/vmcompute"
|
"github.com/Microsoft/hcsshim/internal/vmcompute"
|
||||||
"go.opencensus.io/trace"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
// ContainerError is an error encountered in HCS
|
|
||||||
type Process struct {
|
type Process struct {
|
||||||
handleLock sync.RWMutex
|
handleLock sync.RWMutex
|
||||||
handle vmcompute.HcsProcess
|
handle vmcompute.HcsProcess
|
||||||
@ -50,35 +52,6 @@ func newProcess(process vmcompute.HcsProcess, processID int, computeSystem *Syst
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
type processModifyRequest struct {
|
|
||||||
Operation string
|
|
||||||
ConsoleSize *consoleSize `json:",omitempty"`
|
|
||||||
CloseHandle *closeHandle `json:",omitempty"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type consoleSize struct {
|
|
||||||
Height uint16
|
|
||||||
Width uint16
|
|
||||||
}
|
|
||||||
|
|
||||||
type closeHandle struct {
|
|
||||||
Handle string
|
|
||||||
}
|
|
||||||
|
|
||||||
type processStatus struct {
|
|
||||||
ProcessID uint32
|
|
||||||
Exited bool
|
|
||||||
ExitCode uint32
|
|
||||||
LastWaitResult int32
|
|
||||||
}
|
|
||||||
|
|
||||||
const stdIn string = "StdIn"
|
|
||||||
|
|
||||||
const (
|
|
||||||
modifyConsoleSize string = "ConsoleSize"
|
|
||||||
modifyCloseHandle string = "CloseHandle"
|
|
||||||
)
|
|
||||||
|
|
||||||
// Pid returns the process ID of the process within the container.
|
// Pid returns the process ID of the process within the container.
|
||||||
func (process *Process) Pid() int {
|
func (process *Process) Pid() int {
|
||||||
return process.processID
|
return process.processID
|
||||||
@ -260,14 +233,14 @@ func (process *Process) waitBackground() {
|
|||||||
process.handleLock.RLock()
|
process.handleLock.RLock()
|
||||||
defer process.handleLock.RUnlock()
|
defer process.handleLock.RUnlock()
|
||||||
|
|
||||||
// Make sure we didnt race with Close() here
|
// Make sure we didn't race with Close() here
|
||||||
if process.handle != 0 {
|
if process.handle != 0 {
|
||||||
propertiesJSON, resultJSON, err = vmcompute.HcsGetProcessProperties(ctx, process.handle)
|
propertiesJSON, resultJSON, err = vmcompute.HcsGetProcessProperties(ctx, process.handle)
|
||||||
events := processHcsResult(ctx, resultJSON)
|
events := processHcsResult(ctx, resultJSON)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
err = makeProcessError(process, operation, err, events)
|
err = makeProcessError(process, operation, err, events)
|
||||||
} else {
|
} else {
|
||||||
properties := &processStatus{}
|
properties := &hcsschema.ProcessStatus{}
|
||||||
err = json.Unmarshal([]byte(propertiesJSON), properties)
|
err = json.Unmarshal([]byte(propertiesJSON), properties)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
err = makeProcessError(process, operation, err, nil)
|
err = makeProcessError(process, operation, err, nil)
|
||||||
@ -318,10 +291,9 @@ func (process *Process) ResizeConsole(ctx context.Context, width, height uint16)
|
|||||||
if process.handle == 0 {
|
if process.handle == 0 {
|
||||||
return makeProcessError(process, operation, ErrAlreadyClosed, nil)
|
return makeProcessError(process, operation, ErrAlreadyClosed, nil)
|
||||||
}
|
}
|
||||||
|
modifyRequest := hcsschema.ProcessModifyRequest{
|
||||||
modifyRequest := processModifyRequest{
|
Operation: guestrequest.ModifyProcessConsoleSize,
|
||||||
Operation: modifyConsoleSize,
|
ConsoleSize: &hcsschema.ConsoleSize{
|
||||||
ConsoleSize: &consoleSize{
|
|
||||||
Height: height,
|
Height: height,
|
||||||
Width: width,
|
Width: width,
|
||||||
},
|
},
|
||||||
@ -421,18 +393,12 @@ func (process *Process) CloseStdin(ctx context.Context) (err error) {
|
|||||||
return makeProcessError(process, operation, ErrAlreadyClosed, nil)
|
return makeProcessError(process, operation, ErrAlreadyClosed, nil)
|
||||||
}
|
}
|
||||||
|
|
||||||
process.stdioLock.Lock()
|
|
||||||
defer process.stdioLock.Unlock()
|
|
||||||
if process.stdin == nil {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
//HcsModifyProcess request to close stdin will fail if the process has already exited
|
//HcsModifyProcess request to close stdin will fail if the process has already exited
|
||||||
if !process.stopped() {
|
if !process.stopped() {
|
||||||
modifyRequest := processModifyRequest{
|
modifyRequest := hcsschema.ProcessModifyRequest{
|
||||||
Operation: modifyCloseHandle,
|
Operation: guestrequest.CloseProcessHandle,
|
||||||
CloseHandle: &closeHandle{
|
CloseHandle: &hcsschema.CloseHandle{
|
||||||
Handle: stdIn,
|
Handle: guestrequest.STDInHandle,
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -448,8 +414,12 @@ func (process *Process) CloseStdin(ctx context.Context) (err error) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
process.stdin.Close()
|
process.stdioLock.Lock()
|
||||||
process.stdin = nil
|
defer process.stdioLock.Unlock()
|
||||||
|
if process.stdin != nil {
|
||||||
|
process.stdin.Close()
|
||||||
|
process.stdin = nil
|
||||||
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
4
vendor/github.com/Microsoft/hcsshim/internal/hcs/schema2/close_handle.go
generated
vendored
4
vendor/github.com/Microsoft/hcsshim/internal/hcs/schema2/close_handle.go
generated
vendored
@ -9,6 +9,8 @@
|
|||||||
|
|
||||||
package hcsschema
|
package hcsschema
|
||||||
|
|
||||||
|
import "github.com/Microsoft/hcsshim/internal/protocol/guestrequest"
|
||||||
|
|
||||||
type CloseHandle struct {
|
type CloseHandle struct {
|
||||||
Handle string `json:"Handle,omitempty"`
|
Handle guestrequest.STDIOHandle `json:"Handle,omitempty"` // NOTE: Swagger generated as string. Locally updated.
|
||||||
}
|
}
|
||||||
|
9
vendor/github.com/Microsoft/hcsshim/internal/hcs/schema2/console_size.go
generated
vendored
9
vendor/github.com/Microsoft/hcsshim/internal/hcs/schema2/console_size.go
generated
vendored
@ -9,8 +9,11 @@
|
|||||||
|
|
||||||
package hcsschema
|
package hcsschema
|
||||||
|
|
||||||
type ConsoleSize struct {
|
// NOTE: Swagger generated fields as int32. Locally updated to uint16 to match documentation.
|
||||||
Height int32 `json:"Height,omitempty"`
|
// https://learn.microsoft.com/en-us/virtualization/api/hcs/schemareference#ConsoleSize
|
||||||
|
|
||||||
Width int32 `json:"Width,omitempty"`
|
type ConsoleSize struct {
|
||||||
|
Height uint16 `json:"Height,omitempty"`
|
||||||
|
|
||||||
|
Width uint16 `json:"Width,omitempty"`
|
||||||
}
|
}
|
||||||
|
6
vendor/github.com/Microsoft/hcsshim/internal/hcs/schema2/process_modify_request.go
generated
vendored
6
vendor/github.com/Microsoft/hcsshim/internal/hcs/schema2/process_modify_request.go
generated
vendored
@ -9,9 +9,11 @@
|
|||||||
|
|
||||||
package hcsschema
|
package hcsschema
|
||||||
|
|
||||||
// Passed to HcsRpc_ModifyProcess
|
import "github.com/Microsoft/hcsshim/internal/protocol/guestrequest"
|
||||||
|
|
||||||
|
// Passed to HcsRpc_ModifyProcess
|
||||||
type ProcessModifyRequest struct {
|
type ProcessModifyRequest struct {
|
||||||
Operation string `json:"Operation,omitempty"`
|
Operation guestrequest.ProcessModifyOperation `json:"Operation,omitempty"` // NOTE: Swagger generated as string. Locally updated.
|
||||||
|
|
||||||
ConsoleSize *ConsoleSize `json:"ConsoleSize,omitempty"`
|
ConsoleSize *ConsoleSize `json:"ConsoleSize,omitempty"`
|
||||||
|
|
||||||
|
9
vendor/github.com/Microsoft/hcsshim/internal/hcs/schema2/process_status.go
generated
vendored
9
vendor/github.com/Microsoft/hcsshim/internal/hcs/schema2/process_status.go
generated
vendored
@ -9,13 +9,16 @@
|
|||||||
|
|
||||||
package hcsschema
|
package hcsschema
|
||||||
|
|
||||||
// Status of a process running in a container
|
// NOTE: Swagger generated fields as int32. Locally updated to uint16 to match documentation.
|
||||||
|
// https://learn.microsoft.com/en-us/virtualization/api/hcs/schemareference#ConsoleSize
|
||||||
|
|
||||||
|
// Status of a process running in a container
|
||||||
type ProcessStatus struct {
|
type ProcessStatus struct {
|
||||||
ProcessId int32 `json:"ProcessId,omitempty"`
|
ProcessId uint32 `json:"ProcessId,omitempty"` // NOTE: Swagger generated as int32. Locally updated to match documentation.
|
||||||
|
|
||||||
Exited bool `json:"Exited,omitempty"`
|
Exited bool `json:"Exited,omitempty"`
|
||||||
|
|
||||||
ExitCode int32 `json:"ExitCode,omitempty"`
|
ExitCode uint32 `json:"ExitCode,omitempty"` // NOTE: Swagger generated as int32. Locally updated to match documentation.
|
||||||
|
|
||||||
LastWaitResult int32 `json:"LastWaitResult,omitempty"`
|
LastWaitResult int32 `json:"LastWaitResult,omitempty"`
|
||||||
}
|
}
|
||||||
|
31
vendor/github.com/Microsoft/hcsshim/internal/hcs/system.go
generated
vendored
31
vendor/github.com/Microsoft/hcsshim/internal/hcs/system.go
generated
vendored
@ -304,11 +304,22 @@ func (computeSystem *System) WaitError() error {
|
|||||||
return computeSystem.waitError
|
return computeSystem.waitError
|
||||||
}
|
}
|
||||||
|
|
||||||
// Wait synchronously waits for the compute system to shutdown or terminate. If
|
// Wait synchronously waits for the compute system to shutdown or terminate.
|
||||||
// the compute system has already exited returns the previous error (if any).
|
// If the compute system has already exited returns the previous error (if any).
|
||||||
func (computeSystem *System) Wait() error {
|
func (computeSystem *System) Wait() error {
|
||||||
<-computeSystem.WaitChannel()
|
return computeSystem.WaitCtx(context.Background())
|
||||||
return computeSystem.WaitError()
|
}
|
||||||
|
|
||||||
|
// WaitCtx synchronously waits for the compute system to shutdown or terminate, or the context to be cancelled.
|
||||||
|
//
|
||||||
|
// See [System.Wait] for more information.
|
||||||
|
func (computeSystem *System) WaitCtx(ctx context.Context) error {
|
||||||
|
select {
|
||||||
|
case <-computeSystem.WaitChannel():
|
||||||
|
return computeSystem.WaitError()
|
||||||
|
case <-ctx.Done():
|
||||||
|
return ctx.Err()
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// stopped returns true if the compute system stopped.
|
// stopped returns true if the compute system stopped.
|
||||||
@ -735,9 +746,17 @@ func (computeSystem *System) OpenProcess(ctx context.Context, pid int) (*Process
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Close cleans up any state associated with the compute system but does not terminate or wait for it.
|
// Close cleans up any state associated with the compute system but does not terminate or wait for it.
|
||||||
func (computeSystem *System) Close() (err error) {
|
func (computeSystem *System) Close() error {
|
||||||
|
return computeSystem.CloseCtx(context.Background())
|
||||||
|
}
|
||||||
|
|
||||||
|
// CloseCtx is similar to [System.Close], but accepts a context.
|
||||||
|
//
|
||||||
|
// The context is used for all operations, including waits, so timeouts/cancellations may prevent
|
||||||
|
// proper system cleanup.
|
||||||
|
func (computeSystem *System) CloseCtx(ctx context.Context) (err error) {
|
||||||
operation := "hcs::System::Close"
|
operation := "hcs::System::Close"
|
||||||
ctx, span := oc.StartSpan(context.Background(), operation)
|
ctx, span := oc.StartSpan(ctx, operation)
|
||||||
defer span.End()
|
defer span.End()
|
||||||
defer func() { oc.SetSpanStatus(span, err) }()
|
defer func() { oc.SetSpanStatus(span, err) }()
|
||||||
span.AddAttributes(trace.StringAttribute("cid", computeSystem.id))
|
span.AddAttributes(trace.StringAttribute("cid", computeSystem.id))
|
||||||
|
7
vendor/github.com/Microsoft/hcsshim/internal/log/format.go
generated
vendored
7
vendor/github.com/Microsoft/hcsshim/internal/log/format.go
generated
vendored
@ -9,13 +9,16 @@ import (
|
|||||||
"reflect"
|
"reflect"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/containerd/containerd/log"
|
|
||||||
"github.com/sirupsen/logrus"
|
"github.com/sirupsen/logrus"
|
||||||
"google.golang.org/protobuf/encoding/protojson"
|
"google.golang.org/protobuf/encoding/protojson"
|
||||||
"google.golang.org/protobuf/proto"
|
"google.golang.org/protobuf/proto"
|
||||||
)
|
)
|
||||||
|
|
||||||
const TimeFormat = log.RFC3339NanoFixed
|
// TimeFormat is [time.RFC3339Nano] with nanoseconds padded using
|
||||||
|
// zeros to ensure the formatted time is always the same number of
|
||||||
|
// characters.
|
||||||
|
// Based on RFC3339NanoFixed from github.com/containerd/log
|
||||||
|
const TimeFormat = "2006-01-02T15:04:05.000000000Z07:00"
|
||||||
|
|
||||||
func FormatTime(t time.Time) string {
|
func FormatTime(t time.Time) string {
|
||||||
return t.Format(TimeFormat)
|
return t.Format(TimeFormat)
|
||||||
|
5
vendor/github.com/Microsoft/hcsshim/internal/log/hook.go
generated
vendored
5
vendor/github.com/Microsoft/hcsshim/internal/log/hook.go
generated
vendored
@ -6,7 +6,6 @@ import (
|
|||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/Microsoft/hcsshim/internal/logfields"
|
"github.com/Microsoft/hcsshim/internal/logfields"
|
||||||
"github.com/containerd/containerd/log"
|
|
||||||
"github.com/sirupsen/logrus"
|
"github.com/sirupsen/logrus"
|
||||||
"go.opencensus.io/trace"
|
"go.opencensus.io/trace"
|
||||||
)
|
)
|
||||||
@ -30,7 +29,7 @@ type Hook struct {
|
|||||||
// An empty string disables formatting.
|
// An empty string disables formatting.
|
||||||
// When disabled, the fall back will the JSON encoding, if enabled.
|
// When disabled, the fall back will the JSON encoding, if enabled.
|
||||||
//
|
//
|
||||||
// Default is [github.com/containerd/containerd/log.RFC3339NanoFixed].
|
// Default is [TimeFormat].
|
||||||
TimeFormat string
|
TimeFormat string
|
||||||
|
|
||||||
// Duration format converts a [time.Duration] fields to an appropriate encoding.
|
// Duration format converts a [time.Duration] fields to an appropriate encoding.
|
||||||
@ -49,7 +48,7 @@ var _ logrus.Hook = &Hook{}
|
|||||||
|
|
||||||
func NewHook() *Hook {
|
func NewHook() *Hook {
|
||||||
return &Hook{
|
return &Hook{
|
||||||
TimeFormat: log.RFC3339NanoFixed,
|
TimeFormat: TimeFormat,
|
||||||
DurationFormat: DurationFormatString,
|
DurationFormat: DurationFormatString,
|
||||||
AddSpanContext: true,
|
AddSpanContext: true,
|
||||||
}
|
}
|
||||||
|
12
vendor/github.com/Microsoft/hcsshim/internal/log/nopformatter.go
generated
vendored
Normal file
12
vendor/github.com/Microsoft/hcsshim/internal/log/nopformatter.go
generated
vendored
Normal file
@ -0,0 +1,12 @@
|
|||||||
|
package log
|
||||||
|
|
||||||
|
import (
|
||||||
|
"github.com/sirupsen/logrus"
|
||||||
|
)
|
||||||
|
|
||||||
|
type NopFormatter struct{}
|
||||||
|
|
||||||
|
var _ logrus.Formatter = NopFormatter{}
|
||||||
|
|
||||||
|
// Format does nothing and returns a nil slice.
|
||||||
|
func (NopFormatter) Format(*logrus.Entry) ([]byte, error) { return nil, nil }
|
22
vendor/github.com/Microsoft/hcsshim/internal/protocol/guestrequest/types.go
generated
vendored
22
vendor/github.com/Microsoft/hcsshim/internal/protocol/guestrequest/types.go
generated
vendored
@ -5,7 +5,7 @@ package guestrequest
|
|||||||
type RequestType string
|
type RequestType string
|
||||||
type ResourceType string
|
type ResourceType string
|
||||||
|
|
||||||
// RequestType const
|
// RequestType const.
|
||||||
const (
|
const (
|
||||||
RequestTypeAdd RequestType = "Add"
|
RequestTypeAdd RequestType = "Add"
|
||||||
RequestTypeRemove RequestType = "Remove"
|
RequestTypeRemove RequestType = "Remove"
|
||||||
@ -54,3 +54,23 @@ var (
|
|||||||
"305891a9-b251-5dfe-91a2-c25d9212275b",
|
"305891a9-b251-5dfe-91a2-c25d9212275b",
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
|
// constants for v2 schema ProcessModifyRequest
|
||||||
|
|
||||||
|
// Operation type for [hcsschema.ProcessModifyRequest].
|
||||||
|
type ProcessModifyOperation string
|
||||||
|
|
||||||
|
const (
|
||||||
|
ModifyProcessConsoleSize ProcessModifyOperation = "ConsoleSize"
|
||||||
|
CloseProcessHandle ProcessModifyOperation = "CloseHandle"
|
||||||
|
)
|
||||||
|
|
||||||
|
// Standard IO handle(s) to close for [hcsschema.CloseHandle] in [hcsschema.ProcessModifyRequest].
|
||||||
|
type STDIOHandle string
|
||||||
|
|
||||||
|
const (
|
||||||
|
STDInHandle STDIOHandle = "StdIn"
|
||||||
|
STDOutHandle STDIOHandle = "StdOut"
|
||||||
|
STDErrHandle STDIOHandle = "StdErr"
|
||||||
|
AllHandles STDIOHandle = "All"
|
||||||
|
)
|
||||||
|
24
vendor/github.com/Microsoft/hcsshim/internal/wclayer/layerutils.go
generated
vendored
24
vendor/github.com/Microsoft/hcsshim/internal/wclayer/layerutils.go
generated
vendored
@ -7,6 +7,10 @@ package wclayer
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
"fmt"
|
||||||
|
"os"
|
||||||
|
"path/filepath"
|
||||||
|
"strconv"
|
||||||
"syscall"
|
"syscall"
|
||||||
|
|
||||||
"github.com/Microsoft/go-winio/pkg/guid"
|
"github.com/Microsoft/go-winio/pkg/guid"
|
||||||
@ -101,3 +105,23 @@ func layerPathsToDescriptors(ctx context.Context, parentLayerPaths []string) ([]
|
|||||||
|
|
||||||
return layers, nil
|
return layers, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// GetLayerUvmBuild looks for a file named `uvmbuildversion` at `layerPath\uvmbuildversion` and returns the
|
||||||
|
// build number of the UVM from that file.
|
||||||
|
func GetLayerUvmBuild(layerPath string) (uint16, error) {
|
||||||
|
data, err := os.ReadFile(filepath.Join(layerPath, UvmBuildFileName))
|
||||||
|
if err != nil {
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
|
ver, err := strconv.ParseUint(string(data), 10, 16)
|
||||||
|
if err != nil {
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
|
return uint16(ver), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// WriteLayerUvmBuildFile writes a file at path `layerPath\uvmbuildversion` that contains the given `build`
|
||||||
|
// version for future reference.
|
||||||
|
func WriteLayerUvmBuildFile(layerPath string, build uint16) error {
|
||||||
|
return os.WriteFile(filepath.Join(layerPath, UvmBuildFileName), []byte(fmt.Sprintf("%d", build)), 0777)
|
||||||
|
}
|
||||||
|
1
vendor/github.com/Microsoft/hcsshim/layer.go
generated
vendored
1
vendor/github.com/Microsoft/hcsshim/layer.go
generated
vendored
@ -32,6 +32,7 @@ func CreateScratchLayer(info DriverInfo, layerId, parentId string, parentLayerPa
|
|||||||
func DeactivateLayer(info DriverInfo, id string) error {
|
func DeactivateLayer(info DriverInfo, id string) error {
|
||||||
return wclayer.DeactivateLayer(context.Background(), layerPath(&info, id))
|
return wclayer.DeactivateLayer(context.Background(), layerPath(&info, id))
|
||||||
}
|
}
|
||||||
|
|
||||||
func DestroyLayer(info DriverInfo, id string) error {
|
func DestroyLayer(info DriverInfo, id string) error {
|
||||||
return wclayer.DestroyLayer(context.Background(), layerPath(&info, id))
|
return wclayer.DestroyLayer(context.Background(), layerPath(&info, id))
|
||||||
}
|
}
|
||||||
|
149
vendor/github.com/containerd/containerd/log/context_deprecated.go
generated
vendored
149
vendor/github.com/containerd/containerd/log/context_deprecated.go
generated
vendored
@ -1,149 +0,0 @@
|
|||||||
/*
|
|
||||||
Copyright The containerd Authors.
|
|
||||||
|
|
||||||
Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
you may not use this file except in compliance with the License.
|
|
||||||
You may obtain a copy of the License at
|
|
||||||
|
|
||||||
http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
|
|
||||||
Unless required by applicable law or agreed to in writing, software
|
|
||||||
distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
See the License for the specific language governing permissions and
|
|
||||||
limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package log
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
|
|
||||||
"github.com/containerd/log"
|
|
||||||
)
|
|
||||||
|
|
||||||
// G is a shorthand for [GetLogger].
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.G].
|
|
||||||
var G = log.G
|
|
||||||
|
|
||||||
// L is an alias for the standard logger.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.L].
|
|
||||||
var L = log.L
|
|
||||||
|
|
||||||
// Fields type to pass to "WithFields".
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.Fields].
|
|
||||||
type Fields = log.Fields
|
|
||||||
|
|
||||||
// Entry is a logging entry.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.Entry].
|
|
||||||
type Entry = log.Entry
|
|
||||||
|
|
||||||
// RFC3339NanoFixed is [time.RFC3339Nano] with nanoseconds padded using
|
|
||||||
// zeros to ensure the formatted time is always the same number of
|
|
||||||
// characters.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.RFC3339NanoFixed].
|
|
||||||
const RFC3339NanoFixed = log.RFC3339NanoFixed
|
|
||||||
|
|
||||||
// Level is a logging level.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.Level].
|
|
||||||
type Level = log.Level
|
|
||||||
|
|
||||||
// Supported log levels.
|
|
||||||
const (
|
|
||||||
// TraceLevel level.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.TraceLevel].
|
|
||||||
TraceLevel Level = log.TraceLevel
|
|
||||||
|
|
||||||
// DebugLevel level.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.DebugLevel].
|
|
||||||
DebugLevel Level = log.DebugLevel
|
|
||||||
|
|
||||||
// InfoLevel level.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.InfoLevel].
|
|
||||||
InfoLevel Level = log.InfoLevel
|
|
||||||
|
|
||||||
// WarnLevel level.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.WarnLevel].
|
|
||||||
WarnLevel Level = log.WarnLevel
|
|
||||||
|
|
||||||
// ErrorLevel level
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.ErrorLevel].
|
|
||||||
ErrorLevel Level = log.ErrorLevel
|
|
||||||
|
|
||||||
// FatalLevel level.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.FatalLevel].
|
|
||||||
FatalLevel Level = log.FatalLevel
|
|
||||||
|
|
||||||
// PanicLevel level.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.PanicLevel].
|
|
||||||
PanicLevel Level = log.PanicLevel
|
|
||||||
)
|
|
||||||
|
|
||||||
// SetLevel sets log level globally. It returns an error if the given
|
|
||||||
// level is not supported.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.SetLevel].
|
|
||||||
func SetLevel(level string) error {
|
|
||||||
return log.SetLevel(level)
|
|
||||||
}
|
|
||||||
|
|
||||||
// GetLevel returns the current log level.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.GetLevel].
|
|
||||||
func GetLevel() log.Level {
|
|
||||||
return log.GetLevel()
|
|
||||||
}
|
|
||||||
|
|
||||||
// OutputFormat specifies a log output format.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.OutputFormat].
|
|
||||||
type OutputFormat = log.OutputFormat
|
|
||||||
|
|
||||||
// Supported log output formats.
|
|
||||||
const (
|
|
||||||
// TextFormat represents the text logging format.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.TextFormat].
|
|
||||||
TextFormat log.OutputFormat = "text"
|
|
||||||
|
|
||||||
// JSONFormat represents the JSON logging format.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.JSONFormat].
|
|
||||||
JSONFormat log.OutputFormat = "json"
|
|
||||||
)
|
|
||||||
|
|
||||||
// SetFormat sets the log output format.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.SetFormat].
|
|
||||||
func SetFormat(format OutputFormat) error {
|
|
||||||
return log.SetFormat(format)
|
|
||||||
}
|
|
||||||
|
|
||||||
// WithLogger returns a new context with the provided logger. Use in
|
|
||||||
// combination with logger.WithField(s) for great effect.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.WithLogger].
|
|
||||||
func WithLogger(ctx context.Context, logger *log.Entry) context.Context {
|
|
||||||
return log.WithLogger(ctx, logger)
|
|
||||||
}
|
|
||||||
|
|
||||||
// GetLogger retrieves the current logger from the context. If no logger is
|
|
||||||
// available, the default logger is returned.
|
|
||||||
//
|
|
||||||
// Deprecated: use [log.GetLogger].
|
|
||||||
func GetLogger(ctx context.Context) *log.Entry {
|
|
||||||
return log.GetLogger(ctx)
|
|
||||||
}
|
|
3
vendor/modules.txt
vendored
3
vendor/modules.txt
vendored
@ -21,7 +21,7 @@ github.com/Microsoft/go-winio/pkg/fs
|
|||||||
github.com/Microsoft/go-winio/pkg/guid
|
github.com/Microsoft/go-winio/pkg/guid
|
||||||
github.com/Microsoft/go-winio/pkg/security
|
github.com/Microsoft/go-winio/pkg/security
|
||||||
github.com/Microsoft/go-winio/vhd
|
github.com/Microsoft/go-winio/vhd
|
||||||
# github.com/Microsoft/hcsshim v0.12.0-rc.0
|
# github.com/Microsoft/hcsshim v0.12.0-rc.1
|
||||||
## explicit; go 1.18
|
## explicit; go 1.18
|
||||||
github.com/Microsoft/hcsshim
|
github.com/Microsoft/hcsshim
|
||||||
github.com/Microsoft/hcsshim/cmd/containerd-shim-runhcs-v1/options
|
github.com/Microsoft/hcsshim/cmd/containerd-shim-runhcs-v1/options
|
||||||
@ -105,7 +105,6 @@ github.com/containerd/console
|
|||||||
# github.com/containerd/containerd v1.7.8
|
# github.com/containerd/containerd v1.7.8
|
||||||
## explicit; go 1.19
|
## explicit; go 1.19
|
||||||
github.com/containerd/containerd/errdefs
|
github.com/containerd/containerd/errdefs
|
||||||
github.com/containerd/containerd/log
|
|
||||||
# github.com/containerd/continuity v0.4.3
|
# github.com/containerd/continuity v0.4.3
|
||||||
## explicit; go 1.19
|
## explicit; go 1.19
|
||||||
github.com/containerd/continuity
|
github.com/containerd/continuity
|
||||||
|
Loading…
Reference in New Issue
Block a user