upstream/mercurial-mirror Files · tests/test-wireproto.py

localrepo: use the path relative to "self.vfs" instead of "path" argument...

localrepo: use the path relative to "self.vfs" instead of "path" argument As a part of migration to vfs, this patch uses "self.root", which can be recognized as the path relative to "self.vfs", instead of "path" argument. This fix allows to make invocations of "util.makedirs()" and "os.path.exists()" while ensuring repository directory in "localrepository.__init__()" ones indirectly via vfs. But this fix also raises issue 2528: "hg clone" with empty destination. "path" argument is empty in many cases, so this issue can't be fixed in the view of "localrepository.__init__()". Before this patch, it is fixed by empty-ness check ("not name") of exception handler in "util.makedirs()". try: os.mkdir(name) except OSError, err: if err.errno == errno.EEXIST: return if err.errno != errno.ENOENT or not name: raise This requires "localrepository.__init__()" to invoke "util.makedirs()" with "path" instead of "self.root", because empty "path" is treated as "current directory" and "self.root" becomes valid path. But "hg clone" with empty destination can be detected also in "hg.clone()" before "localrepository.__init__()" invocation, so this patch re-fixes issue2528 by checking it in "hg.clone()".

Thomas Arendsen Hein - - Load All Authors

File last commit:

r14765:08ef6b5f stable


                r17159:36a30168

default

Download file

             test-wireproto.py
        
                    45 lines
            
             | 1.1 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / tests / test-wireproto.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      from mercurial import wireproto

      class proto(object):

          def __init__(self, args):

              self.args = args

          def getargs(self, spec):

              args = self.args

              args.setdefault('*', {})

              names = spec.split()

              return [args[n] for n in names]

      class clientrepo(wireproto.wirerepository):

          def __init__(self, serverrepo):

              self.serverrepo = serverrepo

          def _call(self, cmd, **args):

              return wireproto.dispatch(self.serverrepo, proto(args), cmd)

          @wireproto.batchable

          def greet(self, name):

              f = wireproto.future()

              yield wireproto.todict(name=mangle(name)), f

              yield unmangle(f.value)

      class serverrepo(object):

          def greet(self, name):

              return "Hello, " + name

      def mangle(s):

          return ''.join(chr(ord(c) + 1) for c in s)

      def unmangle(s):

          return ''.join(chr(ord(c) - 1) for c in s)

      def greet(repo, proto, name):

          return mangle(repo.greet(unmangle(name)))

      wireproto.commands['greet'] = (greet, 'name',)

      srv = serverrepo()

      clt = clientrepo(srv)

      print clt.greet("Foobar")

      b = clt.batch()

      fs = [b.greet(s) for s in ["Fo, =;o", "Bar"]]

      b.submit()

      print [f.value for f in fs]

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

				from mercurial import wireproto

				class proto(object):
				def __init__(self, args):
				self.args = args
				def getargs(self, spec):
				args = self.args
				args.setdefault('*', {})
				names = spec.split()
				return [args[n] for n in names]

				class clientrepo(wireproto.wirerepository):
				def __init__(self, serverrepo):
				self.serverrepo = serverrepo
				def _call(self, cmd, **args):
				return wireproto.dispatch(self.serverrepo, proto(args), cmd)

				@wireproto.batchable
				def greet(self, name):
				f = wireproto.future()
				yield wireproto.todict(name=mangle(name)), f
				yield unmangle(f.value)

				class serverrepo(object):
				def greet(self, name):
				return "Hello, " + name

				def mangle(s):
				return ''.join(chr(ord(c) + 1) for c in s)
				def unmangle(s):
				return ''.join(chr(ord(c) - 1) for c in s)

				def greet(repo, proto, name):
				return mangle(repo.greet(unmangle(name)))

				wireproto.commands['greet'] = (greet, 'name',)

				srv = serverrepo()
				clt = clientrepo(srv)

				print clt.greet("Foobar")
				b = clt.batch()
				fs = [b.greet(s) for s in ["Fo, =;o", "Bar"]]
				b.submit()
				print [f.value for f in fs]