mirror of
https://github.com/containers/podman.git
synced 2025-09-26 00:06:04 +08:00
Bump github.com/rootless-containers/rootlesskit from 0.14.3 to 0.14.4
Bumps [github.com/rootless-containers/rootlesskit](https://github.com/rootless-containers/rootlesskit) from 0.14.3 to 0.14.4. - [Release notes](https://github.com/rootless-containers/rootlesskit/releases) - [Commits](https://github.com/rootless-containers/rootlesskit/compare/v0.14.3...v0.14.4) --- updated-dependencies: - dependency-name: github.com/rootless-containers/rootlesskit dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] <support@github.com>
This commit is contained in:
2
go.mod
2
go.mod
@ -53,7 +53,7 @@ require (
|
|||||||
github.com/opencontainers/selinux v1.8.3
|
github.com/opencontainers/selinux v1.8.3
|
||||||
github.com/pkg/errors v0.9.1
|
github.com/pkg/errors v0.9.1
|
||||||
github.com/pmezard/go-difflib v1.0.0
|
github.com/pmezard/go-difflib v1.0.0
|
||||||
github.com/rootless-containers/rootlesskit v0.14.3
|
github.com/rootless-containers/rootlesskit v0.14.4
|
||||||
github.com/sirupsen/logrus v1.8.1
|
github.com/sirupsen/logrus v1.8.1
|
||||||
github.com/spf13/cobra v1.2.1
|
github.com/spf13/cobra v1.2.1
|
||||||
github.com/spf13/pflag v1.0.5
|
github.com/spf13/pflag v1.0.5
|
||||||
|
4
go.sum
4
go.sum
@ -812,8 +812,8 @@ github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJ
|
|||||||
github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg=
|
github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg=
|
||||||
github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ=
|
github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ=
|
||||||
github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
|
github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
|
||||||
github.com/rootless-containers/rootlesskit v0.14.3 h1:mS6lkZgT1McqUoZ9wjUIbYq7bWfd9aZGUgZgg8B55Sk=
|
github.com/rootless-containers/rootlesskit v0.14.4 h1:pqx9a+OC/6jjV7sIUKy3D1p6NLEC6WIMiJWAGsGMCUM=
|
||||||
github.com/rootless-containers/rootlesskit v0.14.3/go.mod h1:Ai3detLzryb/4EkzXmNfh8aByUcBXp/qqkQusJs1SO8=
|
github.com/rootless-containers/rootlesskit v0.14.4/go.mod h1:Ai3detLzryb/4EkzXmNfh8aByUcBXp/qqkQusJs1SO8=
|
||||||
github.com/russross/blackfriday/v2 v2.0.1/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
|
github.com/russross/blackfriday/v2 v2.0.1/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
|
||||||
github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
|
github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
|
||||||
github.com/ryanuber/columnize v0.0.0-20160712163229-9b3edd62028f/go.mod h1:sm1tb6uqfes/u+d4ooFouqFdy9/2g9QGwK3SQygK0Ts=
|
github.com/ryanuber/columnize v0.0.0-20160712163229-9b3edd62028f/go.mod h1:sm1tb6uqfes/u+d4ooFouqFdy9/2g9QGwK3SQygK0Ts=
|
||||||
|
33
vendor/github.com/rootless-containers/rootlesskit/pkg/port/builtin/parent/parent.go
generated
vendored
33
vendor/github.com/rootless-containers/rootlesskit/pkg/port/builtin/parent/parent.go
generated
vendored
@ -42,7 +42,7 @@ func NewDriver(logWriter io.Writer, stateDir string) (port.ParentDriver, error)
|
|||||||
socketPath: socketPath,
|
socketPath: socketPath,
|
||||||
childReadyPipePath: childReadyPipePath,
|
childReadyPipePath: childReadyPipePath,
|
||||||
ports: make(map[int]*port.Status, 0),
|
ports: make(map[int]*port.Status, 0),
|
||||||
stoppers: make(map[int]func() error, 0),
|
stoppers: make(map[int]func(context.Context) error, 0),
|
||||||
nextID: 1,
|
nextID: 1,
|
||||||
}
|
}
|
||||||
return &d, nil
|
return &d, nil
|
||||||
@ -54,7 +54,7 @@ type driver struct {
|
|||||||
childReadyPipePath string
|
childReadyPipePath string
|
||||||
mu sync.Mutex
|
mu sync.Mutex
|
||||||
ports map[int]*port.Status
|
ports map[int]*port.Status
|
||||||
stoppers map[int]func() error
|
stoppers map[int]func(context.Context) error
|
||||||
nextID int
|
nextID int
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -139,21 +139,27 @@ func (d *driver) AddPort(ctx context.Context, spec port.Spec) (*port.Status, err
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
// NOTE: routineStopCh is close-only channel. Do not send any data.
|
||||||
|
// See commit 4803f18fae1e39d200d98f09e445a97ccd6f5526 `Revert "port/builtin: RemovePort() block until conn is closed"`
|
||||||
routineStopCh := make(chan struct{})
|
routineStopCh := make(chan struct{})
|
||||||
routineStop := func() error {
|
routineStoppedCh := make(chan error)
|
||||||
routineStopCh <- struct{}{}
|
routineStop := func(ctx context.Context) error {
|
||||||
|
close(routineStopCh)
|
||||||
select {
|
select {
|
||||||
case <-routineStopCh:
|
case stoppedResult, stoppedResultOk := <-routineStoppedCh:
|
||||||
case <-time.After(5 * time.Second):
|
if stoppedResultOk {
|
||||||
return errors.New("stop timeout after 5 seconds")
|
return stoppedResult
|
||||||
|
}
|
||||||
|
return errors.New("routineStoppedCh was closed without sending data?")
|
||||||
|
case <-ctx.Done():
|
||||||
|
return errors.Wrap(err, "timed out while waiting for routineStoppedCh after closing routineStopCh")
|
||||||
}
|
}
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
switch spec.Proto {
|
switch spec.Proto {
|
||||||
case "tcp", "tcp4", "tcp6":
|
case "tcp", "tcp4", "tcp6":
|
||||||
err = tcp.Run(d.socketPath, spec, routineStopCh, d.logWriter)
|
err = tcp.Run(d.socketPath, spec, routineStopCh, routineStoppedCh, d.logWriter)
|
||||||
case "udp", "udp4", "udp6":
|
case "udp", "udp4", "udp6":
|
||||||
err = udp.Run(d.socketPath, spec, routineStopCh, d.logWriter)
|
err = udp.Run(d.socketPath, spec, routineStopCh, routineStoppedCh, d.logWriter)
|
||||||
default:
|
default:
|
||||||
// NOTREACHED
|
// NOTREACHED
|
||||||
return nil, errors.New("spec was not validated?")
|
return nil, errors.New("spec was not validated?")
|
||||||
@ -194,7 +200,12 @@ func (d *driver) RemovePort(ctx context.Context, id int) error {
|
|||||||
if !ok {
|
if !ok {
|
||||||
return errors.Errorf("unknown id: %d", id)
|
return errors.Errorf("unknown id: %d", id)
|
||||||
}
|
}
|
||||||
err := stop()
|
if _, ok := ctx.Deadline(); !ok {
|
||||||
|
var cancel context.CancelFunc
|
||||||
|
ctx, cancel = context.WithTimeout(ctx, 5*time.Second)
|
||||||
|
defer cancel()
|
||||||
|
}
|
||||||
|
err := stop(ctx)
|
||||||
delete(d.stoppers, id)
|
delete(d.stoppers, id)
|
||||||
delete(d.ports, id)
|
delete(d.ports, id)
|
||||||
return err
|
return err
|
||||||
|
6
vendor/github.com/rootless-containers/rootlesskit/pkg/port/builtin/parent/tcp/tcp.go
generated
vendored
6
vendor/github.com/rootless-containers/rootlesskit/pkg/port/builtin/parent/tcp/tcp.go
generated
vendored
@ -12,7 +12,7 @@ import (
|
|||||||
"github.com/rootless-containers/rootlesskit/pkg/port/builtin/msg"
|
"github.com/rootless-containers/rootlesskit/pkg/port/builtin/msg"
|
||||||
)
|
)
|
||||||
|
|
||||||
func Run(socketPath string, spec port.Spec, stopCh chan struct{}, logWriter io.Writer) error {
|
func Run(socketPath string, spec port.Spec, stopCh <-chan struct{}, stoppedCh chan error, logWriter io.Writer) error {
|
||||||
ln, err := net.Listen(spec.Proto, net.JoinHostPort(spec.ParentIP, strconv.Itoa(spec.ParentPort)))
|
ln, err := net.Listen(spec.Proto, net.JoinHostPort(spec.ParentIP, strconv.Itoa(spec.ParentPort)))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Fprintf(logWriter, "listen: %v\n", err)
|
fmt.Fprintf(logWriter, "listen: %v\n", err)
|
||||||
@ -32,8 +32,8 @@ func Run(socketPath string, spec port.Spec, stopCh chan struct{}, logWriter io.W
|
|||||||
}()
|
}()
|
||||||
go func() {
|
go func() {
|
||||||
defer func() {
|
defer func() {
|
||||||
ln.Close()
|
stoppedCh <- ln.Close()
|
||||||
close(stopCh)
|
close(stoppedCh)
|
||||||
}()
|
}()
|
||||||
for {
|
for {
|
||||||
select {
|
select {
|
||||||
|
5
vendor/github.com/rootless-containers/rootlesskit/pkg/port/builtin/parent/udp/udp.go
generated
vendored
5
vendor/github.com/rootless-containers/rootlesskit/pkg/port/builtin/parent/udp/udp.go
generated
vendored
@ -13,7 +13,7 @@ import (
|
|||||||
"github.com/rootless-containers/rootlesskit/pkg/port/builtin/parent/udp/udpproxy"
|
"github.com/rootless-containers/rootlesskit/pkg/port/builtin/parent/udp/udpproxy"
|
||||||
)
|
)
|
||||||
|
|
||||||
func Run(socketPath string, spec port.Spec, stopCh chan struct{}, logWriter io.Writer) error {
|
func Run(socketPath string, spec port.Spec, stopCh <-chan struct{}, stoppedCh chan error, logWriter io.Writer) error {
|
||||||
addr, err := net.ResolveUDPAddr(spec.Proto, net.JoinHostPort(spec.ParentIP, strconv.Itoa(spec.ParentPort)))
|
addr, err := net.ResolveUDPAddr(spec.Proto, net.JoinHostPort(spec.ParentIP, strconv.Itoa(spec.ParentPort)))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
@ -51,7 +51,8 @@ func Run(socketPath string, spec port.Spec, stopCh chan struct{}, logWriter io.W
|
|||||||
case <-stopCh:
|
case <-stopCh:
|
||||||
// udpp.Close closes ln as well
|
// udpp.Close closes ln as well
|
||||||
udpp.Close()
|
udpp.Close()
|
||||||
close(stopCh)
|
stoppedCh <- nil
|
||||||
|
close(stoppedCh)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
2
vendor/modules.txt
vendored
2
vendor/modules.txt
vendored
@ -558,7 +558,7 @@ github.com/prometheus/procfs/internal/fs
|
|||||||
github.com/prometheus/procfs/internal/util
|
github.com/prometheus/procfs/internal/util
|
||||||
# github.com/rivo/uniseg v0.2.0
|
# github.com/rivo/uniseg v0.2.0
|
||||||
github.com/rivo/uniseg
|
github.com/rivo/uniseg
|
||||||
# github.com/rootless-containers/rootlesskit v0.14.3
|
# github.com/rootless-containers/rootlesskit v0.14.4
|
||||||
github.com/rootless-containers/rootlesskit/pkg/api
|
github.com/rootless-containers/rootlesskit/pkg/api
|
||||||
github.com/rootless-containers/rootlesskit/pkg/msgutil
|
github.com/rootless-containers/rootlesskit/pkg/msgutil
|
||||||
github.com/rootless-containers/rootlesskit/pkg/port
|
github.com/rootless-containers/rootlesskit/pkg/port
|
||||||
|
Reference in New Issue
Block a user