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 #include <iostream>
00033
00034 using std::endl ;
00035
00036 #include "BESDapModule.h"
00037
00038 #include "BESDapRequestHandler.h"
00039 #include "BESRequestHandlerList.h"
00040
00041 #include "BESResponseNames.h"
00042 #include "BESResponseHandlerList.h"
00043
00044 #include "BESDASResponseHandler.h"
00045 #include "BESDDSResponseHandler.h"
00046 #include "BESDataResponseHandler.h"
00047 #include "BESDDXResponseHandler.h"
00048
00049 #include "BESCatalogResponseHandler.h"
00050
00051 #include "BESDapTransmit.h"
00052 #include "BESTransmitter.h"
00053 #include "BESReturnManager.h"
00054 #include "BESTransmitterNames.h"
00055
00056 #include "BESDebug.h"
00057 #include "BESException.h"
00058 #include "BESExceptionManager.h"
00059 #include "BESDapHandlerException.h"
00060
00061 void
00062 BESDapModule::initialize( const string &modname )
00063 {
00064 BESDEBUG( "Initializing DAP Modules:" << endl )
00065
00066 BESDEBUG( " adding " << modname << " request handler" << endl )
00067 BESRequestHandlerList::TheList()->add_handler( modname, new BESDapRequestHandler( modname ) ) ;
00068
00069 BESDEBUG( " adding " << DAS_RESPONSE << " response handler" << endl )
00070 BESResponseHandlerList::TheList()->add_handler( DAS_RESPONSE, BESDASResponseHandler::DASResponseBuilder ) ;
00071
00072 BESDEBUG( " adding " << DDS_RESPONSE << " response handler" << endl )
00073 BESResponseHandlerList::TheList()->add_handler( DDS_RESPONSE, BESDDSResponseHandler::DDSResponseBuilder ) ;
00074
00075 BESDEBUG( " adding " << DDX_RESPONSE << " response handler" << endl )
00076 BESResponseHandlerList::TheList()->add_handler( DDX_RESPONSE, BESDDXResponseHandler::DDXResponseBuilder ) ;
00077
00078 BESDEBUG( " adding " << DATA_RESPONSE << " response handler" << endl )
00079 BESResponseHandlerList::TheList()->add_handler( DATA_RESPONSE, BESDataResponseHandler::DataResponseBuilder ) ;
00080
00081 BESDEBUG( " adding " << CATALOG_RESPONSE << " response handler" << endl )
00082 BESResponseHandlerList::TheList()->add_handler( CATALOG_RESPONSE, BESCatalogResponseHandler::CatalogResponseBuilder ) ;
00083
00084 BESDEBUG( "Initializing DAP Basic Transmitters:" << endl )
00085 BESTransmitter *t = BESReturnManager::TheManager()->find_transmitter( BASIC_TRANSMITTER ) ;
00086 if( t )
00087 {
00088 BESDEBUG( " adding " << DAS_TRANSMITTER << endl )
00089 t->add_method( DAS_TRANSMITTER, BESDapTransmit::send_basic_das ) ;
00090
00091 BESDEBUG( " adding " << DDS_TRANSMITTER << endl )
00092 t->add_method( DDS_TRANSMITTER, BESDapTransmit::send_basic_dds ) ;
00093
00094 BESDEBUG( " adding " << DDX_TRANSMITTER << endl )
00095 t->add_method( DDX_TRANSMITTER, BESDapTransmit::send_basic_ddx ) ;
00096
00097 BESDEBUG( " adding " << DATA_TRANSMITTER << endl )
00098 t->add_method( DATA_TRANSMITTER, BESDapTransmit::send_basic_data ) ;
00099 }
00100 else
00101 {
00102 string err = (string)"Unable to initialize basic transmitter "
00103 + "with dap transmit functions" ;
00104 throw BESException( err, __FILE__, __LINE__ ) ;
00105 }
00106
00107 BESDEBUG( "Initializing DAP HTTP Transmitters:" << endl )
00108 t = BESReturnManager::TheManager()->find_transmitter( HTTP_TRANSMITTER ) ;
00109 if( t )
00110 {
00111 BESDEBUG( " adding " << DAS_TRANSMITTER << endl )
00112 t->add_method( DAS_TRANSMITTER, BESDapTransmit::send_http_das ) ;
00113
00114 BESDEBUG( " adding " << DDS_TRANSMITTER << endl )
00115 t->add_method( DDS_TRANSMITTER, BESDapTransmit::send_http_dds ) ;
00116
00117 BESDEBUG( " adding " << DDX_TRANSMITTER << endl )
00118 t->add_method( DDX_TRANSMITTER, BESDapTransmit::send_http_ddx ) ;
00119
00120 BESDEBUG( " adding " << DATA_TRANSMITTER << endl )
00121 t->add_method( DATA_TRANSMITTER, BESDapTransmit::send_http_data ) ;
00122 }
00123 else
00124 {
00125 string err = (string)"Unable to initialize http transmitter "
00126 + "with dap transmit functions" ;
00127 throw BESException( err, __FILE__, __LINE__ ) ;
00128 }
00129
00130 BESDEBUG( " adding dap exception handler" << endl )
00131 BESExceptionManager::TheEHM()->add_ehm_callback( BESDapHandlerException::handleException ) ;
00132 }
00133
00134 void
00135 BESDapModule::terminate( const string &modname )
00136 {
00137 BESDEBUG( "Removing DAP Modules:" << endl )
00138
00139 BESResponseHandlerList::TheList()->remove_handler( DAS_RESPONSE ) ;
00140 BESResponseHandlerList::TheList()->remove_handler( DDS_RESPONSE ) ;
00141 BESResponseHandlerList::TheList()->remove_handler( DDX_RESPONSE ) ;
00142 BESResponseHandlerList::TheList()->remove_handler( DATA_RESPONSE ) ;
00143 BESResponseHandlerList::TheList()->remove_handler( CATALOG_RESPONSE ) ;
00144 }
00145
00152 void
00153 BESDapModule::dump( ostream &strm ) const
00154 {
00155 strm << BESIndent::LMarg << "BESDapModule::dump - ("
00156 << (void *)this << ")" << endl ;
00157 }
00158
00159 extern "C"
00160 {
00161 BESAbstractModule *maker()
00162 {
00163 return new BESDapModule ;
00164 }
00165 }
00166