blob: 77e9a3eb00580242a220d241cc95885c9ac012f5 (
plain)
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
|
#!/usr/bin/env python3
"""Test server for scontrol-remote-during-sync-2.
Choreography (tests bug#80623):
client -> server: LR1 (id=1)
server -> client: RR1 (id=1000)
client -> server: response RR1 "rr1-ok"
server -> client: response LR1 "lr1-ok"
"""
import os
import sys
sys.path.insert(0, os.path.dirname(__file__))
from common import read_msg, write_msg, log, harakiri
def main():
while True:
msg = read_msg()
if msg is None:
break
mid = msg.get('id')
method = msg.get('method')
log(f'<- {method or "(response)"} id={mid}')
if harakiri(msg): break
elif method == 'LR1':
# Send RR1 request
write_msg({'jsonrpc': '2.0', 'id': 1000,
'method': 'RR1', 'params': {}})
log('-> RR1 id=1000')
# Wait for reply to RR1
resp = read_msg()
log(f'<- (response RR1) id={resp.get("id") if resp else None}')
# Only NOW answer LR1
write_msg({'jsonrpc': '2.0', 'id': mid, 'result': 'lr1-ok'})
log(f'-> (response LR1) id={mid}')
if __name__ == '__main__':
main()
|
