BESStreamResponseHandler.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 <cerrno>
00034 #include <iostream>
00035 #include <fstream>
00036 #include <string>
00037 #include <cstring>
00038
00039 using std::ifstream ;
00040 using std::ios ;
00041 using std::endl ;
00042 using std::string ;
00043
00044 #include "BESStreamResponseHandler.h"
00045 #include "BESRequestHandlerList.h"
00046 #include "BESNotFoundError.h"
00047 #include "BESInternalError.h"
00048 #include "BESDataNames.h"
00049 #include "BESContainer.h"
00050
00051 #define BES_STREAM_BUFFER_SIZE 4096
00052
00053 BESStreamResponseHandler::BESStreamResponseHandler( const string &name )
00054 : BESResponseHandler( name )
00055 {
00056 }
00057
00058 BESStreamResponseHandler::~BESStreamResponseHandler( )
00059 {
00060 }
00061
00072 void
00073 BESStreamResponseHandler::execute( BESDataHandlerInterface &dhi )
00074 {
00075 _response = 0 ;
00076
00077
00078
00079
00080
00081
00082
00083
00084
00085
00086
00087 if( dhi.containers.size() != 1 )
00088 {
00089 string err = (string)"Unable to stream file: "
00090 + "no container specified" ;
00091 throw BESInternalError( err, __FILE__, __LINE__ ) ;
00092 }
00093
00094 dhi.first_container() ;
00095 BESContainer *container = dhi.container ;
00096 string filename = container->access() ;
00097 if( filename.empty() )
00098 {
00099 string err = (string)"Unable to stream file: "
00100 + "filename not specified" ;
00101 throw BESInternalError( err, __FILE__, __LINE__ ) ;
00102 }
00103
00104 int bytes = 0 ;
00105 ifstream os ;
00106 os.open( filename.c_str(), ios::in ) ;
00107 int myerrno = errno ;
00108 if( !os )
00109 {
00110 string serr = (string)"Unable to stream file: "
00111 + "cannot open file "
00112 + filename + ": " ;
00113 char *err = strerror( myerrno ) ;
00114 if( err )
00115 serr += err ;
00116 else
00117 serr += "Unknown error" ;
00118
00119 throw BESNotFoundError( err, __FILE__, __LINE__ ) ;
00120 }
00121
00122 int nbytes ;
00123 char block[BES_STREAM_BUFFER_SIZE] ;
00124 os.read( block, sizeof block ) ;
00125 nbytes = os.gcount() ;
00126 while( nbytes )
00127 {
00128 bytes += nbytes ;
00129 dhi.get_output_stream().write( (char*)block, nbytes ) ;
00130 os.read( block, sizeof block ) ;
00131 nbytes = os.gcount() ;
00132 }
00133 os.close() ;
00134 }
00135
00143 void
00144 BESStreamResponseHandler::transmit( BESTransmitter *transmitter,
00145 BESDataHandlerInterface &dhi )
00146 {
00147
00148
00149 }
00150
00157 void
00158 BESStreamResponseHandler::dump( ostream &strm ) const
00159 {
00160 strm << BESIndent::LMarg << "BESStreamResponseHandler::dump - ("
00161 << (void *)this << ")" << endl ;
00162 BESIndent::Indent() ;
00163 BESResponseHandler::dump( strm ) ;
00164 BESIndent::UnIndent() ;
00165 }
00166
00167 BESResponseHandler *
00168 BESStreamResponseHandler::BESStreamResponseBuilder( const string &name )
00169 {
00170 return new BESStreamResponseHandler( name ) ;
00171 }
00172