Mercurial > hg
comparison mercurial/sshpeer.py @ 25456:408b7979bf03
sshpeer: allow write operations through double pipe
We have a shiny toy, lets make it wider.
| author | Pierre-Yves David <pierre-yves.david@fb.com> |
|---|---|
| date | Wed, 20 May 2015 10:58:29 -0500 |
| parents | dc02a284e034 |
| children | 2afa748138e0 |
comparison
equal
deleted
inserted
replaced
| 25455:dc02a284e034 | 25456:408b7979bf03 |
|---|---|
| 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 |