1 files changed, 205 insertions, 0 deletions
diff --git a/src/com/jsyn/ports/PortBlockPart.java b/src/com/jsyn/ports/PortBlockPart.java
new file mode 100644
index 0000000..26bbae0
--- /dev/null
+++ b/src/com/jsyn/ports/PortBlockPart.java
@@ -0,0 +1,205 @@
+/*
+ * Copyright 2009 Phil Burk, Mobileer Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.jsyn.ports;
+
+import java.util.ArrayList;
+
+import com.jsyn.Synthesizer;
+import com.jsyn.engine.SynthesisEngine;
+import com.softsynth.shared.time.ScheduledCommand;
+import com.softsynth.shared.time.TimeStamp;
+
+/**
+ * Part of a multi-part port, for example, the left side of a stereo port.
+ * 
+ * @author Phil Burk (C) 2009 Mobileer Inc
+ */
+public class PortBlockPart implements ConnectableOutput, ConnectableInput {
+    private double[] values = new double[Synthesizer.FRAMES_PER_BLOCK];
+    private ArrayList<PortBlockPart> connections = new ArrayList<PortBlockPart>();
+    private UnitBlockPort unitBlockPort;
+
+    protected PortBlockPart(UnitBlockPort unitBlockPort, double defaultValue) {
+        this.unitBlockPort = unitBlockPort;
+        setValue(defaultValue);
+    }
+
+    public double[] getValues() {
+        return values;
+    }
+
+    public double getValue() {
+        return values[0];
+    }
+
+    public double get() {
+        return values[0];
+    }
+
+    protected void setValue(double value) {
+        for (int i = 0; i < values.length; i++) {
+            values[i] = value;
+        }
+    }
+
+    protected boolean isConnected() {
+        return (connections.size() > 0);
+    }
+
+    private void addConnection(PortBlockPart otherPart) {
+        // System.out.println("addConnection from " + this + " to " + otherPart
+        // );
+        if (connections.contains(otherPart)) {
+            System.out.println("addConnection alreacy had connection from " + this + " to "
+                    + otherPart);
+        } else {
+            connections.add(otherPart);
+        }
+    }
+
+    private void removeConnection(PortBlockPart otherPart) {
+        // System.out.println("removeConnection from " + this + " to " +
+        // otherPart );
+        connections.remove(otherPart);
+    }
+
+    private void connectNow(PortBlockPart otherPart) {
+        addConnection(otherPart);
+        otherPart.addConnection(this);
+    }
+
+    private void disconnectNow(PortBlockPart otherPart) {
+        removeConnection(otherPart);
+        otherPart.removeConnection(this);
+    }
+
+    private void disconnectAllNow() {
+        for (PortBlockPart part : connections) {
+            part.removeConnection(this);
+        }
+        connections.clear();
+    }
+
+    public PortBlockPart getConnection(int i) {
+        return connections.get(i);
+    }
+
+    public int getConnectionCount() {
+        return connections.size();
+    }
+
+    /** Set all values to the last value. */
+    protected void flatten() {
+        double lastValue = values[values.length - 1];
+        for (int i = 0; i < values.length - 1; i++) {
+            values[i] = lastValue;
+        }
+    }
+
+    protected UnitBlockPort getPort() {
+        return unitBlockPort;
+    }
+
+    private void checkConnection(PortBlockPart destination) {
+        SynthesisEngine sourceSynth = unitBlockPort.getSynthesisEngine();
+        SynthesisEngine destSynth = destination.unitBlockPort.getSynthesisEngine();
+        if ((sourceSynth != destSynth) && (sourceSynth != null) && (destSynth != null)) {
+            throw new RuntimeException("Connection between units on different synths.");
+        }
+    }
+
+    protected void connect(final PortBlockPart destination) {
+        checkConnection(destination);
+        unitBlockPort.queueCommand(new ScheduledCommand() {
+            @Override
+            public void run() {
+                connectNow(destination);
+            }
+        });
+    }
+
+    protected void connect(final PortBlockPart destination, TimeStamp timeStamp) {
+        unitBlockPort.scheduleCommand(timeStamp, new ScheduledCommand() {
+            @Override
+            public void run() {
+                connectNow(destination);
+            }
+        });
+    }
+
+    protected void disconnect(final PortBlockPart destination) {
+        unitBlockPort.queueCommand(new ScheduledCommand() {
+            @Override
+            public void run() {
+                disconnectNow(destination);
+            }
+        });
+    }
+
+    protected void disconnect(final PortBlockPart destination, TimeStamp timeStamp) {
+        unitBlockPort.scheduleCommand(timeStamp, new ScheduledCommand() {
+            @Override
+            public void run() {
+                disconnectNow(destination);
+            }
+        });
+    }
+
+    protected void disconnectAll() {
+        unitBlockPort.queueCommand(new ScheduledCommand() {
+            @Override
+            public void run() {
+                disconnectAllNow();
+            }
+        });
+    }
+
+    @Override
+    public void connect(ConnectableInput other) {
+        connect(other.getPortBlockPart());
+    }
+
+    @Override
+    public void connect(ConnectableOutput other) {
+        other.connect(this);
+    }
+
+    @Override
+    public void disconnect(ConnectableOutput other) {
+        other.disconnect(this);
+    }
+
+    @Override
+    public void disconnect(ConnectableInput other) {
+        disconnect(other.getPortBlockPart());
+    }
+
+    /** To implement ConnectableInput */
+    @Override
+    public PortBlockPart getPortBlockPart() {
+        return this;
+    }
+
+    @Override
+    public void pullData(long frameCount, int start, int limit) {
+        for (int i = 0; i < getConnectionCount(); i++) {
+            PortBlockPart part = getConnection(i);
+            part.getPort().getUnitGenerator().pullData(frameCount, start, limit);
+        }
+    }
+
+}