Horus Application: xxx

The xxx_test demo

xxx_test - an interactive test program for the VIEWS stack, the CLSV:FIFO stack or any other stack with group membership information.

SYNOPSIS

xxx_test [-t protocol]

DESCRIPTION

This is an interactive test program for any layer with group membership information. You can create a group, join the group, multicast messages within the group, leave the group, or kill the group. After each membership change, typically the stability matrix at each member is printed.

Invoke the program with xxx_test. It prompts with '>'. You may enter the commands in the following section.

A typical usage for a coordinator at the prompt: create group_a
A typical usage for a non coordinator at the prompt: join group_a

As with any Horus application, a directory server (dirsvr) must be started before starting any xxx_test process.

COMMANDS

authorize {{a, r} site user, {n, k} group}
If the opcode is
- 'a' (add)
  this command authorizes each process owned by ``user'' and residing on ``site'' to join the current group, if it requests to do so.
- 'r' (remove)
  this command removes the right of ``user'' to join the current group from ``site''.
- 'n' (name)
  this command extends the delegation template of the current group by the name of ``group''.
- 'k' (key)
  this command extends the delegation template of the current group by the key of ``group''.
The ``authorize'' command is available only if security is turned on.
delegate {n, k} group
If the opcode is
- 'n' (name)
  this command delegates from the current credential to the name of ``group''.
- 'k' (key)
  this command delegates from the current credential to the key of ``group''.
The ``delegate'' command is available only if security is turned on.
create group
Creates a new group, and register the address in vsync//address and the contact in vsync//contact. If this is the first group to be created or joined, this group becomes the current group.
write name
Opens a new file with the specified name and closes any other files that are open. Performance numbers are written to this file.
join group [option] [message ...]
Join the group, and add
to the group. If this is the first group to be created or joined, this group becomes the current group.
If the Option is
- 'c' or 'C'
  the endpoint joins as a client.
- 's' or 'S' or any other letter
  the endpoint joins as a server.
- unspecified
  the endpoint joins as a server.
gather name [message ...]
Merge this group with another by sending a request to the named endpoint.
pt2pt name
Create a point-to-point group to the given name.
Notice in this case, 'p' is case sensitive.
Pt2ptsend rank [n] [msg ...]
Send n point-to-point messages to the group member with rank.
The default n is 1.
Notice in this case, 'P' is case sensitive.
flush
Flush the current group.
view [rank] [nmembers ...]
Install a new view in the current group. A view can only be installed after a flush.
mcast [number] [message ...]
Multicast the given message to the current group 'number' times.
rpc [number] [message ...]
RPC-style multicast. Like mcast, but a reply message is returned for the last message. The RPC time is printed.
leave [message ...]
Leave the current group.
kill [message ...]
Kill the current group.
options args ...
Set options.
- 'e' is encrypted.
- 'd' is decrypted (default).
- 's' is silent.
- 'v' is verbose (default).
- 'c' is multicast to clients only.
- 'r' is multicast to servers only.
- not 'c' or 'r' means mcast to all members.
endpoint name
Install my endpoint identifier under the given name.
notify name [...]
Report the failure of the given members in the current group.
switch group
Switch to another current group.
quit
Terminate (and restore terminal sanity).
broadcast
Turn on the auto-broadcast option of the current group.
interval interval
Assign interval to the current group.
zdump
Dump the information about the current group.
Note in this case, 'z' is case sensitive.
nflowcontrol value
Change the flow control policy of the current group.
ustat print/clear
Print statistics at various layers.
help
Print help.
?
Print help.

Only the first character of the command is significant, and in most cases the case is not. Thus 'join', 'JOIN', 'j', and 'Jack' are all the same command.

Currently, the following characters are available for allocation to commands: iuvwz

OPTIONS

-t protocol
Specify the protocol stack.

EXAMPLE

Notice the text in bold is what you type in, the normal text is what the program produces.

step 1: invoke one dirsvr and three xxx_test in different windows
- window 0: > ./dirsvr
- window 1: > ./xxx_test
- window 2: > ./xxx_test
- window 3. > ./xxx_test
Notice if all the windows are on the same machine, you might see the warning message after you invoke xxx_test: "bind broadcase address: Address already in use." You can safely ignore the message.
step 2: enter command "c group_a" in window 1.
Notice the endpoint in window 1 is the group coordinator from now on. It has rank 0 in group_a.
- window 0:
- window 1: > c group_a
```
creating 'group_a'
>
group_a: VIEW (#problems = 0; size = 0, time = 0.000000)
        my_rank = 0, origin = 0, nmembers = 1
MCAST STABILITY:
       1
PT2PT STABILITY:
       0
>
```
- window 2:
- window 3:

step 3: enter command "j group_a" in window 2.

Notice the coordinator in window 1 gets join_request from the endpoint in window 2 and starts the flush protocol. From now on, the endpoint in wondow 2 has rank 1 in group_a.

window 0:

window 1:

group_a: JOIN_REQUEST (#problems = 0; size = 0, time = 0.000000)
        my_rank = 0, origin = 0, nmembers = 1
MCAST STABILITY:
       1
PT2PT STABILITY:
       0
> 
group_a: FLUSH_OK (#problems = 0; size = 0, time = 0.000000)
        my_rank = 0, origin = 0, nmembers = 1
MCAST STABILITY:
       1
PT2PT STABILITY:
       0
>
group_a: VIEW (#problems = 0; size = 0, time = 0.000000)
        my_rank = 0, origin = 0, nmembers = 2
I'm contact, some ep joining, done in 0.066537 sec
MCAST STABILITY:
       1       0
       0       0
PT2PT STABILITY:
       0       0
>
group_a: STABLE (#problems = 0; size = 0, time = 0.000000)
        my_rank = 0, origin = 0, nmembers = 2
MCAST STABILITY:
       1       0
       1       0
PT2PT STABILITY:
       0       0
>

window 2: > j group_a

joining 'group_a'
> 
group_a: VIEW (#problems = 0; size = 0, time = 0.000000)
        my_rank = 1, origin = 0, nmembers = 2
I'm joining, done in 0.190353 sec
MCAST STABILITY:
       1       0
       1       0
PT2PT STABILITY:
       0       0
>

window 3:

step 4: enter command "j group_a" in window 3.
Notice the result is similar to step 3.

window 0:

window 1:

group_a: JOIN_REQUEST (#problems = 0; size = 0, time = 0.000000)
        my_rank = 0, origin = 0, nmembers = 2
MCAST STABILITY:
       1       0
       1       0
PT2PT STABILITY:
       0       0
> 
group_a: FLUSH_OK (#problems = 0; size = 0, time = 0.000000)
        my_rank = 0, origin = 0, nmembers = 2
MCAST STABILITY:
       1       0
       1       0
PT2PT STABILITY:
       0       0
> 
group_a: VIEW (#problems = 0; size = 0, time = 0.000000)
        my_rank = 0, origin = 0, nmembers = 3
I'm contact, some ep joining, done in 0.128782 sec
MCAST STABILITY:
       1       0       0
       0       0       0
       0       0       0
PT2PT STABILITY:
       0       0       0
>
group_a: STABLE (#problems = 0; size = 0, time = 0.000000)
        my_rank = 0, origin = 0, nmembers = 3
MCAST STABILITY:
       1       0       0
       0       0       0
       1       0       0
PT2PT STABILITY:
       0       0       0
> 
group_a: STABLE (#problems = 0; size = 0, time = 0.000000)
        my_rank = 0, origin = 0, nmembers = 3
MCAST STABILITY:
       1       0       0
       1       0       0
       1       0       0
PT2PT STABILITY:
       0       0       0
>

window 2:

group_a: FLUSH (#problems = 0; size = 0, time = 0.000000)
        my_rank = 1, origin = 0, nmembers = 2
MCAST STABILITY:
       1       0
       1       0
PT2PT STABILITY:
       0       0
>
group_a: VIEW (#problems = 0; size = 0, time = 0.000000)
        my_rank = 1, origin = 0, nmembers = 3
MCAST STABILITY:
       1       0       0
       1       0       0
       0       0       0
PT2PT STABILITY:
       0       0       0
>
group_a: STABLE (#problems = 0; size = 0, time = 0.000000)
        my_rank = 1, origin = 1, nmembers = 3
MCAST STABILITY:
       1       0       0
       1       0       0
       1       0       0
PT2PT STABILITY:
       0       0       0
>

window 3: > j group_a

joining 'group_a'
> 
group_a: VIEW (#problems = 0; size = 0, time = 0.000000)
        my_rank = 2, origin = 0, nmembers = 3
I'm joining, done in 0.185403 sec
MCAST STABILITY:
       1       0       0
       0       0       0
       1       0       0
PT2PT STABILITY:
       0       0       0
>
group_a: STABLE (#problems = 0; size = 0, time = 0.000000)
        my_rank = 2, origin = 2, nmembers = 3
MCAST STABILITY:
       1       0       0
       1       0       0
       1       0       0
PT2PT STABILITY:
       0       0       0
>

step 5: enter command "m 1 msg_a" in window 2.
This means multicast msg_a to group_a once. Notice there is no local delivery in wondow 2.

window 0:

window 1:

group_a: CAST (#problems = 0; size = 0, time = 0.000000)
        my_rank = 0, origin = 1, nmembers = 3
MCAST STABILITY:
       1       1       0
       1       1       0
       1       0       0
PT2PT STABILITY:
       0       0       0
>
group_a: STABLE (#problems = 0; size = 0, time = 0.000000)
        my_rank = 0, origin = 0, nmembers = 3
MCAST STABILITY:
       1       1       0
       1       1       0
       1       1       0
PT2PT STABILITY:
       0       0       0
>

window 2: > m 1 msg_a

cast to 'group_a'
> 
group_a: STABLE (#problems = 0; size = 0, time = 0.000000)
        my_rank = 1, origin = 1, nmembers = 3
MCAST STABILITY:
       1       1       0
       1       1       0
       1       0       0
PT2PT STABILITY:
       0       0       0
> 
group_a: STABLE (#problems = 0; size = 0, time = 0.000000)
        my_rank = 1, origin = 1, nmembers = 3
MCAST STABILITY:
       1       1       0
       1       1       0
       1       1       0
PT2PT STABILITY:
       0       0       0

>

window 3:

group_a: CAST (#problems = 0; size = 0, time = 0.000000)
        my_rank = 2, origin = 1, nmembers = 3
MCAST STABILITY:
       1       0       0
       1       1       0
       1       1       0
PT2PT STABILITY:
       0       0       0
>
group_a: STABLE (#problems = 0; size = 0, time = 0.000000)
        my_rank = 2, origin = 2, nmembers = 3
MCAST STABILITY:
       1       1       0
       1       1       0
       1       1       0
PT2PT STABILITY:
       0       0       0
>

The xxx_test demo

SYNOPSIS

DESCRIPTION

COMMANDS

OPTIONS

EXAMPLE

FILES

AUTHOR

BUGS