Skip to content
This repository has been archived by the owner on Feb 22, 2020. It is now read-only.

Commit

Permalink
fix(style): double quote to single quote
Browse files Browse the repository at this point in the history
  • Loading branch information
Han Xiao authored Oct 14, 2019
1 parent 2045a54 commit 8911314
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions gnes/service/frontend.py
Original file line number Diff line number Diff line change
Expand Up @@ -129,16 +129,14 @@ def get_response(num_recv, blocked=False):
with self.zmq_context as zmq_client:

for request in request_iterator:
self.logger.info("get request: %d" % request.request_id)
self.logger.info('send request: %s' % request.request_id)
num_recv = max(self.pending_request - self.args.max_pending_request, 1)
yield from get_response(num_recv, num_recv > 1)

# self.logger.info("start to send request: %d (%d) ..." % (request.request_id, self.pending_request))
zmq_client.send_message(self.add_envelope(request, zmq_client), **self.send_recv_kwargs)
# self.logger.info("request has been send out!")
self.pending_request += 1

self.logger.info("all requests are appended, waiting for responses ...")
self.logger.info('all requests are sent, waiting for the responses...')
yield from get_response(self.pending_request, blocked=True)

class ZmqContext:
Expand Down

0 comments on commit 8911314

Please sign in to comment.