diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2018-05-20 15:05:54 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2018-05-20 15:05:54 +0200 |
| commit | 20ac24f66da37cc011e2459c5a347a7083c3272c (patch) | |
| tree | 4a4c4de7b144dbac0f4f59d238697f6ee2d1f3f2 /rpc | |
| parent | 83e20713c1c3b55532f6f022eaaf290471d3b5c5 (diff) | |
move rpc around.. serve html
Diffstat (limited to 'rpc')
| -rw-r--r-- | rpc/__init__.py | 1 | ||||
| -rw-r--r-- | rpc/__main__.py | 8 | ||||
| -rw-r--r-- | rpc/rpc.py | 12 |
3 files changed, 15 insertions, 6 deletions
diff --git a/rpc/__init__.py b/rpc/__init__.py new file mode 100644 index 0000000..93f5256 --- /dev/null +++ b/rpc/__init__.py @@ -0,0 +1 @@ +__init__.py
\ No newline at end of file diff --git a/rpc/__main__.py b/rpc/__main__.py new file mode 100644 index 0000000..894f748 --- /dev/null +++ b/rpc/__main__.py @@ -0,0 +1,8 @@ +from rpc import CortexRPC + +if __name__ == '__main__': + def log_param(key, value): + print("log param. {}: {}".format(key, value)) + + # this will block + rpc = CortexRPC(log_param) @@ -27,9 +27,9 @@ class CortexRPC(object): val = None try: val = self.relay.connected("rpc") - print("rpc connected...".format(val)) + print("RPC connected...".format(val)) except zerorpc.TimeoutExpired: - print("rpc timeout :(") + print("RPC timeout :(") # print("defer sending a file...") # gevent.sleep(2) # self.send_file("test.png") @@ -44,20 +44,20 @@ class CortexRPC(object): return "ok" def get_params(self): - print("get params call received") + print("Get params call received!") return "lmao ok" def send_frame(self, frame): if self.relay is not None: - print("sending a frame...") + print("Sending a frame...") frame = '01234567' * 8 * 8 * 8 * 8 * 2 self.relay.send_frame('frame_00000.png', frame) else: - print("Relay not ready...") + print("Can't send frame, relay not ready...") if __name__ == '__main__': def log_param(key, value): - print("log param. {}: {}".format(key, value)) + print("Log param. {}: {}".format(key, value)) # this will block rpc = CortexRPC(log_param) |