// -*- rust -*-

// Regression tests for circular_buffer when using a unit
// that has a size that is not a power of two

use std;

import std::option;
import std::uint;
import std::vec;

// A 12-byte unit to send over the channel
type record = rec(u32 val1, u32 val2, u32 val3);

// Assuming that the default buffer size needs to hold 8 units,
// then the minimum buffer size needs to be 96. That's not a
// power of two so needs to be rounded up. Don't trigger any
// assertions.
fn test_init() {
    let port[record] myport = port();
    auto mychan = chan(myport);

    let record val = rec(val1=0u32, val2=0u32, val3=0u32);

    mychan <| val;
}

// Dump lots of items into the channel so it has to grow.
// Don't trigger any assertions.
fn test_grow() {
    let port[record] myport = port();
    auto mychan = chan(myport);

    let record val = rec(val1=0u32, val2=0u32, val3=0u32);

    for each (uint i in uint::range(0u, 100u)) {
        mychan <| val;
    }
}

// Don't allow the buffer to shrink below it's original size
fn test_shrink1() {
    let port[i8] myport = port();
    auto mychan = chan(myport);

    mychan <| 0i8;
    auto x; x <- myport;
}

fn test_shrink2() {
    let port[record] myport = port();
    auto mychan = chan(myport);

    let record val = rec(val1=0u32, val2=0u32, val3=0u32);

    for each (uint i in uint::range(0u, 100u)) {
        mychan <| val;
    }

    for each (uint i in uint::range(0u, 100u)) {
        auto x; x <- myport;
    }
}

// Test rotating the buffer when the unit size is not a power of two
fn test_rotate() {
    let port[record] myport = port();
    auto mychan = chan(myport);

    for each (uint i in uint::range(0u, 100u)) {
        auto val = rec(val1=i as u32,
                       val2=i as u32,
                       val3=i as u32);
        mychan <| val;

        auto x; x <- myport;
        assert (x.val1 == i as u32);
        assert (x.val2 == i as u32);
        assert (x.val3 == i as u32);
    }
}

// Test rotating and growing the buffer when
// the unit size is not a power of two
fn test_rotate_grow() {
    let port[record] myport = port();
    auto mychan = chan(myport);

    for each (uint j in uint::range(0u, 10u)) {
        for each (uint i in uint::range(0u, 10u)) {
            let record val = rec(val1=i as u32,
                                 val2=i as u32,
                                 val3=i as u32);
            mychan <| val;
        }

        for each (uint i in uint::range(0u, 10u)) {
            auto x; x <- myport;
            assert (x.val1 == i as u32);
            assert (x.val2 == i as u32);
            assert (x.val3 == i as u32);
        }
    }
}

fn main() {
    test_init();
    test_grow();
    test_shrink1();
    test_shrink2();
    test_rotate();
    test_rotate_grow();
}

// Local Variables:
// mode: rust;
// fill-column: 78;
// indent-tabs-mode: nil
// c-basic-offset: 4
// buffer-file-coding-system: utf-8-unix
// compile-command: "make -k -C .. 2>&1 | sed -e 's/\\/x\\//x:\\//g'";
// End: