scaproust 0.3.2

Nanomsg scalability protocols implementation in rust. Various messaging patterns over pluggable transports
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

#!/bin/bash

COMPAT_PATH="$( cd "$(dirname "$0")" ; pwd -P )"
source "$COMPAT_PATH/test_helper.bash"

function test_case1 {
    $EXAMPLE_PATH/bus node0 $1 $2 $3 > /tmp/bus_tc1_node0.log & node0=$!
    $EXAMPLE_PATH/bus node1 $2 $3 $4 > /tmp/bus_tc1_node1.log & node1=$!
    $EXAMPLE_PATH/bus node2 $3 $4    > /tmp/bus_tc1_node2.log & node2=$!
    nanocat --bus --bind $4 --connect $1 --ascii --data node3 -d 2 -i 10 > /tmp/bus_tc1_node3.log & node3=$!
    sleep 3.5 && kill $node0 $node1 $node2 $node3
    result=`sort /tmp/bus_tc1_node0.log`
    expected=`sort $COMPAT_PATH/bus_tc1_node0_expected.log`
    if [[ ! $result == $expected ]]; then
        echo_test_case_failed "bus test case 1"
        return 1
    fi
    result=`sort /tmp/bus_tc1_node1.log`
    expected=`sort $COMPAT_PATH/bus_tc1_node1_expected.log`
    if [[ ! $result == $expected ]]; then
        echo_test_case_failed "bus test case 1"
        return 2
    fi
    result=`sort /tmp/bus_tc1_node2.log`
    expected=`sort $COMPAT_PATH/bus_tc1_node2_expected.log`
    if [[ ! $result == $expected ]]; then
        echo_test_case_failed "bus test case 1"
        return 3
    fi
    result=`sort /tmp/bus_tc1_node3.log`
    expected=`sort $COMPAT_PATH/bus_tc1_node3_expected.log`
    if [[ ! $result == $expected ]]; then
        echo_test_case_failed "bus test case 1"
        return 4
    fi
    echo_test_case_succeeded "bus test case 1"
}

function test_suite {
    test_case1 $1 $2 $3 $4
}

URL0="tcp://127.0.0.1:5450"
URL1="tcp://127.0.0.1:5451"
URL2="tcp://127.0.0.1:5452"
URL3="tcp://127.0.0.1:5453"
test_suite $URL0 $URL1 $URL2 $URL3