List of addPacket() Examples

Examples of addPacket()

com.illposed.osc.OSCBundle.addPacket()
Add a packet to the list of packets in this bundle. @param packet OSCMessage or OSCBundle
de.sciss.net.OSCBundle.addPacket()
dijjer.io.xfer.PartiallyReceivedBlock.addPacket()
org.hornetq.core.client.impl.LargeMessageBufferImpl.addPacket()
Add a buff to the List, or save it to the OutputStream if set @param packet
org.hornetq.core.client.impl.LargeMessageControllerImpl.addPacket()
Add a buff to the List, or save it to the OutputStream if set @param packet

Examples of de.sciss.net.OSCBundle.addPacket()

        bndl  = new OSCBundle();
        start  = Math.max( 0, pos - DISKBUF_PAD );
        fill  = (int) (start + DISKBUF_PAD - pos);
        if( fill > 0 ) {
          for( int i = 0; i < ct.bufsDisk.length; i++ ) {
            bndl.addPacket( ct.bufsDisk[ i ].fillMsg( 0, fill * ct.bufsDisk[ i ].getNumChannels(), 0.0f ));
          }
        }
        bufSpans = t.foldSpans( new Span( start, pos - DISKBUF_PAD + DISKBUF_SIZE ), MIN_LOOP_LEN );
        doc.getAudioTrail().addBufferReadMessages( bndl, bufSpans, ct.bufsDisk, fill );

View Full Code Here

Examples of de.sciss.net.OSCBundle.addPacket()

//      finally {
//        doc.bird.releaseShared( Session.DOOR_MTE );
//      }
      
      bndl    = new OSCBundle();
      bndl.addPacket( grpInput.freeAllMsg() );
      ct.newInputSynths();  // re-create synthsBufRd and synthPhasor
      for( int i = 0, off = 0; i < ct.numFiles; i++ ) {
        bndl.addPacket( ct.synthsBufRd[ i ].newMsg( grpInput, new String[] {
          "i_aInBf",                    "i_aOtBs",                       "i_aPhBs",            "i_intrp" }, new float[] {
          ct.bufsDisk[ i ].getBufNum(), ct.busInternal.getIndex() + off, busPhasor.getIndex(), interpolation }

View Full Code Here

Examples of de.sciss.net.OSCBundle.addPacket()

      
      bndl    = new OSCBundle();
      bndl.addPacket( grpInput.freeAllMsg() );
      ct.newInputSynths();  // re-create synthsBufRd and synthPhasor
      for( int i = 0, off = 0; i < ct.numFiles; i++ ) {
        bndl.addPacket( ct.synthsBufRd[ i ].newMsg( grpInput, new String[] {
          "i_aInBf",                    "i_aOtBs",                       "i_aPhBs",            "i_intrp" }, new float[] {
          ct.bufsDisk[ i ].getBufNum(), ct.busInternal.getIndex() + off, busPhasor.getIndex(), interpolation }
        ));
        nw.register( ct.synthsBufRd[ i ]);
        off += ct.chanMaps[ i ].length;

View Full Code Here

Examples of de.sciss.net.OSCBundle.addPacket()

        ));
        nw.register( ct.synthsBufRd[ i ]);
        off += ct.chanMaps[ i ].length;
      }
      if( ct.numFiles > 0 ) {
        bndl.addPacket( ct.synthPhasor.newMsg( grpInput, new String[] {
          "i_aInBf",            "rate",   "i_aPhBs"          }, new float[] {
          ct.bufsDisk[ 0 ].getBufNum(), realRate, busPhasor.getIndex() }));
        nw.register( ct.synthPhasor );
      }
      bndl.addPacket( grpOutput.runMsg( true ));

View Full Code Here

Examples of de.sciss.net.OSCBundle.addPacket()

        bndl.addPacket( ct.synthPhasor.newMsg( grpInput, new String[] {
          "i_aInBf",            "rate",   "i_aPhBs"          }, new float[] {
          ct.bufsDisk[ 0 ].getBufNum(), realRate, busPhasor.getIndex() }));
        nw.register( ct.synthPhasor );
      }
      bndl.addPacket( grpOutput.runMsg( true ));


      playOffset  = pos;
      clock    = 0;
      try {
        trigResp.add();

View Full Code Here

Examples of de.sciss.net.OSCBundle.addPacket()

      busInternal.free();
      busPan.free();
//      busMeter.free();
      
      final OSCBundle bndl = new OSCBundle();
      for( int i = 0; i < bufsDisk.length; i++ ) bndl.addPacket( bufsDisk[ i ].freeMsg() );
      if( bufsAllocated ) {
        bufsAllocated = false;
        if( (bndl.getPacketCount() > 0) && server.isRunning() && !server.sync( bndl, TIMEOUT )) {
          printTimeOutMsg( "dispose" );
        }

View Full Code Here

Examples of de.sciss.net.OSCBundle.addPacket()

    collAllClients.remove( mc );
    if( collActiveClients.remove( mc )) {
      bndl = new OSCBundle();
      for( int i = 0; i < mc.synths.length; i++ ) {
        if( mc.synths[ i ] != null ) {
          bndl.addPacket( mc.synths[ i ].freeMsg() );
          mc.synths[ i ] = null;
        }
      }
      if( bndl.getPacketCount() > 0 ) {
        try {

View Full Code Here

Examples of de.sciss.net.OSCBundle.addPacket()


    for( int i = 0; i < collActiveClients.size(); i++ ) {
      mc = (Client) collActiveClients.get( i );
      for( int j = 0; j < mc.synths.length; j++ ) {
        if( mc.synths[ j ] != null ) {
          bndl.addPacket( mc.synths[ j ].freeMsg() );
          mc.synths[ j ] = null;
        }
      }
      mc.setOffset( off );
      off += mc.cNum;

View Full Code Here

Examples of de.sciss.net.OSCBundle.addPacket()

                new Integer( g.getNodeID() ), "t_trig", new Integer( 1 )}));
            } else {
              if( grp == null ) {
                grp = Group.basicNew( server );
                grp.setName( "MeterManager" );
                bndl.addPacket( grp.newMsg( server.getDefaultGroup(), kAddToTail ));
                nw.register( grp );
              }
              g  = grp;
              if( !haveGrpTrig ) {
                meterBangBndl.addPacket( new OSCMessage( "/n_set", new Object[] {

View Full Code Here

Examples of de.sciss.net.OSCBundle.addPacket()

            }
            for( int j = 0, m = bus.getIndex() + mc.cOffset; j < mc.synths.length; j++, m += 2 ) {
              srcChan      = mc.channels[ j ];
              if( srcChan >= 0 ) {
                mc.synths[ j ] = Synth.basicNew( "eisk-meter", server );
                bndl.addPacket( mc.synths[ j ].newMsg( g, new String[] {
                  "i_aInBs",  "i_kOtBs" }, new float[] {
                  srcChan,    m }, kAddToTail ));
                if( !mc.task ) {
                  bndl.addPacket( mc.synths[ j ].runMsg( false ));
                }

View Full Code Here

0 1 2 3 4 5

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.