Subversion Repositories openrisc

// $G $D/$F.go && $L $F.$A && ./$A.out

// Copyright 2009 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

// Verify that unbuffered channels act as pure fifos.

package main

import "os"

const N = 10

func AsynchFifo() {
        ch := make(chan int, N)
        for i := 0; i < N; i++ {
                ch <- i
        }
        for i := 0; i < N; i++ {
                if <-ch != i {
                        print("bad receive\n")
                        os.Exit(1)
                }
        }
}

func Chain(ch <-chan int, val int, in <-chan int, out chan<- int) {
        <-in
        if <-ch != val {
                panic(val)
        }
        out <- 1
}

// thread together a daisy chain to read the elements in sequence
func SynchFifo() {
        ch := make(chan int)
        in := make(chan int)
        start := in
        for i := 0; i < N; i++ {
                out := make(chan int)
                go Chain(ch, i, in, out)
                in = out
        }
        start <- 0
        for i := 0; i < N; i++ {
                ch <- i
        }
        <-in
}

func main() {
        AsynchFifo()
        SynchFifo()
}