9
9
"io"
10
10
"io/ioutil"
11
11
"os"
12
+ "runtime"
12
13
"strconv"
13
14
"strings"
14
15
"testing"
@@ -125,6 +126,10 @@ func TestPipelineReadFromSlowly(t *testing.T) {
125
126
}
126
127
127
128
func TestPipelineReadFromSlowly2 (t * testing.T ) {
129
+ if runtime .GOOS == "windows" {
130
+ t .Skip ("FIXME: test skipped on Windows: 'seq' unavailable" )
131
+ }
132
+
128
133
t .Parallel ()
129
134
ctx , cancel := context .WithTimeout (context .Background (), 2 * time .Second )
130
135
defer cancel ()
@@ -179,6 +184,10 @@ func TestPipelineTwoCommandsPiping(t *testing.T) {
179
184
}
180
185
181
186
func TestPipelineDir (t * testing.T ) {
187
+ if runtime .GOOS == "windows" {
188
+ t .Skip ("FIXME: test skipped on Windows: 'pwd' incompatibility" )
189
+ }
190
+
182
191
t .Parallel ()
183
192
ctx := context .Background ()
184
193
@@ -227,6 +236,10 @@ func TestPipelineStderr(t *testing.T) {
227
236
}
228
237
229
238
func TestPipelineInterrupted (t * testing.T ) {
239
+ if runtime .GOOS == "windows" {
240
+ t .Skip ("FIXME: test skipped on Windows: 'sleep' unavailable" )
241
+ }
242
+
230
243
t .Parallel ()
231
244
stdout := & bytes.Buffer {}
232
245
@@ -244,6 +257,10 @@ func TestPipelineInterrupted(t *testing.T) {
244
257
}
245
258
246
259
func TestPipelineCanceled (t * testing.T ) {
260
+ if runtime .GOOS == "windows" {
261
+ t .Skip ("FIXME: test skipped on Windows: 'sleep' unavailable" )
262
+ }
263
+
247
264
t .Parallel ()
248
265
249
266
stdout := & bytes.Buffer {}
@@ -267,6 +284,10 @@ func TestPipelineCanceled(t *testing.T) {
267
284
// unread output in this case *does fit* within the OS-level pipe
268
285
// buffer.
269
286
func TestLittleEPIPE (t * testing.T ) {
287
+ if runtime .GOOS == "windows" {
288
+ t .Skip ("FIXME: test skipped on Windows: 'sleep' unavailable" )
289
+ }
290
+
270
291
t .Parallel ()
271
292
272
293
p := pipe .New ()
@@ -286,6 +307,10 @@ func TestLittleEPIPE(t *testing.T) {
286
307
// amount of unread output in this case *does not fit* within the
287
308
// OS-level pipe buffer.
288
309
func TestBigEPIPE (t * testing.T ) {
310
+ if runtime .GOOS == "windows" {
311
+ t .Skip ("FIXME: test skipped on Windows: 'seq' unavailable" )
312
+ }
313
+
289
314
t .Parallel ()
290
315
291
316
p := pipe .New ()
@@ -305,6 +330,10 @@ func TestBigEPIPE(t *testing.T) {
305
330
// amount of unread output in this case *does not fit* within the
306
331
// OS-level pipe buffer.
307
332
func TestIgnoredSIGPIPE (t * testing.T ) {
333
+ if runtime .GOOS == "windows" {
334
+ t .Skip ("FIXME: test skipped on Windows: 'seq' unavailable" )
335
+ }
336
+
308
337
t .Parallel ()
309
338
310
339
p := pipe .New ()
0 commit comments