Package org.red5.server.net.rtmp.event

Examples of org.red5.server.net.rtmp.event.IRTMPEvent

2018
2019
2020
2021
2022
2023
2024
2025
2026
2027
2028
        /**
         * Releases pending message body, nullifies pending message object
         */
    private synchronized void releasePendingMessage() {
      if (pendingMessage != null) {
        IRTMPEvent body = pendingMessage.getBody();
        if (body instanceof IStreamData && ((IStreamData) body).getData() != null) {
          ((IStreamData) body).getData().release();
        }
        pendingMessage.setBody(null);
        pendingMessage = null;
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
    }
    if (writer == null) {
      init();
    }
    RTMPMessage rtmpMsg = (RTMPMessage) message;
    final IRTMPEvent msg = rtmpMsg.getBody();
    if (startTimestamp == -1) {
      startTimestamp = msg.getTimestamp();
    }
    int timestamp = msg.getTimestamp() - startTimestamp;
    if (timestamp < 0) {
      log.warn("Skipping message with negative timestamp.");
      return;
    }
    lastTimestamp = timestamp;

    ITag tag = new Tag();

    tag.setDataType(msg.getDataType());
    tag.setTimestamp(timestamp + offset);
    if (msg instanceof IStreamData) {
      ByteBuffer data = ((IStreamData) msg).getData().asReadOnlyBuffer();
      tag.setBodySize(data.limit());
      tag.setBody(data);
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
    this.state = state;
  }

  /** {@inheritDoc} */
    public boolean canSendPacket(RTMPMessage message, long pending) {
    IRTMPEvent packet = message.getBody();
    if (!(packet instanceof VideoData)) {
      // We currently only drop video packets.
      return true;
    }

View Full Code Here
123
124
125
126
127
128
129
130
131
132
133
    return result;
  }

  /** {@inheritDoc} */
    public void dropPacket(RTMPMessage message) {
    IRTMPEvent packet = message.getBody();
    if (!(packet instanceof VideoData)) {
      // Only check video packets.
      return;
    }

View Full Code Here
748
749
750
751
752
753
754
755
756
757
758
759
      return creationTime;
    }
   
    /** {@inheritDoc} */
    public int getCurrentTimestamp() {
      final IRTMPEvent msg = engine.lastMessage;
      if (msg == null) {
        return 0;
      }
     
      return msg.getTimestamp();
    }
View Full Code Here
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
      return bytesSent;
    }
   
    /** {@inheritDoc} */
    public double getEstimatedBufferFill() {
      final IRTMPEvent msg = engine.lastMessage;
      if (msg == null) {
        // Nothing has been sent yet
        return 0.0;
      }
     
    // Buffer size as requested by the client
    final long buffer = getClientBufferDuration();
    if (buffer == 0) {
      return 100.0;
    }
   
    // Duration the stream is playing
    final long delta = System.currentTimeMillis() - engine.playbackStart;
    // Expected amount of data present in client buffer
    final long buffered = msg.getTimestamp() - delta;
      return (buffered * 100.0) / buffer;
    }
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
    if (!reader.hasMoreTags()) {
      return null;
    }
    ITag tag = reader.readTag();

    IRTMPEvent msg;
    switch (tag.getDataType()) {
      case TYPE_AUDIO_DATA:
        msg = new AudioData(tag.getBody());
        break;
      case TYPE_VIDEO_DATA:
        msg = new VideoData(tag.getBody());
        break;
      case TYPE_INVOKE:
        msg = new Invoke(tag.getBody());
        break;
      case TYPE_NOTIFY:
        msg = new Notify(tag.getBody());
        break;
      default:
        log.warn("Unexpected type? " + tag.getDataType());
        msg = new Unknown(tag.getDataType(), tag.getBody());
        break;
    }
    msg.setTimestamp(tag.getTimestamp());
    //msg.setSealed(true);
    return msg;
  }
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
   * @param message          RTMP message
   * @return <tt>true</tt> indicates success and <tt>false</tt>
   * indicates buffer is full.
   */
  public boolean putMessage(RTMPMessage message) {
    IRTMPEvent body = message.getBody();
    if (!(body instanceof IStreamData)) {
      throw new RuntimeException("expected IStreamData but got " + body);
    }

    int size = ((IStreamData) body).getData().limit();
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
   * @return <tt>null</tt> if buffer is empty.
   */
  public RTMPMessage takeMessage() {
    RTMPMessage message = messageQueue.poll();
    if (message != null) {
      IRTMPEvent body = message.getBody();
      if (!(body instanceof IStreamData)) {
        throw new RuntimeException("expected IStreamData but got "
            + body);
      }

View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
    } else if (message instanceof StatusMessage) {
      StatusMessage statusMsg = (StatusMessage) message;
      data.sendStatus(statusMsg.getBody());
    } else if (message instanceof RTMPMessage) {
      RTMPMessage rtmpMsg = (RTMPMessage) message;
      IRTMPEvent msg = rtmpMsg.getBody();
      Header header = new Header();
      int timestamp = streamTracker.add(msg);
      if (timestamp < 0) {
        log.warn("Skipping message with negative timestamp.");
        return;
      }
      header.setTimerRelative(streamTracker.isRelative());
      header.setTimer(timestamp);

      switch (msg.getDataType()) {
        case Constants.TYPE_STREAM_METADATA:
          Notify notify = new Notify(((Notify) msg).getData()
              .asReadOnlyBuffer());
          notify.setHeader(header);
          notify.setTimestamp(header.getTimer());
View Full Code Here
TOP

Related Classes of org.red5.server.net.rtmp.event.IRTMPEvent

  • chat.Application
  • org.apache.mina.core.buffer.IoBuffer
  • org.apache.openmeetings.data.flvrecord.listener.async.BaseStreamWriter
  • org.apache.openmeetings.data.flvrecord.listener.async.StreamAudioWriter
  • org.apache.openmeetings.data.flvrecord.listener.async.StreamVideoWriter
  • org.apache.openmeetings.data.user.UserManager
  • org.apache.openmeetings.remote.ChatService
  • org.apache.openmeetings.remote.ConferenceLibrary
  • org.apache.openmeetings.remote.ConferenceService
  • org.apache.openmeetings.remote.FLVRecorderService
    • Copyright © 2018 www.massapicom. 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.