diff options
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/mpeg/source/server/server.cpp')
| -rw-r--r-- | TAO/orbsvcs/tests/AVStreams/mpeg/source/server/server.cpp | 783 |
1 files changed, 0 insertions, 783 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/server.cpp b/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/server.cpp deleted file mode 100644 index 975e0aafa40..00000000000 --- a/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/server.cpp +++ /dev/null @@ -1,783 +0,0 @@ -// $Id$ - -#include "server.h" -#include "ace/Process.h" - -int AV_Server::done_; -pid_t AV_Server::current_pid_ = -1; - -// Initialize the svc_handler, and the acceptor. - -AV_Svc_Handler::AV_Svc_Handler (ACE_Thread_Manager *t) -{ -} - -// Client connected to our control port called by the reactor -// (acceptor). - -int -AV_Svc_Handler::open (void *) -{ - // Lets use threads at a later point. The current scheme works fine - // with fork.. this will activate a thread this->activate - // (THR_BOUND); - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) AV_Svc_Handler::open called\n")); - return this->svc (); - // return 0; -} - -// this will handle the connection -int -AV_Svc_Handler::svc (void) -{ - int result; - result = this->handle_connection (); - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) AV_Svc_Handler::svc exiting\n")); - - return result; -} - -// handles the connection - -int -AV_Svc_Handler::handle_connection (ACE_HANDLE) -{ - // Client is sending us a command - int cmd; - if (this->peer ().recv_n (&cmd, - sizeof (cmd)) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) Command recieve failed: %p\n"), - -1); - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Command recieved is %d\n", - cmd)); - // Change these CMD's to enums and put them in a "appropriate" namespace - switch (cmd) - { - case CmdINITvideo: - { - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Spawning the video server process\n")); - - // %% what does this do ?!! - if (Mpeg_Global::live_audio) LeaveLiveAudio (); - /* result = VideoServer (this->peer ().get_handle (), - this->dgram_.get_handle (), - Mpeg_Global::rttag, - -INET_SOCKET_BUFFER_SIZE); - */ - - ACE_Process_Options video_process_options; - video_process_options.command_line ("./vs -ORBport 0"); - // ORBport of 0 makes the video server pick a port for itself - - ACE_Process video_process; - - AV_Server::done_ = 0; - - if ((AV_Server::current_pid_ = - video_process.spawn (video_process_options)) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) ACE_Process:: spawn failed: %p\n", - "spawn"), - -1); - // %% need to close down the orb fd's - // in the child process!! - - char sem_str [BUFSIZ]; - - // create a unique semaphore name - ::sprintf (sem_str, - "%s:%d", - "Video_Server_Semaphore", - AV_Server::current_pid_); - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) semaphore is %s\n", - sem_str)); - // Create the semaphore - ACE_Process_Semaphore semaphore (0, // 0 means that the - // semaphore is locked initially - sem_str); - - // %% wait until the child finishes booting - while (AV_Server::done_ == 0) - { - if (semaphore.acquire () == -1) - { - if (errno != EINTR) - break; - } - else - break; - } - - AV_Server::current_pid_ = -1; - if (semaphore.remove () == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) semaphore remove failed: %p\n", - "remove"), - -1); - - // Wait until a ACE_SV_Semaphore's value is greater than 0, the - // decrement it by 1 and return. Dijkstra's P operation, Tannenbaums - // DOWN operation. - // ::sleep (5); - // ACE_DEBUG ((LM_DEBUG, "(%P|%t) %s:%d\n", __FILE__, __LINE__)); - int ack = 42; - if (this->peer ().send_n (&ack, - sizeof (ack)) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t), ACK send failed: %p", - "AV_Svc_Handler::handle_connection"), - -1); - // ACE_DEBUG ((LM_DEBUG, "(%P|%t) %s:%d\n", __FILE__, __LINE__)); - } - // close down the connected socket in the main process - this->destroy (); - break; - case CmdINITaudio: - // ACE_DEBUG ((LM_DEBUG,"(%P|%t) Received CmdINITaudio\n")); -// { -// ACE_Process_Options audio_process_options; - -// char command_str[BUFSIZ]; -// sprintf (command_str,"./as -ORBport 0 -f %d",this->peer ().get_handle ()); -// ACE_DEBUG ((LM_DEBUG,"Audio command string %s",command_str)); -// audio_process_options.command_line (command_str); - -// ACE_Process audio_process; - -// audio_process.spawn (audio_process_options); -// } - - { - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Spawning the audio server process\n")); - - ACE_Process_Options audio_process_options; - audio_process_options.command_line ("./as -ORBport 0"); - // ORBport of 0 makes the audio server pick a port for itself - - ACE_Process audio_process; - - AV_Server::done_ = 0; - - if ((AV_Server::current_pid_ - = audio_process.spawn (audio_process_options)) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) ACE_Process:: spawn failed: %p\n", - "spawn"), - -1); - // %% need to close down the orb fd's - // in the child process!! - - char sem_str [BUFSIZ]; - - // create a unique semaphore name - ::sprintf (sem_str, - "%s:%d", - "Audio_Server_Semaphore", - AV_Server::current_pid_); - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) semaphore is %s\n", - sem_str)); - // Create the semaphore - ACE_Process_Semaphore semaphore (0, // 0 means that the - // semaphore is locked initially - sem_str); - - // %% wait until the child finishes booting - while (AV_Server::done_ == 0) - { - if (semaphore.acquire () == -1) - { - if (errno != EINTR) - { - ACE_DEBUG ((LM_DEBUG,"Semaphore acquire failed\n")); - return -1; - } - // break; - } - else - break; - } -// if (semaphore.acquire () == -1) -// ACE_ERROR_RETURN ((LM_ERROR, -// "(%P|%t) semaphore acquire failed: %p\n", -// "acquire"), -// -1); - // ~~?? remove the semaphore. - // Wait until a ACE_SV_Semaphore's value is greater than 0, the - // decrement it by 1 and return. Dijkstra's P operation, Tannenbaums - // DOWN operation. - // ::sleep (5); - - AV_Server::current_pid_ = -1; - if (semaphore.remove () == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) semaphore remove failed: %p\n", - "remove"), - -1); - - // ACE_DEBUG ((LM_DEBUG, "(%P|%t) %s:%d\n", __FILE__, __LINE__)); - // ?? do we need the ack even for audio! - int ack = 42; - if (this->peer ().send_n (&ack, - sizeof (ack)) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t), ACK send failed: %p", - "AV_Svc_Handler::handle_connection"), - -1); - // ACE_DEBUG ((LM_DEBUG, "(%P|%t) %s:%d\n", __FILE__, __LINE__)); - } - // close down the connected socket in the main process - this->destroy (); - break; - // %% need to fork here -// switch (ACE_OS::fork ("child")) -// { -// case 0: -// TAO_ORB_Core_instance ()->orb ()-> shutdown (); -// // Remove the acceptor handler and other signal handlers registered by the parent. -// TAO_ORB_Core_instance ()->reactor ()->remove_handler (AV_SERVER::instance ()->acceptor (), -// ACE_Event_Handler::ACCEPT_MASK); - -// ACE_DEBUG ((LM_DEBUG,"(%P|%t) New process forked \n")); -// if (Mpeg_Global::live_audio) -// LeaveLiveAudio (); -// ACE_NEW_RETURN (this->as_, -// Audio_Server, -// -1); -// ACE_DEBUG ((LM_DEBUG,"(%P|%t) AudioServer created\n")); -// int result; -// result = this->as_->init (this->peer (), -// Mpeg_Global::rttag, -// -INET_SOCKET_BUFFER_SIZE); -// if (result < 0) -// ACE_ERROR_RETURN ((LM_ERROR,"(%P|%t) Audio_Server init failed ()\n"),-1); -// result = as_->run (); - -// if (result != 0) -// ACE_ERROR_RETURN ((LM_ERROR, -// "(%P|%t) handle_connection : %d\n"), -// result); -// return result; -// break; -// default: -// this->destroy (); -// return 0; -// } -// break; - default: - ACE_ERROR_RETURN ((LM_ERROR,"(%P|%t)Unknown command received\n"),-1); - break; - } - - return 0; -} - -int -AV_Svc_Handler::close (u_long) -{ - ACE_DEBUG ((LM_DEBUG, - "(%P|%t)AV_Svc_Handler::close called \n")); - return 0; -} - -int -AV_Svc_Handler::handle_timeout (const ACE_Time_Value &, - const void *arg) -{ - ACE_DEBUG ((LM_DEBUG, - "(%P|%t)AV_Svc_Handler::handle_timeout called \n")); - return 0; -} - -// AV_Server_Sig_Handler routines - -AV_Server_Sig_Handler::AV_Server_Sig_Handler (void) -{ -} - -int -AV_Server_Sig_Handler::register_handler (void) -{ - // Assign the Sig_Handler a dummy I/O descriptor. Note that even - // though we open this file "Write Only" we still need to use the - // ACE_Event_Handler::NULL_MASK when registering this with the - // ACE_Reactor (see below). - this->handle_ = ACE_OS::open (ACE_DEV_NULL, O_WRONLY); - ACE_ASSERT (this->handle_ != -1); - // ACE_DEBUG ((LM_DEBUG,"(%P|%t) sig_handler == %d\n",this->handle_)); - - // Register signal handler object. Note that NULL_MASK is used to - // keep the ACE_Reactor from calling us back on the "/dev/null" - // descriptor. - - if (TAO_ORB_Core_instance ()->reactor ()->register_handler - (this, ACE_Event_Handler::NULL_MASK) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "register_handler"), - -1); - - // handles these signals. - // this->sig_set.fill_set (); - this->sig_set.sig_add (SIGCHLD); - this->sig_set.sig_add (SIGBUS); - this->sig_set.sig_add (SIGINT); - this->sig_set.sig_add (SIGTERM); - - // Register the signal handler object to catch the signals. if - if (TAO_ORB_Core_instance ()->reactor ()->register_handler - (this->sig_set, this) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "register_handler"), - -1); - return 0; -} - -// Called by the ACE_Reactor to extract the fd. -ACE_HANDLE -AV_Server_Sig_Handler::get_handle (void) const -{ - return this->handle_; -} - -int -AV_Server_Sig_Handler::handle_input (ACE_HANDLE) -{ - ACE_DEBUG ((LM_DEBUG, "(%t) handling asynchonrous input...\n")); - return 0; -} - -int -AV_Server_Sig_Handler::shutdown (ACE_HANDLE, ACE_Reactor_Mask) -{ - ACE_DEBUG ((LM_DEBUG, "(%t) closing down Sig_Handler...\n")); - return 0; -} - -// This method handles all the signals that are being caught by this -// object. In our simple example, we are simply catching SIGALRM, -// SIGINT, and SIGQUIT. Anything else is logged and ignored. -// -// There are several advantages to using this approach. First, -// the behavior triggered by the signal is handled in the main event -// loop, rather than in the signal handler. Second, the ACE_Reactor's -// signal handling mechanism eliminates the need to use global signal -// handler functions and data. - -int -AV_Server_Sig_Handler::handle_signal (int signum, siginfo_t *, ucontext_t *) -{ - // ACE_DEBUG ((LM_DEBUG, "(%P|%t) received signal %S\n", signum)); - - switch (signum) - { - case SIGCHLD: - // Handle the death of child signal. - this->clear_child (SIGCHLD); - break; - case SIGBUS: - // Handle the Bus error signal - case SIGINT: - // Handle the interrupt signal - case SIGTERM: - // Handle the process termination signal. - this->int_handler (signum); - break; - default: - // ACE_DEBUG ((LM_DEBUG, "(%P|%t) %S: not handled, returning to program\n", signum)); - break; - } - return 0; -} - -// SIGCHLD handler -void -AV_Server_Sig_Handler::clear_child (int sig) -{ - int pid; - int status; - - // ACE_DEBUG ((LM_DEBUG,"(%P|%t) AV_Server: Reaping the children\n")); - // reap the children - while ((pid = ACE_OS::waitpid (-1, - &status, - WNOHANG)) > 0) - { - if (pid == AV_Server::current_pid_) - { - cerr << "The child currently being waited for has died\n"; - // ACE_DEBUG ((LM_DEBUG,"(%P|%t) The child currently being waited for has died.\n")); - AV_Server::done_ = 1; - } - - // decrement the count of number of active children - Mpeg_Global::session_num --; - - if (status == 0) - continue; - - // ACE_DEBUG ((LM_DEBUG, "(%P|%t) AV_Server: child %d (status %d)\n", pid, status)); - } - return; -} - -// ctrl-c, Bus error, interrupt sig handler -void -AV_Server_Sig_Handler::int_handler (int sig) -{ - TAO_ORB_Core_instance ()->orb ()->shutdown (); - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) AV server killed by signal %d\n", - sig)); -} - -AV_Server_Sig_Handler::~AV_Server_Sig_Handler (void) -{ - TAO_ORB_Core_instance ()->reactor ()->remove_handler (this->sig_set); -} - -Video_Server_MMDevice::Video_Server_MMDevice (CosNaming::NamingContext_ptr ns) - :naming_context_ (ns) -{ -} - -AVStreams::StreamEndPoint_B_ptr -Video_Server_MMDevice::create_B (AVStreams::StreamCtrl_ptr the_requester, - AVStreams::VDev_out the_vdev, - AVStreams::streamQoS &the_qos, - CORBA::Boolean_out met_qos, - char *&named_vdev, - const AVStreams::flowSpec &the_spec, - CORBA::Environment &env) -{ - ACE_DEBUG ((LM_DEBUG,"(%P|%t) Video_Server_MMDevice::create_B (..)\n")); - ACE_DEBUG ((LM_DEBUG,"(%P|%t) Spawning the video server process\n")); - - // %% what does this do ?!! - if (Mpeg_Global::live_audio) LeaveLiveAudio (); - - ACE_Process_Options video_process_options; - video_process_options.command_line ("./vs -ORBport 0"); - // ORBport of 0 makes the video server pick a port for itself - - ACE_Process video_process; - - AV_Server::done_ = 0; - - if ((AV_Server::current_pid_ = - video_process.spawn (video_process_options)) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) ACE_Process:: spawn failed: %p\n", - "spawn"), - 0); - // %% need to close down the orb fd's - // in the child process!! - - char sem_str [BUFSIZ]; - - // create a unique semaphore name - ::sprintf (sem_str,"%s:%d","Video_Server_Semaphore",AV_Server::current_pid_); - - ACE_DEBUG ((LM_DEBUG,"(%P|%t) semaphore is %s\n",sem_str)); - // Create the semaphore - ACE_Process_Semaphore semaphore (0,sem_str); - // 0 means that - // semaphore is locked initially - - // %% wait until the child finishes booting - while (AV_Server::done_ == 0) - { - if (semaphore.acquire () == -1) - { - if (errno != EINTR) - break; - } - else - break; - } - - AV_Server::current_pid_ = -1; - if (semaphore.remove () == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) semaphore remove failed: %p\n", - "remove"), - 0); - // Find the vdev and stream endpoint from the Naming Service. - - CosNaming::Name video_vdev_name; - video_vdev_name.length (1); - video_vdev_name [0].id = CORBA::string_dup ("video_vdev"); - CORBA::Object_var video_vdev_obj = - this->naming_context_->resolve (video_vdev_name, - env); - TAO_CHECK_ENV_RETURN (env,0); - - the_vdev = - AVStreams::VDev::_narrow (video_vdev_obj.in (), - env); - TAO_CHECK_ENV_RETURN (env,0); - - CosNaming::Name video_streamendpoint_name; - - video_streamendpoint_name.length (1); - video_streamendpoint_name [0].id = CORBA::string_dup ("video_streamendpoint"); - CORBA::Object_var video_streamendpoint_obj = - this->naming_context_->resolve (video_streamendpoint_name, - env); - TAO_CHECK_ENV_RETURN (env,0); - - AVStreams::StreamEndPoint_B_var streamendpoint_ptr = - AVStreams::StreamEndPoint_B::_narrow (video_streamendpoint_obj.in (), - env); - TAO_CHECK_ENV_RETURN (env,0); - - return streamendpoint_ptr; -} - -// AV_Server routines - -// Default Constructor -AV_Server::AV_Server (void) -{ -} - -// %% move to the destructor or sig handler -void -AV_Server::on_exit_routine (void) -{ - // %% what does the following do - if (Mpeg_Global::parentpid != ACE_OS::getpid ()) - { - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Process is exiting\n")); - return; - } - - // %% what does the following do - if (Mpeg_Global::live_audio > 1) - ExitLiveAudio (); - if (Mpeg_Global::live_video > 1) - ExitLiveVideo (); - // ComCloseServer(); -} - - -// Parses the command line arguments -int -AV_Server::parse_args (int argc, - char **argv) -{ - ACE_Get_Opt get_opts (argc, argv, "rd:s:vamh"); - int c; - - while ((c = get_opts ()) != -1) - switch (c) - { - case 'r': // real time flag - Mpeg_Global::rttag = 1; - break; - case 'd': // clock drift in ppm - Mpeg_Global::drift_ppm = ACE_OS::atoi (get_opts.optarg); - break; - case 's':// limit on number of sessions - Mpeg_Global::session_limit = ACE_OS::atoi (get_opts.optarg); - break; - case 'v':// live video flag - Mpeg_Global::live_video = 1; - break; - case 'a':// live audio flag - Mpeg_Global::live_audio = 1; - break; - case 'm':// remove flag - ACE_OS::unlink (VCR_UNIX_PORT); - break; - case '?': - case 'h':// help flag - ACE_DEBUG ((LM_DEBUG, - "Usage: %s [-r ] [-m]\n" - " [-d#int(clock drift in ppm)]\n" - " [-s#int(limit on number of sessions)]\n" - " [-v] [-a] [-?] [-h]", - argv [0])); - return -1; - } - return 0; -} - - -// Initializes the mpeg server -int -AV_Server::init (int argc, - char **argv, - CORBA::Environment& env) -{ - int result; - - // Initialize the orb_manager - this->orb_manager_.init_child_poa (argc, - argv, - "child_poa", - env); - TAO_CHECK_ENV_RETURN (env, - -1); - - CORBA::ORB_var orb = - this->orb_manager_.orb (); - - PortableServer::POA_var child_poa = - this->orb_manager_.child_poa (); - - result = this->parse_args (argc, argv); - if (result < 0) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) Error parsing arguments"), - -1); - // Resolve the Naming service reference. - - CORBA::Object_var naming_obj = orb->resolve_initial_references ("NameService"); - if (CORBA::is_nil (naming_obj.in ())) - ACE_ERROR_RETURN ((LM_ERROR, - " (%P|%t) Unable to resolve the Name Service.\n"), - -1); - - this->naming_context_ = - CosNaming::NamingContext::_narrow (naming_obj.in (), - env); - TAO_CHECK_ENV_RETURN (env,-1); - - // Register the video mmdevice object with the ORB - ACE_NEW_RETURN (this->video_mmdevice_, - Video_Server_MMDevice (this->naming_context_.in ()), - -1); - - // create the video server mmdevice with the naming service pointer. - this->orb_manager_.activate_under_child_poa ("Video_MMDevice", - this->video_mmdevice_, - env); - TAO_CHECK_ENV_RETURN (env,-1); - - // Register the video_mmdevice with the naming service. - - CosNaming::Name video_server_mmdevice_name (1); - video_server_mmdevice_name.length (1); - video_server_mmdevice_name [0].id = CORBA::string_dup ("Video_Server_MMDevice"); - - // Register the video control object with the naming server. - this->naming_context_->bind (video_server_mmdevice_name, - this->video_mmdevice_->_this (env), - env); - - if (env.exception () != 0) - { - env.clear (); - this->naming_context_->rebind (video_server_mmdevice_name, - this->video_mmdevice_->_this (env), - env); - TAO_CHECK_ENV_RETURN (env,-1); - } - - - - // Register the various signal handlers with the reactor. - result = this->signal_handler_.register_handler (); - - if (result < 0) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) Error registering signal handler"), - -1); - - ::atexit (on_exit_routine); - return 0; -} - -// Runs the mpeg server -int -AV_Server::run (CORBA::Environment& env){ - int result; - this->server_control_addr_.set (VCR_TCP_PORT); - - // "listen" on the socket - if (this->acceptor_.open (this->server_control_addr_, - TAO_ORB_Core_instance ()->reactor ()) == -1) - // 0, - // 0 - // &this->thread_strategy_) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) acceptor_handler == %d\n", - this->acceptor_.get_handle ())); - - // Run the ORB event loop - this->orb_manager_.run (env); - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) AV_Server::run () " - "came out of the (acceptor) " - "event loop %p\n", - "run_event_loop")); - return 0; - -} - -AV_ACCEPTOR * -AV_Server::acceptor (void) -{ - return &(this->acceptor_); -} - - -AV_Server::~AV_Server (void) -{ - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) AV_Server: Removing handlers from the Reactor\n")); - - if (this->video_mmdevice_ != 0) - delete this->video_mmdevice_; -// if (TAO_ORB_Core_instance ()->reactor ()->handler (this->acceptor_.get_handle (), -// ACE_Event_Handler::ACCEPT_MASK) == 0) -// if (TAO_ORB_Core_instance ()->reactor ()->remove_handler -// (this->acceptor_.get_handle (), -// ACE_Event_Handler::ACCEPT_MASK) == -1) -// ACE_ERROR ((LM_ERROR, -// "(%P|%t) remove_handler for acceptor failed\n")); - -} - -int -main (int argc, char **argv) -{ - // AV_Server vcr_server; - - TAO_TRY - { - // Parses the arguments, and initializes the server. - // if (vcr_server.init (argc, argv, TAO_TRY_ENV) == -1) - if (AV_SERVER::instance ()->init (argc, argv, TAO_TRY_ENV) == -1) - return 1; - TAO_CHECK_ENV; - // Runs the reactor event loop. - // vcr_server.run (TAO_TRY_ENV); - AV_SERVER::instance ()->run (TAO_TRY_ENV); - TAO_CHECK_ENV; - } - TAO_CATCHANY - { - TAO_TRY_ENV.print_exception ("Exception"); - return -1; - } - TAO_ENDTRY; - - return 0; -} |