null if no previous header was received */
- public RtmpHeader prevHeaderRx() {
- return prevHeaderRx;
- }
-
- /** Sets the previous header that was received on this channel, or null if no previous header was sent */
- public void setPrevHeaderRx(RtmpHeader previousHeader) {
- this.prevHeaderRx = previousHeader;
- }
-
- /** @return the previous header that was transmitted on this channel */
- public RtmpHeader getPrevHeaderTx() {
- return prevHeaderTx;
- }
-
- public boolean canReusePrevHeaderTx(RtmpHeader.MessageType forMessageType) {
- return (prevHeaderTx != null && prevHeaderTx.getMessageType() == forMessageType);
- }
-
- /** Sets the previous header that was transmitted on this channel */
- public void setPrevHeaderTx(RtmpHeader prevHeaderTx) {
- this.prevHeaderTx = prevHeaderTx;
- }
-
- /** Sets the session beginning timestamp for all chunks */
- public static void markSessionTimestampTx() {
- sessionBeginTimestamp = System.nanoTime() / 1000000;
- }
-
- /** Utility method for calculating & synchronizing transmitted timestamps */
- public long markAbsoluteTimestampTx() {
- return System.nanoTime() / 1000000 - sessionBeginTimestamp;
- }
-
- /** Utility method for calculating & synchronizing transmitted timestamp deltas */
- public long markDeltaTimestampTx() {
- long currentTimestamp = System.nanoTime() / 1000000;
- long diffTimestamp = currentTimestamp - realLastTimestamp;
- realLastTimestamp = currentTimestamp;
- return diffTimestamp;
- }
-
- /** @return true if all packet data has been stored, or false if not */
- public boolean storePacketChunk(InputStream in, int chunkSize) throws IOException {
- final int remainingBytes = prevHeaderRx.getPacketLength() - baos.size();
- byte[] chunk = new byte[Math.min(remainingBytes, chunkSize)];
- Util.readBytesUntilFull(in, chunk);
- baos.write(chunk);
- return (baos.size() == prevHeaderRx.getPacketLength());
- }
-
- public ByteArrayInputStream getStoredPacketInputStream() {
- ByteArrayInputStream bis = new ByteArrayInputStream(baos.toByteArray());
- baos.reset();
- return bis;
- }
-
- /** Clears all currently-stored packet chunks (used when an ABORT packet is received) */
- public void clearStoredChunks() {
- baos.reset();
- }
-}
diff --git a/rtmp/src/main/java/com/github/faucamp/simplertmp/io/RtmpConnection.java b/rtmp/src/main/java/com/github/faucamp/simplertmp/io/RtmpConnection.java
deleted file mode 100644
index 7125b26..0000000
--- a/rtmp/src/main/java/com/github/faucamp/simplertmp/io/RtmpConnection.java
+++ /dev/null
@@ -1,695 +0,0 @@
-package com.github.faucamp.simplertmp.io;
-
-import android.util.Log;
-
-import com.github.faucamp.simplertmp.RtmpPublisher;
-import com.github.faucamp.simplertmp.Util;
-import com.github.faucamp.simplertmp.amf.AmfMap;
-import com.github.faucamp.simplertmp.amf.AmfNull;
-import com.github.faucamp.simplertmp.amf.AmfNumber;
-import com.github.faucamp.simplertmp.amf.AmfObject;
-import com.github.faucamp.simplertmp.amf.AmfString;
-import com.github.faucamp.simplertmp.packets.Abort;
-import com.github.faucamp.simplertmp.packets.Audio;
-import com.github.faucamp.simplertmp.packets.Command;
-import com.github.faucamp.simplertmp.packets.Data;
-import com.github.faucamp.simplertmp.packets.Handshake;
-import com.github.faucamp.simplertmp.packets.RtmpPacket;
-import com.github.faucamp.simplertmp.packets.SetPeerBandwidth;
-import com.github.faucamp.simplertmp.packets.UserControl;
-import com.github.faucamp.simplertmp.packets.Video;
-import com.github.faucamp.simplertmp.packets.WindowAckSize;
-import java.io.BufferedInputStream;
-import java.io.BufferedOutputStream;
-import java.io.EOFException;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-import java.net.InetSocketAddress;
-import java.net.Socket;
-import java.net.SocketAddress;
-import java.net.SocketException;
-import java.util.Random;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-import net.ossrs.rtmp.BitrateManager;
-import net.ossrs.rtmp.ConnectCheckerRtmp;
-import net.ossrs.rtmp.CreateSSLSocket;
-
-/**
- * Main RTMP connection implementation class
- *
- * @author francois, leoma, pedro
- */
-public class RtmpConnection implements RtmpPublisher {
-
- private static final String TAG = "RtmpConnection";
- private static final Pattern rtmpUrlPattern =
- Pattern.compile("^rtmps?://([^/:]+)(?::(\\d+))*/([^/]+)/?([^*]*)$");
-
- private int port;
- private String host;
- private String appName;
- private String streamName;
- private String publishType;
- private String swfUrl;
- private String tcUrl;
- private String pageUrl;
- private Socket socket;
- private RtmpSessionInfo rtmpSessionInfo;
- private RtmpDecoder rtmpDecoder;
- private BufferedInputStream inputStream;
- private BufferedOutputStream outputStream;
- private Thread rxPacketHandler;
- private volatile boolean connected = false;
- private volatile boolean publishPermitted = false;
- private final Object connectingLock = new Object();
- private final Object publishLock = new Object();
- private int currentStreamId = 0;
- private int transactionIdCounter = 0;
- private int videoWidth;
- private int videoHeight;
- private ConnectCheckerRtmp connectCheckerRtmp;
- //for secure transport
- private boolean tlsEnabled;
- //for auth
- private String user = null;
- private String password = null;
- private String salt = null;
- private String challenge = null;
- private String opaque = null;
- private boolean onAuth = false;
- private String netConnectionDescription;
- private BitrateManager bitrateManager;
-
- public RtmpConnection(ConnectCheckerRtmp connectCheckerRtmp) {
- this.connectCheckerRtmp = connectCheckerRtmp;
- bitrateManager = new BitrateManager(connectCheckerRtmp);
- }
-
- private void handshake(InputStream in, OutputStream out) throws IOException {
- Handshake handshake = new Handshake();
- handshake.writeC0(out);
- handshake.writeC1(out); // Write C1 without waiting for S0
- out.flush();
- handshake.readS0(in);
- handshake.readS1(in);
- handshake.writeC2(out);
- out.flush();
- handshake.readS2(in);
- }
-
- @Override
- public boolean connect(String url) {
- Matcher rtmpMatcher = rtmpUrlPattern.matcher(url);
- if (rtmpMatcher.matches()) {
- tlsEnabled = rtmpMatcher.group(0).startsWith("rtmps");
- } else {
- connectCheckerRtmp.onConnectionFailedRtmp(
- "Endpoint malformed, should be: rtmp://ip:port/appname/streamname");
- return false;
- }
-
- swfUrl = "";
- pageUrl = "";
- host = rtmpMatcher.group(1);
- String portStr = rtmpMatcher.group(2);
- port = portStr != null ? Integer.parseInt(portStr) : 1935;
- appName = rtmpMatcher.group(3);
- streamName = rtmpMatcher.group(4);
- tcUrl = rtmpMatcher.group(0).substring(0, rtmpMatcher.group(0).length() - streamName.length());
-
- // socket connection
- Log.d(TAG, "connect() called. Host: "
- + host
- + ", port: "
- + port
- + ", appName: "
- + appName
- + ", publishPath: "
- + streamName);
- rtmpSessionInfo = new RtmpSessionInfo();
- rtmpDecoder = new RtmpDecoder(rtmpSessionInfo);
- try {
- if (!tlsEnabled) {
- socket = new Socket();
- SocketAddress socketAddress = new InetSocketAddress(host, port);
- socket.connect(socketAddress, 5000);
- } else {
- socket = CreateSSLSocket.createSSlSocket(host, port);
- if (socket == null) throw new IOException("Socket creation failed");
- }
- inputStream = new BufferedInputStream(socket.getInputStream());
- outputStream = new BufferedOutputStream(socket.getOutputStream());
- Log.d(TAG, "connect(): socket connection established, doing handhake...");
- handshake(inputStream, outputStream);
- Log.d(TAG, "connect(): handshake done");
- } catch (IOException e) {
- Log.e(TAG, "Error", e);
- connectCheckerRtmp.onConnectionFailedRtmp("Connect error, " + e.getMessage());
- return false;
- }
-
- // Start the "main" handling thread
- rxPacketHandler = new Thread(new Runnable() {
-
- @Override
- public void run() {
- Log.d(TAG, "starting main rx handler loop");
- handleRxPacketLoop();
- }
- });
- rxPacketHandler.start();
- return rtmpConnect();
- }
-
- private boolean rtmpConnect() {
- if (connected) {
- connectCheckerRtmp.onConnectionFailedRtmp("Already connected");
- return false;
- }
-
- if (user != null && password != null) {
- sendConnect("?authmod=adobe&user=" + user);
- } else {
- sendConnect("");
- }
- synchronized (connectingLock) {
- try {
- connectingLock.wait(5000);
- } catch (InterruptedException ex) {
- // do nothing
- }
- }
- if (!connected) {
- shutdown(true);
- connectCheckerRtmp.onConnectionFailedRtmp("Fail to connect, time out");
- }
- return connected;
- }
-
- private void sendConnect(String user) {
- ChunkStreamInfo.markSessionTimestampTx();
- Log.d(TAG, "rtmpConnect(): Building 'connect' invoke packet");
- ChunkStreamInfo chunkStreamInfo =
- rtmpSessionInfo.getChunkStreamInfo(ChunkStreamInfo.RTMP_CID_OVER_STREAM);
- Command invoke = new Command("connect", ++transactionIdCounter, chunkStreamInfo);
- invoke.getHeader().setMessageStreamId(0);
- AmfObject args = new AmfObject();
- args.setProperty("app", appName + user);
- args.setProperty("flashVer", "FMLE/3.0 (compatible; Lavf57.56.101)");
- args.setProperty("swfUrl", swfUrl);
- args.setProperty("tcUrl", tcUrl + user);
- args.setProperty("fpad", false);
- args.setProperty("capabilities", 239);
- args.setProperty("audioCodecs", 3191);
- args.setProperty("videoCodecs", 252);
- args.setProperty("videoFunction", 1);
- args.setProperty("pageUrl", pageUrl);
- args.setProperty("objectEncoding", 0);
- invoke.addData(args);
- sendRtmpPacket(invoke);
- }
-
- private String getAuthUserResult(String user, String password, String salt,
- String challenge, String opaque) {
- String challenge2 = String.format("%08x", new Random().nextInt());
- String response = Util.stringToMD5BASE64(user + salt + password);
- if (!opaque.isEmpty()) {
- response += opaque;
- } else if (!challenge.isEmpty()) {
- response += challenge;
- }
- response = Util.stringToMD5BASE64(response + challenge2);
- String result =
- "?authmod=adobe&user=" + user + "&challenge=" + challenge2 + "&response=" + response;
- if (!opaque.isEmpty()) {
- result += "&opaque=" + opaque;
- }
- return result;
- }
-
- @Override
- public boolean publish(String type) {
- if (type == null) {
- connectCheckerRtmp.onConnectionFailedRtmp("Null publish type");
- return false;
- }
- publishType = type;
- return createStream();
- }
-
- private boolean createStream() {
- if (!connected || currentStreamId != 0) {
- connectCheckerRtmp.onConnectionFailedRtmp(
- "Create stream failed, connected= " + connected + ", StreamId= " + currentStreamId);
- return false;
- }
- netConnectionDescription = null;
-
- Log.d(TAG, "createStream(): Sending releaseStream command...");
- // transactionId == 2
- Command releaseStream = new Command("releaseStream", ++transactionIdCounter);
- releaseStream.getHeader().setChunkStreamId(ChunkStreamInfo.RTMP_CID_OVER_STREAM);
- releaseStream.addData(new AmfNull()); // command object: null for "createStream"
- releaseStream.addData(streamName); // command object: null for "releaseStream"
- sendRtmpPacket(releaseStream);
-
- Log.d(TAG, "createStream(): Sending FCPublish command...");
- // transactionId == 3
- Command FCPublish = new Command("FCPublish", ++transactionIdCounter);
- FCPublish.getHeader().setChunkStreamId(ChunkStreamInfo.RTMP_CID_OVER_STREAM);
- FCPublish.addData(new AmfNull()); // command object: null for "FCPublish"
- FCPublish.addData(streamName);
- sendRtmpPacket(FCPublish);
-
- Log.d(TAG, "createStream(): Sending createStream command...");
- ChunkStreamInfo chunkStreamInfo =
- rtmpSessionInfo.getChunkStreamInfo(ChunkStreamInfo.RTMP_CID_OVER_CONNECTION);
- // transactionId == 4
- Command createStream = new Command("createStream", ++transactionIdCounter, chunkStreamInfo);
- createStream.addData(new AmfNull()); // command object: null for "createStream"
- sendRtmpPacket(createStream);
-
- // Waiting for "NetStream.Publish.Start" response.
- synchronized (publishLock) {
- try {
- publishLock.wait(5000);
- } catch (InterruptedException ex) {
- // do nothing
- }
- }
- if (!publishPermitted) {
- shutdown(true);
- if (netConnectionDescription != null && !netConnectionDescription.isEmpty()) {
- connectCheckerRtmp.onConnectionFailedRtmp(netConnectionDescription);
- } else {
- connectCheckerRtmp.onConnectionFailedRtmp(
- "Error configure stream, publish permitted failed");
- }
- }
- return publishPermitted;
- }
-
- private void fmlePublish() {
- if (!connected || currentStreamId == 0) {
- Log.e(TAG, "fmlePublish failed");
- return;
- }
-
- Log.d(TAG, "fmlePublish(): Sending publish command...");
- Command publish = new Command("publish", 0);
- publish.getHeader().setChunkStreamId(ChunkStreamInfo.RTMP_CID_OVER_STREAM);
- publish.getHeader().setMessageStreamId(currentStreamId);
- publish.addData(new AmfNull()); // command object: null for "publish"
- publish.addData(streamName);
- publish.addData(publishType);
- sendRtmpPacket(publish);
- }
-
- private void onMetaData() {
- if (!connected || currentStreamId == 0) {
- Log.e(TAG, "onMetaData failed");
- return;
- }
-
- Log.d(TAG, "onMetaData(): Sending empty onMetaData...");
- Data metadata = new Data("@setDataFrame");
- metadata.getHeader().setMessageStreamId(currentStreamId);
- metadata.addData("onMetaData");
- AmfMap ecmaArray = new AmfMap();
- ecmaArray.setProperty("duration", 0);
- ecmaArray.setProperty("width", videoWidth);
- ecmaArray.setProperty("height", videoHeight);
- ecmaArray.setProperty("videocodecid", 7);
- ecmaArray.setProperty("framerate", 30);
- ecmaArray.setProperty("videodatarate", 0);
- // @see FLV video_file_format_spec_v10_1.pdf
- // According to E.4.2.1 AUDIODATA
- // "If the SoundFormat indicates AAC, the SoundType should be 1 (stereo) and the SoundRate should be 3 (44 kHz).
- // However, this does not mean that AAC audio in FLV is always stereo, 44 kHz data. Instead, the Flash Player ignores
- // these values and extracts the channel and sample rate data is encoded in the AAC bit stream."
- ecmaArray.setProperty("audiocodecid", 10);
- ecmaArray.setProperty("audiosamplerate", 44100);
- ecmaArray.setProperty("audiosamplesize", 16);
- ecmaArray.setProperty("audiodatarate", 0);
- ecmaArray.setProperty("stereo", true);
- ecmaArray.setProperty("filesize", 0);
- metadata.addData(ecmaArray);
- sendRtmpPacket(metadata);
- }
-
- @Override
- public void close() {
- if (socket != null) {
- closeStream();
- }
- shutdown(true);
- }
-
- private void closeStream() {
- if (!connected || currentStreamId == 0 || !publishPermitted) {
- Log.e(TAG, "closeStream failed");
- return;
- }
- Log.d(TAG, "closeStream(): setting current stream ID to 0");
- Command closeStream = new Command("closeStream", 0);
- closeStream.getHeader().setChunkStreamId(ChunkStreamInfo.RTMP_CID_OVER_STREAM);
- closeStream.getHeader().setMessageStreamId(currentStreamId);
- closeStream.addData(new AmfNull());
- sendRtmpPacket(closeStream);
- }
-
- private synchronized void shutdown(boolean r) {
- if (socket != null) {
- try {
- // It will raise EOFException in handleRxPacketThread
- socket.shutdownInput();
- // It will raise SocketException in sendRtmpPacket
- socket.shutdownOutput();
- } catch (IOException | UnsupportedOperationException e) {
- Log.e(TAG, "Shutdown socket", e);
- }
-
- // shutdown rxPacketHandler
- if (rxPacketHandler != null) {
- rxPacketHandler.interrupt();
- try {
- rxPacketHandler.join(100);
- } catch (InterruptedException ie) {
- rxPacketHandler.interrupt();
- }
- rxPacketHandler = null;
- }
-
- // shutdown socket as well as its input and output stream
- try {
- socket.close();
- Log.d(TAG, "socket closed");
- } catch (IOException ex) {
- Log.e(TAG, "shutdown(): failed to close socket", ex);
- }
- }
-
- if (r) {
- reset();
- }
- }
-
- private void reset() {
- connected = false;
- publishPermitted = false;
- netConnectionDescription = null;
- tcUrl = null;
- swfUrl = null;
- pageUrl = null;
- appName = null;
- streamName = null;
- publishType = null;
- currentStreamId = 0;
- transactionIdCounter = 0;
- socket = null;
- rtmpSessionInfo = null;
- user = null;
- password = null;
- salt = null;
- challenge = null;
- opaque = null;
- }
-
- @Override
- public void publishAudioData(byte[] data, int size, int dts) {
- if (data == null
- || data.length == 0
- || dts < 0
- || !connected
- || currentStreamId == 0
- || !publishPermitted) {
- return;
- }
- Audio audio = new Audio();
- audio.setData(data, size);
- audio.getHeader().setAbsoluteTimestamp(dts);
- audio.getHeader().setMessageStreamId(currentStreamId);
- sendRtmpPacket(audio);
- //bytes to bits
- bitrateManager.calculateBitrate(size * 8);
- }
-
- @Override
- public void publishVideoData(byte[] data, int size, int dts) {
- if (data == null
- || data.length == 0
- || dts < 0
- || !connected
- || currentStreamId == 0
- || !publishPermitted) {
- return;
- }
- Video video = new Video();
- video.setData(data, size);
- video.getHeader().setAbsoluteTimestamp(dts);
- video.getHeader().setMessageStreamId(currentStreamId);
- sendRtmpPacket(video);
- //bytes to bits
- bitrateManager.calculateBitrate(size * 8);
- }
-
- private void sendRtmpPacket(RtmpPacket rtmpPacket) {
- try {
- ChunkStreamInfo chunkStreamInfo =
- rtmpSessionInfo.getChunkStreamInfo(rtmpPacket.getHeader().getChunkStreamId());
- chunkStreamInfo.setPrevHeaderTx(rtmpPacket.getHeader());
- if (!(rtmpPacket instanceof Video || rtmpPacket instanceof Audio)) {
- rtmpPacket.getHeader()
- .setAbsoluteTimestamp((int) chunkStreamInfo.markAbsoluteTimestampTx());
- }
- rtmpPacket.writeTo(outputStream, rtmpSessionInfo.getTxChunkSize(), chunkStreamInfo);
- Log.d(TAG,
- "wrote packet: " + rtmpPacket + ", size: " + rtmpPacket.getHeader().getPacketLength());
- if (rtmpPacket instanceof Command) {
- rtmpSessionInfo.addInvokedCommand(((Command) rtmpPacket).getTransactionId(),
- ((Command) rtmpPacket).getCommandName());
- }
- outputStream.flush();
- } catch (SocketException ignored) {
- } catch (IOException ioe) {
- connectCheckerRtmp.onConnectionFailedRtmp("Error send packet: " + ioe.getMessage());
- Log.e(TAG, "Caught IOException during write loop, shutting down: " + ioe.getMessage());
- Thread.currentThread().interrupt();
- }
- }
-
- private void handleRxPacketLoop() {
- // Handle all queued received RTMP packets
- while (!Thread.interrupted()) {
- try {
- // It will be blocked when no data in input stream buffer
- RtmpPacket rtmpPacket = rtmpDecoder.readPacket(inputStream);
- if (rtmpPacket != null) {
- //Log.d(TAG, "handleRxPacketLoop(): RTMP rx packet message type: " + rtmpPacket.getHeader().getMessageType());
- switch (rtmpPacket.getHeader().getMessageType()) {
- case ABORT:
- rtmpSessionInfo.getChunkStreamInfo(((Abort) rtmpPacket).getChunkStreamId())
- .clearStoredChunks();
- break;
- case USER_CONTROL_MESSAGE:
- UserControl user = (UserControl) rtmpPacket;
- switch (user.getType()) {
- case STREAM_BEGIN:
- break;
- case PING_REQUEST:
- ChunkStreamInfo channelInfo =
- rtmpSessionInfo.getChunkStreamInfo(ChunkStreamInfo.RTMP_CID_PROTOCOL_CONTROL);
- Log.d(TAG, "handleRxPacketLoop(): Sending PONG reply..");
- UserControl pong = new UserControl(user, channelInfo);
- sendRtmpPacket(pong);
- break;
- case STREAM_EOF:
- Log.i(TAG, "handleRxPacketLoop(): Stream EOF reached, closing RTMP writer...");
- break;
- default:
- // Ignore...
- break;
- }
- break;
- case WINDOW_ACKNOWLEDGEMENT_SIZE:
- WindowAckSize windowAckSize = (WindowAckSize) rtmpPacket;
- int size = windowAckSize.getAcknowledgementWindowSize();
- Log.d(TAG, "handleRxPacketLoop(): Setting acknowledgement window size: " + size);
- rtmpSessionInfo.setAcknowledgmentWindowSize(size);
- break;
- case SET_PEER_BANDWIDTH:
- rtmpSessionInfo.setAcknowledgmentWindowSize(socket.getSendBufferSize());
- int acknowledgementWindowsize = rtmpSessionInfo.getAcknowledgementWindowSize();
- ChunkStreamInfo chunkStreamInfo =
- rtmpSessionInfo.getChunkStreamInfo(ChunkStreamInfo.RTMP_CID_PROTOCOL_CONTROL);
- Log.d(TAG, "handleRxPacketLoop(): Send acknowledgement window size: "
- + acknowledgementWindowsize);
- sendRtmpPacket(new WindowAckSize(acknowledgementWindowsize, chunkStreamInfo));
- // Set socket option. This line could produce bps calculation problems.
- socket.setSendBufferSize(acknowledgementWindowsize);
- break;
- case COMMAND_AMF0:
- handleRxInvoke((Command) rtmpPacket);
- break;
- default:
- Log.w(TAG, "handleRxPacketLoop(): Not handling unimplemented/unknown packet of type: "
- + rtmpPacket.getHeader().getMessageType());
- break;
- }
- }
- } catch (EOFException eof) {
- Thread.currentThread().interrupt();
- } catch (IOException e) {
- connectCheckerRtmp.onConnectionFailedRtmp("Error reading packet: " + e.getMessage());
- Log.e(TAG, "Caught SocketException while reading/decoding packet, shutting down: "
- + e.getMessage());
- Thread.currentThread().interrupt();
- }
- }
- }
-
- private void handleRxInvoke(Command invoke) {
- String commandName = invoke.getCommandName();
- switch (commandName) {
- case "_error":
- try {
- String description = ((AmfString) ((AmfObject) invoke.getData().get(1)).getProperty(
- "description")).getValue();
- Log.i(TAG, description);
- if (description.contains("reason=authfailed")) {
- connectCheckerRtmp.onAuthErrorRtmp();
- connected = false;
- synchronized (connectingLock) {
- connectingLock.notifyAll();
- }
- } else if (user != null
- && password != null
- && description.contains("challenge=")
- && description.contains("salt=")) {
- onAuth = true;
- try {
- shutdown(false);
- } catch (Exception e) {
- e.printStackTrace();
- }
- rtmpSessionInfo = new RtmpSessionInfo();
- rtmpDecoder = new RtmpDecoder(rtmpSessionInfo);
- if (!tlsEnabled) {
- socket = new Socket(host, port);
- } else {
- socket = CreateSSLSocket.createSSlSocket(host, port);
- if (socket == null) throw new IOException("Socket creation failed");
- }
- inputStream = new BufferedInputStream(socket.getInputStream());
- outputStream = new BufferedOutputStream(socket.getOutputStream());
- Log.d(TAG, "connect(): socket connection established, doing handshake...");
- salt = Util.getSalt(description);
- challenge = Util.getChallenge(description);
- opaque = Util.getOpaque(description);
- handshake(inputStream, outputStream);
- rxPacketHandler = new Thread(new Runnable() {
- @Override
- public void run() {
- handleRxPacketLoop();
- }
- });
- rxPacketHandler.start();
- sendConnect(getAuthUserResult(user, password, salt, challenge, opaque));
- } else if (description.contains("code=403") && user == null || password == null) {
- connectCheckerRtmp.onAuthErrorRtmp();
- connected = false;
- synchronized (connectingLock) {
- connectingLock.notifyAll();
- }
- } else {
- connectCheckerRtmp.onConnectionFailedRtmp(description);
- connected = false;
- synchronized (connectingLock) {
- connectingLock.notifyAll();
- }
- }
- } catch (Exception e) {
- connectCheckerRtmp.onConnectionFailedRtmp(e.getMessage());
- connected = false;
- synchronized (connectingLock) {
- connectingLock.notifyAll();
- }
- }
- break;
- case "_result":
- // This is the result of one of the methods invoked by us
- String method = rtmpSessionInfo.takeInvokedCommand(invoke.getTransactionId());
-
- Log.i(TAG, "handleRxInvoke: Got result for invoked method: " + method);
- if ("connect".equals(method)) {
- if (onAuth) {
- connectCheckerRtmp.onAuthSuccessRtmp();
- onAuth = false;
- }
- // Capture server ip/pid/id information if any
- // We can now send createStream commands
- connected = true;
- synchronized (connectingLock) {
- connectingLock.notifyAll();
- }
- } else if ("createStream".contains(method)) {
- // Get stream id
- currentStreamId = (int) ((AmfNumber) invoke.getData().get(1)).getValue();
- Log.d(TAG, "handleRxInvoke(): Stream ID to publish: " + currentStreamId);
- if (streamName != null && publishType != null) {
- fmlePublish();
- }
- } else if ("releaseStream".contains(method)) {
- Log.d(TAG, "handleRxInvoke(): 'releaseStream'");
- } else if ("FCPublish".contains(method)) {
- Log.d(TAG, "handleRxInvoke(): 'FCPublish'");
- } else {
- Log.w(TAG, "handleRxInvoke(): '_result' message received for unknown method: " + method);
- }
- break;
- case "onBWDone":
- Log.d(TAG, "handleRxInvoke(): 'onBWDone'");
- break;
- case "onFCPublish":
- Log.d(TAG, "handleRxInvoke(): 'onFCPublish'");
- break;
- case "onStatus":
- String code =
- ((AmfString) ((AmfObject) invoke.getData().get(1)).getProperty("code")).getValue();
- Log.d(TAG, "handleRxInvoke(): onStatus " + code);
- if (code.equals("NetStream.Publish.Start")) {
- onMetaData();
- // We can now publish AV data
- publishPermitted = true;
- synchronized (publishLock) {
- publishLock.notifyAll();
- }
- } else if (code.equals("NetConnection.Connect.Rejected")) {
- netConnectionDescription = ((AmfString) ((AmfObject) invoke.getData().get(1)).getProperty(
- "description")).getValue();
- publishPermitted = false;
- synchronized (publishLock) {
- publishLock.notifyAll();
- }
- }
- break;
- default:
- Log.e(TAG, "handleRxInvoke(): Unknown/unhandled server invoke: " + invoke);
- break;
- }
- }
-
- @Override
- public void setVideoResolution(int width, int height) {
- videoWidth = width;
- videoHeight = height;
- }
-
- @Override
- public void setAuthorization(String user, String password) {
- this.user = user;
- this.password = password;
- }
-}
diff --git a/rtmp/src/main/java/com/github/faucamp/simplertmp/io/RtmpDecoder.java b/rtmp/src/main/java/com/github/faucamp/simplertmp/io/RtmpDecoder.java
deleted file mode 100644
index fd82cf6..0000000
--- a/rtmp/src/main/java/com/github/faucamp/simplertmp/io/RtmpDecoder.java
+++ /dev/null
@@ -1,96 +0,0 @@
-package com.github.faucamp.simplertmp.io;
-
-import java.io.IOException;
-import java.io.InputStream;
-
-import android.util.Log;
-
-import com.github.faucamp.simplertmp.packets.Abort;
-import com.github.faucamp.simplertmp.packets.Audio;
-import com.github.faucamp.simplertmp.packets.Command;
-import com.github.faucamp.simplertmp.packets.Data;
-import com.github.faucamp.simplertmp.packets.RtmpHeader;
-import com.github.faucamp.simplertmp.packets.RtmpPacket;
-import com.github.faucamp.simplertmp.packets.SetChunkSize;
-import com.github.faucamp.simplertmp.packets.SetPeerBandwidth;
-import com.github.faucamp.simplertmp.packets.UserControl;
-import com.github.faucamp.simplertmp.packets.Video;
-import com.github.faucamp.simplertmp.packets.WindowAckSize;
-import com.github.faucamp.simplertmp.packets.Acknowledgement;
-
-/**
- * @author francois
- */
-public class RtmpDecoder {
-
- private static final String TAG = "RtmpDecoder";
-
- private RtmpSessionInfo rtmpSessionInfo;
-
- public RtmpDecoder(RtmpSessionInfo rtmpSessionInfo) {
- this.rtmpSessionInfo = rtmpSessionInfo;
- }
-
- public RtmpPacket readPacket(InputStream in) throws IOException {
-
- RtmpHeader header = RtmpHeader.readHeader(in, rtmpSessionInfo);
- // Log.d(TAG, "readPacket(): header.messageType: " + header.getMessageType());
-
- ChunkStreamInfo chunkStreamInfo = rtmpSessionInfo.getChunkStreamInfo(header.getChunkStreamId());
- chunkStreamInfo.setPrevHeaderRx(header);
-
- if (header.getPacketLength() > rtmpSessionInfo.getRxChunkSize()) {
- // If the packet consists of more than one chunk,
- // store the chunks in the chunk stream until everything is read
- if (!chunkStreamInfo.storePacketChunk(in, rtmpSessionInfo.getRxChunkSize())) {
- // return null because of incomplete packet
- return null;
- } else {
- // stored chunks complete packet, get the input stream of the chunk stream
- in = chunkStreamInfo.getStoredPacketInputStream();
- }
- }
-
- RtmpPacket rtmpPacket;
- switch (header.getMessageType()) {
- case SET_CHUNK_SIZE:
- SetChunkSize setChunkSize = new SetChunkSize(header);
- setChunkSize.readBody(in);
- Log.d(TAG, "readPacket(): Setting chunk size to: " + setChunkSize.getChunkSize());
- rtmpSessionInfo.setRxChunkSize(setChunkSize.getChunkSize());
- return null;
- case ABORT:
- rtmpPacket = new Abort(header);
- break;
- case USER_CONTROL_MESSAGE:
- rtmpPacket = new UserControl(header);
- break;
- case WINDOW_ACKNOWLEDGEMENT_SIZE:
- rtmpPacket = new WindowAckSize(header);
- break;
- case SET_PEER_BANDWIDTH:
- rtmpPacket = new SetPeerBandwidth(header);
- break;
- case AUDIO:
- rtmpPacket = new Audio(header);
- break;
- case VIDEO:
- rtmpPacket = new Video(header);
- break;
- case COMMAND_AMF0:
- rtmpPacket = new Command(header);
- break;
- case DATA_AMF0:
- rtmpPacket = new Data(header);
- break;
- case ACKNOWLEDGEMENT:
- rtmpPacket = new Acknowledgement(header);
- break;
- default:
- throw new IOException(
- "No packet body implementation for message type: " + header.getMessageType());
- }
- rtmpPacket.readBody(in);
- return rtmpPacket;
- }
-}
diff --git a/rtmp/src/main/java/com/github/faucamp/simplertmp/io/RtmpSessionInfo.java b/rtmp/src/main/java/com/github/faucamp/simplertmp/io/RtmpSessionInfo.java
deleted file mode 100644
index aa32cc7..0000000
--- a/rtmp/src/main/java/com/github/faucamp/simplertmp/io/RtmpSessionInfo.java
+++ /dev/null
@@ -1,83 +0,0 @@
-package com.github.faucamp.simplertmp.io;
-
-import java.util.HashMap;
-import java.util.Map;
-import java.util.concurrent.ConcurrentHashMap;
-
-import com.github.faucamp.simplertmp.packets.RtmpPacket;
-
-/**
- * @author francois
- */
-public class RtmpSessionInfo {
-
- /** The (total) number of bytes read for this window (resets to 0 if the agreed-upon RTMP window acknowledgement size is reached) */
- private int windowBytesRead;
- /** The window acknowledgement size for this RTMP session, in bytes; default to max to avoid unnecessary "Acknowledgment" messages from being sent */
- private int acknowledgementWindowSize = Integer.MAX_VALUE;
- /** Used internally to store the total number of bytes read (used when sending Acknowledgement messages) */
- private int totalBytesRead = 0;
-
- /** Default chunk size is 128 bytes */
- private int rxChunkSize = 128;
- private int txChunkSize = 128;
- private Maptrue if an "acknowledgement" packet should be sent, false otherwise
- */
- public final void addToWindowBytesRead(final int numBytes, final RtmpPacket packet)
- throws WindowAckRequired {
- windowBytesRead += numBytes;
- totalBytesRead += numBytes;
- if (windowBytesRead >= acknowledgementWindowSize) {
- windowBytesRead -= acknowledgementWindowSize;
- throw new WindowAckRequired(totalBytesRead, packet);
- }
- }
-}
diff --git a/rtmp/src/main/java/com/github/faucamp/simplertmp/io/WindowAckRequired.java b/rtmp/src/main/java/com/github/faucamp/simplertmp/io/WindowAckRequired.java
deleted file mode 100644
index 4431f36..0000000
--- a/rtmp/src/main/java/com/github/faucamp/simplertmp/io/WindowAckRequired.java
+++ /dev/null
@@ -1,40 +0,0 @@
-package com.github.faucamp.simplertmp.io;
-
-import com.github.faucamp.simplertmp.packets.RtmpPacket;
-
-/**
- * Thrown by RTMP read thread when an Acknowledgement packet needs to be sent
- * to acknowledge the RTMP window size. It contains the RTMP packet that was
- * read when this event occurred (if any).
- *
- * @author francois
- */
-public class WindowAckRequired extends Exception {
-
- private RtmpPacket rtmpPacket;
- private int bytesRead;
-
- /**
- * Used when the window acknowledgement size was reached, whilst fully reading
- * an RTMP packet or not. If a packet is present, it should still be handled as if it was returned
- * by the RTMP decoder.
- *
- * @param bytesReadThusFar The (total) number of bytes received so far
- * @param rtmpPacket The packet that was read (and thus should be handled), can be null
- */
- public WindowAckRequired(int bytesReadThusFar, RtmpPacket rtmpPacket) {
- this.rtmpPacket = rtmpPacket;
- this.bytesRead = bytesReadThusFar;
- }
-
- /**
- * @return The RTMP packet that should be handled, or null if no full packet is available
- */
- public RtmpPacket getRtmpPacket() {
- return rtmpPacket;
- }
-
- public int getBytesRead() {
- return bytesRead;
- }
-}
diff --git a/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/Abort.java b/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/Abort.java
deleted file mode 100644
index 520f184..0000000
--- a/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/Abort.java
+++ /dev/null
@@ -1,59 +0,0 @@
-package com.github.faucamp.simplertmp.packets;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-
-import com.github.faucamp.simplertmp.Util;
-import com.github.faucamp.simplertmp.io.ChunkStreamInfo;
-
-/**
- * A "Abort" RTMP control message, received on chunk stream ID 2 (control channel)
- *
- * @author francois
- */
-public class Abort extends RtmpPacket {
-
- private int chunkStreamId;
-
- public Abort(RtmpHeader header) {
- super(header);
- }
-
- public Abort(int chunkStreamId) {
- super(new RtmpHeader(RtmpHeader.ChunkType.TYPE_1_RELATIVE_LARGE,
- ChunkStreamInfo.RTMP_CID_PROTOCOL_CONTROL, RtmpHeader.MessageType.SET_CHUNK_SIZE));
- this.chunkStreamId = chunkStreamId;
- }
-
- /** @return the ID of the chunk stream to be aborted */
- public int getChunkStreamId() {
- return chunkStreamId;
- }
-
- /** Sets the ID of the chunk stream to be aborted */
- public void setChunkStreamId(int chunkStreamId) {
- this.chunkStreamId = chunkStreamId;
- }
-
- @Override
- public void readBody(InputStream in) throws IOException {
- // Value is received in the 4 bytes of the body
- chunkStreamId = Util.readUnsignedInt32(in);
- }
-
- @Override
- protected byte[] array() {
- return null;
- }
-
- @Override
- protected int size() {
- return 0;
- }
-
- @Override
- protected void writeBody(OutputStream out) throws IOException {
- Util.writeUnsignedInt32(out, chunkStreamId);
- }
-}
diff --git a/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/Acknowledgement.java b/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/Acknowledgement.java
deleted file mode 100644
index 9f13b53..0000000
--- a/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/Acknowledgement.java
+++ /dev/null
@@ -1,75 +0,0 @@
-package com.github.faucamp.simplertmp.packets;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-
-import com.github.faucamp.simplertmp.Util;
-import com.github.faucamp.simplertmp.io.ChunkStreamInfo;
-
-/**
- * (Window) Acknowledgement
- *
- * The client or the server sends the acknowledgment to the peer after
- * receiving bytes equal to the window size. The window size is the
- * maximum number of bytes that the sender sends without receiving
- * acknowledgment from the receiver. The server sends the window size to
- * the client after application connects. This message specifies the
- * sequence number, which is the number of the bytes received so far.
- *
- * @author francois
- */
-public class Acknowledgement extends RtmpPacket {
-
- private int sequenceNumber;
-
- public Acknowledgement(RtmpHeader header) {
- super(header);
- }
-
- public Acknowledgement(int numBytesReadThusFar) {
- super(
- new RtmpHeader(RtmpHeader.ChunkType.TYPE_0_FULL, ChunkStreamInfo.RTMP_CID_PROTOCOL_CONTROL,
- RtmpHeader.MessageType.ACKNOWLEDGEMENT));
- this.sequenceNumber = numBytesReadThusFar;
- }
-
- public int getAcknowledgementWindowSize() {
- return sequenceNumber;
- }
-
- /** @return the sequence number, which is the number of the bytes received so far */
- public int getSequenceNumber() {
- return sequenceNumber;
- }
-
- /** Sets the sequence number, which is the number of the bytes received so far */
- public void setSequenceNumber(int numBytesRead) {
- this.sequenceNumber = numBytesRead;
- }
-
- @Override
- public void readBody(InputStream in) throws IOException {
- sequenceNumber = Util.readUnsignedInt32(in);
- }
-
- @Override
- protected void writeBody(OutputStream out) throws IOException {
- Util.writeUnsignedInt32(out, sequenceNumber);
- }
-
- @Override
- protected byte[] array() {
- return null;
- }
-
- @Override
- protected int size() {
- return 0;
- }
-
- @Override
- public String toString() {
- return "RTMP Acknowledgment (sequence number: " + sequenceNumber + ")";
- }
-}
diff --git a/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/Audio.java b/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/Audio.java
deleted file mode 100644
index b436a7e..0000000
--- a/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/Audio.java
+++ /dev/null
@@ -1,25 +0,0 @@
-package com.github.faucamp.simplertmp.packets;
-
-import com.github.faucamp.simplertmp.io.ChunkStreamInfo;
-
-/**
- * Audio data packet
- *
- * @author francois
- */
-public class Audio extends ContentData {
-
- public Audio(RtmpHeader header) {
- super(header);
- }
-
- public Audio() {
- super(new RtmpHeader(RtmpHeader.ChunkType.TYPE_0_FULL, ChunkStreamInfo.RTMP_CID_AUDIO,
- RtmpHeader.MessageType.AUDIO));
- }
-
- @Override
- public String toString() {
- return "RTMP Audio";
- }
-}
diff --git a/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/Command.java b/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/Command.java
deleted file mode 100644
index 90122e0..0000000
--- a/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/Command.java
+++ /dev/null
@@ -1,94 +0,0 @@
-package com.github.faucamp.simplertmp.packets;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-
-import com.github.faucamp.simplertmp.amf.AmfNumber;
-import com.github.faucamp.simplertmp.amf.AmfString;
-import com.github.faucamp.simplertmp.io.ChunkStreamInfo;
-
-/**
- * Encapsulates an command/"invoke" RTMP packet
- *
- * Invoke/command packet structure (AMF encoded):
- * (String) getEventData()[0]
- */
- public int getFirstEventData() {
- return eventData[0];
- }
-
- public int[] getEventData() {
- return eventData;
- }
-
- /** Used to set (a single) event data for most user control message types */
- public void setEventData(int eventData) {
- if (type == Type.SET_BUFFER_LENGTH) {
- throw new IllegalStateException(
- "SET_BUFFER_LENGTH requires two event data values; use setEventData(int, int) instead");
- }
- this.eventData = new int[] { eventData };
- }
-
- /** Used to set event data for the SET_BUFFER_LENGTH user control message types */
- public void setEventData(int streamId, int bufferLength) {
- if (type != Type.SET_BUFFER_LENGTH) {
- throw new IllegalStateException("User control type "
- + type
- + " requires only one event data value; use setEventData(int) instead");
- }
- this.eventData = new int[] { streamId, bufferLength };
- }
-
- @Override
- public void readBody(InputStream in) throws IOException {
- // Bytes 0-1: first parameter: ping type (mandatory)
- type = Type.valueOf(Util.readUnsignedInt16(in));
- int bytesRead = 2;
- // Event data (1 for most types, 2 for SET_BUFFER_LENGTH)
- if (type == Type.SET_BUFFER_LENGTH) {
- setEventData(Util.readUnsignedInt32(in), Util.readUnsignedInt32(in));
- bytesRead += 8;
- } else {
- setEventData(Util.readUnsignedInt32(in));
- bytesRead += 4;
- }
- // To ensure some strange non-specified UserControl/ping message does not slip through
- assert header.getPacketLength() == bytesRead;
- }
-
- @Override
- protected void writeBody(OutputStream out) throws IOException {
- // Write the user control message type
- Util.writeUnsignedInt16(out, type.getIntValue());
- // Now write the event data
- Util.writeUnsignedInt32(out, eventData[0]);
- if (type == Type.SET_BUFFER_LENGTH) {
- Util.writeUnsignedInt32(out, eventData[1]);
- }
- }
-
- @Override
- protected byte[] array() {
- return null;
- }
-
- @Override
- protected int size() {
- return 0;
- }
-
- @Override
- public String toString() {
- return "RTMP User Control (type: " + type + ", event data: " + eventData + ")";
- }
-}
diff --git a/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/VariableBodyRtmpPacket.java b/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/VariableBodyRtmpPacket.java
deleted file mode 100644
index d4126fa..0000000
--- a/rtmp/src/main/java/com/github/faucamp/simplertmp/packets/VariableBodyRtmpPacket.java
+++ /dev/null
@@ -1,78 +0,0 @@
-package com.github.faucamp.simplertmp.packets;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-import java.util.ArrayList;
-import java.util.List;
-
-import com.github.faucamp.simplertmp.amf.AmfBoolean;
-import com.github.faucamp.simplertmp.amf.AmfData;
-import com.github.faucamp.simplertmp.amf.AmfDecoder;
-import com.github.faucamp.simplertmp.amf.AmfNull;
-import com.github.faucamp.simplertmp.amf.AmfNumber;
-import com.github.faucamp.simplertmp.amf.AmfString;
-
-/**
- * RTMP packet with a "variable" body structure (i.e. the structure of the
- * body depends on some other state/parameter in the packet.
- *
- * Examples of this type of packet are Command and Data; this abstract class
- * exists mostly for code re-use.
- *
- * @author francois
- */
-public abstract class VariableBodyRtmpPacket extends RtmpPacket {
-
- protected List
- *
- * @param individualAllocationSize The length of each individual {@link Allocation}.
- * @param initialAllocationCount The number of allocations to create up front.
- */
- public SrsAllocator(int individualAllocationSize, int initialAllocationCount) {
- this.individualAllocationSize = individualAllocationSize;
- this.availableSentinel = initialAllocationCount + 10;
- this.availableAllocations = new Allocation[availableSentinel];
- for (int i = 0; i < availableSentinel; i++) {
- availableAllocations[i] = new Allocation(individualAllocationSize);
- }
- }
-
- public synchronized Allocation allocate(int size) {
- for (int i = 0; i < availableSentinel; i++) {
- if (availableAllocations[i].size() >= size) {
- Allocation ret = availableAllocations[i];
- availableAllocations[i] = null;
- return ret;
- }
- }
-
- return new Allocation(size > individualAllocationSize ? size : individualAllocationSize);
- }
-
- public synchronized void release(Allocation allocation) {
- allocation.clear();
-
- for (int i = 0; i < availableSentinel; i++) {
- if (availableAllocations[i].size() == 0) {
- availableAllocations[i] = allocation;
- return;
- }
- }
-
- if (availableSentinel + 1 > availableAllocations.length) {
- availableAllocations = Arrays.copyOf(availableAllocations, availableAllocations.length * 2);
- }
- availableAllocations[availableSentinel++] = allocation;
- }
-}
\ No newline at end of file
diff --git a/rtmp/src/main/java/net/ossrs/rtmp/SrsFlvMuxer.java b/rtmp/src/main/java/net/ossrs/rtmp/SrsFlvMuxer.java
deleted file mode 100644
index e0d7cf6..0000000
--- a/rtmp/src/main/java/net/ossrs/rtmp/SrsFlvMuxer.java
+++ /dev/null
@@ -1,1048 +0,0 @@
-package net.ossrs.rtmp;
-
-import android.media.MediaCodec;
-import android.os.Handler;
-import android.os.Looper;
-import android.os.Process;
-import android.util.Log;
-import com.github.faucamp.simplertmp.DefaultRtmpPublisher;
-import com.github.faucamp.simplertmp.RtmpPublisher;
-
-import java.nio.ByteBuffer;
-import java.util.ArrayList;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.TimeUnit;
-
-/**
- * Created by winlin on 5/2/15.
- * Updated by leoma on 4/1/16.
- * modified by pedro
- * to POST the h.264/avc annexb frame over RTMP.
- * modified by Troy
- * to accept any RtmpPublisher implementation.
- *
- * Usage:
- * muxer = new SrsRtmp("rtmp://ossrs.net/live/yasea");
- * muxer.start();
- *
- * MediaFormat aformat = MediaFormat.createAudioFormat(MediaFormat.MIMETYPE_AUDIO_AAC, sampleRate,
- * achannel);
- * // setup the aformat for audio.
- * atrack = muxer.addTrack(aformat);
- *
- * MediaFormat vformat = MediaFormat.createVideoFormat(MediaFormat.MIMETYPE_VIDEO_AVC, vsize.width,
- * vsize.height);
- * // setup the vformat for video.
- * vtrack = muxer.addTrack(vformat);
- *
- * // encode the video frame from camera by h.264 codec to es and bi,
- * // where es is the h.264 ES(element stream).
- * ByteBuffer es, MediaCodec.BufferInfo bi;
- * muxer.writeSampleData(vtrack, es, bi);
- *
- * // encode the audio frame from microphone by aac codec to es and bi,
- * // where es is the aac ES(element stream).
- * ByteBuffer es, MediaCodec.BufferInfo bi;
- * muxer.writeSampleData(atrack, es, bi);
- *
- * muxer.stop();
- * muxer.release();
- */
-
-public class SrsFlvMuxer {
-
- private static final String TAG = "SrsFlvMuxer";
-
- private static final int VIDEO_ALLOC_SIZE = 128 * 1024;
- private static final int AUDIO_ALLOC_SIZE = 4 * 1024;
- private volatile boolean connected = false;
- private RtmpPublisher publisher;
- private Thread worker;
- private SrsFlv flv = new SrsFlv();
- private boolean needToFindKeyFrame = true;
- private SrsFlvFrame mVideoSequenceHeader;
- private SrsFlvFrame mAudioSequenceHeader;
- private SrsAllocator mVideoAllocator = new SrsAllocator(VIDEO_ALLOC_SIZE);
- private SrsAllocator mAudioAllocator = new SrsAllocator(AUDIO_ALLOC_SIZE);
- private volatile BlockingQueue