haiwen/libsearpc
1
0
Fork 0
mirror of https://github.com/haiwen/libsearpc.git synced 2025-09-13 13:32:45 +00:00
Code Issues Releases Wiki Activity

Support python 3 in pysearpc.

Browse Source
This commit is contained in:
Jonathan Xu
2019-06-06 17:36:19 +08:00
parent 4f32f8be00
commit ac0750d058
7 changed files with 30 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
pysearpc/named_pipe.py
View File

@@ -2,6 +2,7 @@
RPC client/server implementation based on named pipe transport.
"""
from builtins import object
import json
import logging
import os
@@ -56,7 +57,7 @@ class NamedPipeTransport(SearpcTransport):
# "I" for unsiged int
header = struct.pack('I', len(body))
sendall(self.pipe_fd, header)
sendall(self.pipe_fd, body)
sendall(self.pipe_fd, body.encode(encoding='utf-8'))
resp_header = recvall(self.pipe_fd, 4)
# logger.info('resp_header is %s', resp_header)
@@ -64,7 +65,7 @@ class NamedPipeTransport(SearpcTransport):
# logger.info('resp_size is %s', resp_size)
resp = recvall(self.pipe_fd, resp_size)
# logger.info('resp is %s', resp)
return resp
return resp.decode(encoding='utf-8')
class NamedPipeClient(SearpcClient):
@@ -141,10 +142,10 @@ class PipeHandlerThread(Thread):
req = recvall(self.pipe_fd, req_size)
# logger.info('req is %s', req)
data = json.loads(req)
data = json.loads(req.decode(encoding='utf-8'))
resp = searpc_server.call_function(data['service'], data['request'])
# logger.info('resp is %s', resp)
resp_header = struct.pack('I', len(resp))
sendall(self.pipe_fd, resp_header)
sendall(self.pipe_fd, resp)
sendall(self.pipe_fd, resp.encode(encoding='utf-8'))