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 "BESInternalFatalError.h"
00058 #include "BESExceptionManager.h"
00059 #include "BESDapError.h"
00060
00061 void
00062 BESDapModule::initialize( const string &modname )
00063 {
00064 BESDEBUG( "dap", "Initializing DAP Modules:" << endl )
00065
00066 BESDEBUG( "dap", " adding " << modname << " request handler" << endl )
00067 BESRequestHandlerList::TheList()->add_handler( modname, new BESDapRequestHandler( modname ) ) ;
00068
00069 BESDEBUG( "dap", " adding " << DAS_RESPONSE << " response handler" << endl )
00070 BESResponseHandlerList::TheList()->add_handler( DAS_RESPONSE, BESDASResponseHandler::DASResponseBuilder ) ;
00071
00072 BESDEBUG( "dap", " adding " << DDS_RESPONSE << " response handler" << endl )
00073 BESResponseHandlerList::TheList()->add_handler( DDS_RESPONSE, BESDDSResponseHandler::DDSResponseBuilder ) ;
00074
00075 BESDEBUG( "dap", " adding " << DDX_RESPONSE << " response handler" << endl )
00076 BESResponseHandlerList::TheList()->add_handler( DDX_RESPONSE, BESDDXResponseHandler::DDXResponseBuilder ) ;
00077
00078 BESDEBUG( "dap", " adding " << DATA_RESPONSE << " response handler" << endl )
00079 BESResponseHandlerList::TheList()->add_handler( DATA_RESPONSE, BESDataResponseHandler::DataResponseBuilder ) ;
00080
00081 BESDEBUG( "dap", " adding " << CATALOG_RESPONSE << " response handler" << endl )
00082 BESResponseHandlerList::TheList()->add_handler( CATALOG_RESPONSE, BESCatalogResponseHandler::CatalogResponseBuilder ) ;
00083
00084 BESDEBUG( "dap", "Initializing DAP Basic Transmitters:" << endl )
00085 BESTransmitter *t = BESReturnManager::TheManager()->find_transmitter( BASIC_TRANSMITTER ) ;
00086 if( t )
00087 {
00088 BESDEBUG( "dap", " adding " << DAS_TRANSMITTER << endl )
00089 t->add_method( DAS_TRANSMITTER, BESDapTransmit::send_basic_das ) ;
00090
00091 BESDEBUG( "dap", " adding " << DDS_TRANSMITTER << endl )
00092 t->add_method( DDS_TRANSMITTER, BESDapTransmit::send_basic_dds ) ;
00093
00094 BESDEBUG( "dap", " adding " << DDX_TRANSMITTER << endl )
00095 t->add_method( DDX_TRANSMITTER, BESDapTransmit::send_basic_ddx ) ;
00096
00097 BESDEBUG( "dap", " 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 BESInternalFatalError( err, __FILE__, __LINE__ ) ;
00105 }
00106
00107 BESDEBUG( "dap", "Initializing DAP HTTP Transmitters:" << endl )
00108 t = BESReturnManager::TheManager()->find_transmitter( HTTP_TRANSMITTER ) ;
00109 if( t )
00110 {
00111 BESDEBUG( "dap", " adding " << DAS_TRANSMITTER << endl )
00112 t->add_method( DAS_TRANSMITTER, BESDapTransmit::send_http_das ) ;
00113
00114 BESDEBUG( "dap", " adding " << DDS_TRANSMITTER << endl )
00115 t->add_method( DDS_TRANSMITTER, BESDapTransmit::send_http_dds ) ;
00116
00117 BESDEBUG( "dap", " adding " << DDX_TRANSMITTER << endl )
00118 t->add_method( DDX_TRANSMITTER, BESDapTransmit::send_http_ddx ) ;
00119
00120 BESDEBUG( "dap", " 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 BESInternalFatalError( err, __FILE__, __LINE__ ) ;
00128 }
00129
00130 BESDEBUG( "dap", " adding dap exception handler" << endl )
00131 BESExceptionManager::TheEHM()->add_ehm_callback( BESDapError::handleException ) ;
00132
00133 BESDEBUG( "dap", " adding dap debug context" << endl )
00134 BESDebug::Register( "dap" ) ;
00135
00136 BESDEBUG( "dap", "Done Initializing DAP Modules:" << endl )
00137 }
00138
00139 void
00140 BESDapModule::terminate( const string &modname )
00141 {
00142 BESDEBUG( "dap", "Removing DAP Modules:" << endl )
00143
00144 BESDEBUG( "dap", " removing dap Response handlers" << modname << endl )
00145 BESResponseHandlerList::TheList()->remove_handler( DAS_RESPONSE ) ;
00146 BESResponseHandlerList::TheList()->remove_handler( DDS_RESPONSE ) ;
00147 BESResponseHandlerList::TheList()->remove_handler( DDX_RESPONSE ) ;
00148 BESResponseHandlerList::TheList()->remove_handler( DATA_RESPONSE ) ;
00149 BESResponseHandlerList::TheList()->remove_handler( CATALOG_RESPONSE ) ;
00150
00151 BESDEBUG( "dap", " removing dap Request Handler" << modname << endl )
00152 BESRequestHandler *rh = BESRequestHandlerList::TheList()->remove_handler( modname ) ;
00153 if( rh ) delete rh ;
00154
00155 BESDEBUG( "dap", "Done Removing DAP Modules:" << endl )
00156 }
00157
00164 void
00165 BESDapModule::dump( ostream &strm ) const
00166 {
00167 strm << BESIndent::LMarg << "BESDapModule::dump - ("
00168 << (void *)this << ")" << endl ;
00169 }
00170
00171 extern "C"
00172 {
00173 BESAbstractModule *maker()
00174 {
00175 return new BESDapModule ;
00176 }
00177 }
00178