|
@@ -38,6 +38,9 @@ class StoreServer(object):
|
|
# Make stdin non-blocking
|
|
# Make stdin non-blocking
|
|
fl = fcntl.fcntl(sys.stdin.fileno(), fcntl.F_GETFL)
|
|
fl = fcntl.fcntl(sys.stdin.fileno(), fcntl.F_GETFL)
|
|
fcntl.fcntl(sys.stdin.fileno(), fcntl.F_SETFL, fl | os.O_NONBLOCK)
|
|
fcntl.fcntl(sys.stdin.fileno(), fcntl.F_SETFL, fl | os.O_NONBLOCK)
|
|
|
|
+ # Make stdout blocking
|
|
|
|
+ fl = fcntl.fcntl(sys.stdout.fileno(), fcntl.F_GETFL)
|
|
|
|
+ fcntl.fcntl(sys.stdout.fileno(), fcntl.F_SETFL, fl & ~os.O_NONBLOCK)
|
|
unpacker = msgpack.Unpacker()
|
|
unpacker = msgpack.Unpacker()
|
|
while True:
|
|
while True:
|
|
r, w, es = select.select([sys.stdin], [], [], 10)
|
|
r, w, es = select.select([sys.stdin], [], [], 10)
|