Package org.apache.mina.core.buffer

Examples of org.apache.mina.core.buffer.IoBuffer.asReadOnlyBuffer()

351
352
353
354
355
356
357
358
359
360
361
          if (videoCodec != null) {
            //check for decoder configuration to send
            IoBuffer config = videoCodec.getDecoderConfiguration();
            if (config != null) {
              log.debug("Decoder configuration is available for {}", videoCodec.getName());
              VideoData videoConf = new VideoData(config.asReadOnlyBuffer());
              try {
                log.debug("Setting decoder configuration for recording");
                listener.getFileConsumer().setVideoDecoderConfiguration(videoConf);
              } finally {
                videoConf.release();
View Full Code Here
369
370
371
372
373
374
375
376
377
378
379
          if (audioCodec != null) {
            //check for decoder configuration to send
            IoBuffer config = audioCodec.getDecoderConfiguration();
            if (config != null) {
              log.debug("Decoder configuration is available for {}", audioCodec.getName());
              AudioData audioConf = new AudioData(config.asReadOnlyBuffer());
              try {
                log.debug("Setting decoder configuration for recording");
                listener.getFileConsumer().setAudioDecoderConfiguration(audioConf);
              } finally {
                audioConf.release();
View Full Code Here
155
156
157
158
159
160
161
162
163
164
165
          break;
        case Constants.TYPE_AUDIO_DATA:
          log.trace("Audio data");
          buf = ((AudioData) msg).getData();
          if (buf != null) {
            AudioData audioData = new AudioData(buf.asReadOnlyBuffer());
            audioData.setHeader(header);
            audioData.setTimestamp(header.getTimer());
            log.trace("Source type: {}", ((AudioData) msg).getSourceType());
            audioData.setSourceType(((AudioData) msg).getSourceType());
            audio.write(audioData);
View Full Code Here
169
170
171
172
173
174
175
176
177
178
179
          break;
        case Constants.TYPE_VIDEO_DATA:
          log.trace("Video data");
          buf = ((VideoData) msg).getData();
          if (buf != null) {
            VideoData videoData = new VideoData(buf.asReadOnlyBuffer());
            videoData.setHeader(header);
            videoData.setTimestamp(header.getTimer());
            log.trace("Source type: {}", ((VideoData) msg).getSourceType());
            videoData.setSourceType(((VideoData) msg).getSourceType());
            video.write(videoData);
View Full Code Here
540
541
542
543
544
545
546
547
548
549
550
            //check for decoder configuration to send
            IoBuffer config = videoCodec.getDecoderConfiguration();
            if (config != null) {
              log.debug("Decoder configuration is available for {}", videoCodec.getName());
              //log.debug("Dump:\n{}", Hex.encodeHex(config.array()));
              VideoData conf = new VideoData(config.asReadOnlyBuffer());
              log.trace("Configuration ts: {}", conf.getTimestamp());
              RTMPMessage confMsg = RTMPMessage.build(conf);
              try {
                log.debug("Pushing decoder configuration");
                msgOut.pushMessage(confMsg);
View Full Code Here
554
555
556
557
558
559
560
561
562
563
564
            }
            //check for a keyframe to send
            IoBuffer keyFrame = videoCodec.getKeyframe();
            if (keyFrame != null) {
              log.debug("Keyframe is available");
              VideoData video = new VideoData(keyFrame.asReadOnlyBuffer());
              log.trace("Keyframe ts: {}", video.getTimestamp());
              //log.debug("Dump:\n{}", Hex.encodeHex(keyFrame.array()));
              RTMPMessage videoMsg = RTMPMessage.build(video);
              try {
                log.debug("Pushing keyframe");
View Full Code Here
577
578
579
580
581
582
583
584
585
586
587
            // check for decoder configuration to send
            IoBuffer config = audioCodec.getDecoderConfiguration();
            if (config != null) {
              log.debug("Decoder configuration is available for {}", audioCodec.getName());
              //log.debug("Dump:\n{}", Hex.encodeHex(config.array()));
              AudioData conf = new AudioData(config.asReadOnlyBuffer());
              log.trace("Configuration ts: {}", conf.getTimestamp());
              RTMPMessage confMsg = RTMPMessage.build(conf);
              try {
                log.debug("Pushing decoder configuration");
                msgOut.pushMessage(confMsg);
View Full Code Here
282
283
284
285
286
287
288
289
290
291
292
              }
            } else if (codecInfo != null) {
              audioStreamCodec = codecInfo.getAudioCodec();
            }
            if (audioStreamCodec != null) {
              audioStreamCodec.addData(buf.asReadOnlyBuffer());
            }
            if (info != null) {
              info.setHasAudio(true);
            }
            eventTime = rtmpEvent.getTimestamp();
View Full Code Here
301
302
303
304
305
306
307
308
309
310
311
              checkVideoCodec = false;
            } else if (codecInfo != null) {
              videoStreamCodec = codecInfo.getVideoCodec();
            }
            if (videoStreamCodec != null) {
              videoStreamCodec.addData(buf.asReadOnlyBuffer());
            }
            if (info != null) {
              info.setHasVideo(true);
            }
            eventTime = rtmpEvent.getTimestamp();
View Full Code Here
635
636
637
638
639
640
641
642
643
644
645
          if (videoCodec != null) {
            //check for decoder configuration to send
            IoBuffer config = videoCodec.getDecoderConfiguration();
            if (config != null) {
              log.debug("Decoder configuration is available for {}", videoCodec.getName());
              VideoData videoConf = new VideoData(config.asReadOnlyBuffer());
              try {
                log.debug("Setting decoder configuration for recording");
                listener.getFileConsumer().setVideoDecoderConfiguration(videoConf);
              } finally {
                videoConf.release();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.