?? odfilebuf.cpp
字號(hào):
#include <stdlib.h>#include "OdaCommon.h"#include "OdFileBuf.h"//////////////////////////////////////////////////////////////////////// Construction/Destruction//////////////////////////////////////////////////////////////////////OdBaseFileBuf::OdBaseFileBuf() : m_fp(0) , m_FileName("") , m_length(ERR_VAL) , m_shMode(Oda::kShareDenyNo){}void OdBaseFileBuf::close(){ m_length = ERR_VAL; m_FileName = ""; if (m_fp) { if (fclose(m_fp) != 0) { ODA_FAIL(); // eFileCloseError; } m_fp = 0; }}#ifdef _WIN32_WCE#define _IOFBF 0x0000#endifvoid OdBaseFileBuf::open(const OdChar *path, const char *access){ m_fp = fopen(path, access); if (m_fp) { setvbuf(m_fp, 0, _IOFBF, 8192); m_FileName = path; } else throw OdError_CantOpenFile(path);}////////////////////////////////////////////////////////////////////OdWrFileBuf::OdWrFileBuf() : m_position(ERR_VAL) {}OdWrFileBuf::~OdWrFileBuf(){ close();}void OdWrFileBuf::open( const OdChar* path, Oda::FileShareMode /*shMode*/, Oda::FileAccessMode /*nDesiredAccess*/, Oda::FileCreationDisposition /*nCreationDisposition*/){ OdString sMode = "wb"; //if (shMode == Oda::kShareDenyReadWrite) m_position = 0; m_length = 0; OdBaseFileBuf::open(path, "wb"); return;}void OdWrFileBuf::close(){ m_position = ERR_VAL; OdBaseFileBuf::close();}OdUInt32 OdWrFileBuf::length(){ return m_length;}OdUInt32 OdWrFileBuf::seek(OdInt32 offset, OdDb::FilerSeekType whence){ switch (whence) { case OdDb::kSeekFromStart: m_position = offset; break; case OdDb::kSeekFromCurrent: m_position += offset; break; case OdDb::kSeekFromEnd: m_position = m_length - offset; break; } if (fseek(m_fp, m_position, SEEK_SET) != 0) m_position = ERR_VAL; // Error return m_position;}OdUInt32 OdWrFileBuf::tell(){ return m_position;}bool OdWrFileBuf::isEof(){ return (m_position >= m_length);}OdUInt32 OdWrFileBuf::getShareMode(){ return (OdUInt32)m_shMode;}void OdWrFileBuf::putByte(OdUInt8 val){ if(::fputc(val,m_fp)==EOF) { throw OdError_FileWriteError(m_FileName); } if (++m_position > m_length) m_length = m_position;}void OdWrFileBuf::putBytes(const void* buff, OdUInt32 nByteLen){ if(::fwrite(buff, 1, nByteLen, m_fp) < nByteLen) { throw OdError_FileWriteError(m_FileName); } m_position += nByteLen; if (m_position > m_length) m_length = m_position;}////////////////////////////////////////////////////////////////////////////////const int OdRdFileBuf::m_BufSize = 8192;const int OdRdFileBuf::m_PosMask(~(8192-1));OdRdFileBuf::OdRdFileBuf() : m_Counter(0L){ init();}void OdRdFileBuf::init(){ for (int i = 0; i < NUM_BUFFERS; i++) { m_DataBlock[i].buf = NULL; m_DataBlock[i].counter = -1L; m_DataBlock[i].validbytes=0; m_DataBlock[i].startaddr = ERR_VAL; }}OdRdFileBuf::~OdRdFileBuf(){ close();}void OdRdFileBuf::close(){ // indicate buffers no longer in use for (int i = 0; i < NUM_BUFFERS; i++) { if (m_DataBlock[i].buf) ::odrxFree(m_DataBlock[i].buf); m_DataBlock[i].buf = NULL; m_DataBlock[i].counter = -1L; m_DataBlock[i].validbytes=0; m_DataBlock[i].startaddr = ERR_VAL; } OdBaseFileBuf::close();}void OdRdFileBuf::open( const OdChar * fname, Oda::FileShareMode shMode, Oda::FileAccessMode /*nDesiredAccess*/, Oda::FileCreationDisposition /*nCreationDisposition*/){ OdString caMode; if (shMode == Oda::kShareDenyWrite || shMode == Oda::kShareDenyReadWrite) caMode = "r+b"; else caMode = "rb"; OdBaseFileBuf::open(fname, caMode.c_str()); // Get file length OdUInt32 curLoc = ftell(m_fp); fseek(m_fp, 0L, 2); m_length = ftell(m_fp); fseek(m_fp, curLoc, 0); int i; m_BufBytes= 0; m_BytesLeft= 0; m_BufPos=0L; // to start reads from 0L m_pCurBuf=NULL; m_pNextChar = m_pCurBuf; m_UsingBlock = -1; m_PhysFilePos=0L; for (i = 0; i < NUM_BUFFERS; i++) { m_DataBlock[i].buf = (OdUInt8*)::odrxAlloc(m_BufSize); m_DataBlock[i].validbytes=0; m_DataBlock[i].counter = -1L; m_DataBlock[i].startaddr = ERR_VAL; } seek(0L, OdDb::kSeekFromStart); // initial seek, gets a buffer & stuff return;}bool OdRdFileBuf::filbuf( ){ int i, minindex; OdInt32 minlru; struct blockstru *minptr; m_UsingBlock = -1; /* see if we are holding it already */ for (i = 0; i < NUM_BUFFERS; i++) { if (m_DataBlock[i].startaddr==m_BufPos) break; } if (i < NUM_BUFFERS) // we are already holding this part of the file { m_pCurBuf=m_DataBlock[i].buf; m_BufPos=m_DataBlock[i].startaddr; m_BytesLeft=m_BufBytes=m_DataBlock[i].validbytes; m_pNextChar=m_pCurBuf; m_DataBlock[i].counter=m_Counter++; m_UsingBlock=i; return true; } /* not holding it, so look for a buffer to read into */ /* first see if any are not yet loaded */ minptr=NULL; minindex=0; for (i = 0; i < NUM_BUFFERS; i++) { if (m_DataBlock[i].startaddr==ERR_VAL) { minindex=i; minptr=&m_DataBlock[i]; break; } } /* if all were used, then look for the least recently used one */ if (minptr==NULL) { minlru=0x7FFFFFFF; minptr=NULL; minindex=0; for (i = 0; i < NUM_BUFFERS; i++) { if (m_DataBlock[i].counter<0L) m_DataBlock[i].counter=0L; if (m_DataBlock[i].counter<minlru) { minlru=m_DataBlock[i].counter; minptr=&m_DataBlock[i]; minindex=i; } } } if (minptr==NULL) { ODA_FAIL(); return false; /* couldn't find one */ } /* if we are not already physically at the read location, move there */ /* then read into the buffer */ if (m_PhysFilePos!=m_BufPos /*|| readerror*/) { fseek(m_fp, m_BufPos, SEEK_SET); } m_BufBytes = m_BytesLeft = (short) fread(minptr->buf, 1, m_BufSize, m_fp); m_PhysFilePos=m_BufPos+m_BufBytes; if (m_BufBytes > 0) { minptr->validbytes = m_BufBytes; minptr->startaddr = m_BufPos; minptr->counter=m_Counter++; m_pCurBuf=minptr->buf; m_pNextChar = m_pCurBuf; m_UsingBlock=minindex; return true; } return false;}OdUInt32 OdRdFileBuf::getShareMode(){ return (OdUInt32)m_shMode;}OdUInt32 OdRdFileBuf::length(){ return m_length;}OdUInt32 OdRdFileBuf::seek(OdInt32 offset, OdDb::FilerSeekType whence){ int bytestoadvance; switch (whence) { case OdDb::kSeekFromStart: break; case OdDb::kSeekFromCurrent: offset += (m_BufPos+(m_pNextChar - m_pCurBuf)); break; case OdDb::kSeekFromEnd: offset = m_length - offset; break; } ODA_ASSERT(offset >= 0); // from here on assume whence is 0 // if it's not in the area we're holding, seek to it if (OdUInt32(offset) < m_BufPos || OdUInt32(offset) >= m_BufPos + m_BufBytes) { m_BufPos=offset & m_PosMask; if (!filbuf( )) // locates it if we're already holding in another block { m_pNextChar = NULL; m_pCurBuf = NULL; m_BytesLeft = 0; throw OdError(eEndOfFile); //return ERR_VAL; } } m_pNextChar = (m_pCurBuf + (bytestoadvance=(OdUInt16)(offset - m_BufPos))); m_BytesLeft = m_BufBytes - bytestoadvance; return(offset);}OdUInt32 OdRdFileBuf::tell(){ return (m_BufPos + (m_pNextChar - m_pCurBuf));}bool OdRdFileBuf::isEof(){ if (m_BytesLeft > 0) return false; if (m_length == 0) return true; m_BufPos += m_BufBytes; return !filbuf();}OdUInt8 OdRdFileBuf::getByte(){ m_DataBlock[m_UsingBlock].counter=m_Counter++; if (m_BytesLeft<=0) { m_BufPos+=m_BufBytes; if (!filbuf()) { throw OdError(eEndOfFile); } } m_BytesLeft--; return (*m_pNextChar++);}void OdRdFileBuf::getBytes(void* buffer, OdUInt32 nLen){ OdInt32 bytesleft; OdUInt16 bytestoread; unsigned char *buf=(unsigned char *)buffer; if (nLen > 0) { m_DataBlock[m_UsingBlock].counter=m_Counter++; bytesleft = nLen; while (bytesleft > 0L && !isEof( )) { if ((OdInt32)m_BytesLeft<bytesleft) bytestoread=(OdUInt16)m_BytesLeft; else bytestoread=(OdUInt16)bytesleft; memcpy(buf,m_pNextChar,bytestoread); m_BytesLeft -= bytestoread; m_pNextChar += bytestoread; buf += bytestoread; bytesleft -= bytestoread; } if (bytesleft > 0L) throw OdError(eEndOfFile); }}?? 快捷鍵說(shuō)明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -