fixed getref bug
This commit is contained in:
@ -2648,6 +2648,7 @@ class KNodeClient(KBase):
|
|||||||
|
|
||||||
self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||||
self.sock.connect((self.host, self.port))
|
self.sock.connect((self.host, self.port))
|
||||||
|
|
||||||
self.rfile = self.sock.makefile("rb")
|
self.rfile = self.sock.makefile("rb")
|
||||||
self.read = self.rfile.read
|
self.read = self.rfile.read
|
||||||
self.readline = self.rfile.readline
|
self.readline = self.rfile.readline
|
||||||
@ -2667,7 +2668,7 @@ class KNodeClient(KBase):
|
|||||||
def close(self):
|
def close(self):
|
||||||
|
|
||||||
self.rfile.close()
|
self.rfile.close()
|
||||||
self.wfile.close()
|
#self.wfile.close()
|
||||||
self.sock.close()
|
self.sock.close()
|
||||||
|
|
||||||
#@-node:close
|
#@-node:close
|
||||||
@ -2748,12 +2749,12 @@ class KNodeClient(KBase):
|
|||||||
|
|
||||||
res = self.readline().strip()
|
res = self.readline().strip()
|
||||||
|
|
||||||
self.close()
|
|
||||||
|
|
||||||
if res == "ok":
|
if res == "ok":
|
||||||
ref = self.readline().strip()
|
ref = self.readline().strip()
|
||||||
|
self.close()
|
||||||
return ref
|
return ref
|
||||||
else:
|
else:
|
||||||
|
self.close()
|
||||||
return "failed"
|
return "failed"
|
||||||
|
|
||||||
#@-node:getref
|
#@-node:getref
|
||||||
@ -2772,6 +2773,7 @@ class KNodeClient(KBase):
|
|||||||
|
|
||||||
return res
|
return res
|
||||||
|
|
||||||
|
|
||||||
#@-node:pingall
|
#@-node:pingall
|
||||||
#@+node:kill
|
#@+node:kill
|
||||||
def kill(self):
|
def kill(self):
|
||||||
@ -2787,6 +2789,7 @@ class KNodeClient(KBase):
|
|||||||
except:
|
except:
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
||||||
#@-node:kill
|
#@-node:kill
|
||||||
#@+node:__getitem__
|
#@+node:__getitem__
|
||||||
def __getitem__(self, item):
|
def __getitem__(self, item):
|
||||||
|
Reference in New Issue
Block a user