package com.basic.security.utils.socket;
|
|
import java.io.ByteArrayOutputStream;
|
import java.util.LinkedList;
|
|
public class YuvFrameQueue {
|
private final int mFrameLength;
|
byte[] data11 = new byte[460800];
|
private int mTotalLength = 0;
|
private ByteArrayOutputStream mByteArrayOutputStream;
|
|
public YuvFrameQueue(int frameLength, int width, int height) {
|
mByteArrayOutputStream = new ByteArrayOutputStream();
|
mFrameLength = frameLength;
|
}
|
|
public int fillBuffer(byte[] data, int off, int len, LinkedList<byte[]> YUVQueue) {
|
mTotalLength += len;
|
if (mTotalLength == mFrameLength) {
|
synchronized (YUVQueue) {
|
System.arraycopy(data, off, data11, 0, data11.length);
|
YUVQueue.add(data11);
|
}
|
mTotalLength = 0;
|
}
|
return 0;
|
}
|
}
|