light9 Changeset - dc474426845d

Changeset - dc474426845d

Parent rev.

Child rev.

[Not reviewed]

default

0 3 0

Drew Perttula - 11 years ago 2014-06-03 07:11:12
drewp@bigasterisk.com

effecteval better logging. everyone put their curve files in the right place.
Ignore-this: 7cb0ea890a0602783eb581459f28b72d

3 files changed with 32 insertions and 18 deletions:

bin/effecteval

light9/curvecalc/curve.py

light9/effecteval/effect.py

0 comments (0 inline, 0 general)

bin/effecteval

➞

Show inline comments

@@ @@ -30,32 +30,34 @@ class EffectEdit(PrettyErrorHandler, cyc @@
             (song, L9['effect'], uri, ctx),
             ]))
 class SongEffects(PrettyErrorHandler, cyclone.web.RequestHandler):
     def post(self):
         song = URIRef(self.get_argument('uri'))
-        drop = URIRef(self.get_argument('drop'))
+        dropped = URIRef(self.get_argument('drop'))
         ctx = song
         graph = self.settings.graph
         effect = graph.sequentialUri(song + "/effect/e-")
         curve = graph.sequentialUri(song + "/curve/c-")
         effect = graph.sequentialUri(song + "/effect-")
         curve = graph.sequentialUri(song + "/curve-")
         with graph.currentState(
                 tripleFilter=(drop, RDFS.label, None)) as g:
             dropSubLabel = g.label(drop)
                 tripleFilter=(dropped, RDFS.label, None)) as g:
             droppedSubLabel = g.label(dropped)
         graph.patch(Patch(addQuads=[
             (song, L9['curve'], curve, ctx),
             (song, L9['effect'], effect, ctx),
             (effect, RDF.type, L9['Effect'], ctx),
             (effect, L9['code'],
-             Literal('out = sub(%s, intensity=%s)' % (drop.n3(), curve.n3())),
+             Literal('out = sub(%s, intensity=%s)' % (dropped.n3(), curve.n3())),
              ctx),
             (curve, RDF.type, L9['Curve'], ctx),
             (curve, RDFS.label, Literal('sub %s' % dropSubLabel), ctx),
             (curve, L9['points'], Literal('0 0'), ctx),
             (curve, RDFS.label, Literal('sub %s' % droppedSubLabel), ctx),
             ]))
         graph.patch(Patch(addQuads=[
             (curve, L9['points'], Literal('0 0'), Curve(uri=curve).curvePointsContext()),
             ]))
 class SongEffectsUpdates(cyclone.websocket.WebSocketHandler):
     def connectionMade(self, *args, **kwargs):
         self.graph = self.settings.graph
         self.graph.addHandler(self.updateClient)
@@ @@ -124,12 +126,14 @@ class EffectLoop(object): @@
     """maintains a collection of the current EffectNodes, gets time from
     music player, sends dmx"""
     def __init__(self, graph, stats):
         self.graph, self.stats = graph, stats
         self.currentSong = None
         self.currentEffects = []
         self.lastLogTime = 0
         self.lastLogMsg = ""
         self.graph.addHandler(self.setEffects)
         self.period = 1 / 30
         self.coastSecs = .3 # main reason to keep this low is to notice play/pause
         self.songTimeFromRequest = 0
         self.requestTime = 0 # unix sec for when we fetched songTime
@@ @@ -178,29 +182,43 @@ class EffectLoop(object): @@
                 outSubs = []
                 for e in self.currentEffects:
                     outSubs.append(e.eval(songTime))
                 out = Submaster.sub_maxes(*outSubs)
                 self.logLevels(t1, out)
                 dmx = out.get_dmx_list()
                 if log.isEnabledFor(logging.DEBUG):
                     log.debug("send dmx: %r", out.get_levels())
                 with self.stats.writeDmx.time():
                     yield dmxclient.outputlevels(dmx, twisted=True)
                 elapsed = time.time() - t1
                 dt = max(0, self.period - elapsed)
         except Exception:
             self.stats.errors += 1
             traceback.print_exc()
             dt = 1
         reactor.callLater(dt, self.sendLevels)
     def logLevels(self, now, out):
         # this would look nice on the top of the effecteval web pages too
         if log.isEnabledFor(logging.DEBUG):
             log.debug(self.logMessage(out))
         else:
             if now > self.lastLogTime + 5:
                 msg = self.logMessage(out)
                 if msg != self.lastLogMsg:
                     log.info(msg)
                     self.lastLogMsg = msg
                 self.lastLogTime = now
     def logMessage(self, out):
         return ("send dmx: {%s}" %
                 ", ".join("%r: %.3g" % (str(k), v)
                           for k,v in out.get_levels().items()))
 class App(object):
     def __init__(self, show):
         self.show = show
         self.graph = SyncedGraph("effectEval")
         self.graph.initiallySynced.addCallback(self.launch)

light9/curvecalc/curve.py

➞

Show inline comments

@@ @@ -328,13 +328,13 @@ class Curveset(object): @@
             return
         if not renameIfExisting and name in self.curves:
             return
         while name in self.curves:
            name=name+"-1"
-        uri = self.graph.sequentialUri(self.currentSong + '/curve/c-')
         uri = self.graph.sequentialUri(self.currentSong + '/curve-')
         c = Curve(uri)
         s, e = self.get_time_range()
         c.points.extend([(s, 0), (e, 0)])
         ctx = self.currentSong
         self.graph.patch(Patch(addQuads=[
             (self.currentSong, L9['curve'], uri, ctx),

light9/effecteval/effect.py

➞

Show inline comments

@@ @@ -32,16 +32,12 @@ class EffectNode(object): @@
         subs = Submaster.get_global_submasters(self.graph)
         self.sub = subs.get_sub_by_uri(subUri)
         intensityCurve = uriFromCode(m.group(2))
         self.curve = Curve(uri=intensityCurve)
         # read from disk ok? how do we know to reread? start with
         # mtime. the mtime check could be done occasionally so on
         # average we read at most one curve's mtime per effectLoop.
         pts = self.graph.value(intensityCurve, L9['points'])
         if pts is None:
             log.info("curve %r has no points" % intensityCurve)
         else:
             self.curve.set_from_string(pts)

0 comments (0 inline, 0 general)