X-Git-Url: https://git.saurik.com/wxWidgets.git/blobdiff_plain/ce4169a4d129fc6cd165b2e9ccc5cf5d48356020..866592d872daa1f4e3d44948d7d3a6c90b0af9d0:/src/common/wfstream.cpp?ds=sidebyside diff --git a/src/common/wfstream.cpp b/src/common/wfstream.cpp index e4da5d94df..b43ddb3fba 100644 --- a/src/common/wfstream.cpp +++ b/src/common/wfstream.cpp @@ -20,15 +20,11 @@ #pragma hdrstop #endif -#ifndef WX_PRECOMP - #include "wx/defs.h" -#endif - #if wxUSE_STREAMS && wxUSE_FILE #include -#include -#include +#include "wx/stream.h" +#include "wx/wfstream.h" // ---------------------------------------------------------------------------- // wxFileInputStream @@ -39,7 +35,6 @@ wxFileInputStream::wxFileInputStream(const wxString& fileName) { m_file = new wxFile(fileName, wxFile::read); m_file_destroy = TRUE; - m_i_streambuf->SetBufferIO(1024); } wxFileInputStream::wxFileInputStream() @@ -53,14 +48,12 @@ wxFileInputStream::wxFileInputStream(wxFile& file) { m_file = &file; m_file_destroy = FALSE; - m_i_streambuf->SetBufferIO(1024); } wxFileInputStream::wxFileInputStream(int fd) { m_file = new wxFile(fd); m_file_destroy = TRUE; - m_i_streambuf->SetBufferIO(1024); } wxFileInputStream::~wxFileInputStream() @@ -69,19 +62,25 @@ wxFileInputStream::~wxFileInputStream() delete m_file; } -char wxFileInputStream::Peek() -{ - return 0; -} - -size_t wxFileInputStream::StreamSize() const +size_t wxFileInputStream::GetSize() const { return m_file->Length(); } size_t wxFileInputStream::OnSysRead(void *buffer, size_t size) { - return m_file->Read(buffer, size); + off_t ret; + + ret = m_file->Read(buffer, size); + + if (m_file->Eof()) + m_lasterror = wxStream_EOF; + if (ret == wxInvalidOffset) { + m_lasterror = wxStream_READ_ERR; + ret = 0; + } + + return ret; } off_t wxFileInputStream::OnSysSeek(off_t pos, wxSeekMode mode) @@ -102,20 +101,17 @@ wxFileOutputStream::wxFileOutputStream(const wxString& fileName) { m_file = new wxFile(fileName, wxFile::write); m_file_destroy = TRUE; - m_o_streambuf->SetBufferIO(1024); } wxFileOutputStream::wxFileOutputStream(wxFile& file) { m_file = &file; m_file_destroy = FALSE; - m_o_streambuf->SetBufferIO(1024); } wxFileOutputStream::wxFileOutputStream() : wxOutputStream() { - m_o_streambuf->SetBufferIO(1024); m_file_destroy = FALSE; m_file = NULL; } @@ -124,7 +120,6 @@ wxFileOutputStream::wxFileOutputStream(int fd) { m_file = new wxFile(fd); m_file_destroy = TRUE; - m_o_streambuf->SetBufferIO(1024); } wxFileOutputStream::~wxFileOutputStream() @@ -138,7 +133,10 @@ wxFileOutputStream::~wxFileOutputStream() size_t wxFileOutputStream::OnSysWrite(const void *buffer, size_t size) { size_t ret = m_file->Write(buffer, size); - m_lasterror = wxStream_EOF; // TODO + if (m_file->Error()) + m_lasterror = wxStream_WRITE_ERR; + else + m_lasterror = wxStream_NOERROR; return ret; } @@ -158,7 +156,7 @@ void wxFileOutputStream::Sync() m_file->Flush(); } -size_t wxFileOutputStream::StreamSize() const +size_t wxFileOutputStream::GetSize() const { return m_file->Length(); } @@ -171,5 +169,148 @@ wxFileStream::wxFileStream(const wxString& fileName) { } +// ---------------------------------------------------------------------------- +// wxFFileInputStream +// ---------------------------------------------------------------------------- + +wxFFileInputStream::wxFFileInputStream(const wxString& fileName) + : wxInputStream() +{ + m_file = new wxFFile(fileName, "r"); + m_file_destroy = TRUE; +} + +wxFFileInputStream::wxFFileInputStream() + : wxInputStream() +{ + m_file_destroy = FALSE; + m_file = NULL; +} + +wxFFileInputStream::wxFFileInputStream(wxFFile& file) +{ + m_file = &file; + m_file_destroy = FALSE; +} + +wxFFileInputStream::wxFFileInputStream(FILE *file) +{ + m_file = new wxFFile(file); + m_file_destroy = TRUE; +} + +wxFFileInputStream::~wxFFileInputStream() +{ + if (m_file_destroy) + delete m_file; +} + +size_t wxFFileInputStream::GetSize() const +{ + return m_file->Length(); +} + +size_t wxFFileInputStream::OnSysRead(void *buffer, size_t size) +{ + off_t ret; + + ret = m_file->Read(buffer, size); + + if (m_file->Eof()) + m_lasterror = wxStream_EOF; + if (ret == wxInvalidOffset) { + m_lasterror = wxStream_READ_ERR; + ret = 0; + } + + return ret; +} + +off_t wxFFileInputStream::OnSysSeek(off_t pos, wxSeekMode mode) +{ + return m_file->Seek(pos, mode); +} + +off_t wxFFileInputStream::OnSysTell() const +{ + return m_file->Tell(); +} + +// ---------------------------------------------------------------------------- +// wxFFileOutputStream +// ---------------------------------------------------------------------------- + +wxFFileOutputStream::wxFFileOutputStream(const wxString& fileName) +{ + m_file = new wxFFile(fileName, "w+"); + m_file_destroy = TRUE; +} + +wxFFileOutputStream::wxFFileOutputStream(wxFFile& file) +{ + m_file = &file; + m_file_destroy = FALSE; +} + +wxFFileOutputStream::wxFFileOutputStream() + : wxOutputStream() +{ + m_file_destroy = FALSE; + m_file = NULL; +} + +wxFFileOutputStream::wxFFileOutputStream(FILE *file) +{ + m_file = new wxFFile(file); + m_file_destroy = TRUE; +} + +wxFFileOutputStream::~wxFFileOutputStream() +{ + if (m_file_destroy) { + Sync(); + delete m_file; + } +} + +size_t wxFFileOutputStream::OnSysWrite(const void *buffer, size_t size) +{ + size_t ret = m_file->Write(buffer, size); + if (m_file->Error()) + m_lasterror = wxStream_WRITE_ERR; + else + m_lasterror = wxStream_NOERROR; + return ret; +} + +off_t wxFFileOutputStream::OnSysTell() const +{ + return m_file->Tell(); +} + +off_t wxFFileOutputStream::OnSysSeek(off_t pos, wxSeekMode mode) +{ + return m_file->Seek(pos, mode); +} + +void wxFFileOutputStream::Sync() +{ + wxOutputStream::Sync(); + m_file->Flush(); +} + +size_t wxFFileOutputStream::GetSize() const +{ + return m_file->Length(); +} + +// ---------------------------------------------------------------------------- +// wxFFileStream +// ---------------------------------------------------------------------------- +wxFFileStream::wxFFileStream(const wxString& fileName) + : wxFFileInputStream(fileName), wxFFileOutputStream(*wxFFileInputStream::m_file) +{ +} #endif // wxUSE_STREAMS && wxUSE_FILE +