00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035
00036
00037
00038
00039
00040
00044
#include "FilePStreamBuf.h"
00045
00046
namespace PLearn {
00047
using namespace std;
00048
00049 string FilePStreamBuf::getFilePathFromURL(
string fileurl)
00050 {
00051
return fileurl;
00052 }
00053
00054 FilePStreamBuf::FilePStreamBuf()
00055 : f(0)
00056
00057 {
00058
00059
00060
00061
00062 }
00063
00064 FilePStreamBuf::~FilePStreamBuf()
00065 {
00066
if(
f)
00067 fclose(
f);
00068 }
00069
00070
00071
PLEARN_IMPLEMENT_OBJECT(
FilePStreamBuf,
"ONE LINE DESCRIPTION",
"MULTI LINE\nHELP");
00072
00073 void FilePStreamBuf::declareOptions(
OptionList& ol)
00074 {
00075
declareOption(ol,
"url", &FilePStreamBuf::url, OptionBase::buildoption,
00076
"Uniform resource location of file");
00077
00078
declareOption(ol,
"openmode", &FilePStreamBuf::openmode, OptionBase::buildoption,
00079
"Uniform resource location of file");
00080
00081
00082 inherited::declareOptions(ol);
00083 }
00084
00085 void FilePStreamBuf::build_()
00086 {
00087
string filepath =
getFilePathFromURL(
url);
00088
00089 is_random_accessible =
true;
00090
if(
openmode==
"r")
00091 {
00092 is_readable =
true;
00093 is_writable =
false;
00094 }
00095
else if(
openmode==
"w" ||
openmode==
"a")
00096 {
00097 is_readable =
false;
00098 is_writable =
true;
00099 }
00100
else if(
openmode==
"r+" ||
openmode==
"w+" ||
openmode==
"a+")
00101 {
00102 is_readable =
true;
00103 is_writable =
true;
00104 }
00105
else
00106
PLERROR(
"In FilePStreamBuf::build Invalid openmode. Must be one of r, w, a, r+, w+, a+. The 'b' character is not used to denote 'binary mode'. All files are opened in binary mode anyway.");
00107
00108
string binaryopenmode =
openmode+
'b';
00109
f = fopen(filepath.c_str(), binaryopenmode.c_str());
00110
if(!
f)
00111
PLERROR(
"Failed to open file %s in mode %s",filepath.c_str(), openmode.c_str());
00112 }
00113
00114
00115 void FilePStreamBuf::build()
00116 {
00117 inherited::build();
00118
build_();
00119 }
00120
00121 FilePStreamBuf::streamsize FilePStreamBuf::read_(
char* p, streamsize n)
00122 {
00123
return fread(p, 1, n,
f);
00124 }
00125
00127 void FilePStreamBuf::write_(
const char* p, streamsize n)
00128 {
00129 streamsize nwritten = fwrite(p, 1, n,
f);
00130
if(nwritten!=n)
00131
PLERROR(
"In FilePStreamBuf::write_ failed to write the requested number of bytes");
00132 fflush(
f);
00133 }
00134
00135 void FilePStreamBuf::makeDeepCopyFromShallowCopy(map<const void*, void*>& copies)
00136 {
00137 inherited::makeDeepCopyFromShallowCopy(copies);
00138
00139
f = 0;
00140
build();
00141 }
00142
00143 }