"{ Encoding: utf8 }"

"{ Package: 'stx:goodies/regression' }"

"{ NameSpace: RegressionTests }"

TestCase subclass:#PipeStreamTest
	instanceVariableNames:''
	classVariableNames:''
	poolDictionaries:''
	category:'tests-Regression-Streams'
!


!PipeStreamTest methodsFor:'tests'!

testPipeWriteRead
    | makeReader makeWriter count threads ok blocker|

    count := 1000.
    threads := 200.
    "/ There's limit to 50 open files in BCC5.5 libc, sigh.
    OperatingSystem isMSWINDOWSlike ifTrue:[
	threads := 20.
    ].
    ok := true.
    blocker := Semaphore new: 2 - threads.

    makeReader := [:stream |
	    [
		| c |
		c := 0.
		[ stream atEnd ] whileFalse:[
		    stream next.
		    c := c + 1.
		].
		stream close.
		ok := ok and:[ count == c ].
		blocker signal.
	    ]
	].

    makeWriter := [:stream |
	    [
		[
		    count timesRepeat:[stream nextPut: $P]
		] on: Error do:[
		    ok := false
		].
		stream close.
	    ]
	].

    threads timesRepeat:[
	|pipe rs ws|

	pipe := NonPositionableExternalStream makePipe.
	rs := pipe at:1.
	ws := pipe at:2.

	(makeReader value: rs) fork.
	(makeWriter value: ws) fork.
    ].

    blocker wait.
    self assert: ok.

    "Created: / 27-03-2014 / 16:21:52 / Jan Vrany <jan.vrany@fit.cvut.cz>"
!

testReadCheckPipe4
    "readCheck a pipe.
     Do this and interrupt the reading thread heavily"

    | cmd s p count|

    OperatingSystem isMSWINDOWSlike ifTrue:[
        cmd := 'waitfor /T 3 pause'.
    ] ifFalse:[
        cmd := 'sleep 3'.
    ].

    s := PipeStream readingFrom:cmd.

    p := [
        s readWait.
        '   --- testReadCheckPipe4: readWait finished' printCR.
    ] forkAt:7.

    count := 0.
    [p isDead] whileFalse:[
        Delay waitForMilliseconds:5.
        p interruptWith:[count := count + 1].
    ].
    ('   --- testReadCheckPipe4: readWait interrupted <1p> times' expandMacrosWith:count) printCR.

    s close.

    "/ assume that our timer resolution is at least 20Hz (usually it is much better...)
    self assert:(count >= (3 / (1/20))).

    "
     self new testReadCheckPipe4
    "

    "Modified: / 12.8.1998 / 13:42:13 / cg"
!

testReadCheckPipe5
    "readCheck a pipe.
     Do this and interrupt the reading thread heavily"

    | s p count line cmd|

    OperatingSystem isMSWINDOWSlike ifTrue:[
        cmd := 'waitfor /T 3 pause & echo hello'.
    ] ifFalse:[
        cmd := 'sleep 3; echo hello'.
    ].
    s := PipeStream readingFrom:cmd.

    p := [
        s readWait.
        line := s nextLine.
        '   --- testReadCheckPipe5: readWait finished' printCR.
    ] forkAt:7.

    count := 0.
    [p isDead] whileFalse:[
        Delay waitForMilliseconds:5.
        p interruptWith:[count := count + 1].
    ].
    ('   --- testReadCheckPipe5: readWait interrupted <1p> times' expandMacrosWith:count) printCR.

    s close.

    self assert:(line = 'hello').
    "/ assume that our timer resolution is at least 20Hz (usually it is much better...)
    self assert:(count >= (3 / (1/20))).

    "
     self new testReadCheckPipe5
    "

    "Modified: / 12.8.1998 / 13:42:13 / cg"
!

testReadPipe6
    "read a pipe.
     Do this and interrupt the reading thread heavily"

    | s p count error line  cmd|

    error := nil.

    "/ self createTestFile.

    OperatingSystem isMSWINDOWSlike ifTrue:[
        cmd := 'waitfor /T 3 pause'.
    ] ifFalse:[
        cmd := 'sleep 3'.
    ].

    s := PipeStream readingFrom:cmd.

    p := [
        [
            line := s nextLine.
            "/ line printCR.
        ] on: Error do:[:ex|
            error := ex.
        ]
    ] forkAt:7.

    count := 0.
    [p isDead] whileFalse:[
        Delay waitForMilliseconds:5.
        p interruptWith:[count := count + 1].
    ].
    ('   --- testReadPipe6: read interrupted <1p> times' expandMacrosWith:count) printCR.

    s close.

    self assert: error isNil.
    self assert: line isEmptyOrNil.
    "/ assume that our timer resolution is at least 20Hz (usually it is much better...)
    self assert:(count >= (3 / (1/20))).

    "
     self new testReadPipe6
    "

    "Modified: / 12.8.1998 / 13:42:13 / cg"
!

testReadPipe7
    "read a pipe.
     Do this and interrupt the reading thread heavily"

    |s p count error line  cmd|

    OperatingSystem isMSWINDOWSlike ifTrue:[
        cmd := 'waitfor /T 3 pause & echo hello'.
    ] ifFalse:[
        cmd := 'sleep 3; echo hello'.
    ].
    s := PipeStream readingFrom:cmd.

    p := [
        [
            line := s nextLine.
            "/ line printCR.
        ] on: Error do:[:ex|
            error := ex.
        ]
    ] forkAt:7.

    count := 0.
    [p isDead] whileFalse:[
        Delay waitForMilliseconds:5.
        p interruptWith:[count := count + 1].
    ].
    ('   --- read interrupted <1p> times' expandMacrosWith:count) printCR.

    s close.

    self assert: error isNil.
    self assert: line = 'hello'.
    "/ assume that our timer resolution is at least 20Hz (usually it is much better...)
    self assert:(count >= (3 / (1/20))).

    "
     self test7
    "

    "Modified: / 12.8.1998 / 13:42:13 / cg"
! !

!PipeStreamTest class methodsFor:'documentation'!

version
    ^ '$Header$'
! !