YUVPlayer/FileReader.cpp at master · lmshao/YUVPlayer · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
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
103
104
105
//
// Copyright 2022-2025 SHAO Liming <lmshao@163.com>. All rights reserved.
//

#include "FileReader.h"

#include <cstring>

#include "Utils.h"

FileReader::~FileReader()
{
    if (fd_.is_open()) {
        LOG("fd.close()");
        fd_.close();
    }

    if (buffer_) {
        delete[] buffer_;
        buffer_ = nullptr;
    }
}

bool FileReader::Open(const std::string &fileName)
{
    fd_.open(fileName, std::ios::in | std::ios::binary);
    if (!fd_.is_open()) {
        return false;
    }

    fd_.seekg(0, std::ios::end);
    fileSize_ = (long long)fd_.tellg();
    fd_.seekg(0);
    LOG("FileReader::Open ok, size(%lld)", fileSize_);
    return true;
}

void FileReader::SetFrameSize(int frameSize)
{
    LOG("FileReader::SetFrameSize(%d)", frameSize);
    if (frameSize > 0 && frameSize_ != frameSize) {
        frameSize_ = frameSize;
        fd_.seekg(0);
        if (buffer_) {
            delete[] buffer_;
            buffer_ = nullptr;
        }
    }
}

void FileReader::Reset()
{
    fd_.seekg(0);
    if (buffer_) {
        delete[] buffer_;
        buffer_ = nullptr;
    }
}

char *FileReader::GetNextFrame()
{
    if (frameSize_ <= 0 || fd_.tellg() >= fileSize_)
        return nullptr;

    if (!buffer_) {
        buffer_ = new char[frameSize_];
    }

    memset(buffer_, 0, frameSize_);
    fd_.read(buffer_, frameSize_);
    if (fd_.eof()) {
        return nullptr;
    }

    return buffer_;
}

char *FileReader::GetNthFrame(int seq)
{
    if (seq <= 0 || seq * frameSize_ > fileSize_) {
        LOG("GetNthFrame(%d) param error, frameSize(%d) fileSize(%lld)", seq, frameSize_, fileSize_);
        return nullptr;
    }

    if (!buffer_) {
        buffer_ = new char[frameSize_];
    }

    fd_.seekg((seq - 1) * frameSize_, std::ios::beg);
    fd_.read(buffer_, frameSize_);
    if (fd_.eof()) {
        LOG("GetNthFrame(%d) eof", seq);
        return nullptr;
    }
    return buffer_;
}

int FileReader::GetFrameNum() const
{
    if (frameSize_ <= 0 || fileSize_ <= 0) {
        return -1;
    }

    return (int)(fileSize_ / frameSize_);
}