"{ 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 finished blocker|

    count := 1000.

    threads := 200.

    "/ There's limit to 50 open files in BCC5.5 libc, sigh.

    OperatingSystem isMSWINDOWSlike ifTrue:[

        threads := 20.

    ].

    finished := false.

    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.

        finished := true.

    ] valueWithTimeout:3 minutes.

    self assert:(finished and:[ok]).

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

    "Modified: / 17-09-2018 / 15:30:19 / Claus Gittinger"

!

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$'

! !