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()

            fill  = (int) (start - pos);
            bufOff  = even * DISKBUF_SIZE_H;
            if( fill > 0 ) {
              for( int j = 0; j < ct.bufsDisk.length; j++ ) {
                numCh = ct.bufsDisk[ j ].getNumChannels();
                bndl2.addPacket( ct.bufsDisk[ j ].fillMsg( bufOff * numCh, fill * numCh, 0.0f ));
              }
            }
            bufSpans = transport.foldSpans( new Span( start, pos + DISKBUF_SIZE_H ), MIN_LOOP_LEN );
            doc.getAudioTrail().addBufferReadMessages( bndl2, bufSpans, ct.bufsDisk, bufOff + fill );

View Full Code Here

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

    if( onOff != activeOutput ) {
      activeOutput = onOff;
      if( transport.isRunning() ) return;
      
      final OSCBundle bndl = new OSCBundle();
      bndl.addPacket( grpOutput.runMsg( activeOutput ));
      if( activeOutput ) {
        syncOutput.activate( bndl );
      } else {
        syncOutput.deactivate( bndl );
      }

View Full Code Here

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


        defs = createOutputDefs( oCfg.numChannels );
        if( defs != null ) {
          bndl  = new OSCBundle();
          for( int i = 0; i < defs.length; i++ ) {
            bndl.addPacket( defs[ i ].recvMsg() );
          }
          if( !server.sync( bndl, TIMEOUT )) {
            printTimeOutMsg( "defs" );
          }
        }

View Full Code Here

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

          }
        }
        
        bndl  = new OSCBundle();
        for( int i = 0; i < ct.numFiles; i++ ) {
          bndl.addPacket( ct.bufsDisk[ i ].allocMsg() );
        }


        for( int ch = 0; ch < ct.numInChans; ch++ ) {
//          bndl.addPacket( ct.synthsPan[ ch ].newMsg( grpOutput, new String[] {
//            "i_aInBs",             "i_aOtBs",         "volume", "orient" }, new float[] {

View Full Code Here

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


        for( int ch = 0; ch < ct.numInChans; ch++ ) {
//          bndl.addPacket( ct.synthsPan[ ch ].newMsg( grpOutput, new String[] {
//            "i_aInBs",             "i_aOtBs",         "volume", "orient" }, new float[] {
//            ct.busInternal.getIndex() + ch, ct.busPan.getIndex(), volume,   orient  }, kAddToTail ));
          bndl.addPacket( ct.synthsPan[ ch ].newMsg( grpOutput, new String[] {
            "i_aInBs",             "i_aOtBs",         "orient" }, new float[] {
            ct.busInternal.getIndex() + ch, ct.busPan.getIndex(), orient  }, kAddToTail ));
          nw.register( ct.synthsPan[ ch ]);
        }
        for( int ch = 0; ch < oCfg.numChannels; ch++ ) {

View Full Code Here

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

          nw.register( ct.synthsPan[ ch ]);
        }
        for( int ch = 0; ch < oCfg.numChannels; ch++ ) {
//System.err.println( "routing ch " +(ch+1)+" from " + (ct.busPan.getIndex() + ch) + " to " + oCfg.mapping[ ch ]);
          if( oCfg.mapping[ ch ] < server.getOptions().getNumOutputBusChannels() ) {
            bndl.addPacket( ct.synthsRoute[ ch ].newMsg( grpOutput, new String[] {
              "i_aInBs",           "i_aOtBs"       }, new float[] {
              ct.busPan.getIndex() + ch, oCfg.mapping[ ch ]}, kAddToTail ));
            nw.register( ct.synthsRoute[ ch ]);
          }
        }

View Full Code Here

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

//System.err.println( "clock = "+clock+"; pos = "+pos+"; time = "+time );
        bndl        = new OSCBundle( time );
//        if( pos >= DISKBUF_PAD ) {
        if( pos < 0 ) {
          for( int i = 0; i < bufsDisk.length; i++ ) {
            bndl.addPacket( bufsDisk[ i ].fillMsg( 0, DISKBUF_PAD * bufsDisk[ i ].getNumChannels(), 0.0f ));
          }
          pos += DISKBUF_PAD;
        }
//          bufSpans[ 0 ] = new Span( pos - DISKBUF_PAD, pos - DISKBUF_PAD + DISKBUF_SIZE_H );
        bufSpans[ 0 ] = new Span( pos, pos + DISKBUF_SIZE_H );

View Full Code Here

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

    
//      playOffset  = -1;
      try {
        trigResp.remove();
        final OSCBundle bndl = new OSCBundle();
        bndl.addPacket( grpInput.freeAllMsg() );
        if( !activeOutput ) {
          bndl.addPacket( grpOutput.runMsg( false ));
          syncOutput.deactivate( bndl );
        }
        if( !activeInput ) {

View Full Code Here

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

      try {
        trigResp.remove();
        final OSCBundle bndl = new OSCBundle();
        bndl.addPacket( grpInput.freeAllMsg() );
        if( !activeOutput ) {
          bndl.addPacket( grpOutput.runMsg( false ));
          syncOutput.deactivate( bndl );
        }
        if( !activeInput ) {
          syncInput.deactivate( bndl );
        }

View Full Code Here

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

          continue;
        }
        if( fill > 0 ) {
          for( int j = 0; j < ct.bufsDisk.length; j++ ) {
            numCh = ct.bufsDisk[ j ].getNumChannels();
            bndl.addPacket( ct.bufsDisk[ j ].fillMsg( bufOff * numCh, fill * numCh, 0.0f ));
          }
        }
        doc.getAudioTrail().addBufferReadMessages( bndl, bufSpans, ct.bufsDisk, bufOff + fill );
      
if( DEBUG_FOLD ) {

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.