Update containerd before release.

Signed-off-by: Lantao Liu <lantaol@google.com>
This commit is contained in:
Lantao Liu 2018-04-23 10:04:53 -07:00
parent 09ff081784
commit d77a0c117e
12 changed files with 22 additions and 25 deletions

View File

@ -4,7 +4,7 @@ github.com/boltdb/bolt e9cf4fae01b5a8ff89d0ec6b32f0d9c9f79aefdd
github.com/BurntSushi/toml a368813c5e648fee92e5f6c30e3944ff9d5e8895 github.com/BurntSushi/toml a368813c5e648fee92e5f6c30e3944ff9d5e8895
github.com/containerd/cgroups fe281dd265766145e943a034aa41086474ea6130 github.com/containerd/cgroups fe281dd265766145e943a034aa41086474ea6130
github.com/containerd/console cb7008ab3d8359b78c5f464cb7cf160107ad5925 github.com/containerd/console cb7008ab3d8359b78c5f464cb7cf160107ad5925
github.com/containerd/containerd v1.1.0-rc.2 github.com/containerd/containerd 1381f8fddc4f826e12b48d46c9def347d5aa338a
github.com/containerd/continuity 3e8f2ea4b190484acb976a5b378d373429639a1a github.com/containerd/continuity 3e8f2ea4b190484acb976a5b378d373429639a1a
github.com/containerd/fifo 3d5202aec260678c48179c56f40e6f38a095738c github.com/containerd/fifo 3d5202aec260678c48179c56f40e6f38a095738c
github.com/containerd/go-cni f2d7272f12d045b16ed924f50e91f9f9cecc55a7 github.com/containerd/go-cni f2d7272f12d045b16ed924f50e91f9f9cecc55a7

View File

@ -320,7 +320,7 @@ func (c *Client) Pull(ctx context.Context, ref string, opts ...RemoteOpt) (Image
childrenHandler := images.ChildrenHandler(store) childrenHandler := images.ChildrenHandler(store)
// Set any children labels for that content // Set any children labels for that content
childrenHandler = images.SetChildrenLabels(store, childrenHandler) childrenHandler = images.SetChildrenLabels(store, childrenHandler)
// Filter childen by platforms // Filter children by platforms
childrenHandler = images.FilterPlatforms(childrenHandler, pullCtx.Platforms...) childrenHandler = images.FilterPlatforms(childrenHandler, pullCtx.Platforms...)
handler = images.Handlers(append(pullCtx.BaseHandlers, handler = images.Handlers(append(pullCtx.BaseHandlers,

View File

@ -62,7 +62,7 @@ var ContainerFlags = []cli.Flag{
}, },
cli.StringSliceFlag{ cli.StringSliceFlag{
Name: "mount", Name: "mount",
Usage: "specify additional container mount (ex: type=bind,src=/tmp,dest=/host,options=rbind:ro)", Usage: "specify additional container mount (ex: type=bind,src=/tmp,dst=/host,options=rbind:ro)",
}, },
cli.BoolFlag{ cli.BoolFlag{
Name: "net-host", Name: "net-host",

View File

@ -136,10 +136,7 @@ func Copy(ctx context.Context, cw Writer, r io.Reader, size int64, expected dige
} }
} }
buf := bufPool.Get().(*[]byte) if _, err := copyWithBuffer(cw, r); err != nil {
defer bufPool.Put(buf)
if _, err := io.CopyBuffer(cw, r, *buf); err != nil {
return err return err
} }
@ -160,11 +157,7 @@ func CopyReaderAt(cw Writer, ra ReaderAt, n int64) error {
return err return err
} }
buf := bufPool.Get().(*[]byte) _, err = copyWithBuffer(cw, io.NewSectionReader(ra, ws.Offset, n))
defer bufPool.Put(buf)
_, err = io.CopyBuffer(cw, io.NewSectionReader(ra, ws.Offset, n), *buf)
return err return err
} }
@ -195,10 +188,7 @@ func seekReader(r io.Reader, offset, size int64) (io.Reader, error) {
} }
// well then, let's just discard up to the offset // well then, let's just discard up to the offset
buf := bufPool.Get().(*[]byte) n, err := copyWithBuffer(ioutil.Discard, io.LimitReader(r, offset))
defer bufPool.Put(buf)
n, err := io.CopyBuffer(ioutil.Discard, io.LimitReader(r, offset), *buf)
if err != nil { if err != nil {
return nil, errors.Wrap(err, "failed to discard to offset") return nil, errors.Wrap(err, "failed to discard to offset")
} }
@ -208,3 +198,10 @@ func seekReader(r io.Reader, offset, size int64) (io.Reader, error) {
return r, nil return r, nil
} }
func copyWithBuffer(dst io.Writer, src io.Reader) (written int64, err error) {
buf := bufPool.Get().(*[]byte)
written, err = io.CopyBuffer(dst, src, *buf)
bufPool.Put(buf)
return
}

View File

@ -14,6 +14,6 @@
limitations under the License. limitations under the License.
*/ */
// Package defaults provides several common defaults for interacting wtih // Package defaults provides several common defaults for interacting with
// containerd. These can be used on the client-side or server-side. // containerd. These can be used on the client-side or server-side.
package defaults package defaults

View File

@ -92,7 +92,7 @@ var Always FilterFunc = func(adaptor Adaptor) bool {
return true return true
} }
// Any allows multiple filters to be matched aginst the object // Any allows multiple filters to be matched against the object
type Any []Filter type Any []Filter
// Match returns true if any of the provided filters are true // Match returns true if any of the provided filters are true
@ -106,7 +106,7 @@ func (m Any) Match(adaptor Adaptor) bool {
return false return false
} }
// All allows multiple filters to be matched aginst the object // All allows multiple filters to be matched against the object
type All []Filter type All []Filter
// Match only returns true if all filters match the object // Match only returns true if all filters match the object

View File

@ -315,7 +315,7 @@ func (s *gcScheduler) run(ctx context.Context) {
// Reschedule garbage collection for same duration + 1 second // Reschedule garbage collection for same duration + 1 second
schedC, nextCollection = schedule(nextCollection.Sub(*lastCollection) + time.Second) schedC, nextCollection = schedule(nextCollection.Sub(*lastCollection) + time.Second)
// Update last collection time even though failure occured // Update last collection time even though failure occurred
lastCollection = &last lastCollection = &last
for _, w := range s.waiters { for _, w := range s.waiters {

View File

@ -279,7 +279,7 @@ func Check(ctx context.Context, provider content.Provider, image ocispec.Descrip
// TODO(stevvooe): It is possible that referenced conponents could have // TODO(stevvooe): It is possible that referenced conponents could have
// children, but this is rare. For now, we ignore this and only verify // children, but this is rare. For now, we ignore this and only verify
// that manfiest components are present. // that manifest components are present.
required = append([]ocispec.Descriptor{mfst.Config}, mfst.Layers...) required = append([]ocispec.Descriptor{mfst.Config}, mfst.Layers...)
for _, desc := range required { for _, desc := range required {

View File

@ -200,7 +200,7 @@ func (r *Runtime) Create(ctx context.Context, id string, opts runtime.CreateOpts
log.G(ctx).WithField("id", id).Info("shim reaped") log.G(ctx).WithField("id", id).Info("shim reaped")
t, err := r.tasks.Get(ctx, id) t, err := r.tasks.Get(ctx, id)
if err != nil { if err != nil {
// Task was never started or was already sucessfully deleted // Task was never started or was already successfully deleted
return return
} }
lc := t.(*Task) lc := t.(*Task)

View File

@ -89,7 +89,7 @@ type Registration struct {
// InitFn is called when initializing a plugin. The registration and // InitFn is called when initializing a plugin. The registration and
// context are passed in. The init function may modify the registration to // context are passed in. The init function may modify the registration to
// add exports, capabilites and platform support declarations. // add exports, capabilities and platform support declarations.
InitFn func(*InitContext) (interface{}, error) InitFn func(*InitContext) (interface{}, error)
} }

View File

@ -81,7 +81,7 @@ func (s ExitStatus) ExitTime() time.Time {
return s.exitedAt return s.exitedAt
} }
// Error returns the error, if any, that occured while waiting for the // Error returns the error, if any, that occurred while waiting for the
// process. // process.
func (s ExitStatus) Error() error { func (s ExitStatus) Error() error {
return s.err return s.err

View File

@ -34,7 +34,7 @@ type config struct {
// Order is the order of preference in which to try diff algorithms, the // Order is the order of preference in which to try diff algorithms, the
// first differ which is supported is used. // first differ which is supported is used.
// Note when multiple differs may be supported, this order will be // Note when multiple differs may be supported, this order will be
// respected for which is choosen. Each differ should return the same // respected for which is chosen. Each differ should return the same
// correct output, allowing any ordering to be used to prefer // correct output, allowing any ordering to be used to prefer
// more optimimal implementations. // more optimimal implementations.
Order []string `toml:"default"` Order []string `toml:"default"`