Definition at line 67 of file File.h. References Impala::Util::IOBuffer::Available(), Impala::Util::Channel::DATA_BUFFER_SIZE, GetReadBuffer(), GetWriteBuffer(), Impala::Util::IOBuffer::Read(), and Impala::Util::IOBuffer::Write(). Referenced by Impala::Persistency::SvmRepositoryInFile::Add(), Impala::Persistency::RepositoryInFileSystem::CopyFile(), Impala::Persistency::SvmRepositoryInFile::Get(), and Impala::Persistency::DistributedAccessRepositoryInFile::WriteParts(). 00068 { 00069 IOBuffer* srcBuf = srcFile.GetReadBuffer(); 00070 if (!srcBuf) 00071 return; 00072 IOBuffer* dstBuf = GetWriteBuffer(); 00073 if (!dstBuf) 00074 { 00075 delete srcBuf; 00076 return; 00077 } 00078 int bufSize = Util::Channel::DATA_BUFFER_SIZE; 00079 char* buf = new char[bufSize]; 00080 while (srcBuf->Available() > 0) 00081 { 00082 int nrRead = srcBuf->Read(buf, bufSize); 00083 dstBuf->Write(buf, nrRead); 00084 } 00085 delete buf; 00086 delete dstBuf; 00087 delete srcBuf; 00088 }
Here is the call graph for this function: ![]()
|