Examples of ptolemy.actor.IOPort.send()

ptolemy.actor.IOPort.send()
Send the specified token to all receivers connected to the specified channel. Tokens are in general immutable, so each receiver is given a reference to the same token and no clones are made. If the port is not connected to anything, or receivers have not been created in the remote port, or the channel index is out of range, or the port is not an output port, then just silently return. This behavior makes it easy to leave output ports unconnected when you are not interested in the output. The transfer is accomplished by calling the put() method of the remote receivers. If the port is not connected to anything, or receivers have not been created in the remote port, then just return.
Some of this method is read-synchronized on the workspace. Since it is possible for a thread to block while executing a put, it is important that the thread does not hold read access on the workspace when it is blocked. Thus this method releases read access on the workspace before calling put. @param channelIndex The index of the channel, from 0 to width-1 @param token The token to send @exception NoRoomException If there is no room in the receiver. @exception IllegalActionException Not thrown in this base class.

                    if (_debugging) {
                        _debug("** Transferring parameter to output: "
                                + port.getName());
                    }


                    port.send(0, ((Variable) attribute).getToken());
                } else if (attribute instanceof Settable) {
                    if (_debugging) {
                        _debug("** Transferring parameter as string to output: "
                                + port.getName());
                    }

View Full Code Here

                    if (_debugging) {
                        _debug("** Transferring parameter as string to output: "
                                + port.getName());
                    }


                    port.send(0, new StringToken(((Settable) attribute)
                            .getExpression()));
                }
            }
        }
    }

View Full Code Here

                    if (_debugging) {
                        _debug("** Transferring parameter to output: "
                                + port.getName());
                    }


                    port.send(0, ((Variable) attribute).getToken());
                } else if (attribute instanceof Settable) {
                    if (_debugging) {
                        _debug("** Transferring parameter as string to output: "
                                + port.getName());
                    }

View Full Code Here

                    if (_debugging) {
                        _debug("** Transferring parameter as string to output: "
                                + port.getName());
                    }


                    port.send(0, new StringToken(((Settable) attribute)
                            .getExpression()));
                }
            }
        }
    }

View Full Code Here

                            if (_debugging) {
                                _debug(getName(), "transferring output from "
                                        + port.getName());
                            }


                            port.send(i, t);
                        } else {
                            throw new IllegalActionException(this, port,
                                    "Port should produce " + rate
                                            + " tokens, but there were only "
                                            + k + " tokens available.");

View Full Code Here


                // since the record received may contain more fields than the
                // output ports, some fields may not have a corresponding
                // output port.
                if (port != null) {
                    port.send(0, value);
                }
            }
        }
    }

View Full Code Here

                                            + destination.getName()
                                            + " channel: " + channel.intValue()
                                            + ", Clear!");
                                }
                            } else {
                                destination.send(channel.intValue(), token);


                                if (_debugging) {
                                    _debug(getFullName() + " port: "
                                            + destination.getName()
                                            + " channel: " + channel.intValue()

View Full Code Here

        while (outputPorts.hasNext()) {
            IOPort outputPort = (IOPort) outputPorts.next();


            for (int i = 0; i < outputPort.getWidthInside(); i++) {
                while (outputPort.hasTokenInside(i)) {
                    outputPort.send(i, outputPort.getInside(i));
                }
            }
        }
    }

View Full Code Here

                while (outputPorts.hasNext()) {
                    IOPort port = (IOPort) (outputPorts.next());


                    // FIXME: Handle multiports
                    if (port.getWidth() > 0) {
                        port.send(0, matlabEngine.get(engine, port.getName(),
                                _dataParameters));
                    }
                }


                // Restore previous path if path was modified above

View Full Code Here

                        Receiver[][] localReceivers = destination
                                .getReceivers();


                        if (channel != null) {
                            int chanelValue = channel.intValue();
                            destination.send(chanelValue, token);


                            if (isInput) {
                                // If the destination is both input and output,
                                // also send the tokens to local receivers.
                                localReceivers[chanelValue][0].put(token);

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.