PPTStreamBuf.cc
Go to the documentation of this file.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 #include <sys/types.h>
00034
00035 #include <cstdio>
00036 #include <unistd.h>
00037 #include <sstream>
00038 #include <iomanip>
00039 #include <iostream>
00040
00041 using std::ostringstream ;
00042 using std::hex ;
00043 using std::setw ;
00044 using std::setfill ;
00045
00046 #include "PPTStreamBuf.h"
00047 #include "BESDebug.h"
00048
00049 PPTStreamBuf::PPTStreamBuf( int fd, unsigned bufsize )
00050 : d_bufsize( bufsize ),
00051 d_buffer( 0 ),
00052 count( 0 )
00053 {
00054 open( fd, bufsize ) ;
00055 }
00056
00057 PPTStreamBuf::~PPTStreamBuf()
00058 {
00059 if(d_buffer)
00060 {
00061 sync() ;
00062 delete [] d_buffer ;
00063 }
00064 }
00065
00066 void
00067 PPTStreamBuf::open( int fd, unsigned bufsize )
00068 {
00069 d_fd = fd ;
00070 d_bufsize = bufsize == 0 ? 1 : bufsize ;
00071
00072 d_buffer = new char[d_bufsize] ;
00073 setp( d_buffer, d_buffer + d_bufsize ) ;
00074 }
00075
00076 int
00077 PPTStreamBuf::sync()
00078 {
00079 if( pptr() > pbase() )
00080 {
00081 ostringstream strm ;
00082 strm << hex << setw( 7 ) << setfill( '0' ) << (unsigned int)(pptr() - pbase()) << "d" ;
00083 string tmp_str = strm.str() ;
00084 write( d_fd, tmp_str.c_str(), tmp_str.length() ) ;
00085 count += write( d_fd, d_buffer, pptr() - pbase() ) ;
00086 setp( d_buffer, d_buffer + d_bufsize ) ;
00087
00088 fsync(d_fd);
00089 }
00090 return 0 ;
00091 }
00092
00093 int
00094 PPTStreamBuf::overflow( int c )
00095 {
00096 sync() ;
00097 if( c != EOF )
00098 {
00099 *pptr() = static_cast<char>(c) ;
00100 pbump( 1 ) ;
00101 }
00102 return c ;
00103 }
00104
00105 void
00106 PPTStreamBuf::finish()
00107 {
00108 sync() ;
00109 ostringstream strm ;
00110
00111
00112
00113
00114
00115
00116 strm << hex << setw( 7 ) << setfill( '0' ) << (unsigned int)0 << "d" ;
00117 string tmp_str = strm.str() ;
00118 BESDEBUG( "ppt", "PPTStreamBuf::finish - writing " << tmp_str << endl ) ;
00119 write( d_fd, tmp_str.c_str(), tmp_str.length() ) ;
00120
00121 fsync(d_fd);
00122 count = 0 ;
00123 }
00124