import libvirt 
import memcache 
import os 
import time 
from xml.etree import ElementTree as ET 

mc = memcache.Client(['192.168.0.112:11211']) 
while True: 
    conn = libvirt.open('qemu:///system') 
 
    dom = conn.listDomainsID() 
    for i in dom: 
        vmm_id = conn.lookupByID(i) 
        vmm_name = vmm_id.name() 
        if "wrksp" in vmm_name: 
            try: 
        #    vmm_namevmm_name_id = vmm_name.split('-')[1] 
                vmm_id_str = str(vmm_name) 
                vmmid = vmm_id_str.split('-')[1] 
                print vmmid 
                vmm_dom_xml = vmm_id.XMLDesc(0) 
                vmm_xml_name = vmm_id_str + '.' + 'xml' 
                vmm_xml_path = '/tmp/' + vmm_xml_name 
                print vmm_xml_path 
                if os.path.exists(vmm_xml_path): 
                    pass 
                else : 
                    os.mknod(vmm_xml_path) 
             
                xml_open = open(vmm_xml_path,'w') 
                for lines in vmm_dom_xml: 
                    xml_open.write(lines) 
                xml_open.close() 
                 
                vmm_xml_open = ET.parse(vmm_xml_path) 
                path_list=[] 
                path = vmm_xml_open.findall('//source') 
                for i in path: 
                    file1 = i.attrib 
                    filename=file1.get('file') 
                    if filename: 
                        path_list.append(filename) 
                 
    #    print path_list 
                interface_list = [] 
                interface = vmm_xml_open.findall('//target') 
                for j in interface: 
                    interface_network = j.attrib 
                    dev1 = interface_network.get('dev') 
                    dev3 = 'vnet' 
                    dev2 = str(dev1) 
                    if dev3 in dev2: 
                        interface_list.append(dev1) 
                 
        #    print interface_list 
                 
                totalrd = vmmid + 'rd' 
                totalrd_byte = 0 
                totalwr = vmmid + 'wr' 
                totalwr_byte = 0 
                totalrx = vmmid + 'rx' 
                totalrx_byte = 0 
                totaltx = vmmid + 'tx' 
                totaltx_byte = 0 
                totalrp = vmmid + 'rp' 
                totalrx_packet = 0 
                totaltp = vmmid + 'tp' 
                totaltx_packet = 0 
             
                for image_file in  path_list:   
        #        print image_file 
        #        size = vmm_id.blockInfo(image_file,0) 
                    block_status = vmm_id.blockStatsFlags(image_file,0) 
         
                    totalrd_bytetotalrd_byte = totalrd_byte + block_status['rd_bytes'] 
                    totalwr_bytetotalwr_byte = totalwr_byte + block_status['wr_bytes'] 
                print totalrd_byte    
                print totalwr_byte 
        #        print totalwr_byte 
             
             
                for interfaceinfo_path in interface_list: 
                    interfaceinfo = vmm_id.interfaceStats(interfaceinfo_path) 
                    totalrx_bytetotalrx_byte = totalrx_byte + interfaceinfo[0] 
                    totalrx_packettotalrx_packet = totalrx_packet + interfaceinfo[1] 
                    totaltx_bytetotaltx_byte = totaltx_byte + interfaceinfo[4] 
                    totaltx_packettotaltx_packet = totaltx_packet + interfaceinfo[5] 
             
                totalmem = vmmid + 'actual' 
                totalmem_data = 0 
                rssmem = vmmid + 'rss' 
                rssmem_data = 0 
                mem_status = vmm_id.memoryStats() 
                totalmem_data = mem_status['actual'] 
                rssmem_data = mem_status['rss']   
        #    print totalmem_data 
        #    print rssmem_data    
             
                totalcpu = vmmid + 'cpu' 
                totalcpu_usage = 0 
                cpu_time =  vmm_id.info()[4] 
                timetime1 = time.time() 
                time.sleep(3) 
                timetime2 = time.time() 
                cpu_new_time = vmm_id.info()[4] 
                totalcpu_usage = int(((cpu_new_time - cpu_time)/((time2 - time1)*10000000))*100) 
                print totalcpu_usage 
             
                mc.set('centosliran', '1234', 20) 
                mc.set('centos_clusterliran','345',20) 
                mc.set_multi({totalrd:totalrd_byte,totalwr:totalwr_byte,totalrx:totalrx_byte,totaltx:totaltx_byte,totalrp:totalrx_packet,totaltp:totaltx_packet,totalmem:totalmem_data,rssmem:rssmem_data,totalcpu:totalcpu_usage},60)   
                    #value = mc.get('key') 
                   # print value 
            except: 
                pass