eddf6f1637
Using print >>ini_file syntax instead of reassigning sys.stdout allows the python debugger to be used. --HG-- extra : convert_revision : 63fc268f2e80f338ad1a7abe54b9e979e2239609
184 lines
6.2 KiB
Python
184 lines
6.2 KiB
Python
# Copyright (c) 2005 The Regents of The University of Michigan
|
|
# All rights reserved.
|
|
#
|
|
# Redistribution and use in source and binary forms, with or without
|
|
# modification, are permitted provided that the following conditions are
|
|
# met: redistributions of source code must retain the above copyright
|
|
# notice, this list of conditions and the following disclaimer;
|
|
# redistributions in binary form must reproduce the above copyright
|
|
# notice, this list of conditions and the following disclaimer in the
|
|
# documentation and/or other materials provided with the distribution;
|
|
# neither the name of the copyright holders nor the names of its
|
|
# contributors may be used to endorse or promote products derived from
|
|
# this software without specific prior written permission.
|
|
#
|
|
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
|
# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
|
# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
|
# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
|
# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
|
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|
# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|
# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
|
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
#
|
|
# Authors: Nathan Binkert
|
|
# Steve Reinhardt
|
|
|
|
import atexit
|
|
import os
|
|
import sys
|
|
|
|
# import the SWIG-wrapped main C++ functions
|
|
import internal
|
|
from main import options
|
|
import SimObject
|
|
import ticks
|
|
import objects
|
|
|
|
# The final hook to generate .ini files. Called from the user script
|
|
# once the config is built.
|
|
def instantiate(root):
|
|
# we need to fix the global frequency
|
|
ticks.fixGlobalFrequency()
|
|
|
|
root.unproxy_all()
|
|
|
|
ini_file = file(os.path.join(options.outdir, 'config.ini'), 'w')
|
|
root.print_ini(ini_file)
|
|
ini_file.close() # close config.ini
|
|
|
|
# Initialize the global statistics
|
|
internal.stats.initSimStats()
|
|
|
|
# Create the C++ sim objects and connect ports
|
|
root.createCCObject()
|
|
root.connectPorts()
|
|
|
|
# Do a second pass to finish initializing the sim objects
|
|
internal.core.initAll()
|
|
|
|
# Do a third pass to initialize statistics
|
|
internal.core.regAllStats()
|
|
|
|
# Check to make sure that the stats package is properly initialized
|
|
internal.stats.check()
|
|
|
|
# Reset to put the stats in a consistent state.
|
|
internal.stats.reset()
|
|
|
|
def doDot(root):
|
|
dot = pydot.Dot()
|
|
instance.outputDot(dot)
|
|
dot.orientation = "portrait"
|
|
dot.size = "8.5,11"
|
|
dot.ranksep="equally"
|
|
dot.rank="samerank"
|
|
dot.write("config.dot")
|
|
dot.write_ps("config.ps")
|
|
|
|
need_resume = []
|
|
need_startup = True
|
|
def simulate(*args, **kwargs):
|
|
global need_resume, need_startup
|
|
|
|
if need_startup:
|
|
internal.core.SimStartup()
|
|
need_startup = False
|
|
|
|
for root in need_resume:
|
|
resume(root)
|
|
need_resume = []
|
|
|
|
return internal.event.simulate(*args, **kwargs)
|
|
|
|
# Export curTick to user script.
|
|
def curTick():
|
|
return internal.core.cvar.curTick
|
|
|
|
# Python exit handlers happen in reverse order. We want to dump stats last.
|
|
atexit.register(internal.stats.dump)
|
|
|
|
# register our C++ exit callback function with Python
|
|
atexit.register(internal.core.doExitCleanup)
|
|
|
|
# This loops until all objects have been fully drained.
|
|
def doDrain(root):
|
|
all_drained = drain(root)
|
|
while (not all_drained):
|
|
all_drained = drain(root)
|
|
|
|
# Tries to drain all objects. Draining might not be completed unless
|
|
# all objects return that they are drained on the first call. This is
|
|
# because as objects drain they may cause other objects to no longer
|
|
# be drained.
|
|
def drain(root):
|
|
all_drained = False
|
|
drain_event = internal.event.createCountedDrain()
|
|
unready_objects = root.startDrain(drain_event, True)
|
|
# If we've got some objects that can't drain immediately, then simulate
|
|
if unready_objects > 0:
|
|
drain_event.setCount(unready_objects)
|
|
simulate()
|
|
else:
|
|
all_drained = True
|
|
internal.event.cleanupCountedDrain(drain_event)
|
|
return all_drained
|
|
|
|
def resume(root):
|
|
root.resume()
|
|
|
|
def checkpoint(root, dir):
|
|
if not isinstance(root, objects.Root):
|
|
raise TypeError, "Checkpoint must be called on a root object."
|
|
doDrain(root)
|
|
print "Writing checkpoint"
|
|
internal.core.serializeAll(dir)
|
|
resume(root)
|
|
|
|
def restoreCheckpoint(root, dir):
|
|
print "Restoring from checkpoint"
|
|
internal.core.unserializeAll(dir)
|
|
need_resume.append(root)
|
|
|
|
def changeToAtomic(system):
|
|
if not isinstance(system, (objects.Root, objects.System)):
|
|
raise TypeError, "Parameter of type '%s'. Must be type %s or %s." % \
|
|
(type(system), objects.Root, objects.System)
|
|
if system.getMemoryMode() != objects.params.atomic:
|
|
doDrain(system)
|
|
print "Changing memory mode to atomic"
|
|
system.changeTiming(objects.params.atomic)
|
|
|
|
def changeToTiming(system):
|
|
if not isinstance(system, (objects.Root, objects.System)):
|
|
raise TypeError, "Parameter of type '%s'. Must be type %s or %s." % \
|
|
(type(system), objects.Root, objects.System)
|
|
|
|
if system.getMemoryMode() != objects.params.timing:
|
|
doDrain(system)
|
|
print "Changing memory mode to timing"
|
|
system.changeTiming(objects.params.timing)
|
|
|
|
def switchCpus(cpuList):
|
|
print "switching cpus"
|
|
if not isinstance(cpuList, list):
|
|
raise RuntimeError, "Must pass a list to this function"
|
|
for item in cpuList:
|
|
if not isinstance(item, tuple) or len(item) != 2:
|
|
raise RuntimeError, "List must have tuples of (oldCPU,newCPU)"
|
|
|
|
for old_cpu, new_cpu in cpuList:
|
|
if not isinstance(old_cpu, objects.BaseCPU):
|
|
raise TypeError, "%s is not of type BaseCPU" % old_cpu
|
|
if not isinstance(new_cpu, objects.BaseCPU):
|
|
raise TypeError, "%s is not of type BaseCPU" % new_cpu
|
|
|
|
# Now all of the CPUs are ready to be switched out
|
|
for old_cpu, new_cpu in cpuList:
|
|
old_cpu._ccObject.switchOut()
|
|
|
|
for old_cpu, new_cpu in cpuList:
|
|
new_cpu.takeOverFrom(old_cpu)
|