chris@163: /**
chris@163:  * Copyright (c) 2014, 2015, Enzien Audio Ltd.
chris@163:  *
chris@163:  * Permission to use, copy, modify, and/or distribute this software for any
chris@163:  * purpose with or without fee is hereby granted, provided that the above
chris@163:  * copyright notice and this permission notice appear in all copies.
chris@163:  *
chris@163:  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
chris@163:  * REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
chris@163:  * AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
chris@163:  * INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
chris@163:  * LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
chris@163:  * OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
chris@163:  * PERFORMANCE OF THIS SOFTWARE.
chris@163:  */
chris@163: 
chris@163: #include "ControlDelay.h"
chris@163: 
chris@163: hv_size_t cDelay_init(HvBase *_c, ControlDelay *o, float delayMs) {
chris@163:   o->delay = ctx_millisecondsToSamples(_c, delayMs);
chris@163:   hv_memset(o->msgs, __HV_DELAY_MAX_MESSAGES*sizeof(HvMessage *));
chris@163:   return 0;
chris@163: }
chris@163: 
chris@163: void cDelay_onMessage(HvBase *_c, ControlDelay *o, int letIn, const HvMessage *const m,
chris@163:     void (*sendMessage)(HvBase *, int, const HvMessage *const)) {
chris@163:   switch (letIn) {
chris@163:     case 0: {
chris@163:       if (msg_compareSymbol(m, 0, "flush")) {
chris@163:         // send all messages immediately
chris@163:         for (int i = 0; i < __HV_DELAY_MAX_MESSAGES; i++) {
chris@163:           HvMessage *n = o->msgs[i];
chris@163:           if (n != NULL) {
chris@163:             msg_setTimestamp(n, msg_getTimestamp(m)); // update the timestamp to now
chris@163:             sendMessage(_c, 0, n); // send the message
chris@163:             ctx_cancelMessage(_c, n, sendMessage); // then clear it
chris@163:             // NOTE(mhroth): there may be a problem here if a flushed message causes a clear message to return
chris@163:             // to this object in the same step
chris@163:           }
chris@163:         }
chris@163:         hv_memset(o->msgs, __HV_DELAY_MAX_MESSAGES*sizeof(HvMessage *));
chris@163:       } else if (msg_compareSymbol(m, 0, "clear")) {
chris@163:         // cancel (clear) all (pending) messages
chris@163:         for (int i = 0; i < __HV_DELAY_MAX_MESSAGES; i++) {
chris@163:           HvMessage *n = o->msgs[i];
chris@163:           if (n != NULL) {
chris@163:             ctx_cancelMessage(_c, n, sendMessage);
chris@163:           }
chris@163:         }
chris@163:         hv_memset(o->msgs, __HV_DELAY_MAX_MESSAGES*sizeof(HvMessage *));
chris@163:       } else {
chris@163:         hv_uint32_t ts = msg_getTimestamp(m);
chris@163:         msg_setTimestamp((HvMessage *) m, ts+o->delay); // update the timestamp to set the delay
chris@163:         int i;
chris@163:         for (i = 0; i < __HV_DELAY_MAX_MESSAGES; i++) {
chris@163:           if (o->msgs[i] == NULL) {
chris@163:             o->msgs[i] = ctx_scheduleMessage(_c, m, sendMessage, 0);
chris@163:             break;
chris@163:           }
chris@163:         }
chris@163:         hv_assert(i < __HV_DELAY_MAX_MESSAGES); // scheduled message limit reached
chris@163:         msg_setTimestamp((HvMessage *) m, ts); // return to the original timestamp
chris@163:       }
chris@163:       break;
chris@163:     }
chris@163:     case 1: {
chris@163:       if (msg_isFloat(m,0)) {
chris@163:         // set delay in milliseconds
chris@163:         o->delay = ctx_millisecondsToSamples(_c,msg_getFloat(m,0));
chris@163:       }
chris@163:       break;
chris@163:     }
chris@163:     case 2: {
chris@163:       if (msg_isFloat(m,0)) {
chris@163:         // set delay in samples
chris@163:         o->delay = (hv_uint32_t) msg_getFloat(m,0);
chris@163:       }
chris@163:       break;
chris@163:     }
chris@163:     default: break;
chris@163:   }
chris@163: }
chris@163: 
chris@163: void cDelay_clearExecutingMessage(ControlDelay *o, const HvMessage *const m) {
chris@163:   for (int i = 0; i < __HV_DELAY_MAX_MESSAGES; ++i) {
chris@163:     if (o->msgs[i] == m) {
chris@163:       o->msgs[i] = NULL;
chris@163:       break;
chris@163:     }
chris@163:   }
chris@163: }