package com.basic.security.utils.yuv;

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;
//        mByteArrayOutputStream.write(data, off, len);

        if (mTotalLength == mFrameLength) {

            synchronized (YUVQueue) {
                System.arraycopy(data, off, data11, 0, data11.length);
                YUVQueue.add(data11);
//                YUVQueue.add(mByteArrayOutputStream.toByteArray());
//                mByteArrayOutputStream.reset();
            }

            mTotalLength = 0;
//            System.out.println("received file");
        }

        return 0;
    }
}