356 lines
14 KiB
Python
356 lines
14 KiB
Python
import re
|
|
import inspect
|
|
import math
|
|
import logging
|
|
import random
|
|
|
|
import formulas
|
|
import workspaceFormulas
|
|
from slipnet import slipnet
|
|
from codelet import Codelet
|
|
from coderackPressure import CoderackPressures
|
|
|
|
NUMBER_OF_BINS = 7
|
|
MAX_NUMBER_OF_CODELETS = 100
|
|
|
|
codeletsUsed = {}
|
|
|
|
|
|
def getUrgencyBin(urgency):
|
|
i = int(urgency) * NUMBER_OF_BINS / 100
|
|
if i >= NUMBER_OF_BINS:
|
|
return NUMBER_OF_BINS
|
|
return i + 1
|
|
|
|
|
|
class CodeRack(object):
|
|
def __init__(self):
|
|
#logging.debug('coderack.__init__()')
|
|
self.speedUpBonds = False
|
|
self.removeBreakerCodelets = False
|
|
self.removeTerracedScan = False
|
|
self.pressures = CoderackPressures()
|
|
self.pressures.initialisePressures()
|
|
self.reset()
|
|
self.initialCodeletNames = ('bottom-up-bond-scout',
|
|
'replacement-finder',
|
|
'bottom-up-correspondence-scout')
|
|
self.codeletMethodsDir = None
|
|
self.runCodelets = {}
|
|
self.postings = {}
|
|
|
|
def reset(self):
|
|
#logging.debug('coderack.reset()')
|
|
from temperature import temperature
|
|
|
|
self.codelets = []
|
|
self.codeletsRun = 0
|
|
temperature.clamped = True
|
|
self.pressures.reset()
|
|
|
|
def updateCodelets(self):
|
|
if self.codeletsRun > 0:
|
|
self.postTopDownCodelets()
|
|
self.postBottomUpCodelets()
|
|
|
|
def post(self, codelet):
|
|
self.postings[codelet.name] = self.postings.get(codelet.name, 0) + 1
|
|
self.pressures.addCodelet(codelet)
|
|
self.codelets += [codelet]
|
|
if len(self.codelets) > 100:
|
|
oldCodelet = self.chooseOldCodelet()
|
|
self.removeCodelet(oldCodelet)
|
|
|
|
def postTopDownCodelets(self):
|
|
for node in slipnet.slipnodes:
|
|
#logging.info('Trying slipnode: %s' % node.get_name())
|
|
if node.activation != 100.0:
|
|
continue
|
|
#logging.info('using slipnode: %s' % node.get_name())
|
|
for codeletName in node.codelets:
|
|
probability = workspaceFormulas.probabilityOfPosting(
|
|
codeletName)
|
|
howMany = workspaceFormulas.howManyToPost(codeletName)
|
|
for _ in range(0, howMany):
|
|
if random.random() >= probability:
|
|
continue
|
|
urgency = getUrgencyBin(
|
|
node.activation * node.conceptualDepth / 100.0)
|
|
codelet = Codelet(codeletName, urgency, self.codeletsRun)
|
|
codelet.arguments += [node]
|
|
logging.info('Post top down: %s, with urgency: %d',
|
|
codelet.name, urgency)
|
|
self.post(codelet)
|
|
|
|
def postBottomUpCodelets(self):
|
|
logging.info("posting bottom up codelets")
|
|
self.__postBottomUpCodelets('bottom-up-description-scout')
|
|
self.__postBottomUpCodelets('bottom-up-bond-scout')
|
|
self.__postBottomUpCodelets('group-scout--whole-string')
|
|
self.__postBottomUpCodelets('bottom-up-correspondence-scout')
|
|
self.__postBottomUpCodelets('important-object-correspondence-scout')
|
|
self.__postBottomUpCodelets('replacement-finder')
|
|
self.__postBottomUpCodelets('rule-scout')
|
|
self.__postBottomUpCodelets('rule-translator')
|
|
if not self.removeBreakerCodelets:
|
|
self.__postBottomUpCodelets('breaker')
|
|
|
|
def __postBottomUpCodelets(self, codeletName):
|
|
probability = workspaceFormulas.probabilityOfPosting(codeletName)
|
|
howMany = workspaceFormulas.howManyToPost(codeletName)
|
|
#if codeletName == 'bottom-up-bond-scout':
|
|
# print 'post --> %f:%d' % (probability,howMany)
|
|
if self.speedUpBonds:
|
|
if 'bond' in codeletName or 'group' in codeletName:
|
|
howMany *= 3
|
|
urgency = 3
|
|
if codeletName == 'breaker':
|
|
urgency = 1
|
|
if formulas.Temperature < 25.0 and 'translator' in codeletName:
|
|
urgency = 5
|
|
for _ in range(0, howMany):
|
|
if random.random() < probability:
|
|
codelet = Codelet(codeletName, urgency, self.codeletsRun)
|
|
self.post(codelet)
|
|
|
|
def removeCodelet(self, codelet):
|
|
self.codelets.remove(codelet)
|
|
self.pressures.removeCodelet(codelet)
|
|
|
|
def newCodelet(self, name, oldCodelet, strength, arguments=None):
|
|
#logging.debug('Posting new codelet called %s' % name)
|
|
urgency = getUrgencyBin(strength)
|
|
newCodelet = Codelet(name, urgency, self.codeletsRun)
|
|
if arguments:
|
|
newCodelet.arguments = [arguments]
|
|
else:
|
|
newCodelet.arguments = oldCodelet.arguments
|
|
newCodelet.pressure = oldCodelet.pressure
|
|
self.tryRun(newCodelet)
|
|
|
|
# pylint: disable=too-many-arguments
|
|
def proposeRule(self, facet, description, category, relation, oldCodelet):
|
|
"""Creates a proposed rule, and posts a rule-strength-tester codelet.
|
|
|
|
The new codelet has urgency a function of
|
|
the degree of conceptual-depth of the descriptions in the rule
|
|
"""
|
|
from rule import Rule
|
|
|
|
rule = Rule(facet, description, category, relation)
|
|
rule.updateStrength()
|
|
if description and relation:
|
|
depths = description.conceptualDepth + relation.conceptualDepth
|
|
depths /= 200.0
|
|
urgency = math.sqrt(depths) * 100.0
|
|
else:
|
|
urgency = 0
|
|
self.newCodelet('rule-strength-tester', oldCodelet, urgency, rule)
|
|
|
|
def proposeCorrespondence(self, initialObject, targetObject,
|
|
conceptMappings, flipTargetObject, oldCodelet):
|
|
from correspondence import Correspondence
|
|
|
|
correspondence = Correspondence(initialObject, targetObject,
|
|
conceptMappings, flipTargetObject)
|
|
for mapping in conceptMappings:
|
|
mapping.initialDescriptionType.buffer = 100.0
|
|
mapping.initialDescriptor.buffer = 100.0
|
|
mapping.targetDescriptionType.buffer = 100.0
|
|
mapping.targetDescriptor.buffer = 100.0
|
|
mappings = correspondence.distinguishingConceptMappings()
|
|
urgency = sum(mapping.strength() for mapping in mappings)
|
|
numberOfMappings = len(mappings)
|
|
if urgency:
|
|
urgency /= numberOfMappings
|
|
binn = getUrgencyBin(urgency)
|
|
logging.info('urgency: %s, number: %d, bin: %d',
|
|
urgency, numberOfMappings, binn)
|
|
self.newCodelet('correspondence-strength-tester',
|
|
oldCodelet, urgency, correspondence)
|
|
|
|
def proposeDescription(self, objekt, type_, descriptor, oldCodelet):
|
|
from description import Description
|
|
|
|
description = Description(objekt, type_, descriptor)
|
|
descriptor.buffer = 100.0
|
|
urgency = type_.activation
|
|
self.newCodelet('description-strength-tester',
|
|
oldCodelet, urgency, description)
|
|
|
|
def proposeSingleLetterGroup(self, source, codelet):
|
|
self.proposeGroup([source], [], slipnet.samenessGroup, None,
|
|
slipnet.letterCategory, codelet)
|
|
|
|
def proposeGroup(self, objects, bondList, groupCategory, directionCategory,
|
|
bondFacet, oldCodelet):
|
|
from group import Group
|
|
|
|
bondCategory = groupCategory.getRelatedNode(slipnet.bondCategory)
|
|
bondCategory.buffer = 100.0
|
|
if directionCategory:
|
|
directionCategory.buffer = 100.0
|
|
group = Group(objects[0].string, groupCategory, directionCategory,
|
|
bondFacet, objects, bondList)
|
|
urgency = bondCategory.bondDegreeOfAssociation()
|
|
self.newCodelet('group-strength-tester', oldCodelet, urgency, group)
|
|
|
|
def proposeBond(self, source, destination, bondCategory, bondFacet,
|
|
sourceDescriptor, destinationDescriptor, oldCodelet):
|
|
from bond import Bond
|
|
|
|
bondFacet.buffer = 100.0
|
|
sourceDescriptor.buffer = 100.0
|
|
destinationDescriptor.buffer = 100.0
|
|
bond = Bond(source, destination, bondCategory, bondFacet,
|
|
sourceDescriptor, destinationDescriptor)
|
|
urgency = bondCategory.bondDegreeOfAssociation()
|
|
self.newCodelet('bond-strength-tester', oldCodelet, urgency, bond)
|
|
|
|
def chooseOldCodelet(self):
|
|
# selects an old codelet to remove from the coderack
|
|
# more likely to select lower urgency codelets
|
|
if not len(self.codelets):
|
|
return None
|
|
urgencies = []
|
|
for codelet in self.codelets:
|
|
urgency = ((coderack.codeletsRun - codelet.timeStamp) *
|
|
(7.5 - codelet.urgency))
|
|
urgencies += [urgency]
|
|
threshold = random.random() * sum(urgencies)
|
|
sumOfUrgencies = 0.0
|
|
for i in range(0, len(self.codelets)):
|
|
sumOfUrgencies += urgencies[i]
|
|
if sumOfUrgencies > threshold:
|
|
return self.codelets[i]
|
|
return self.codelets[0]
|
|
|
|
def postInitialCodelets(self):
|
|
for name in self.initialCodeletNames:
|
|
for _ in range(0, workspaceFormulas.numberOfObjects()):
|
|
codelet = Codelet(name, 1, self.codeletsRun)
|
|
self.post(codelet)
|
|
codelet2 = Codelet(name, 1, self.codeletsRun)
|
|
self.post(codelet2)
|
|
|
|
def tryRun(self, newCodelet):
|
|
if self.removeTerracedScan:
|
|
self.run(newCodelet)
|
|
else:
|
|
self.post(newCodelet)
|
|
|
|
def getCodeletmethods(self):
|
|
import codeletMethods
|
|
|
|
self.codeletMethodsDir = dir(codeletMethods)
|
|
knownCodeletNames = (
|
|
'breaker',
|
|
'bottom-up-description-scout',
|
|
'top-down-description-scout',
|
|
'description-strength-tester',
|
|
'description-builder',
|
|
'bottom-up-bond-scout',
|
|
'top-down-bond-scout--category',
|
|
'top-down-bond-scout--direction',
|
|
'bond-strength-tester',
|
|
'bond-builder',
|
|
'top-down-group-scout--category',
|
|
'top-down-group-scout--direction',
|
|
'group-scout--whole-string',
|
|
'group-strength-tester',
|
|
'group-builder',
|
|
'replacement-finder',
|
|
'rule-scout',
|
|
'rule-strength-tester',
|
|
'rule-builder',
|
|
'rule-translator',
|
|
'bottom-up-correspondence-scout',
|
|
'important-object-correspondence-scout',
|
|
'correspondence-strength-tester',
|
|
'correspondence-builder',)
|
|
self.methods = {}
|
|
for codeletName in knownCodeletNames:
|
|
methodName = re.sub('[ -]', '_', codeletName)
|
|
if methodName not in self.codeletMethodsDir:
|
|
raise NotImplementedError(
|
|
'Cannot find %s in codeletMethods' % methodName)
|
|
method = getattr(codeletMethods, methodName)
|
|
self.methods[methodName] = method
|
|
|
|
def chooseAndRunCodelet(self):
|
|
if not len(coderack.codelets):
|
|
coderack.postInitialCodelets()
|
|
codelet = self.chooseCodeletToRun()
|
|
if codelet:
|
|
self.run(codelet)
|
|
|
|
def chooseCodeletToRun(self):
|
|
if not self.codelets:
|
|
return None
|
|
|
|
#logging.info('temperature: %f', formulas.Temperature)
|
|
#logging.info('actualTemperature: %f', formulas.actualTemperature)
|
|
#logging.info('Slipnet:')
|
|
#for node in slipnet.slipnodes:
|
|
# logging.info("\tnode %s, activation: %d, buffer: %d, depth: %s",
|
|
# node.get_name(), node.activation, node.buffer,
|
|
# node.conceptualDepth)
|
|
#logging.info('Coderack:')
|
|
#for codelet in self.codelets:
|
|
# logging.info('\t%s, %d', codelet.name, codelet.urgency)
|
|
|
|
#from workspace import workspace
|
|
#workspace.initial.log("Initial: ")
|
|
#workspace.target.log("Target: ")
|
|
|
|
scale = (100.0 - formulas.Temperature + 10.0) / 15.0
|
|
urgsum = sum(codelet.urgency ** scale for codelet in self.codelets)
|
|
threshold = random.random() * urgsum
|
|
chosen = self.codelets[0]
|
|
urgencySum = 0.0
|
|
|
|
for codelet in self.codelets:
|
|
urgencySum += codelet.urgency ** scale
|
|
if urgencySum > threshold:
|
|
chosen = codelet
|
|
break
|
|
self.removeCodelet(chosen)
|
|
logging.info('chosen codelet\n\t%s, urgency = %s',
|
|
chosen.name, chosen.urgency)
|
|
return chosen
|
|
|
|
def run(self, codelet):
|
|
methodName = re.sub('[ -]', '_', codelet.name)
|
|
self.codeletsRun += 1
|
|
self.runCodelets[methodName] = self.runCodelets.get(methodName, 0) + 1
|
|
|
|
#if self.codeletsRun > 2000:
|
|
#import sys
|
|
#print "running too many codelets"
|
|
#for name,count in self.postings.iteritems():
|
|
#print '%d:%s' % (count,name)
|
|
#raise ValueError
|
|
#else:
|
|
# print 'running %d' % self.codeletsRun
|
|
if not self.codeletMethodsDir:
|
|
self.getCodeletmethods()
|
|
#if not self.codeletMethodsDir:
|
|
method = self.methods[methodName]
|
|
if not method:
|
|
raise ValueError('Found %s in codeletMethods, but cannot get it',
|
|
methodName)
|
|
if not callable(method):
|
|
raise RuntimeError('Cannot call %s()' % methodName)
|
|
args, _varargs, _varkw, _defaults = inspect.getargspec(method)
|
|
#global codeletsUsed
|
|
#codeletsUsed[methodName] = codeletsUsed.get(methodName,0) + 1
|
|
try:
|
|
if 'codelet' in args:
|
|
method(codelet)
|
|
else:
|
|
method()
|
|
except AssertionError:
|
|
pass
|
|
|
|
coderack = CodeRack()
|