/*
    signalflowgrap.cpp:

    Copyright (C) 2016 by Michael Gogins

    This file is part of Csound.

    The Csound Library 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 2.1 of the License, or (at your option) any later version.

    Csound 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 Csound; if not, write to the Free Software
    Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
    02110-1301 USA
*/

/**
 * T H E   S I G N A L   F L O W   G R A P H   O P C O D E S
 *
 * Michael Gogins
 *
 * These opcodes enable the use of signal flow graphs
 * (AKA asynchronous data flow graphs) in Csound orchestras.
 * Signals flow from the outlets of source instruments
 * and are summed in the inlets of sink instruments.
 * Signals may be k-rate, a-rate, or f-rate.
 * Any number of outlets may be connected to any number of inlets.
 * When a new instance of an instrument is instantiated during performance,
 * the declared connections also are automatically instantiated.
 *
 * Signal flow graphs simplify the construction of complex mixers,
 * signal processing chains, and the like. They also simplify the re-use
 * of "plug and play" instrument definitions and even entire sub-orchestras,
 * which can simply be #included and then "plugged in" to existing orchestras.
 *
 * Note that inlets and outlets are defined in instruments without reference
 * to how they are connected. Connections are defined in the orchestra header.
 * It is this separation that enables plug-in instruments.
 *
 * Inlets must be named. Instruments may be named or numbered, but in
 * either case each source instrument must be defined
 * in the orchestra before any of its sinks. Naming instruments makes
 * it easier to connect outlets and inlets in any higher-level orchestra
 * to inlets and outlets in any lower-level #included orchestra.
 *
 * O P C O D E S
 *
 * outleta Sname, asignal
 * outletk Sname, ksignal
 * outletf Sname, fsignal
 * outletv Sname, xsignal[]
 *
 * Outlets send a, k, or f-rate signals out from an instrument.
 * A- and k-rate signals may be arrays.
 *
 * The name of the outlet is implicitly qualified by the instrument name
 * or number,`so it is valid to use the same outlet name in more than one
 * instrument (but not to use the same outlet name twice in one instrument).
 *
 * asignal   inleta Sname
 * ksignal   inletk Sname
 * fsignal   inletf Sname
 * xsignal[] inletv SName
 *
 * Inlets receive a, k, or f-rate signals from outlets in
 * other instruments. A- and k-rate signals may be arrays.
 *
 * Outlets are connected to inlets of the same type using the connect
 * opcode. If arrays are used, the inlets and outlets must be a-rate
 * and the same shape.
 *
 * The name of the inlet is implicitly qualified by the instrument name,
 * or number, so it is valid to use the same inlet name in more than one
 * instrument (but not to use the same inlet name twice in one instrument).
 *
 * connect Tsource1, Soutlet1, Tsink1, Sinlet1
 *
 * The connect opcode, valid only in orchestra headers, sends the signals
 * from the indicated outlet in all instances of the indicated source
 * instrument to the indicated inlet in all instances of the indicated sink
 * instrument. Each inlet instance receives the sum of the signals in all
 * outlet instances. Thus multiple instances of an outlet may fan in to one
 * instance of an inlet, or one instance of an outlet may fan out to
 * multiple instances of an inlet.
 *
 * alwayson Tinstrument [p4, ..., pn]
 *
 * Activates the indicated instrument in the orchestra header,
 * without need for an i statement. Instruments must be
 * activated in the same order as they are defined.
 *
 * The alwayson opcode is designed to simplify
 * the definition of re-usable orchestras with
 * signal processing or effects chains and networks.
 *
 * When the instrument is activated, p1 is the insno, p2 is 0, and p3 is -1.
 * Pfields from p4 on may optionally be sent to the instrument.
 *
 * ifno ftgenonce ip1, ip2dummy, isize, igen, iarga, iargb [, ...]
 *
 * Enables the creation of function tables entirely inside
 * instrument definitions, without any duplication of data.
 *
 * The ftgenonce opcode is designed to simplify writing instrument definitions
 * that can be re-used in different orchestras simply by #including them
 * and plugging them into some output instrument. There is no need to define
 * function tables either in the score, or in the orchestra header.
 *
 * The ftgenonce opcode is similar to ftgentmp, and has identical arguments.
 * However, function tables are neither duplicated nor deleted. Instead,
 * all of the arguments to the opcode are concatenated to form the key to a
 * dictionary that points to the function table number. Thus, every request
 * to ftgenonce with the same arguments receives the same instance of the
 * function table data. Every change in the value of any ftgenonce argument
 * causes the creation of a new function table.
 */

#include <algorithm>
#include <cmath>
#include <cstdio>
#include <cstring>
#include <functional>
#include <iostream>
#include <map>
#include <string>
#include <vector>
#include "OpcodeBase.hpp"
#include "sysdep.h"
#include "text.h"
#include <pstream.h>

#define SIGNALFLOWGRAPH_DEBUG 0

namespace csound {

struct SignalFlowGraph;
struct Outleta;
struct Outletk;
struct Outletf;
struct Outletkid;
struct Outletv;
struct Inleta;
struct Inletk;
struct Inletf;
struct Inletkid;
struct Inletv;
struct Connect;
struct AlwaysOn;
struct FtGenOnce;

static int (*isstrcod)(MYFLT) = nullptr;

std::ostream &operator<<(std::ostream &stream, const EVTBLK &a) {
  stream << a.opcod;
  for (int i = 0; i < a.pcnt; i++) {
    stream << " " << a.p[i];
  }
  return stream;
}

// Stupid hash from http://www.cse.yorku.ca/~oz/hash.html.
unsigned long djb2_hash(unsigned char *str) {
  unsigned long hash = 5381;
  int c;
  while ((c = *str++))
    hash = ((hash << 5) + hash) + c; /* hash * 33 + c */
  return hash;
}


/**
 * A wrapper to get proper C++ value
 * semantics for a map key.
 */
struct EventBlock {
  EVTBLK evtblk;
  unsigned long strarg_djb2_hash;
};


bool operator<(const EventBlock &a, const EventBlock &b) {
  // If the number of p-fields differ, compare and exit.
  if (a.evtblk.pcnt != b.evtblk.pcnt) {
    return a.evtblk.pcnt < b.evtblk.pcnt;
  }
  int n = a.evtblk.pcnt;
  for (int i = 0; i < n+1; ++i) {
    // Return if one's a string and the other isn't.
    if (isstrcod(a.evtblk.p[i]) != isstrcod(b.evtblk.p[i])) {
       return isstrcod(a.evtblk.p[i]) < isstrcod(b.evtblk.p[i]);
    }
    // If both are strings..
    if (isstrcod(a.evtblk.p[i])) {
      // ..return if the hashes are unequal.
      if (a.strarg_djb2_hash != b.strarg_djb2_hash) return a.strarg_djb2_hash < b.strarg_djb2_hash;
    } else {
      // If both are numbers, return if the values are unequal.
      if (a.evtblk.p[i] != b.evtblk.p[i]) return a.evtblk.p[i] < b.evtblk.p[i];
    }
  }
  return false;
}

// Identifiers are always "sourcename:outletname" and "sinkname:inletname",
// or "sourcename:idname:outletname" and "sinkname:inletname."

struct SignalFlowGraphState {
  CSOUND *csound;
  void *signal_flow_ports_lock;
  void *signal_flow_ftables_lock;
  std::map<std::string, std::vector<Outleta *>> aoutletsForSourceOutletIds;
  std::map<std::string, std::vector<Outletk *>> koutletsForSourceOutletIds;
  std::map<std::string, std::vector<Outletf *>> foutletsForSourceOutletIds;
  std::map<std::string, std::vector<Outletv *>> voutletsForSourceOutletIds;
  std::map<std::string, std::vector<Outletkid *>> kidoutletsForSourceOutletIds;
  std::map<std::string, std::vector<Inleta *>> ainletsForSinkInletIds;
  std::map<std::string, std::vector<Inletk *>> kinletsForSinkInletIds;
  std::map<std::string, std::vector<Inletf *>> finletsForSinkInletIds;
  std::map<std::string, std::vector<Inletv *>> vinletsForSinkInletIds;
  std::map<std::string, std::vector<Inletkid *>> kidinletsForSinkInletIds;
  std::map<std::string, std::vector<std::string>> connections;
  std::map<EventBlock, int> functionTablesForEvtblks;
  std::vector<std::vector<std::vector<Outleta *> *> *> aoutletVectors;
  std::vector<std::vector<std::vector<Outletk *> *> *> koutletVectors;
  std::vector<std::vector<std::vector<Outletf *> *> *> foutletVectors;
  std::vector<std::vector<std::vector<Outletv *> *> *> voutletVectors;
  std::vector<std::vector<std::vector<Outletkid *> *> *> kidoutletVectors;
  SignalFlowGraphState(CSOUND *csound_) {
    csound = csound_;
    signal_flow_ports_lock = csound->Create_Mutex(0);
    signal_flow_ftables_lock = csound->Create_Mutex(0);
  }
  ~SignalFlowGraphState() {}
  void clear() {
    LockGuard guard(csound, signal_flow_ports_lock);

    for (std::vector<std::vector<std::vector<Outleta *> *> *>::iterator it = aoutletVectors.begin(), end = aoutletVectors.end(); it != end; it++)
      delete *it;
    for (std::vector<std::vector<std::vector<Outletk *> *> *>::iterator it = koutletVectors.begin(), end = koutletVectors.end(); it != end; it++)
      delete *it;
    for (std::vector<std::vector<std::vector<Outletf *> *> *>::iterator it = foutletVectors.begin(), end = foutletVectors.end(); it != end; it++)
      delete *it;
    for (std::vector<std::vector<std::vector<Outletv *> *> *>::iterator it = voutletVectors.begin(), end = voutletVectors.end(); it != end; it++)
      delete *it;
    for (std::vector<std::vector<std::vector<Outletkid *> *> *>::iterator it = kidoutletVectors.begin(), end = kidoutletVectors.end(); it != end; it++)
      delete *it;

    aoutletsForSourceOutletIds.clear();
    ainletsForSinkInletIds.clear();
    aoutletVectors.clear();
    koutletsForSourceOutletIds.clear();
    kinletsForSinkInletIds.clear();
    koutletVectors.clear();
    foutletsForSourceOutletIds.clear();
    voutletsForSourceOutletIds.clear();
    kidoutletsForSourceOutletIds.clear();
    vinletsForSinkInletIds.clear();
    kidinletsForSinkInletIds.clear();
    finletsForSinkInletIds.clear();
    foutletVectors.clear();
    voutletVectors.clear();
    kidoutletVectors.clear();
    connections.clear();
  }
};

// For true thread-safety, access to shared data must be protected.
// We will use one critical section for each logically independent
// potential data race here: ports and ftables.

struct Outleta : public OpcodeNoteoffBase<Outleta> {
  /**
   * Inputs.
   */
  STRINGDAT *Sname;
  MYFLT *asignal;
  /**
   * State.
   */
  char sourceOutletId[0x100];
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    // warn(csound, "BEGAN Outleta::init()...\n");
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    sourceOutletId[0] = 0;
    const char *insname =
        csound->GetInstrumentList(csound)[opds.insdshead->insno]->insname;
    if (insname) {
      std::sprintf(sourceOutletId, "%s:%s", insname, (char *)Sname->data);
    } else {
      std::sprintf(sourceOutletId, "%d:%s", opds.insdshead->insno,
                   (char *)Sname->data);
    }
    std::vector<Outleta *> &aoutlets =
        sfg_globals->aoutletsForSourceOutletIds[sourceOutletId];
    if (std::find(aoutlets.begin(), aoutlets.end(), this) == aoutlets.end()) {
      aoutlets.push_back(this);
      warn(csound, Str("Created instance 0x%x of %d instances of outlet %s\n"),
           this, aoutlets.size(), sourceOutletId);
    }
    // warn(csound, "ENDED Outleta::init()...\n");
    return OK;
  }
  int noteoff(CSOUND *csound) {
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    std::vector<Outleta *> &aoutlets =
        sfg_globals->aoutletsForSourceOutletIds[sourceOutletId];
    std::vector<Outleta *>::iterator thisoutlet =
        std::find(aoutlets.begin(), aoutlets.end(), this);
    aoutlets.erase(thisoutlet);
    warn(csound, Str("Removed instance 0x%x of %d instances of outleta %s\n"),
         this, aoutlets.size(), sourceOutletId);
    return OK;
  }
};

struct Inleta : public OpcodeBase<Inleta> {
  /**
   * Output.
   */
  MYFLT *asignal;
  /**
   * Inputs.
   */
  STRINGDAT *Sname;
  /**
   * State.
   */
  char sinkInletId[0x100];
  std::vector<std::vector<Outleta *> *> *sourceOutlets;
  int sampleN;
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    warn(csound, "BEGAN Inleta::init()...\n");
    sampleN = opds.insdshead->ksmps;
    warn(csound, "sourceOutlets: 0x%x\n", sourceOutlets);
    // think problem is here
    // should always create
    if (std::find(sfg_globals->aoutletVectors.begin(),
                  sfg_globals->aoutletVectors.end(),
                  sourceOutlets) == sfg_globals->aoutletVectors.end()) {
      sourceOutlets = new std::vector<std::vector<Outleta *> *>;
      sfg_globals->aoutletVectors.push_back(sourceOutlets);
    } else {
      sourceOutlets->clear();
    }
    warn(csound, "sourceOutlets: 0x%x\n", sourceOutlets);
    sinkInletId[0] = 0;
    const char *insname =
        csound->GetInstrumentList(csound)[opds.insdshead->insno]->insname;
    if (insname) {
      std::sprintf(sinkInletId, "%s:%s", insname, (char *)Sname->data);
    } else {
      std::sprintf(sinkInletId, "%d:%s", opds.insdshead->insno,
                   (char *)Sname->data);
    }
    std::vector<Inleta *> &ainlets =
        sfg_globals->ainletsForSinkInletIds[sinkInletId];
    if (std::find(ainlets.begin(), ainlets.end(), this) == ainlets.end()) {
      ainlets.push_back(this);
      warn(csound, Str("Created instance 0x%x of inlet %s\n"), this,
           sinkInletId);
    }
    // Find source outlets connecting to this.
    // Any number of sources may connect to any number of sinks.
    std::vector<std::string> &sourceOutletIds =
        sfg_globals->connections[sinkInletId];
    for (size_t i = 0, n = sourceOutletIds.size(); i < n; i++) {
      const std::string &sourceOutletId = sourceOutletIds[i];
      std::vector<Outleta *> &aoutlets =
          sfg_globals->aoutletsForSourceOutletIds[sourceOutletId];
      if (std::find(sourceOutlets->begin(), sourceOutlets->end(), &aoutlets) ==
          sourceOutlets->end()) {
        sourceOutlets->push_back(&aoutlets);
        warn(csound, Str("Connected instances of outlet %s to instance 0x%x of "
                         "inlet %s.\n"),
             sourceOutletId.c_str(), this, sinkInletId);
      }
    }
    warn(csound, "ENDED Inleta::init().\n");
    return OK;
  }
  /**
   * Sum arate values from active outlets feeding this inlet.
   */
  int audio(CSOUND *csound) {
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    // warn(csound, "BEGAN Inleta::audio()...\n");
    // Zero the inlet buffer.
    for (int sampleI = 0; sampleI < sampleN; sampleI++) {
      asignal[sampleI] = FL(0.0);
    }
    // Loop over the source connections...
    for (size_t sourceI = 0, sourceN = sourceOutlets->size(); sourceI < sourceN;
         sourceI++) {
      // Loop over the source connection instances...
      std::vector<Outleta *> *instances = sourceOutlets->at(sourceI);
      for (size_t instanceI = 0, instanceN = instances->size();
           instanceI < instanceN; instanceI++) {
        Outleta *sourceOutlet = instances->at(instanceI);
        // Skip inactive instances.
        if (sourceOutlet->opds.insdshead->actflg) {
          for (int sampleI = 0, sampleN = ksmps(); sampleI < sampleN;
               ++sampleI) {
            asignal[sampleI] += sourceOutlet->asignal[sampleI];
          }
        }
      }
    }
    // warn(csound, "ENDED Inleta::audio().\n");
    return OK;
  }
};

struct Outletk : public OpcodeNoteoffBase<Outletk> {
  /**
   * Inputs.
   */
  STRINGDAT *Sname;
  MYFLT *ksignal;
  /**
   * State.
   */
  char sourceOutletId[0x100];
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    const char *insname =
        csound->GetInstrumentList(csound)[opds.insdshead->insno]->insname;
    if (insname) {
      std::sprintf(sourceOutletId, "%s:%s", insname, (char *)Sname->data);
    } else {
      std::sprintf(sourceOutletId, "%d:%s", opds.insdshead->insno,
                   (char *)Sname->data);
    }
    std::vector<Outletk *> &koutlets =
        sfg_globals->koutletsForSourceOutletIds[sourceOutletId];
    if (std::find(koutlets.begin(), koutlets.end(), this) == koutlets.end()) {
      koutlets.push_back(this);
      warn(csound, Str("Created instance 0x%x of %d instances of outlet %s\n"),
           this, koutlets.size(), sourceOutletId);
    }
    return OK;
  }
  int noteoff(CSOUND *csound) {
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    std::vector<Outletk *> &koutlets =
        sfg_globals->koutletsForSourceOutletIds[sourceOutletId];
    std::vector<Outletk *>::iterator thisoutlet =
        std::find(koutlets.begin(), koutlets.end(), this);
    koutlets.erase(thisoutlet);
    warn(csound, Str("Removed 0x%x of %d instances of outletk %s\n"), this,
         koutlets.size(), sourceOutletId);
    return OK;
  }
};

struct Inletk : public OpcodeBase<Inletk> {
  /**
   * Output.
   */
  MYFLT *ksignal;
  /**
   * Inputs.
   */
  STRINGDAT *Sname;
  /**
   * State.
   */
  char sinkInletId[0x100];
  std::vector<std::vector<Outletk *> *> *sourceOutlets;
  int ksmps;
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    ksmps = opds.insdshead->ksmps;
    if (std::find(sfg_globals->koutletVectors.begin(),
                  sfg_globals->koutletVectors.end(),
                  sourceOutlets) == sfg_globals->koutletVectors.end()) {
      sourceOutlets = new std::vector<std::vector<Outletk *> *>;
      sfg_globals->koutletVectors.push_back(sourceOutlets);
    } else {
      sourceOutlets->clear();
    }
    sinkInletId[0] = 0;
    const char *insname =
        csound->GetInstrumentList(csound)[opds.insdshead->insno]->insname;
    if (insname) {
      std::sprintf(sinkInletId, "%s:%s", insname, (char *)Sname->data);
    } else {
      std::sprintf(sinkInletId, "%d:%s", opds.insdshead->insno,
                   (char *)Sname->data);
    }
    std::vector<Inletk *> &kinlets =
        sfg_globals->kinletsForSinkInletIds[sinkInletId];
    if (std::find(kinlets.begin(), kinlets.end(), this) == kinlets.end()) {
      kinlets.push_back(this);
      warn(csound, Str("Created instance 0x%x of inlet %s\n"), this,
           sinkInletId);
    }
    // Find source outlets connecting to this.
    // Any number of sources may connect to any number of sinks.
    std::vector<std::string> &sourceOutletIds =
        sfg_globals->connections[sinkInletId];
    for (size_t i = 0, n = sourceOutletIds.size(); i < n; i++) {
      const std::string &sourceOutletId = sourceOutletIds[i];
      std::vector<Outletk *> &koutlets =
          sfg_globals->koutletsForSourceOutletIds[sourceOutletId];
      if (std::find(sourceOutlets->begin(), sourceOutlets->end(), &koutlets) ==
          sourceOutlets->end()) {
        sourceOutlets->push_back(&koutlets);
        warn(csound, Str("Connected instances of outlet %s to instance 0x%x"
                         "of inlet %s.\n"),
             sourceOutletId.c_str(), this, sinkInletId);
      }
    }
    return OK;
  }
  /**
   * Sum krate values from active outlets feeding this inlet.
   */
  int kontrol(CSOUND *csound) {
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    // Zero the inlet buffer.
    *ksignal = FL(0.0);
    // Loop over the source connections...
    for (size_t sourceI = 0, sourceN = sourceOutlets->size(); sourceI < sourceN;
         sourceI++) {
      // Loop over the source connection instances...
      const std::vector<Outletk *> *instances = sourceOutlets->at(sourceI);
      for (size_t instanceI = 0, instanceN = instances->size();
           instanceI < instanceN; instanceI++) {
        const Outletk *sourceOutlet = instances->at(instanceI);
        // Skip inactive instances.
        if (sourceOutlet->opds.insdshead->actflg) {
          *ksignal += *sourceOutlet->ksignal;
        }
      }
    }
    return OK;
  }
};

struct Outletf : public OpcodeNoteoffBase<Outletf> {
  /**
   * Inputs.
   */
  STRINGDAT *Sname;
  PVSDAT *fsignal;
  /**
   * State.
   */
  char sourceOutletId[0x100];
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    const char *insname =
        csound->GetInstrumentList(csound)[opds.insdshead->insno]->insname;
    if (insname) {
      std::sprintf(sourceOutletId, "%s:%s", insname, (char *)Sname->data);
    } else {
      std::sprintf(sourceOutletId, "%d:%s", opds.insdshead->insno,
                   (char *)Sname->data);
    }
    std::vector<Outletf *> &foutlets =
        sfg_globals->foutletsForSourceOutletIds[sourceOutletId];
    if (std::find(foutlets.begin(), foutlets.end(), this) == foutlets.end()) {
      foutlets.push_back(this);
      warn(csound, Str("Created instance 0x%x of outlet %s\n"), this,
           sourceOutletId);
    }
    return OK;
  }
  int noteoff(CSOUND *csound) {
    std::vector<Outletf *> &foutlets =
        sfg_globals->foutletsForSourceOutletIds[sourceOutletId];
    std::vector<Outletf *>::iterator thisoutlet =
        std::find(foutlets.begin(), foutlets.end(), this);
    foutlets.erase(thisoutlet);
    warn(csound, Str("Removed 0x%x of %d instances of outletf %s\n"), this,
         foutlets.size(), sourceOutletId);
    return OK;
  }
};

struct Inletf : public OpcodeBase<Inletf> {
  /**
   * Output.
   */
  PVSDAT *fsignal;
  /**
   * Inputs.
   */
  STRINGDAT *Sname;
  /**
   * State.
   */
  char sinkInletId[0x100];
  std::vector<std::vector<Outletf *> *> *sourceOutlets;
  int ksmps;
  int lastframe;
  bool fsignalInitialized;
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    ksmps = opds.insdshead->ksmps;
    lastframe = 0;
    fsignalInitialized = false;
    if (std::find(sfg_globals->foutletVectors.begin(),
                  sfg_globals->foutletVectors.end(),
                  sourceOutlets) == sfg_globals->foutletVectors.end()) {
      sourceOutlets = new std::vector<std::vector<Outletf *> *>;
      sfg_globals->foutletVectors.push_back(sourceOutlets);
    } else {
      sourceOutlets->clear();
    }
    sinkInletId[0] = 0;
    const char *insname =
        csound->GetInstrumentList(csound)[opds.insdshead->insno]->insname;
    if (insname) {
      std::sprintf(sinkInletId, "%s:%s", insname, (char *)Sname->data);
    } else {
      std::sprintf(sinkInletId, "%d:%s", opds.insdshead->insno,
                   (char *)Sname->data);
    }
    std::vector<Inletf *> &finlets =
        sfg_globals->finletsForSinkInletIds[sinkInletId];
    if (std::find(finlets.begin(), finlets.end(), this) == finlets.end()) {
      finlets.push_back(this);
      warn(csound, Str("Created instance 0x%x of inlet %s\n"), this,
           sinkInletId);
    }
    // Find source outlets connecting to this.
    // Any number of sources may connect to any number of sinks.
    std::vector<std::string> &sourceOutletIds =
        sfg_globals->connections[sinkInletId];
    for (size_t i = 0, n = sourceOutletIds.size(); i < n; i++) {
      const std::string &sourceOutletId = sourceOutletIds[i];
      std::vector<Outletf *> &foutlets =
          sfg_globals->foutletsForSourceOutletIds[sourceOutletId];
      if (std::find(sourceOutlets->begin(), sourceOutlets->end(), &foutlets) ==
          sourceOutlets->end()) {
        sourceOutlets->push_back(&foutlets);
        warn(csound, Str("Connected instances of outlet %s to instance 0x%x of "
                         "inlet %s.\n"),
             sourceOutletId.c_str(), this, sinkInletId);
      }
    }
    return OK;
  }
  /**
   * Mix fsig values from active outlets feeding this inlet.
   */
  int audio(CSOUND *csound) {
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    int result = OK;
    float *sink = 0;
    float *source = 0;
    CMPLX *sinkFrame = 0;
    CMPLX *sourceFrame = 0;
    // Loop over the source connections...
    for (size_t sourceI = 0, sourceN = sourceOutlets->size(); sourceI < sourceN;
         sourceI++) {
      // Loop over the source connection instances...
      const std::vector<Outletf *> *instances = sourceOutlets->at(sourceI);
      for (size_t instanceI = 0, instanceN = instances->size();
           instanceI < instanceN; instanceI++) {
        const Outletf *sourceOutlet = instances->at(instanceI);
        // Skip inactive instances.
        if (sourceOutlet->opds.insdshead->actflg) {
          if (!fsignalInitialized) {
            int32 N = sourceOutlet->fsignal->N;
            if (UNLIKELY(sourceOutlet->fsignal == fsignal)) {
              csound->Warning(csound,
                              "%s", Str("Unsafe to have same fsig as in and out"));
            }
            fsignal->sliding = 0;
            if (sourceOutlet->fsignal->sliding) {
              if (fsignal->frame.auxp == 0 ||
                  fsignal->frame.size <
                      sizeof(MYFLT) * opds.insdshead->ksmps * (N + 2))
                csound->AuxAlloc(
                    csound, (N + 2) * sizeof(MYFLT) * opds.insdshead->ksmps,
                    &fsignal->frame);
              fsignal->NB = sourceOutlet->fsignal->NB;
              fsignal->sliding = 1;
            } else if (fsignal->frame.auxp == 0 ||
                       fsignal->frame.size < sizeof(float) * (N + 2)) {
              csound->AuxAlloc(csound, (N + 2) * sizeof(float),
                               &fsignal->frame);
            }
            fsignal->N = N;
            fsignal->overlap = sourceOutlet->fsignal->overlap;
            fsignal->winsize = sourceOutlet->fsignal->winsize;
            fsignal->wintype = sourceOutlet->fsignal->wintype;
            fsignal->format = sourceOutlet->fsignal->format;
            fsignal->framecount = 1;
            lastframe = 0;
            if (UNLIKELY(!((fsignal->format == PVS_AMP_FREQ) ||
                           (fsignal->format == PVS_AMP_PHASE))))
              result = csound->InitError(csound,
                                         "%s", Str("inletf: signal format "
                                             "must be amp-phase or amp-freq."));
            fsignalInitialized = true;
          }
          if (fsignal->sliding) {
            for (int frameI = 0; frameI < ksmps; frameI++) {
              sinkFrame = (CMPLX *)fsignal->frame.auxp + (fsignal->NB * frameI);
              sourceFrame = (CMPLX *)sourceOutlet->fsignal->frame.auxp +
                            (fsignal->NB * frameI);
              for (size_t binI = 0, binN = fsignal->NB; binI < binN; binI++) {
                if (sourceFrame[binI].re > sinkFrame[binI].re) {
                  sinkFrame[binI] = sourceFrame[binI];
                }
              }
            }
          }
        } else {
          sink = (float *)fsignal->frame.auxp;
          source = (float *)sourceOutlet->fsignal->frame.auxp;
          if (lastframe < int(fsignal->framecount)) {
            for (size_t binI = 0, binN = fsignal->N + 2; binI < binN;
                 binI += 2) {
              if (source[binI] > sink[binI]) {
                source[binI] = sink[binI];
                source[binI + 1] = sink[binI + 1];
              }
            }
            fsignal->framecount = lastframe = sourceOutlet->fsignal->framecount;
          }
        }
      }
    }
    return result;
  }
};

struct Outletv : public OpcodeNoteoffBase<Outletv> {
  /**
   * Inputs.
   */
  STRINGDAT *Sname;
  ARRAYDAT *vsignal;
  /**
   * State.
   */
  char sourceOutletId[0x100];
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    warn(csound, "BEGAN Outletv::init()...\n");
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    sourceOutletId[0] = 0;
    const char *insname =
        csound->GetInstrumentList(csound)[opds.insdshead->insno]->insname;
    if (insname) {
      std::sprintf(sourceOutletId, "%s:%s", insname, (char *)Sname->data);
    } else {
      std::sprintf(sourceOutletId, "%d:%s", opds.insdshead->insno,
                   (char *)Sname->data);
    }
    std::vector<Outletv *> &voutlets =
        sfg_globals->voutletsForSourceOutletIds[sourceOutletId];
    if (std::find(voutlets.begin(), voutlets.end(), this) == voutlets.end()) {
      voutlets.push_back(this);
      warn(csound,
           Str("Created instance 0x%x of %d instances of outlet %s (out "
               "arraydat: 0x%x dims: %2d size: %4d [%4d] data: 0x%x (0x%x))\n"),
           this, voutlets.size(), sourceOutletId, vsignal, vsignal->dimensions,
           vsignal->sizes[0], vsignal->arrayMemberSize, vsignal->data,
           &vsignal->data);
    }
    warn(csound, "ENDED Outletv::init()...\n");
    return OK;
  }
  int noteoff(CSOUND *csound) {
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    std::vector<Outletv *> &voutlets =
        sfg_globals->voutletsForSourceOutletIds[sourceOutletId];
    std::vector<Outletv *>::iterator thisoutlet =
        std::find(voutlets.begin(), voutlets.end(), this);
    voutlets.erase(thisoutlet);
    warn(csound, Str("Removed 0x%x of %d instances of outletv %s\n"), this,
         voutlets.size(), sourceOutletId);
    return OK;
  }
};

struct Inletv : public OpcodeBase<Inletv> {
  /**
   * Output.
   */
  ARRAYDAT *vsignal;
  /**
   * Inputs.
   */
  STRINGDAT *Sname;
  /**
   * State.
   */
  char sinkInletId[0x100];
  std::vector<std::vector<Outletv *> *> *sourceOutlets;
  size_t arraySize;
  size_t myFltsPerArrayElement;
  int sampleN;
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    warn(csound, "BEGAN Inletv::init()...\n");
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    sampleN = opds.insdshead->ksmps;
    // The array elements may be krate (1 MYFLT) or arate (ksmps MYFLT).
    myFltsPerArrayElement = vsignal->arrayMemberSize / sizeof(MYFLT);
    warn(csound, "myFltsPerArrayElement: %d\n", myFltsPerArrayElement);
    arraySize = myFltsPerArrayElement;
    for (size_t dimension = 0; dimension < (size_t)vsignal->dimensions;
         ++dimension) {
      arraySize *= vsignal->sizes[dimension];
    }
    warn(csound, "arraySize: %d\n", arraySize);
    warn(csound, "sourceOutlets: 0x%x\n", sourceOutlets);
    if (std::find(sfg_globals->voutletVectors.begin(),
                  sfg_globals->voutletVectors.end(),
                  sourceOutlets) == sfg_globals->voutletVectors.end()) {
      sourceOutlets = new std::vector<std::vector<Outletv *> *>;
      sfg_globals->voutletVectors.push_back(sourceOutlets);
    } else {
      sourceOutlets->clear();
    }
    warn(csound, "sourceOutlets: 0x%x\n", sourceOutlets);
    sinkInletId[0] = 0;
    const char *insname =
        csound->GetInstrumentList(csound)[opds.insdshead->insno]->insname;
    if (insname) {
      std::sprintf(sinkInletId, "%s:%s", insname, (char *)Sname->data);
    } else {
      std::sprintf(sinkInletId, "%d:%s", opds.insdshead->insno,
                   (char *)Sname->data);
    }
    std::vector<Inletv *> &vinlets =
        sfg_globals->vinletsForSinkInletIds[sinkInletId];
    if (std::find(vinlets.begin(), vinlets.end(), this) == vinlets.end()) {
      vinlets.push_back(this);
      warn(csound, Str("Created instance 0x%x of inlet %s (in arraydat: 0x%x "
                       "dims: %2d size: %4d [%4d] data: 0x%x (0x%x))\n"),
           this, sinkInletId, vsignal, vsignal->dimensions, vsignal->sizes[0],
           vsignal->arrayMemberSize, vsignal->data, &vsignal->data);
    }
    // Find source outlets connecting to this.
    // Any number of sources may connect to any number of sinks.
    std::vector<std::string> &sourceOutletIds =
        sfg_globals->connections[sinkInletId];
    for (size_t i = 0, n = sourceOutletIds.size(); i < n; i++) {
      const std::string &sourceOutletId = sourceOutletIds[i];
      std::vector<Outletv *> &voutlets =
          sfg_globals->voutletsForSourceOutletIds[sourceOutletId];
      if (std::find(sourceOutlets->begin(), sourceOutlets->end(), &voutlets) ==
          sourceOutlets->end()) {
        sourceOutlets->push_back(&voutlets);
        warn(csound, Str("Connected instances of outlet %s to instance 0x%x of "
                         "inlet %s\n"),
             sourceOutletId.c_str(), this, sinkInletId);
      }
    }
    warn(csound, "ENDED Inletv::init().\n");
    return OK;
  }
  /**
   * Sum values from active outlets feeding this inlet.
   */
  int audio(CSOUND *csound) {
    // warn(csound, "BEGAN Inletv::audio()...\n");
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    for (uint32_t signalI = 0; signalI < arraySize; ++signalI) {
      vsignal->data[signalI] = FL(0.0);
    }
    // Loop over the source connections...
    for (size_t sourceI = 0, sourceN = sourceOutlets->size(); sourceI < sourceN;
         sourceI++) {
      // Loop over the source connection instances...
      std::vector<Outletv *> *instances = sourceOutlets->at(sourceI);
      for (size_t instanceI = 0, instanceN = instances->size();
           instanceI < instanceN; instanceI++) {
        Outletv *sourceOutlet = instances->at(instanceI);
        // Skip inactive instances.
        if (sourceOutlet->opds.insdshead->actflg) {
          for (uint32_t signalI = 0; signalI < arraySize; ++signalI) {
            ARRAYDAT *insignal = sourceOutlet->vsignal;
            MYFLT *indata = insignal->data;
            // warn(csound, "Inletv::audio: sourceOutlet: 0%x in arraydat: 0x%x
            // data: 0x%x (0x%x)\n", sourceOutlet, insignal, indata,
            // &insignal->data);
            vsignal->data[signalI] += indata[signalI];
          }
        }
      }
    }
    // warn(csound, "ENDED Inletv::audio().\n");
    return OK;
  }
};

struct Outletkid : public OpcodeNoteoffBase<Outletkid> {
  /**
   * Inputs.
   */
  STRINGDAT *Sname;
  STRINGDAT *SinstanceId;
  MYFLT *ksignal;
  /**
   * State.
   */
  char sourceOutletId[0x100];
  char *instanceId;
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    const char *insname =
        csound->GetInstrumentList(csound)[opds.insdshead->insno]->insname;
    instanceId = csound->strarg2name(csound, (char *)0, SinstanceId->data,
                                     (char *)"", 1);
    if (insname && instanceId) {
      std::sprintf(sourceOutletId, "%s:%s", insname, (char *)Sname->data);
    } else {
      std::sprintf(sourceOutletId, "%d:%s", opds.insdshead->insno,
                   (char *)Sname->data);
    }
    if (insname) {
      std::sprintf(sourceOutletId, "%s:%s", insname, (char *)Sname->data);
    } else {
      std::sprintf(sourceOutletId, "%d:%s", opds.insdshead->insno,
                   (char *)Sname->data);
    }
    std::vector<Outletkid *> &koutlets =
        sfg_globals->kidoutletsForSourceOutletIds[sourceOutletId];
    if (std::find(koutlets.begin(), koutlets.end(), this) == koutlets.end()) {
      koutlets.push_back(this);
      warn(csound, Str("Created instance 0x%x of %d instances of outlet %s\n"),
           this, koutlets.size(), sourceOutletId);
    }
    return OK;
  }
  int noteoff(CSOUND *csound) {
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    std::vector<Outletkid *> &koutlets =
        sfg_globals->kidoutletsForSourceOutletIds[sourceOutletId];
    std::vector<Outletkid *>::iterator thisoutlet =
        std::find(koutlets.begin(), koutlets.end(), this);
    koutlets.erase(thisoutlet);
    warn(csound, Str("Removed 0x%x of %d instances of outletkid %s\n"), this,
         koutlets.size(), sourceOutletId);
    return OK;
  }
};

struct Inletkid : public OpcodeBase<Inletkid> {
  /**
   * Output.
   */
  MYFLT *ksignal;
  /**
   * Inputs.
   */
  STRINGDAT *Sname;
  STRINGDAT *SinstanceId;
  /**
   * State.
   */
  char sinkInletId[0x100];
  char *instanceId;
  std::vector<std::vector<Outletkid *> *> *sourceOutlets;
  int ksmps;
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    ksmps = opds.insdshead->ksmps;
    if (std::find(sfg_globals->kidoutletVectors.begin(),
                  sfg_globals->kidoutletVectors.end(),
                  sourceOutlets) == sfg_globals->kidoutletVectors.end()) {
      sourceOutlets = new std::vector<std::vector<Outletkid *> *>;
      sfg_globals->kidoutletVectors.push_back(sourceOutlets);
    } else {
      sourceOutlets->clear();
    }
    sinkInletId[0] = 0;
    instanceId = csound->strarg2name(csound, (char *)0, SinstanceId->data,
                                     (char *)"", 1);
    const char *insname =
        csound->GetInstrumentList(csound)[opds.insdshead->insno]->insname;
    if (insname) {
      std::sprintf(sinkInletId, "%s:%s", insname, (char *)Sname->data);
    } else {
      std::sprintf(sinkInletId, "%d:%s", opds.insdshead->insno,
                   (char *)Sname->data);
    }
    std::vector<Inletkid *> &kinlets =
        sfg_globals->kidinletsForSinkInletIds[sinkInletId];
    if (std::find(kinlets.begin(), kinlets.end(), this) == kinlets.end()) {
      kinlets.push_back(this);
      warn(csound, Str("Created instance 0x%x of inlet %s\n"), this,
           sinkInletId);
    }
    // Find source outlets connecting to this.
    // Any number of sources may connect to any number of sinks.
    std::vector<std::string> &sourceOutletIds =
        sfg_globals->connections[sinkInletId];
    for (size_t i = 0, n = sourceOutletIds.size(); i < n; i++) {
      const std::string &sourceOutletId = sourceOutletIds[i];
      std::vector<Outletkid *> &koutlets =
          sfg_globals->kidoutletsForSourceOutletIds[sourceOutletId];
      if (std::find(sourceOutlets->begin(), sourceOutlets->end(), &koutlets) ==
          sourceOutlets->end()) {
        sourceOutlets->push_back(&koutlets);
        warn(csound, Str("Connected instances of outlet %s to instance 0x%x of "
                         "inlet %s.\n"),
             sourceOutletId.c_str(), this, sinkInletId);
      }
    }
    return OK;
  }
  /**
   * Replay instance signal.
   */
  int kontrol(CSOUND *csound) {
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    // Zero the / buffer.
    *ksignal = FL(0.0);
    // Loop over the source connections...
    for (size_t sourceI = 0, sourceN = sourceOutlets->size(); sourceI < sourceN;
         sourceI++) {
      // Loop over the source connection instances...
      const std::vector<Outletkid *> *instances = sourceOutlets->at(sourceI);
      for (size_t instanceI = 0, instanceN = instances->size();
           instanceI < instanceN; instanceI++) {
        const Outletkid *sourceOutlet = instances->at(instanceI);
        // Skip inactive instances and also all non-matching instances.
        if (sourceOutlet->opds.insdshead->actflg) {
          if (std::strcmp(sourceOutlet->instanceId, instanceId) == 0) {
            *ksignal += *sourceOutlet->ksignal;
          }
        }
      }
    }
    return OK;
  }
};

struct Connect : public OpcodeBase<Connect> {
  /**
   * Inputs.
   */
  MYFLT *Source;
  STRINGDAT *Soutlet;
  MYFLT *Sink;
  STRINGDAT *Sinlet;
  MYFLT *gain;
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    std::string sourceOutletId = csound->strarg2name(
        csound, (char *)0,
        ((isstrcod(*Source)) ? csound->GetString(csound, *Source)
                               : (char *)Source),
        (char *)"", isstrcod(*Source));
    sourceOutletId += ":";
    sourceOutletId +=
        csound->strarg2name(csound, (char *)0, Soutlet->data, (char *)"", 1);

    std::string sinkInletId = csound->strarg2name(
        csound, (char *)0,
        ((isstrcod(*Sink)) ? csound->GetString(csound, *Sink) : (char *)Sink),
        (char *)"", isstrcod(*Sink));
    sinkInletId += ":";
    sinkInletId +=
        csound->strarg2name(csound, (char *)0, Sinlet->data, (char *)"", 1);
    warn(csound, Str("Connected outlet %s to inlet %s.\n"),
         sourceOutletId.c_str(), sinkInletId.c_str());
    sfg_globals->connections[sinkInletId].push_back(sourceOutletId);
    return OK;
  }
};

struct Connecti : public OpcodeBase<Connecti> {
  /**
   * Inputs.
   */
  MYFLT *Source;
  STRINGDAT *Soutlet;
  STRINGDAT *Sink;
  STRINGDAT *Sinlet;
  MYFLT *gain;
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    std::string sourceOutletId = csound->strarg2name(
        csound, (char *)0,
        ((isstrcod(*Source)) ? csound->GetString(csound, *Source)
                               : (char *)Source),
        (char *)"", isstrcod(*Source));
    sourceOutletId += ":";
    sourceOutletId +=
        csound->strarg2name(csound, (char *)0, Soutlet->data, (char *)"", 1);
    std::string sinkInletId =
        csound->strarg2name(csound, (char *)0, Sink->data, (char *)"", 1);
    sinkInletId += ":";
    sinkInletId +=
        csound->strarg2name(csound, (char *)0, Sinlet->data, (char *)"", 1);
    warn(csound, Str("Connected outlet %s to inlet %s.\n"),
         sourceOutletId.c_str(), sinkInletId.c_str());
    sfg_globals->connections[sinkInletId].push_back(sourceOutletId);
    return OK;
  }
};

struct Connectii : public OpcodeBase<Connectii> {
  /**
   * Inputs.
   */
  STRINGDAT *Source;
  STRINGDAT *Soutlet;
  MYFLT *Sink;
  STRINGDAT *Sinlet;
  MYFLT *gain;
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    std::string sourceOutletId =
        csound->strarg2name(csound, (char *)0, Source->data, (char *)"", 1);
    sourceOutletId += ":";
    sourceOutletId +=
        csound->strarg2name(csound, (char *)0, Soutlet->data, (char *)"", 1);
    std::string sinkInletId = csound->strarg2name(
        csound, (char *)0,
        ((isstrcod(*Sink)) ? csound->GetString(csound, *Sink) : (char *)Sink),
        (char *)"", isstrcod(*Sink));
    ;
    sinkInletId += ":";
    sinkInletId +=
        csound->strarg2name(csound, (char *)0, Sinlet->data, (char *)"", 1);
    warn(csound, Str("Connected outlet %s to inlet %s.\n"),
         sourceOutletId.c_str(), sinkInletId.c_str());
    sfg_globals->connections[sinkInletId].push_back(sourceOutletId);
    return OK;
  }
};

struct ConnectS : public OpcodeBase<ConnectS> {
  /**
   * Inputs.
   */
  STRINGDAT *Source;
  STRINGDAT *Soutlet;
  STRINGDAT *Sink;
  STRINGDAT *Sinlet;
  MYFLT *gain;
  SignalFlowGraphState *sfg_globals;
  int init(CSOUND *csound) {
    QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
    LockGuard guard(csound, sfg_globals->signal_flow_ports_lock);
    std::string sourceOutletId =
        csound->strarg2name(csound, (char *)0, Source->data, (char *)"", 1);
    sourceOutletId += ":";
    sourceOutletId +=
        csound->strarg2name(csound, (char *)0, Soutlet->data, (char *)"", 1);
    std::string sinkInletId =
        csound->strarg2name(csound, (char *)0, Sink->data, (char *)"", 1);
    sinkInletId += ":";
    sinkInletId +=
        csound->strarg2name(csound, (char *)0, Sinlet->data, (char *)"", 1);
    warn(csound, Str("Connected outlet %s to inlet %s.\n"),
         sourceOutletId.c_str(), sinkInletId.c_str());
    sfg_globals->connections[sinkInletId].push_back(sourceOutletId);
    return OK;
  }
};

struct AlwaysOnS : public OpcodeBase<AlwaysOnS> {
  /**
   * Inputs.
   */
  STRINGDAT *Sinstrument;
  MYFLT *argums[VARGMAX];
  /**
   * State.
   */
  EVTBLK evtblk;
  int init(CSOUND *csound) {
    MYFLT offset = csound->GetScoreOffsetSeconds(csound);
    evtblk.opcod = 'i';
    evtblk.strarg = 0;
    evtblk.p[0] = FL(0.0);
    evtblk.p[1] = csound->strarg2insno(csound, Sinstrument->data, 1);
    evtblk.p[2] = evtblk.p2orig = offset;
    evtblk.p[3] = evtblk.p3orig = FL(-1.0);
    size_t inArgCount = csound->GetInputArgCnt(this);
    // Add 2, for hard-coded p2 and p3.
    evtblk.pcnt = (int16)inArgCount + 2;
    // Subtract 1, for only required inarg p1.
    size_t argumN = inArgCount - 1;
    // Start evtblk at 4, argums at 0.
    for (size_t pfieldI = 4, argumI = 0; argumI < argumN; pfieldI++, argumI++) {
      evtblk.p[pfieldI] = *argums[argumI];
    }
    csound->insert_score_event_at_sample(csound, &evtblk, 0);
    return OK;
  }
};

struct AlwaysOn : public OpcodeBase<AlwaysOn> {
  /**
   * Inputs.
   */
  MYFLT *Sinstrument;
  MYFLT *argums[VARGMAX];
  /**
   * State.
   */
  EVTBLK evtblk;
  int init(CSOUND *csound) {
    std::string source =
        csound->strarg2name(csound, (char *)0, Sinstrument, (char *)"", (int)0);
    MYFLT offset = csound->GetScoreOffsetSeconds(csound);
    evtblk.opcod = 'i';
    evtblk.strarg = 0;
    evtblk.p[0] = FL(0.0);
    evtblk.p[1] = *Sinstrument;
    evtblk.p[2] = evtblk.p2orig = offset;
    evtblk.p[3] = evtblk.p3orig = FL(-1.0);

    size_t inArgCount = csound->GetInputArgCnt(this);
    // Add 2, for hard-coded p2 and p3.
    evtblk.pcnt = (int16)inArgCount + 2;
    // Subtract 1, for only required inarg p1.
    size_t argumN = inArgCount - 1;
    // Start evtblk at 4, argums at 0.
    for (size_t pfieldI = 4, argumI = 0; argumI < argumN; pfieldI++, argumI++) {
      evtblk.p[pfieldI] = *argums[argumI];
    }
    csound->insert_score_event_at_sample(csound, &evtblk, 0);
    return OK;
  }
};

typedef struct {
  OPDS h;
  MYFLT *ifno, *p1, *p2, *p3, *p4, *p5, *argums[VARGMAX];
} FTGEN;

typedef struct namedgen {
  char *name;
  int genum;
  struct namedgen *next;
} NAMEDGEN;

/* Unused.
static void log(CSOUND *csound, const char *format,...)
{
        va_list args;
        va_start(args, format);
        if (csound) {
                csound->MessageV(csound, 0, format, args);
        } else {
                vfprintf(stdout, format, args);
        }
        va_end(args);
}
*/
static void warn(CSOUND *csound, const char *format, ...) {
  if (csound) {
    if (csound->GetMessageLevel(csound) & CS_WARNMSG) {
      va_list args;
      va_start(args, format);
      csound->MessageV(csound, CSOUNDMSG_WARNING, format, args);
      va_end(args);
    }
  } else {
    va_list args;
    va_start(args, format);
    vfprintf(stderr, format, args);
    va_end(args);
  }
}


/**
 * Copy all event parameters to a structure that will be used as a key to
 * a dictionary for pre-allocated function tables. If the key is in the
 * dictionary, the function table number is returned; if the key is not in
 * the dictionary, the function table is created, its number is stored in
 * the dictionary, and the number is returned.
 */
static int ftgenonce_(CSOUND *csound, FTGEN *p, bool isNamedGenerator,
                      bool hasStringParameter) {
  SignalFlowGraphState *sfg_globals;
  QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
  LockGuard guard(csound, sfg_globals->signal_flow_ftables_lock);
  int result = OK;
  EventBlock eventBlock;
  EVTBLK *ftevt = &eventBlock.evtblk;
  *p->ifno = FL(0.0);
  std::memset(ftevt, 0, sizeof(EVTBLK));
  // ifno ftgenonce ipfno, ip2dummy, ip4size, ip5gen, ip6arga, ip7argb,...
  ftevt->opcod = 'f';
  ftevt->strarg = 0;
  MYFLT *fp = &ftevt->p[0];
  ftevt->p[0] = FL(0.0);
  ftevt->p[1] = *p->p1;
  ftevt->p[2] = ftevt->p2orig = FL(0.0);
  ftevt->p[3] = ftevt->p3orig = *p->p3;
  if (isNamedGenerator) {
    NAMEDGEN *named = (NAMEDGEN *)csound->GetNamedGens(csound);
    while (named) {
      if (strcmp(named->name, ((STRINGDAT *)p->p4)->data) == 0) {
        /* Look up by name */
        break;
      }
      named = named->next; /*  and round again   */
    }
    if (UNLIKELY(named == 0)) {
      if (sfg_globals->signal_flow_ftables_lock != 0) {
        csound->UnlockMutex(sfg_globals->signal_flow_ftables_lock);
      }
      return csound->InitError(csound, Str("Named gen \"%s\" not defined"),
                               (char *)p->p4);
    } else {
      ftevt->p[4] = named->genum;
    }
  } else {
    ftevt->p[4] = *p->p4;
  }
  if (hasStringParameter) {
    int n = (int)fp[4];
    ftevt->p[5] = SSTRCOD;
    if (n < 0) {
      n = -n;
    }
    switch (n) { /*   must be Gen01, 23, 28, or 43 */
    case 1:
    case 23:
    case 28:
    case 43:
      ftevt->strarg = ((STRINGDAT *)p->p5)->data;
      break;
    default:
      if (sfg_globals->signal_flow_ftables_lock != 0) {
        csound->UnlockMutex(sfg_globals->signal_flow_ftables_lock);
      }
      return csound->InitError(csound, "%s", Str("ftgen string arg not allowed"));
    }
  } else {
    ftevt->p[5] = *p->p5;
  }
  // Copy the remaining parameters.
  ftevt->pcnt = (int16)csound->GetInputArgCnt(p);
  int n = ftevt->pcnt - 5;
  if (n > 0) {
    MYFLT **argp = p->argums;
    MYFLT *fp = &ftevt->p[0] + 6;
    do {
      *fp++ = **argp++;
    } while (--n);
  }
  // Hash the strarg.
  // We can't refer to the strarg later because it points to memory that will
  // be overwritten by future event blocks.
  if (hasStringParameter) eventBlock.strarg_djb2_hash = djb2_hash((unsigned char *) ftevt->strarg);
  if (sfg_globals->functionTablesForEvtblks.find(eventBlock) !=
      sfg_globals->functionTablesForEvtblks.end()) {
    *p->ifno = sfg_globals->functionTablesForEvtblks[eventBlock];
    warn(csound, Str("ftgenonce: re-using existing func: %f\n"), *p->ifno);
  } else {
    if (sfg_globals->functionTablesForEvtblks.find(eventBlock) !=
        sfg_globals->functionTablesForEvtblks.end()) {
      *p->ifno = sfg_globals->functionTablesForEvtblks[eventBlock];
      warn(csound, Str("ftgenonce: re-using existing func: %f\n"), *p->ifno);
    } else {
      FUNC *func = 0;
      int status = csound->hfgens(csound, &func, ftevt, 1);
      if (UNLIKELY(status != 0)) {
        result = csound->InitError(csound, "%s", Str("ftgenonce error"));
      }
      if (func) {
        sfg_globals->functionTablesForEvtblks[eventBlock] = func->fno;
        *p->ifno = (MYFLT)func->fno;
        warn(csound, Str("ftgenonce: created new func: %d\n"), func->fno);
        if (sfg_globals->functionTablesForEvtblks.find(eventBlock) ==
            sfg_globals->functionTablesForEvtblks.end()) {
#if (SIGNALFLOWGRAPH_DEBUG == 1)
          std::fprintf(stderr, "Oops! inserted but not found.\n");
#endif
        }
      } else {
#if (SIGNALFLOWGRAPH_DEBUG == 1)
        std::fprintf(stderr, "Oops! New but not created.\n");
#endif
      }
    }
  }
  return result;
}

static int ftgenonce(CSOUND *csound, FTGEN *p) {
  return ftgenonce_(csound, p, false, false);
}

static int ftgenonce_S(CSOUND *csound, FTGEN *p) {
  return ftgenonce_(csound, p, true, false);
}

static int ftgenonce_iS(CSOUND *csound, FTGEN *p) {
  return ftgenonce_(csound, p, false, true);
}

static int ftgenonce_SS(CSOUND *csound, FTGEN *p) {
  return ftgenonce_(csound, p, true, true);
}

extern "C" {
static OENTRY oentries[] = {
    {(char *)"outleta", sizeof(Outleta), _CW, 3, (char *)"", (char *)"Sa",
     (SUBR)&Outleta::init_, (SUBR)&Outleta::audio_},
    {(char *)"inleta", sizeof(Inleta), _CR, 3, (char *)"a", (char *)"S",
     (SUBR)&Inleta::init_, (SUBR)&Inleta::audio_},
    {(char *)"outletk", sizeof(Outletk), _CW, 3, (char *)"", (char *)"Sk",
     (SUBR)&Outletk::init_, (SUBR)&Outletk::kontrol_, 0},
    {(char *)"inletk", sizeof(Inletk), _CR, 3, (char *)"k", (char *)"S",
     (SUBR)&Inletk::init_, (SUBR)&Inletk::kontrol_, 0},
    {(char *)"outletkid", sizeof(Outletkid), _CW, 3, (char *)"", (char *)"SSk",
     (SUBR)&Outletk::init_, (SUBR)&Outletk::kontrol_, 0},
    {(char *)"inletkid", sizeof(Inletkid), _CR, 3, (char *)"k", (char *)"SS",
     (SUBR)&Inletk::init_, (SUBR)&Inletk::kontrol_, 0},
    {(char *)"outletf", sizeof(Outletf), _CW, 3, (char *)"", (char *)"Sf",
     (SUBR)&Outletf::init_, (SUBR)&Outletf::audio_},
    {(char *)"inletf", sizeof(Inletf), _CR, 3, (char *)"f", (char *)"S",
     (SUBR)&Inletf::init_, (SUBR)&Inletf::audio_},
    {(char *)"outletv", sizeof(Outletv), _CW, 3, (char *)"", (char *)"Sa[]",
     (SUBR)&Outletv::init_, (SUBR)&Outletv::audio_},
    {(char *)"inletv", sizeof(Inletv), _CR, 3, (char *)"a[]", (char *)"S",
     (SUBR)&Inletv::init_, (SUBR)&Inletv::audio_},
    {(char *)"connect", sizeof(Connect), 0, 1, (char *)"", (char *)"iSiSp",
     (SUBR)&Connect::init_, 0, 0},
    {(char *)"connect.i", sizeof(Connecti), 0, 1, (char *)"", (char *)"iSSSp",
     (SUBR)&Connecti::init_, 0, 0},
    {(char *)"connect.ii", sizeof(Connectii), 0, 1, (char *)"", (char *)"SSiSp",
     (SUBR)&Connectii::init_, 0, 0},
    {(char *)"connect.S", sizeof(ConnectS), 0, 1, (char *)"", (char *)"SSSSp",
     (SUBR)&ConnectS::init_, 0, 0},
    {(char *)"alwayson", sizeof(AlwaysOn), 0, 1, (char *)"", (char *)"im",
     (SUBR)&AlwaysOn::init_, 0, 0},
    {(char *)"alwayson.S", sizeof(AlwaysOnS), 0, 1, (char *)"", (char *)"Sm",
     (SUBR)&AlwaysOnS::init_, 0, 0},
    {(char *)"ftgenonce", sizeof(FTGEN), TW, 1, (char *)"i", (char *)"iiiiim",
     (SUBR)&ftgenonce, 0, 0},
    {(char *)"ftgenonce.S", sizeof(FTGEN), TW, 1, (char *)"i", (char *)"iiiSim",
     (SUBR)&ftgenonce_S, 0, 0},
    {(char *)"ftgenonce.iS", sizeof(FTGEN), TW, 1, (char *)"i",
     (char *)"iiiiSm", (SUBR)&ftgenonce_iS, 0, 0},
    {(char *)"ftgenonce.SS", sizeof(FTGEN), TW, 1, (char *)"i",
     (char *)"iiiSSm", (SUBR)&ftgenonce_SS, 0, 0},
    {0, 0, 0, 0, 0, 0, (SUBR)0, (SUBR)0, (SUBR)0}};

PUBLIC int csoundModuleCreate_signalflowgraph(CSOUND *csound) {
  if (csound->GetDebug(csound)) {
    csound->Message(csound, "signalflowgraph: csoundModuleCreate(%p)\n",
                    csound);
  }
  isstrcod = csound->ISSTRCOD;
  SignalFlowGraphState *sfg_globals = new SignalFlowGraphState(csound);
  CreateGlobalPointer(csound, "sfg_globals", sfg_globals);
  return 0;
}

PUBLIC int csoundModuleInit_signalflowgraph(CSOUND *csound) {
  if (csound->GetDebug(csound)) {
    csound->Message(csound, "signalflowgraph: csoundModuleInit(%p)\n", csound);
  }
  OENTRY *ep = (OENTRY *)&(oentries[0]);
  int err = 0;
  while (ep->opname != 0) {
    err |= csound->AppendOpcode(csound, ep->opname, ep->dsblksiz, ep->flags,
                                ep->thread, ep->outypes, ep->intypes,
                                (int (*)(CSOUND *, void *))ep->iopadr,
                                (int (*)(CSOUND *, void *))ep->kopadr,
                                (int (*)(CSOUND *, void *))ep->aopadr);
    ep++;
  }
  return err;
}
#ifndef INIT_STATIC_MODULES
PUBLIC int csoundModuleCreate(CSOUND *csound) {
  return csoundModuleCreate_signalflowgraph(csound);
}

PUBLIC int csoundModuleInit(CSOUND *csound) {
  return csoundModuleInit_signalflowgraph(csound);
}

PUBLIC int csoundModuleDestroy(CSOUND *csound) {
  if (csound->GetDebug(csound)) {
    csound->Message(csound, "signalflowgraph: csoundModuleDestroy(%p)...\n",
                    csound);
  }
  SignalFlowGraphState *sfg_globals = 0;
  QueryGlobalPointer(csound, "sfg_globals", sfg_globals);
  if (sfg_globals != 0) {
    sfg_globals->clear();
    if (sfg_globals->signal_flow_ports_lock != 0) {
      // Unlocked in clear(): csound->UnlockMutex(sfg_globals->signal_flow_ports_lock);
      csound->DestroyMutex(sfg_globals->signal_flow_ports_lock);
    }
    if (sfg_globals->signal_flow_ftables_lock != 0) {
      csound->LockMutex(sfg_globals->signal_flow_ftables_lock);
      sfg_globals->functionTablesForEvtblks.clear();
      csound->UnlockMutex(sfg_globals->signal_flow_ftables_lock);
      csound->DestroyMutex(sfg_globals->signal_flow_ftables_lock);
    }
    csound->DestroyGlobalVariable(csound, "sfg_globals");
    delete sfg_globals;
    sfg_globals = nullptr;
  }
  if (csound->GetDebug(csound)) {
    csound->Message(csound, "signalflowgraph: csoundModuleDestroy(%p).\n",
                    csound);
  }
  return 0;
}
#endif
}
}