diff options
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/mpeg/source/mpeg_server/Video_Control_i.cpp')
| -rw-r--r-- | TAO/orbsvcs/tests/AVStreams/mpeg/source/mpeg_server/Video_Control_i.cpp | 272 |
1 files changed, 0 insertions, 272 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/mpeg/source/mpeg_server/Video_Control_i.cpp b/TAO/orbsvcs/tests/AVStreams/mpeg/source/mpeg_server/Video_Control_i.cpp deleted file mode 100644 index 5db371090c1..00000000000 --- a/TAO/orbsvcs/tests/AVStreams/mpeg/source/mpeg_server/Video_Control_i.cpp +++ /dev/null @@ -1,272 +0,0 @@ -// $Id$ - -#include "Video_Control_i.h" -#include "mpeg_server/Video_Server.h" - -ACE_RCSID(mpeg_server, Video_Control_i, "$Id$") - -Video_Control_i::Video_Control_i () - : reactor_ (TAO_ORB_Core_instance ()->reactor ()), - state_ (0), - data_handler_ (0), - sig_handler_ (0) -{ -} - -int -Video_Control_i::create_handlers (void) -{ - ACE_NEW_RETURN (this->data_handler_, - Video_Data_Handler, - -1); - - ACE_NEW_RETURN (this->sig_handler_, - Video_Sig_Handler, - -1); - return 0; -} -CORBA::Boolean -Video_Control_i::init_video (const Video_Control::INITvideoPara ¶, - Video_Control::INITvideoReply_out reply, - CORBA::Environment& env) -{ - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Video_Control_i::init_video () called\n")); - - CORBA::Boolean result = this->state_->init_video (para, - reply); - - ACE_DEBUG ((LM_DEBUG, "(%P|%t) Video_Control_State::init_video returned %d\n", result)); - return result; - -} - - -CORBA::Boolean -Video_Control_i::stat_stream (CORBA::Char_out ch, - CORBA::Long_out size, - CORBA::Environment& env) -{ - return 0; -} - - -void -Video_Control_i::close (CORBA::Environment& env) -{ - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Video_Control_i::close:" - "shutting down the ORB\n")); - - TAO_ORB_Core_instance ()-> orb ()-> shutdown (); - return; -} - - -CORBA::Boolean -Video_Control_i::stat_sent (CORBA::Environment& env) -{ - return 0; -} - - -CORBA::Boolean -Video_Control_i::fast_forward (const Video_Control::FFpara ¶, - CORBA::Environment& env) -{ - return this->state_->fast_forward (para); -} - - -CORBA::Boolean -Video_Control_i::fast_backward (const Video_Control::FFpara ¶, - CORBA::Environment& env) -{ - return this->state_->fast_backward (para); -} - - -CORBA::Boolean -Video_Control_i::step (const Video_Control::STEPpara ¶, - CORBA::Environment& env) -{ - return this->state_->step (para); -} - - -// this gets called by the client, when it wants -// to start playback -CORBA::Boolean -Video_Control_i::play (const Video_Control::PLAYpara ¶, - CORBA::Long_out vts, - CORBA::Environment& env) -{ - return this->state_->play (para, - vts); -} - - -CORBA::Boolean -Video_Control_i::position (const Video_Control::POSITIONpara ¶, - CORBA::Environment& env) -{ - return this->state_->position (para); -} - - -CORBA::Boolean -Video_Control_i::speed (const Video_Control::SPEEDpara ¶, - CORBA::Environment& env) -{ - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Video_Control_i::speed () called\n")); - return this->state_->speed (para); -} - - -CORBA::Boolean -Video_Control_i::stop (CORBA::Long cmdsn, - CORBA::Environment& env) -{ - return this->state_->stop (cmdsn); -} - -CORBA::Boolean -Video_Control_i::set_peer (char * &peer, - CORBA::Environment &_tao_environment) -{ - ACE_INET_Addr client_data_addr (peer); - // Data (UDP) Address of the client. - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) set_peer called: %s,%s,%d\n", - peer, - client_data_addr.get_host_addr (), - client_data_addr.get_port_number ())); - - char temp_addr [BUFSIZ]; - if (VIDEO_SINGLETON::instance ()->data_host != 0) - ACE_OS::sprintf (temp_addr,"%s:%d",VIDEO_SINGLETON::instance ()->data_host,0); - else - ACE_OS::sprintf (temp_addr,":%d",0); - - if (VIDEO_SINGLETON::instance ()->dgram.open (client_data_addr) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) UDP open failed: %p\n"), - 0); - - // set the socket buffer sizes to 64k. - int sndbufsize = ACE_DEFAULT_MAX_SOCKET_BUFSIZ; - int rcvbufsize = ACE_DEFAULT_MAX_SOCKET_BUFSIZ; - - if (VIDEO_SINGLETON::instance ()->dgram.set_option (SOL_SOCKET, - SO_SNDBUF, - (void *) &sndbufsize, - sizeof (sndbufsize)) == -1 - && errno != ENOTSUP) - return 0; - else if (VIDEO_SINGLETON::instance ()->dgram.set_option (SOL_SOCKET, - SO_RCVBUF, - (void *) &rcvbufsize, - sizeof (rcvbufsize)) == -1 - && errno != ENOTSUP) - return 0; - - - ACE_INET_Addr server_data_addr; - // Data (UDP) Address of this server. - - if (VIDEO_SINGLETON::instance ()-> dgram.get_local_addr - (server_data_addr) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) UDP get_local_addr failed: %p\n"), - 0); - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Video_Server: My UDP port number is %d\n", - server_data_addr.get_port_number ())); - - if (this->register_handlers () == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) Video_Control_i::set_peer: register_handlers failed\n"), - 0); - - VIDEO_SINGLETON::instance ()->videoSocket = VIDEO_SINGLETON::instance ()->dgram.get_handle (); - - ACE_DEBUG ((LM_DEBUG,"(%P|%t) set_peer: server port = %d\n",server_data_addr.get_port_number ())); - ACE_NEW_RETURN (peer, - char [BUFSIZ], - 0); - // hack to set the ip address correctly. - server_data_addr.set (server_data_addr.get_port_number (), - server_data_addr.get_host_name ()); - server_data_addr.addr_to_string (peer, - BUFSIZ); - - return 1; -} - -int -Video_Control_i::register_handlers (void) -{ - int result; - - - // create the handlers - - if (this->create_handlers () == -1) - return -1; - - this->change_state (VIDEO_CONTROL_WAITING_STATE::instance ()); - // sets the state to waiting. - - // Register the event handlers with the Reactor - // first the data handler, i.e. UDP - result = this->reactor_->register_handler (this->data_handler_, - ACE_Event_Handler::READ_MASK); - if (result < 0) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) register_handler for data_handler failed\n"), - -1); - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) registered fd for data handler = (%d)\n", - this->data_handler_->get_handle ())); - - // finally, the signal handler, for periodic transmission - // of packets - result = this->sig_handler_->register_handler (); - - if (result < 0) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) register_handler for sig_handler" - "failed!\n"), - -1); - - return 0; -} - -// Changes the state of the video control handler from the current -// state to the state represented by the argument. -void -Video_Control_i::change_state (Video_Control_State *state) -{ - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Video_Control_i::Changing to state %d\n", - state->get_state ())); - this->state_ = state; -} - -// Returns the current state object . -Video_Control_State * -Video_Control_i::get_state (void) -{ - return this->state_; -} - - -Video_Control_i::~Video_Control_i () -{ - delete this->data_handler_; - delete this->sig_handler_; -} |