Changeset 37776ea for fedd

Timestamp:

Mar 2, 2010 7:31:35 AM (15 years ago)

Author:

Ted Faber <faber@…>

Branches:

axis_example, compt_changes, info-ops, master, version-3.01, version-3.02

Children:

6f82229

Parents:

6d07908

Message:

Split out proxy code for use with other proxies - e.g. protogeni proxy

Location:

fedd/federation

Files:

• proxy_emulab_segment.py (modified) (2 diffs)
• proxy_segment.py (added)

fedd/federation/proxy_emulab_segment.py

@@ -10 +10 @@
 import signal
 
+from proxy_segment import proxy_segment
 from service_error import service_error
 
-class proxy_emulab_segment:
-    class ssh_cmd_timeout(RuntimeError): pass
-
+class start_segment(proxy_segment):
     def __init__(self, log=None, keyfile=None, debug=False):
-        self.log = log or logging.getLogger(\
-                'fedd.access.proxy_emulab_segment')
-        self.ssh_privkey_file = keyfile
-        self.debug = debug
-        self.ssh_exec="/usr/bin/ssh"
-        self.scp_exec = "/usr/bin/scp"
-        self.ssh_cmd_timeout = proxy_emulab_segment.ssh_cmd_timeout
-
-    def scp_file(self, file, user, host, dest=""):
-        """
-        scp a file to the remote host.  If debug is set the action is only
-        logged.
-        """
-
-        scp_cmd = [self.scp_exec, '-o', 'IdentitiesOnly yes', 
-                '-o', 'StrictHostKeyChecking no', '-i', 
-                self.ssh_privkey_file, file, 
-                "%s@%s:%s" % (user, host, dest)]
-        rv = 0
-
-        try:
-            dnull = open("/dev/null", "w")
-        except IOError:
-            self.log.debug("[ssh_file]: failed to open " + \
-                    "/dev/null for redirect")
-            dnull = Null
-
-        self.log.debug("[scp_file]: %s" % " ".join(scp_cmd))
-        if not self.debug:
-            rv = subprocess.call(scp_cmd, stdout=dnull, 
-                    stderr=dnull, close_fds=True)
-
-        return rv == 0
-
-    def ssh_cmd(self, user, host, cmd, wname=None, timeout=None):
-        """
-        Run a remote command on host as user.  If debug is set, the action
-        is only logged.  Commands are run without stdin, to avoid stray
-        SIGTTINs.
-        """
-        sh_str = ("%s -n -o 'IdentitiesOnly yes' -o " + \
-                "'StrictHostKeyChecking no' -i %s %s@%s %s") % \
-                (self.ssh_exec, self.ssh_privkey_file, 
-                        user, host, cmd)
-
-        try:
-            dnull = open("/dev/null", "w")
-        except IOError:
-            self.log.debug("[ssh_cmd]: failed to open /dev/null " + \
-                    "for redirect")
-            dnull = Null
-
-        self.log.debug("[ssh_cmd]: %s" % sh_str)
-        if not self.debug:
-            if dnull:
-                sub = subprocess.Popen(sh_str, shell=True, stdout=dnull,
-                        stderr=dnull, close_fds=True)
-            else:
-                sub = subprocess.Popen(sh_str, shell=True, close_fds=True)
-            if timeout:
-                i = 0
-                rv = sub.poll()
-                while i < timeout:
-                    if rv is not None: break
-                    else:
-                        time.sleep(1)
-                        rv = sub.poll()
-                        i += 1
-                else:
-                    self.log.debug("Process exceeded runtime: %s" % sh_str)
-                    os.kill(sub.pid, signal.SIGKILL)
-                    raise self.ssh_cmd_timeout();
-                return rv == 0
-            else:
-                return sub.wait() == 0
-        else:
-            if timeout == 0:
-                self.log.debug("debug timeout raised on %s " % sh_str)
-                raise self.ssh_cmd_timeout()
-            else:
-                return True
-
-class start_segment(proxy_emulab_segment):
-    def __init__(self, log=None, keyfile=None, debug=False):
-        proxy_emulab_segment.__init__(self, log=log, 
-                keyfile=keyfile, debug=debug)
+        proxy_segment.__init__(self, log=log, keyfile=keyfile, debug=debug)
         self.null = """
 set ns [new Simulator]
@@ -295 +209 @@
         return True
 
-class stop_segment(proxy_emulab_segment):
+class stop_segment(proxy_segment):
     def __init__(self, log=None, keyfile=None, debug=False):
-        proxy_emulab_segment.__init__(self,
-                log=log, keyfile=keyfile, debug=debug)
+        proxy_segment.__init__(self, log=log, keyfile=keyfile, debug=debug)
 
     def __call__(self, parent, user, pid, eid):