def connect(self):
        """inhibit the resource beyond

        Choose mounting backend (direct or mountbroker),
        set up glusterfs parameters and perform the mount
        with given backend
        """

        label = getattr(gconf, "mountbroker", None)
        if not label:
            uid = os.geteuid()
            if uid != 0:
                label = syncdutils.getusername(uid)
        mounter = label and self.MountbrokerMounter or self.DirectMounter
        params = (
            gconf.gluster_params.split()
            + (gconf.gluster_log_level and ["log-level=" + gconf.gluster_log_level] or [])
            + [
                "log-file=" + gconf.gluster_log_file,
                "volfile-server=" + self.host,
                "volfile-id=" + self.volume,
                "client-pid=-1",
            ]
        )
        mounter(params).inhibit(*[l for l in [label] if l])

 def parse_ssh_address(addr):
     m = re.match("([^@]+)@(.+)", addr)
     if m:
         u, h = m.groups()
     else:
         u, h = syncdutils.getusername(), addr
     return {"user": u, "host": h}

 def canonical_path(self):
     m = re.match("([^@]+)@(.+)", self.remote_addr)
     if m:
         u, h = m.groups()
     else:
         u, h = syncdutils.getusername(), self.remote_addr
     remote_addr = "@".join([u, gethostbyname(h)])
     return ":".join([remote_addr, self.inner_rsc.get_url(canonical=True)])

 def parse_ssh_address(self):
     m = re.match('([^@]+)@(.+)', self.remote_addr)
     if m:
         u, h = m.groups()
     else:
         u, h = syncdutils.getusername(), self.remote_addr
     self.remotehost = h
     return {'user': u, 'host': h}

    def connect(self):
        """inhibit the resource beyond

        Choose mounting backend (direct or mountbroker),
        set up glusterfs parameters and perform the mount
        with given backend
        """

        label = getattr(gconf, 'mountbroker', None)
        if not label and not privileged():
            label = syncdutils.getusername()
        mounter = label and self.MountbrokerMounter or self.DirectMounter
        params = gconf.gluster_params.split() + \
                   (gconf.gluster_log_level and ['log-level=' + gconf.gluster_log_level] or []) + \
                   ['log-file=' + gconf.gluster_log_file, 'volfile-server=' + self.host,
                    'volfile-id=' + self.volume, 'client-pid=-1']
        mounter(params).inhibit(*[l for l in [label] if l])

 def make_mount_argv(self, label):
     return self.make_cli_argv() + ["mount", label, "user-map-root=" + syncdutils.getusername()] + self.params

 def make_mount_argv(self, label):
     return self.make_cli_argv() + \
            ['mount', label, 'user-map-root=' + syncdutils.getusername()] + self.params