diff options
Diffstat (limited to 'TAO/examples/Content_Server/AMI_Observer/Callback_Handler.cpp')
| -rw-r--r-- | TAO/examples/Content_Server/AMI_Observer/Callback_Handler.cpp | 171 |
1 files changed, 171 insertions, 0 deletions
diff --git a/TAO/examples/Content_Server/AMI_Observer/Callback_Handler.cpp b/TAO/examples/Content_Server/AMI_Observer/Callback_Handler.cpp new file mode 100644 index 00000000000..832e96b6732 --- /dev/null +++ b/TAO/examples/Content_Server/AMI_Observer/Callback_Handler.cpp @@ -0,0 +1,171 @@ +// -*- C++ -*- +// $Id$ + +// Ossama Othman <ossama@uci.edu> + +#include "ace/FILE_Connector.h" +#include "ace/Log_Msg.h" +#include "Callback_Handler.h" + +ACE_RCSID (AMI_Observer, Callback_Handler, "$Id$") + +Callback_Handler::Callback_Handler (const char *pathname, + Web_Server::Callback_ptr client_callback) + : file_ (pathname), + file_io_ (), + callback_ (Web_Server::Callback::_duplicate (client_callback)), + ami_handler_ (), + chunk_ (new Web_Server::Chunk_Type), + chunk_index_ (0), + last_chunk_ (0) +{ + // Nothing else +} + +Callback_Handler::~Callback_Handler (void) +{ + // Nothing else +} + +void +Callback_Handler::next_chunk (ACE_ENV_SINGLE_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + if (this->last_chunk_ == 1) + { + this->deactivate (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; + + return; + } + + // Allocate a buffer for the file being read. + CORBA::Octet *buf = + Web_Server::Chunk_Type::allocbuf (BUFSIZ); + + if (buf == 0) + ACE_THROW (CORBA::NO_MEMORY ()); + + ssize_t bytes_read = this->file_io_.recv (buf, + BUFSIZ); + if (bytes_read == -1) + { + Web_Server::Chunk_Type::freebuf (buf); + + ACE_THROW (CORBA::INTERNAL ()); + } + else if (bytes_read == 0) + { + Web_Server::Chunk_Type::freebuf (buf); + this->last_chunk_ = 1; + } + else + { + this->chunk_index_++; + + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("Sending chunk %d from %s of size <%d>\n"), + this->chunk_index_, + this->file_.get_path_name (), + bytes_read)); + + // Place the contents of the buffer into the outgoing octet + // sequence. Only replace the amount of data actually read. + this->chunk_->replace (bytes_read, + bytes_read, + buf, + 1); // The sequence releases memory for us. + } + + this->callback_->sendc_next_chunk (this->ami_handler_.in (), + this->chunk_.in (), + this->last_chunk_ + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; +} + +void +Callback_Handler::next_chunk_excep + (::Messaging::ExceptionHolder *excep_holder + ACE_ENV_ARG_DECL_NOT_USED) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + this->last_chunk_ = 1; + + ACE_DECLARE_NEW_CORBA_ENV; + ACE_TRY + { + this->deactivate (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + + excep_holder->raise_exception (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + } + ACE_CATCHANY + { + ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, + ACE_TEXT ("Exception occured during ") + ACE_TEXT ("sendc_next_chunk() call:")); + } + ACE_ENDTRY; +} + +void +Callback_Handler::run (ACE_ENV_SINGLE_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException, + Web_Server::Error_Result)) +{ + // Open the file to be downloaded + this->open_file (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; + + // Activate this Reply Handler. + this->ami_handler_ = this->_this (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; + + // Begin the asynchronous invocation. Note that the AMI + // "sendc_next_chunk()" call is done within the following call, + // since data must first be read into the Chunk. + this->next_chunk (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; +} + +void +Callback_Handler::open_file (ACE_ENV_SINGLE_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException, + Web_Server::Error_Result)) +{ + // Create a temporary file to store the retrieved data. + ACE_FILE_Connector connector; + + if (connector.connect (this->file_io_, + this->file_, + 0, + ACE_Addr::sap_any, + 0, + O_RDONLY) == -1) + // HTTP 1.1 "Not Found" + ACE_THROW (Web_Server::Error_Result (404)); +} + +void +Callback_Handler::deactivate (ACE_ENV_SINGLE_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + // Close the file that was sent to the client. + (void) this->file_io_.close (); + + // Get the POA used when activating the Reply Handler object. + PortableServer::POA_var poa = this->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; + + // Get the object ID associated with this servant. + PortableServer::ObjectId_var oid = + poa->servant_to_id (this + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + + // Now deactivate the AMI_CallbackHandler object. + poa->deactivate_object (oid.in () ACE_ENV_ARG_PARAMETER); + ACE_CHECK; +} |