Skip to content

MAPREDUCE-7388. Remove unused variable _eof in GzipCodec.cc #4429

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
aajisaka merged 2 commits into from
Jul 8, 2022
Merged

MAPREDUCE-7388. Remove unused variable _eof in GzipCodec.cc #4429

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
1b94011
remove unused variable _eof
Jun 11, 2022
6dd151a
Merge branch 'apache:trunk' into trunk
cfg1234 Jun 22, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 0 additions & 2 deletions ...apreduce-client/hadoop-mapreduce-client-nativetask/src/main/native/src/codec/GzipCodec.cc
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,6 @@ GzipDecompressStream::GzipDecompressStream(InputStream * stream, uint32_t buffer
}
zstream->next_in = NULL;
zstream->avail_in = 0;
_eof = false;
}

GzipDecompressStream::~GzipDecompressStream() {
Expand All @@ -156,7 +155,6 @@ int32_t GzipDecompressStream::read(void * buff, uint32_t length) {
if (zstream->avail_in == 0) {
int32_t rd = _stream->read(_buffer, _capacity);
if (rd <= 0) {
_eof = true;
size_t wt = zstream->next_out - (Bytef*)buff;
return wt > 0 ? wt : -1;
} else {
Expand Down
1 change: 0 additions & 1 deletion ...mapreduce-client/hadoop-mapreduce-client-nativetask/src/main/native/src/codec/GzipCodec.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,6 @@ class GzipDecompressStream : public DecompressStream {
char * _buffer;
uint32_t _capacity;
void * _zstream;
bool _eof;
public:
GzipDecompressStream(InputStream * stream, uint32_t bufferSizeHint);

Expand Down