Skip to content

Instantly share code, notes, and snippets.

@willkelly
Created May 8, 2014 15:33
Show Gist options
  • Save willkelly/6ddd537ece141c65814d to your computer and use it in GitHub Desktop.
Save willkelly/6ddd537ece141c65814d to your computer and use it in GitHub Desktop.
Broker announcing intentions on unrelated pipe
Error in test "scripts/simple_writer.yml"
## Host "writer" (10.127.52.31) ##
### Test script ###
~~~~
sleep 1
timeout 3000
open pipe1 write
write pipe1 abc
close pipe1 write
~~~~
### Script Log ###
~~~~
Set prefix to 12
Set broker to 12-0
Sleeping for 1 seconds
Set timeout to 3000
Opening descriptor "12-0|>12-pipe1"
Opened pipe "pipe1" for write
Writing "abc" to pipe "pipe1"
Wrote to pipe "pipe1"
Closing write pipe "pipe1"
Closed pipe "pipe1"
Test passed
~~~~
### Broker Log ###
~~~~
zbroker service/0.0.1
Copyright (c) 2014 the Contributors
This Software is provided under the MPLv2 License on an "as is" basis,
without warranty of any kind, either expressed, implied, or statutory.
14-05-08 10:31:37 I: starting zpipes broker using config in '/tmp/tmpY63aRB/zbroker.cfg'
14-05-08 10:31:37 I: joining cluster as 69A337
14-05-08 10:31:37 N: starting zpipes_server service
14-05-08 10:31:37 I: ZPIPES server appeared at 448186
14-05-08 10:31:37 I: ZPIPES server appeared at 160667
14-05-08 10:31:37 I: ZPIPES server appeared at 4A2F53
14-05-08 10:31:37 I: ZPIPES server appeared at 74234E
14-05-08 10:31:37 I: ZPIPES server appeared at 1BC4E3
14-05-08 10:31:37 I: ZPIPES server appeared at CC5071
14-05-08 10:31:37 I: ZPIPES server appeared at 5B5BA7
14-05-08 10:31:37 I: ZPIPES server appeared at 75C315
14-05-08 10:31:37 I: ZPIPES server appeared at 3537D9
14-05-08 10:31:37 I: ZPIPES server appeared at 63AD88
14-05-08 10:31:37 I: ZPIPES server appeared at 1479FC
14-05-08 10:31:37 I: ZPIPES server appeared at BE30C5
14-05-08 10:31:37 I: ZPIPES server appeared at 4A9167
14-05-08 10:31:39 D: remote=CC5071 command=HAVE WRITER pipe=7-pipe1 unicast=0
14-05-08 10:31:39 7-pipe1: attach remote writer
14-05-08 10:31:39 D: remote=1BC4E3 command=HAVE WRITER pipe=8-pipe1 unicast=0
14-05-08 10:31:39 8-pipe1: attach remote writer
14-05-08 10:31:39 D: remote=3537D9 command=HAVE WRITER pipe=9-pipe1 unicast=0
14-05-08 10:31:39 9-pipe1: attach remote writer
14-05-08 10:31:39 D: remote=4A2F53 command=HAVE WRITER pipe=10-pipe1 unicast=0
14-05-08 10:31:39 10-pipe1: attach remote writer
14-05-08 10:31:39 D: remote=74234E command=HAVE WRITER pipe=11-pipe1 unicast=0
14-05-08 10:31:39 11-pipe1: attach remote writer
14-05-08 10:31:39 D: remote=63AD88 command=HAVE READER pipe=12-pipe1 unicast=0
14-05-08 10:31:39 12-pipe1: attach remote reader
14-05-08 10:31:39 D: 1: : start:
14-05-08 10:31:39 D: 1: : OUTPUT
14-05-08 10:31:39 D: 1: : $ lookup or create pipe
14-05-08 10:31:39 D: 1:12-pipe1 : $ open pipe writer
14-05-08 10:31:39 12-pipe1: attach local writer
14-05-08 10:31:39 12-pipe1: tell peer we are now writer
14-05-08 10:31:39 D: 1:12-pipe1 : open local writer
14-05-08 10:31:39 D: 1:12-pipe1 : > before writing
14-05-08 10:31:39 D: 1:12-pipe1 : before writing:
14-05-08 10:31:39 D: 1:12-pipe1 : ok
14-05-08 10:31:39 D: 1:12-pipe1 : $ send OUTPUT_OK
14-05-08 10:31:39 D: 1:12-pipe1 : > writing
14-05-08 10:31:39 D: 1:12-pipe1 : writing:
14-05-08 10:31:39 D: 1:12-pipe1 : WRITE
14-05-08 10:31:39 D: 1:12-pipe1 : $ process write request
14-05-08 10:31:39 D: 1:12-pipe1 : > processing write
14-05-08 10:31:39 D: 1:12-pipe1 : processing write:
14-05-08 10:31:39 D: 1:12-pipe1 : have reader
14-05-08 10:31:39 D: 1:12-pipe1 : $ pass data to reader
14-05-08 10:31:39 D: 1:12-pipe1 : write 3 bytes
14-05-08 10:31:39 D: 1:12-pipe1 : $ send WRITE_OK
14-05-08 10:31:39 D: 1:12-pipe1 : > writing
14-05-08 10:31:39 D: 1:12-pipe1 : writing:
14-05-08 10:31:39 D: 1:12-pipe1 : CLOSE
14-05-08 10:31:39 D: 1:12-pipe1 : $ close pipe writer
14-05-08 10:31:39 12-pipe1: tell peer we stopped being writer
14-05-08 10:31:39 D: 1:12-pipe1 : close local writer
14-05-08 10:31:39 D: 1:12-pipe1 : $ send CLOSE_OK
14-05-08 10:31:39 D: 1:12-pipe1 : > start
14-05-08 10:31:39 D: remote=4A9167 command=HAVE WRITER pipe=13-pipe1 unicast=0
14-05-08 10:31:39 13-pipe1: attach remote writer
14-05-08 10:31:39 D: remote=BE30C5 command=HAVE READER pipe=13-pipe1 unicast=0
14-05-08 10:31:39 13-pipe1: attach remote reader
14-05-08 10:31:39 13-pipe1: tell peer we are now writer
zbroker: zpipes_server.c:262: pipe_attach_remote_reader: Assertion `self->writer != (client_t *) -1' failed.
~~~~
## Host "reader" (10.127.52.34) ##
### Test script ###
~~~~
sleep 1
timeout 3000
open pipe1 read
read pipe1 3 abc
close pipe1 read
~~~~
### Script Log ###
~~~~
Set prefix to 12
Set broker to 12-1
Sleeping for 1 seconds
Set timeout to 3000
Opening descriptor "12-1|12-pipe1"
Opened pipe "pipe1" for read
Reading 3 bytes from pipe "pipe1"
Unexpected exception: timeouterror
Test failed
~~~~
### Broker Log ###
~~~~
zbroker service/0.0.1
Copyright (c) 2014 the Contributors
This Software is provided under the MPLv2 License on an "as is" basis,
without warranty of any kind, either expressed, implied, or statutory.
14-05-08 10:31:30 I: starting zpipes broker using config in '/tmp/tmphtDIRN/zbroker.cfg'
14-05-08 10:31:30 I: joining cluster as 63AD88
14-05-08 10:31:30 N: starting zpipes_server service
14-05-08 10:31:30 I: ZPIPES server appeared at 3537D9
14-05-08 10:31:30 I: ZPIPES server appeared at 75C315
14-05-08 10:31:30 I: ZPIPES server appeared at CC5071
14-05-08 10:31:30 I: ZPIPES server appeared at 1479FC
14-05-08 10:31:30 I: ZPIPES server appeared at 74234E
14-05-08 10:31:30 I: ZPIPES server appeared at 4A2F53
14-05-08 10:31:30 I: ZPIPES server appeared at 1BC4E3
14-05-08 10:31:30 I: ZPIPES server appeared at 5B5BA7
14-05-08 10:31:30 I: ZPIPES server appeared at 160667
14-05-08 10:31:30 I: ZPIPES server appeared at 448186
14-05-08 10:31:30 I: ZPIPES server appeared at 69A337
14-05-08 10:31:30 I: ZPIPES server appeared at BE30C5
14-05-08 10:31:30 I: ZPIPES server appeared at 4A9167
14-05-08 10:31:32 D: remote=CC5071 command=HAVE WRITER pipe=7-pipe1 unicast=0
14-05-08 10:31:32 7-pipe1: attach remote writer
14-05-08 10:31:32 D: remote=1BC4E3 command=HAVE WRITER pipe=8-pipe1 unicast=0
14-05-08 10:31:32 8-pipe1: attach remote writer
14-05-08 10:31:32 D: remote=3537D9 command=HAVE WRITER pipe=9-pipe1 unicast=0
14-05-08 10:31:32 9-pipe1: attach remote writer
14-05-08 10:31:32 D: remote=4A2F53 command=HAVE WRITER pipe=10-pipe1 unicast=0
14-05-08 10:31:32 10-pipe1: attach remote writer
14-05-08 10:31:32 D: remote=74234E command=HAVE WRITER pipe=11-pipe1 unicast=0
14-05-08 10:31:32 11-pipe1: attach remote writer
14-05-08 10:31:32 D: 83: : start:
14-05-08 10:31:32 D: 83: : INPUT
14-05-08 10:31:32 D: 83: : $ lookup or create pipe
14-05-08 10:31:32 D: 83:12-pipe1 : $ open pipe reader
14-05-08 10:31:32 12-pipe1: attach local reader
14-05-08 10:31:32 12-pipe1: broadcast we are now reader
14-05-08 10:31:32 D: 83:12-pipe1 : open local reader
14-05-08 10:31:32 D: 83:12-pipe1 : > before reading
14-05-08 10:31:32 D: 83:12-pipe1 : before reading:
14-05-08 10:31:32 D: 83:12-pipe1 : ok
14-05-08 10:31:32 D: 83:12-pipe1 : $ send INPUT_OK
14-05-08 10:31:32 D: 83:12-pipe1 : > reading
14-05-08 10:31:32 D: 83:12-pipe1 : reading:
14-05-08 10:31:32 D: 83:12-pipe1 : READ
14-05-08 10:31:32 D: 83:12-pipe1 : $ process read request
14-05-08 10:31:32 D: 83:12-pipe1 : > processing read
14-05-08 10:31:32 D: remote=69A337 command=HAVE WRITER pipe=12-pipe1 unicast=1
14-05-08 10:31:32 12-pipe1: attach remote writer
14-05-08 10:31:32 D: remote=4A9167 command=HAVE WRITER pipe=13-pipe1 unicast=0
14-05-08 10:31:32 13-pipe1: attach remote writer
14-05-08 10:31:32 D: remote=BE30C5 command=HAVE READER pipe=13-pipe1 unicast=0
14-05-08 10:31:32 13-pipe1: attach remote reader
14-05-08 10:31:32 13-pipe1: tell peer we are now writer
zbroker: zpipes_server.c:262: pipe_attach_remote_reader: Assertion `self->writer != (client_t *) -1' failed.
~~~~
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment