Campbell Barton
2d797f35d8
- moved release/io and release/ui into release/scripts/io, ui - updated scons, cmake, make When porting 2.4x scripts back, use a command like this so as not to loose the commit history... svn cp https://svn.blender.org/svnroot/bf-blender/branches/blender2.4/release/scripts/raw_import.py release/scripts/io/import_raw.py
95 lines
2.2 KiB
Python
95 lines
2.2 KiB
Python
import time
|
|
|
|
from netrender.utils import *
|
|
import netrender.model
|
|
|
|
class RatingRule:
|
|
def rate(self, job):
|
|
return 0
|
|
|
|
class ExclusionRule:
|
|
def test(self, job):
|
|
return False
|
|
|
|
class PriorityRule:
|
|
def test(self, job):
|
|
return False
|
|
|
|
class Balancer:
|
|
def __init__(self):
|
|
self.rules = []
|
|
self.priorities = []
|
|
self.exceptions = []
|
|
|
|
def addRule(self, rule):
|
|
self.rules.append(rule)
|
|
|
|
def addPriority(self, priority):
|
|
self.priorities.append(priority)
|
|
|
|
def addException(self, exception):
|
|
self.exceptions.append(exception)
|
|
|
|
def applyRules(self, job):
|
|
return sum((rule.rate(job) for rule in self.rules))
|
|
|
|
def applyPriorities(self, job):
|
|
for priority in self.priorities:
|
|
if priority.test(job):
|
|
return True # priorities are first
|
|
|
|
return False
|
|
|
|
def applyExceptions(self, job):
|
|
for exception in self.exceptions:
|
|
if exception.test(job):
|
|
return True # exceptions are last
|
|
|
|
return False
|
|
|
|
def sortKey(self, job):
|
|
return (1 if self.applyExceptions(job) else 0, # exceptions after
|
|
0 if self.applyPriorities(job) else 1, # priorities first
|
|
self.applyRules(job))
|
|
|
|
def balance(self, jobs):
|
|
if jobs:
|
|
jobs.sort(key=self.sortKey)
|
|
return jobs[0]
|
|
else:
|
|
return None
|
|
|
|
# ==========================
|
|
|
|
class RatingUsage(RatingRule):
|
|
def rate(self, job):
|
|
# less usage is better
|
|
return job.usage / job.priority
|
|
|
|
class NewJobPriority(PriorityRule):
|
|
def __init__(self, limit = 1):
|
|
self.limit = limit
|
|
|
|
def test(self, job):
|
|
return job.countFrames(status = DONE) < self.limit
|
|
|
|
class MinimumTimeBetweenDispatchPriority(PriorityRule):
|
|
def __init__(self, limit = 10):
|
|
self.limit = limit
|
|
|
|
def test(self, job):
|
|
return job.countFrames(status = DISPATCHED) == 0 and (time.time() - job.last_dispatched) / 60 > self.limit
|
|
|
|
class ExcludeQueuedEmptyJob(ExclusionRule):
|
|
def test(self, job):
|
|
return job.status != JOB_QUEUED or job.countFrames(status = QUEUED) == 0
|
|
|
|
class ExcludeSlavesLimit(ExclusionRule):
|
|
def __init__(self, count_jobs, count_slaves, limit = 0.75):
|
|
self.count_jobs = count_jobs
|
|
self.count_slaves = count_slaves
|
|
self.limit = limit
|
|
|
|
def test(self, job):
|
|
return not ( self.count_jobs() == 1 or self.count_slaves() <= 1 or float(job.countSlaves() + 1) / self.count_slaves() <= self.limit )
|