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

    p := [

    ] forkAt:7.

    count := 0.

    [p isDead] whileFalse:[

    ].

    s close.

    "

     self new testReadCheckPipe4

    "

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

!

testReadCheckPipe5

    "readCheck a pipe.

     Do this and interrupt the reading thread heavily"

    p := [

    ] forkAt:7.

    count := 0.

    [p isDead] whileFalse:[

    ].

    s close.

    "

     self new testReadCheckPipe5

    "

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

!

testReadPipe6

    "read a pipe.

     Do this and interrupt the reading thread heavily"

    error := nil.

    "/ self createTestFile.

    p := [

    ] forkAt:7.

    count := 0.

    [p isDead] whileFalse:[

    ].

    s close.

    "

     self new testReadPipe6

    "

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

!

testReadPipe7

    "read a pipe.

     Do this and interrupt the reading thread heavily"

    p := [

    ] forkAt:7.

    count := 0.

    [p isDead] whileFalse:[

    ].

    ('read interrupted <1p> times' expandMacrosWith:count) printCR.

    s close.

    "

     self test7

    "

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

! !

!PipeStreamTest class methodsFor:'documentation'!

version

    ^ '$Header$'

! !