12_create_concurrent_stress_pos.py

xen虚拟机源代码安装包

#!/usr/bin/python

# Copyright (C) International Business Machines Corp., 2005
# Authors: Dan Smith <[e-mail]>

from XmTestLib import *

import time

DOMS=5
MEM=minSafeMem()
DUR=60

domains = []

free_mem = int(getInfo("free_memory"))
NUM_DOMS = int(free_mem / MEM)

if NUM_DOMS < DOMS:
    SKIP("Need %i MB of RAM to start %i@%iMB domains! (%i MB avail)" %
         (DOMS * MEM, DOMS, MEM, free_mem))

for i in range(0,DOMS):
    dom = XmTestDomain(extraConfig={"memory" : MEM})

    try:
        cons = dom.start()
    except DomainError, e:
        if verbose:
            print str(e)
        FAIL("Failed to start %s" % dom.getName())

    if verbose:
        print "[%i/%i] Started %s" % (i, DOMS, dom.getName())

    domains.append([dom, cons])

# Started DOMS domains, now we put them to work

for d, c in domains:
    if verbose:
        print "Starting task on %s" % d.getName()
    c.sendInput("gzip -c </dev/zero >/dev/null &\n")

if verbose:
    print "Waiting %i seconds..." % DUR

time.sleep(DUR)

for d, c in domains:

    if verbose:
        print "Testing domain %s..." % d.getName()
    
    run = c.runCmd("ls")

    if run["return"] != 0:
        FAIL("Domain %s didn't survive!" % d.getName())