[svn r57481] fix a few things, seems to work again.
--HG-- branch : trunk
This commit is contained in:
parent
353ce8d0ce
commit
a8571daac8
|
@ -25,7 +25,7 @@ class PathServer:
|
||||||
|
|
||||||
def command_GET(self, id, spec):
|
def command_GET(self, id, spec):
|
||||||
path = self.C2P[id]
|
path = self.C2P[id]
|
||||||
self.channel.send(path.get(spec))
|
self.channel.send(path._getbyspec(spec))
|
||||||
|
|
||||||
def command_READ(self, id):
|
def command_READ(self, id):
|
||||||
path = self.C2P[id]
|
path = self.C2P[id]
|
||||||
|
|
|
@ -13,7 +13,8 @@ channel.send(srv.p2c(py.path.local("/tmp")))
|
||||||
|
|
||||||
#gw = py.execnet.SshGateway('codespeak.net')
|
#gw = py.execnet.SshGateway('codespeak.net')
|
||||||
gw = py.execnet.PopenGateway()
|
gw = py.execnet.PopenGateway()
|
||||||
c = gw.remote_exec(SRC)
|
gw.remote_init_threads(5)
|
||||||
|
c = gw.remote_exec(SRC, stdout=py.std.sys.stdout, stderr=py.std.sys.stderr)
|
||||||
subchannel = gw._channelfactory.new()
|
subchannel = gw._channelfactory.new()
|
||||||
c.send(subchannel)
|
c.send(subchannel)
|
||||||
|
|
||||||
|
|
|
@ -33,7 +33,7 @@ class RemotePath(common.FSPathBase):
|
||||||
self._channel.send(('JOIN', self._id, id) + args)
|
self._channel.send(('JOIN', self._id, id) + args)
|
||||||
return RemotePath(self._channel, id)
|
return RemotePath(self._channel, id)
|
||||||
|
|
||||||
def get(self, spec):
|
def _getbyspec(self, spec):
|
||||||
parts = spec.split(',')
|
parts = spec.split(',')
|
||||||
ask = [x for x in parts if x not in self._specs]
|
ask = [x for x in parts if x not in self._specs]
|
||||||
if ask:
|
if ask:
|
||||||
|
|
Loading…
Reference in New Issue