Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
branch: master
Fetching contributors…

Octocat-spinner-32-eaf2f5

Cannot retrieve contributors at this time

file 114 lines (101 sloc) 3.539 kb
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113
/*
* Copyright 2009,2010,2011 Reality Jockey, Ltd.
* info@rjdj.me
* http://rjdj.me/
*
* This file is part of ZenGarden.
*
* ZenGarden is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* ZenGarden is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with ZenGarden. If not, see <http://www.gnu.org/licenses/>.
*
*/

#include "MessageMetro.h"
#include "PdGraph.h"

MessageObject *MessageMetro::newObject(PdMessage *initMessage, PdGraph *graph) {
  return new MessageMetro(initMessage, graph);
}

MessageMetro::MessageMetro(PdMessage *initMessage, PdGraph *graph) : MessageObject(2, 1, graph) {
  // default to interval of one second
  intervalInMs = initMessage->isFloat(0) ? (double) initMessage->getFloat(0) : 1000.0;
  pendingMessage = NULL;
}

MessageMetro::~MessageMetro() {
  // nothign to do. pendingMessage object is owned by context.
}

const char *MessageMetro::getObjectLabel() {
  return "metro";
}

string MessageMetro::toString() {
  char str[snprintf(NULL, 0, "%s %g", getObjectLabel(), intervalInMs)+1];
  snprintf(str, sizeof(str), "%s %g", getObjectLabel(), intervalInMs);
  return string(str);
}

void MessageMetro::processMessage(int inletIndex, PdMessage *message) {
  switch (inletIndex) {
    case 0: {
      switch (message->getType(0)) {
        case FLOAT: {
          // any non-zero float may start the metro
          (message->getFloat(0) == 0.0f) ? stopMetro() : startMetro(message->getTimestamp());
          break;
        }
        case SYMBOL: {
          if (message->isSymbol(0, "stop")) {
            stopMetro();
          }
          break;
        }
        case BANG: {
          startMetro(message->getTimestamp());
          break;
        }
        default: {
          break;
        }
      }
      break;
    }
    case 1: {
      if (message->isFloat(0)) {
        intervalInMs = (double) message->getFloat(0);
      }
      break;
    }
    default: {
      break;
    }
  }
}

void MessageMetro::sendMessage(int outletIndex, PdMessage *message) {
  // schedule the pending message before the current one is sent so that if a stop message
  // arrives at this object while in this function, then the next message can be cancelled
  pendingMessage = PD_MESSAGE_ON_STACK(1);
  pendingMessage->initWithTimestampAndBang(message->getTimestamp() + intervalInMs);
  pendingMessage = graph->scheduleMessage(this, 0, pendingMessage);
  
  MessageObject::sendMessage(outletIndex, message);
}

void MessageMetro::startMetro(double timestamp) {
  // Ensure that there is no pending message for this metro. If there is, then cancel it.
  // This allows a metro to be banged multiple times and always restart the timing from the most
  // recently received bang.
  stopMetro();
  
  PdMessage *outgoingMessage = PD_MESSAGE_ON_STACK(1);
  outgoingMessage->initWithTimestampAndBang(timestamp);
  sendMessage(0, outgoingMessage);
}

void MessageMetro::stopMetro() {
  if (pendingMessage != NULL) {
    graph->cancelMessage(this, 0, pendingMessage);
    pendingMessage = NULL;
  }
}
Something went wrong with that request. Please try again.