Mercurial > public > mercurial-scm > hg-stable

comparison mercurial/sshpeer.py @ 25456:408b7979bf03

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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