You are viewing a plain text version of this content. The canonical link for it is here.
Posted to tashi-commits@incubator.apache.org by st...@apache.org on 2011/07/26 22:00:17 UTC
svn commit: r1151267 -
/incubator/tashi/trunk/src/zoni/hardware/f10s50switch.py
Author: stroucki
Date: Tue Jul 26 22:00:17 2011
New Revision: 1151267
URL: http://svn.apache.org/viewvc?rev=1151267&view=rev
Log:
f10s50switch: add sort of configuration module for force10 network switch. The configuration here is sufficiently different from other switches, so I doubt the existing interface can work with this switch
Added:
incubator/tashi/trunk/src/zoni/hardware/f10s50switch.py
Added: incubator/tashi/trunk/src/zoni/hardware/f10s50switch.py
URL: http://svn.apache.org/viewvc/incubator/tashi/trunk/src/zoni/hardware/f10s50switch.py?rev=1151267&view=auto
==============================================================================
--- incubator/tashi/trunk/src/zoni/hardware/f10s50switch.py (added)
+++ incubator/tashi/trunk/src/zoni/hardware/f10s50switch.py Tue Jul 26 22:00:17 2011
@@ -0,0 +1,405 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+#
+# $Id: dellswitch.py 1034085 2010-11-11 19:56:30Z rgass $
+#
+# switch configuration manager for force10 s50
+
+import os
+import sys
+import pexpect
+import datetime
+import time
+import thread
+import string
+import getpass
+import socket
+import tempfile
+import logging
+
+#import zoni
+from zoni.data.resourcequerysql import *
+from zoni.hardware.hwswitchinterface import HwSwitchInterface
+from zoni.data.resourcequerysql import ResourceQuerySql
+from zoni.agents.dhcpdns import DhcpDns
+
+
+''' Using pexpect to control switches because couldn't get snmp to work
+'''
+
+class HwF10S50Switch(HwSwitchInterface):
+ def __init__(self, config, host=None):
+ self.config = config
+ self.host = host
+ self.verbose = False
+ self.log = logging.getLogger(os.path.basename(__file__))
+
+
+ def setVerbose(self, verbose):
+ self.verbose = verbose
+
+ def __login(self):
+
+ switchIp = "ssh " + self.host['hw_userid'] + "@" + self.host['hw_name']
+ child = pexpect.spawn(switchIp)
+
+ # Be Verbose and print everything
+ if self.verbose:
+ child.logfile = sys.stdout
+
+ opt = child.expect(['Name:', 'assword:', 'Are you sure.*', pexpect.EOF, pexpect.TIMEOUT])
+ #XXX Doesn't seem to do what I want:(
+ child.setecho(False)
+
+ # Send a yes to register authenticity of host for ssh
+ if opt == 2:
+ child.sendline("yes")
+ opt = child.expect(['Name:', 'assword:', 'Are you sure.*', pexpect.EOF, pexpect.TIMEOUT])
+
+ if opt == 0:
+ child.sendline(self.host['hw_userid'])
+ i = child.expect(['assword:', 'Connection', pexpect.EOF, pexpect.TIMEOUT])
+ child.sendline(self.host['hw_password'])
+ i=child.expect(['console','#', 'Name:', pexpect.EOF, pexpect.TIMEOUT])
+ if i == 2:
+ mesg = "ERROR: Login to %s failed\n" % (self.host['hw_name'])
+ self.log.error(mesg)
+ exit(1)
+
+ if opt == 1:
+ # the S50 doesn't prompt for username
+ child.sendline(self.host['hw_password'])
+ i=child.expect(['console','>', 'Name:', pexpect.EOF, pexpect.TIMEOUT])
+ # on the S50, need to send enable, just send to all
+ child.sendline('enable')
+ i=child.expect(['assword:', pexpect.EOF, pexpect.TIMEOUT])
+ child.sendline(self.host['hw_password'])
+ i=child.expect(['#', pexpect.EOF, pexpect.TIMEOUT])
+
+
+ return child
+
+ def __getPrsLabel(self):
+ dadate = datetime.datetime.now().strftime("%Y%m%d-%H%M-%S")
+ return "PRS_" + dadate
+
+
+ def enableHostPort(self):
+ child = self.__login()
+ child.sendline('config')
+ cmd = "interface g 0/" + str(self.host['hw_port'])
+ child.sendline(cmd)
+ cmd = "no shutdown"
+ child.sendline(cmd)
+ child.sendline('exit')
+ child.terminate()
+
+ def disableHostPort(self):
+ child = self.__login()
+ child.sendline('config')
+ cmd = "interface g 0/" + str(self.host['hw_port'])
+ child.sendline(cmd)
+ cmd = "shutdown"
+ child.sendline(cmd)
+ child.sendline('exit')
+ child.terminate()
+
+ def removeVlan(self, num):
+ # Check for important vlans
+
+ cmd = "no interface vlan " + num
+ child = self.__login()
+ child.sendline('config')
+ child.sendline(cmd)
+ child.sendline('exit')
+ child.terminate()
+
+ def addVlanToTrunk(self, vlan):
+ mesg = "Adding Vlan %s to trunk on switch" % (vlan)
+ self.log.info(mesg)
+ child = self.__login()
+ child.sendline('config')
+ cmd = "interface port-channel 1"
+ child.sendline(cmd)
+ child.expect(["conf-if", pexpect.EOF])
+ child.sendline("switchport")
+ child.sendline("exit")
+ child.sendline("interface vlan " + vlan")
+ child.expect(["conf-if", pexpect.EOF])
+ cmd = "tagged port-channel 1"
+ child.sendline(cmd)
+ child.sendline('exit')
+
+ def createVlansThread(self, vlan, switch,host):
+ mesg = "Creating vlan %s on switch %s" % (str(vlan),str(switch))
+ print "host is ", host
+ self.log(mesg)
+ print "create"
+ self.createVlan(vlan)
+ print "cend"
+ self.addVlanToTrunk(vlan);
+ thread.exit()
+
+ def createVlans(self, vlan, switchlist, query):
+ for switch in switchlist:
+ #print "working on switch ", switch
+ #self.host = query.getSwitchInfo(switch)
+ #thread.start_new_thread(self.createVlansThread, (vlan, switch, self.host))
+ mesg = "Creating vlan %s on switch %s" % (str(vlan), str(switch))
+ self.log.info(mesg)
+ self.host = query.getSwitchInfo(switch)
+ self.createVlan(vlan)
+ self.addVlanToTrunk(vlan);
+
+ def removeVlans(self, vlan, switchlist, query):
+ for switch in switchlist:
+ mesg = "Deleting vlan %s on switch %s" % (str(vlan),str(switch))
+ self.log.info(mesg)
+ self.host = query.getSwitchInfo(switch)
+ self.removeVlan(vlan)
+
+ def createVlan(self, val):
+
+ vlanname = False
+ if ":" in val:
+ num = int(val.split(":")[0])
+ vlanname = val.split(":")[1]
+ else:
+ vlanname = self.__getPrsLabel()
+ num = int(val)
+
+ #if type(num) != int:
+ #mesg = "ERROR: Vlan must be a number (0-4095)\n"
+ #sys.stderr.write(mesg)
+ #exit(1)
+ if num > 4095 or num < 0:
+ mesg = "Vlan out of range. Must be < %s" % (self.config['vlan_max'])
+ self.log.error(mesg)
+ exit(1)
+
+ child = self.__login()
+ child.sendline('config')
+ child.expect(["config",pexpect.EOF, pexpect.TIMEOUT])
+ child.sendline('interface vlan %d' % num)
+ child.expect(["conf-if",pexpect.EOF, pexpect.TIMEOUT])
+ child.sendline("shutdown")
+ child.sendline("no ip address")
+ if vlanname:
+ child.sendline("name " + vlanname)
+ child.sendline('exit')
+ child.expect(["config",pexpect.EOF, pexpect.TIMEOUT])
+
+ # Raw Switch commands. DEBUG ONLY!, Doesn't work!
+ def sendSwitchCommand(self, cmds):
+ if len(cmds) > 0:
+ child = self.__login()
+ child.logfile = sys.stdout
+ for cmd in cmds.split(";"):
+ child.sendline(cmd)
+ try:
+ i=child.expect(['console','#', 'Name:', pexpect.EOF, pexpect.TIMEOUT], timeout=2)
+ i=child.expect(['console','#', 'Name:', pexpect.EOF, pexpect.TIMEOUT], timeout=2)
+
+ except EOF:
+ print "EOF", i
+ #child.sendline()
+ except TIMEOUT:
+ print "TIMEOUT", i
+ #child.interact(escape_character='\x1d', input_filter=None, output_filter=None)
+
+ child.terminate()
+ #print "before", child.before
+ #print "after", child.after
+
+ def addNodeToVlan(self, vlan):
+ mesg = "NOOP Adding Node to vlan %s" % (str(vlan))
+ self.log.info(mesg)
+
+ def removeNodeFromVlan(self, vlan):
+ mesg = "NOOP Removing Node from vlan %s" % (str(vlan))
+ self.log.info(mesg)
+
+ def setNativeVlan(self, vlan):
+ child = self.__login()
+ child.logfile = sys.stdout
+ child.sendline('config')
+ cmd = "interface vlan " + vlan)
+ child.sendline(cmd)
+ i=child.expect(['conf-if', pexpect.EOF, pexpect.TIMEOUT])
+ if i > 0:
+ self.log.error("setNativeVlan %s failed" % (cmd))
+
+ cmd = "untagged g 0/" + str(self.host['hw_port'])
+ child.sendline(cmd)
+ child.expect(['config-if', pexpect.EOF, pexpect.TIMEOUT])
+ child.sendline('exit')
+ child.terminate()
+
+ # Restore Native Vlan. In Dell's case, this is vlan 1
+ def restoreNativeVlan(self):
+ pass
+
+ # Setup the switch for node allocation
+ def allocateNode(self):
+ pass
+
+ # Remove all vlans from the interface
+ def removeAllVlans(self):
+ pass
+
+ def showInterfaceConfig(self):
+ child = self.__login()
+ print "\n------------------------------------"
+ print "SWITCH - " + self.host['hw_name'] + "/" + str(self.host['hw_port'])
+ print "NODE - " + self.host['location']
+ print "------------------------------------\n"
+ child.logfile = sys.stdout
+ cmd = "show interfaces g 0/" + str(self.host['hw_port'])
+ child.sendline(cmd)
+ i = child.expect(['#', pexpect.EOF, pexpect.TIMEOUT])
+ child.terminate()
+
+ def interactiveSwitchConfig(self):
+ switchIp = "ssh " + self.host['hw_name']
+ child = pexpect.spawn(switchIp)
+ child.setecho(False)
+ #child.expect('Name:')
+ child.sendline(self.host['hw_userid'])
+ #i=child.expect(['test','password:','Password:', pexpect.EOF, pexpect.TIMEOUT])
+ #child.logfile = sys.stdout
+ child.sendline(self.host['hw_password'])
+ child.interact(escape_character='\x1d', input_filter=None, output_filter=None)
+
+ def registerToZoni(self, user, password, host):
+ host = string.strip(str(host))
+ # Get hostname of the switch
+ if len(host.split(".")) == 4:
+ ip = host
+ try:
+ host = string.strip(socket.gethostbyaddr(ip)[0].split(".")[0])
+ except Exception, e:
+ mesg = "Host (%s) not registered in DNS, %s" % (host,str(e))
+ self.log.warning(mesg)
+ else:
+ # Maybe a hostname was entered...
+ try:
+ ip = socket.gethostbyname(host)
+ except Exception, e:
+ mesg = "Host (%s) not registered in DNS, %s" % (host, str(e))
+ self.log.error(mesg)
+ mesg = "Unable to resolve hostname"
+ self.log.critical(mesg)
+ exit()
+
+ switchIp = "ssh " + user + "@" + ip
+ child = pexpect.spawn(switchIp)
+ opt = child.expect(['Name:', 'assword:', 'Are you sure.*', pexpect.EOF, pexpect.TIMEOUT])
+ #XXX Doesn't seem to do what I want:(
+ child.setecho(False)
+
+ # Send a yes to register authenticity of host for ssh
+ if opt == 2:
+ child.sendline("yes")
+ opt = child.expect(['Name:', 'assword:', 'Are you sure.*', pexpect.EOF, pexpect.TIMEOUT])
+
+ if opt == 0:
+ child.sendline(user)
+ i = child.expect(['assword:', 'Connection', pexpect.EOF, pexpect.TIMEOUT])
+ child.sendline(password)
+ i=child.expect(['console',host, 'Name:', pexpect.EOF, pexpect.TIMEOUT])
+ if i == 2:
+ mesg = "Login to switch %s failed" % (host)
+ self.log.error(mesg)
+ exit(1)
+
+ if opt == 1:
+ child.sendline(password)
+ i=child.expect(['console',host, 'Name:', pexpect.EOF, pexpect.TIMEOUT])
+ # on the 6448 dell, need to send enable, just send to all
+ child.sendline('enable')
+ i=child.expect(['#', pexpect.EOF, pexpect.TIMEOUT])
+
+ fout = tempfile.TemporaryFile()
+ child.logfile = fout
+
+ cmd = "show system"
+ child.sendline(cmd)
+ val = host + "#"
+ i = child.expect([val, '\n\r\n\r', pexpect.EOF, pexpect.TIMEOUT])
+ cmd = "show version"
+ child.sendline(cmd)
+ i = child.expect([val, '\n\r\n\r', pexpect.EOF, pexpect.TIMEOUT])
+
+ fout.seek(0)
+ a={}
+ for i in fout.readlines():
+ if "System Location:" in i:
+ datime = time.strftime("%a, %d %b %Y %H:%M:%S +0000", time.localtime())
+ val = "Registered by Zoni on : " + datime
+ a['hw_notes'] = val + "; " + string.strip(i.split(':', 1)[1])
+ if "System MAC" in i:
+ a['hw_mac'] = string.strip(i.split(':', 1)[1])
+ if "SW version" in i:
+ a['hw_version_sw'] = string.strip(i.split(' ')[1].split()[0])
+ if "HW version" in i:
+ a['hw_version_fw'] = string.strip(i.split(' ')[1].split()[0])
+
+ a['hw_type'] = "switch"
+ a['hw_make'] = "F10S50"
+ a['hw_name'] = host
+ a['hw_ipaddr'] = ip
+ a['hw_userid'] = user
+ a['hw_password'] = password
+ child.sendline('exit')
+ child.sendline('exit')
+ child.terminate()
+
+ # Try to get more info via snmp
+ from pysnmp.entity.rfc3413.oneliner import cmdgen
+ from pysnmp.proto import rfc1902
+
+ user = "public"
+ oid = eval("1,3,6,1,4,1,674,10895,3000,1,2,100,1,0")
+ errorIndication, errorStatus, errorIndex, varBinds = cmdgen.CommandGenerator().getCmd( \
+ cmdgen.CommunityData('my-agent', user, 0), \
+ cmdgen.UdpTransportTarget((host, 161)), oid)
+ a['hw_model'] = str(varBinds[0][1])
+ oid = eval("1,3,6,1,4,1,674,10895,3000,1,2,100,3,0")
+ errorIndication, errorStatus, errorIndex, varBinds = cmdgen.CommandGenerator().getCmd( \
+ cmdgen.CommunityData('my-agent', user, 0), \
+ cmdgen.UdpTransportTarget((host, 161)), oid)
+ a['hw_make'] = str(varBinds[0][1])
+
+ # Register in dns
+ if self.config['dnsEnabled']:
+ try:
+ mesg = "Adding %s(%s) to dns" % (host, ip)
+ self.log.info(mesg)
+ DhcpDns(self.config, verbose=self.verbose).addDns(host, ip)
+ mesg = "Adding %s(%s) to dhcp" % (host, ip)
+ self.log.info(mesg)
+ DhcpDns(self.config, verbose=self.verbose).addDhcp(host, ip, a['hw_mac'])
+ except:
+ mesg = "Adding %s(%s) %s to dhcp/dns failed" % (host, ip, a['hw_mac'])
+ self.log.error(mesg)
+
+ # Add to db
+ # Register to DB
+ query = ResourceQuerySql(self.config, self.verbose)
+ query.registerHardware(a)
+
+