Fix some typo in runtime and snapshots
Signed-off-by: Xiaodong Zhang <a4012017@sina.com>
This commit is contained in:
parent
901b2ea2a7
commit
e6d787172c
@ -73,7 +73,7 @@ func (b *binary) Start(ctx context.Context) (_ *shim, err error) {
|
|||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
// open the log pipe and block until the writer is ready
|
// open the log pipe and block until the writer is ready
|
||||||
// this helps with syncronization of the shim
|
// this helps with synchronization of the shim
|
||||||
// copy the shim's logs to containerd's output
|
// copy the shim's logs to containerd's output
|
||||||
go func() {
|
go func() {
|
||||||
defer f.Close()
|
defer f.Close()
|
||||||
|
@ -518,7 +518,7 @@ func (s *service) Delete(ctx context.Context, r *taskAPI.DeleteRequest) (*taskAP
|
|||||||
|
|
||||||
select {
|
select {
|
||||||
case <-time.After(5 * time.Second):
|
case <-time.After(5 * time.Second):
|
||||||
// Force close the container process since it didnt shutdown in time.
|
// Force close the container process since it didn't shutdown in time.
|
||||||
p.close()
|
p.close()
|
||||||
case <-p.waitBlock:
|
case <-p.waitBlock:
|
||||||
}
|
}
|
||||||
|
@ -66,7 +66,7 @@ func loadShim(ctx context.Context, bundle *Bundle, events *exchange.Exchange, rt
|
|||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
// open the log pipe and block until the writer is ready
|
// open the log pipe and block until the writer is ready
|
||||||
// this helps with syncronization of the shim
|
// this helps with synchronization of the shim
|
||||||
// copy the shim's logs to containerd's output
|
// copy the shim's logs to containerd's output
|
||||||
go func() {
|
go func() {
|
||||||
defer f.Close()
|
defer f.Close()
|
||||||
|
@ -315,7 +315,7 @@ func (s *snapshotter) createSnapshot(ctx context.Context, kind snapshots.Kind, k
|
|||||||
if err := os.MkdirAll(snDir, 0700); err != nil {
|
if err := os.MkdirAll(snDir, 0700); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
// Create the scratch.vhdx cache file if it doesnt already exit.
|
// Create the scratch.vhdx cache file if it doesn't already exit.
|
||||||
scratchPath := filepath.Join(s.root, "scratch.vhdx")
|
scratchPath := filepath.Join(s.root, "scratch.vhdx")
|
||||||
scratchLockPath := filepath.Join(s.root, "scratch.vhdx.lock")
|
scratchLockPath := filepath.Join(s.root, "scratch.vhdx.lock")
|
||||||
startTime := time.Now()
|
startTime := time.Now()
|
||||||
|
@ -71,7 +71,7 @@ func supportsMultipleLowerDir(d string) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Supported returns nil when the overlayfs is functional on the system with the root directory.
|
// Supported returns nil when the overlayfs is functional on the system with the root directory.
|
||||||
// Suppported is not called during plugin initialization, but exposed for downstream projects which uses
|
// Supported is not called during plugin initialization, but exposed for downstream projects which uses
|
||||||
// this snapshotter as a library.
|
// this snapshotter as a library.
|
||||||
func Supported(root string) error {
|
func Supported(root string) error {
|
||||||
if err := os.MkdirAll(root, 0700); err != nil {
|
if err := os.MkdirAll(root, 0700); err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user