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;
    }
}