Fix issue with NewFIFOSetInDir with Terminal true
Signed-off-by: Justin Terry (VM) <juterry@microsoft.com>
This commit is contained in:
parent
c24a74354c
commit
277147135d
@ -31,11 +31,15 @@ const pipeRoot = `\\.\pipe`
|
||||
|
||||
// NewFIFOSetInDir returns a new set of fifos for the task
|
||||
func NewFIFOSetInDir(_, id string, terminal bool) (*FIFOSet, error) {
|
||||
stderrPipe := ""
|
||||
if !terminal {
|
||||
stderrPipe = fmt.Sprintf(`%s\ctr-%s-stderr`, pipeRoot, id)
|
||||
}
|
||||
return NewFIFOSet(Config{
|
||||
Terminal: terminal,
|
||||
Stdin: fmt.Sprintf(`%s\ctr-%s-stdin`, pipeRoot, id),
|
||||
Stdout: fmt.Sprintf(`%s\ctr-%s-stdout`, pipeRoot, id),
|
||||
Stderr: fmt.Sprintf(`%s\ctr-%s-stderr`, pipeRoot, id),
|
||||
Stderr: stderrPipe,
|
||||
}, nil), nil
|
||||
}
|
||||
|
||||
|
49
cio/io_windows_test.go
Normal file
49
cio/io_windows_test.go
Normal file
@ -0,0 +1,49 @@
|
||||
// +build windows
|
||||
|
||||
/*
|
||||
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 cio
|
||||
|
||||
import (
|
||||
"testing"
|
||||
|
||||
"gotest.tools/assert"
|
||||
)
|
||||
|
||||
func TestNewFifoSetInDir_NoTerminal(t *testing.T) {
|
||||
set, err := NewFIFOSetInDir("", t.Name(), false)
|
||||
if err != nil {
|
||||
t.Fatalf("NewFifoSetInDir failed with: %v", err)
|
||||
}
|
||||
|
||||
assert.Assert(t, !set.Terminal, "FIFOSet.Terminal should be false")
|
||||
assert.Assert(t, set.Stdin != "", "FIFOSet.Stdin should be set")
|
||||
assert.Assert(t, set.Stdout != "", "FIFOSet.Stdout should be set")
|
||||
assert.Assert(t, set.Stderr != "", "FIFOSet.Stderr should be set")
|
||||
}
|
||||
|
||||
func TestNewFifoSetInDir_Terminal(t *testing.T) {
|
||||
set, err := NewFIFOSetInDir("", t.Name(), true)
|
||||
if err != nil {
|
||||
t.Fatalf("NewFifoSetInDir failed with: %v", err)
|
||||
}
|
||||
|
||||
assert.Assert(t, set.Terminal, "FIFOSet.Terminal should be false")
|
||||
assert.Assert(t, set.Stdin != "", "FIFOSet.Stdin should be set")
|
||||
assert.Assert(t, set.Stdout != "", "FIFOSet.Stdout should be set")
|
||||
assert.Assert(t, set.Stderr == "", "FIFOSet.Stderr should not be set")
|
||||
}
|
Loading…
Reference in New Issue
Block a user