equal
deleted
inserted
replaced
72 act = util.poll(fds) |
72 act = util.poll(fds) |
73 except NotImplementedError: |
73 except NotImplementedError: |
74 # non supported yet case, assume all have data. |
74 # non supported yet case, assume all have data. |
75 act = fds |
75 act = fds |
76 return (self._main.fileno() in act, self._side.fileno() in act) |
76 return (self._main.fileno() in act, self._side.fileno() in act) |
|
77 |
|
78 def write(self, data): |
|
79 return self._call('write', data) |
77 |
80 |
78 def read(self, size): |
81 def read(self, size): |
79 return self._call('read', size) |
82 return self._call('read', size) |
80 |
83 |
81 def readline(self): |
84 def readline(self): |
100 return meth(data) |
103 return meth(data) |
101 |
104 |
102 def close(self): |
105 def close(self): |
103 return self._main.close() |
106 return self._main.close() |
104 |
107 |
|
108 def flush(self): |
|
109 return self._main.flush() |
|
110 |
105 class sshpeer(wireproto.wirepeer): |
111 class sshpeer(wireproto.wirepeer): |
106 def __init__(self, ui, path, create=False): |
112 def __init__(self, ui, path, create=False): |
107 self._url = path |
113 self._url = path |
108 self.ui = ui |
114 self.ui = ui |
109 self.pipeo = self.pipei = self.pipee = None |
115 self.pipeo = self.pipei = self.pipee = None |