summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/AVStreams/mpeg/source/mpeg_client/Command_Handler.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/mpeg/source/mpeg_client/Command_Handler.cpp')
-rw-r--r--TAO/orbsvcs/tests/AVStreams/mpeg/source/mpeg_client/Command_Handler.cpp1491
1 files changed, 0 insertions, 1491 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/mpeg/source/mpeg_client/Command_Handler.cpp b/TAO/orbsvcs/tests/AVStreams/mpeg/source/mpeg_client/Command_Handler.cpp
deleted file mode 100644
index f89980b8fe4..00000000000
--- a/TAO/orbsvcs/tests/AVStreams/mpeg/source/mpeg_client/Command_Handler.cpp
+++ /dev/null
@@ -1,1491 +0,0 @@
-// $Id$
-
-#include "Command_Handler.h"
-
-// %% yikes!!!
-#include "ctr.cpp"
-
-const char *TAO_AV_ORB_ARGUMENTS = "-ORBobjrefstyle URL";
-
-Command_Handler::Command_Handler (ACE_HANDLE command_handle)
- : command_handle_ (command_handle),
- orb_manager_ (0)
-{
-}
-
-int
-Command_Handler::init (void)
-{
- ACE_ARGV orb_args (TAO_AV_ORB_ARGUMENTS);
- int argc = orb_args.argc ();
-
- ACE_NEW_RETURN (this->orb_manager_,
- TAO_ORB_Manager,
- -1);
-
- TAO_TRY
- {
- this->orb_manager_->init (argc,
- orb_args.argv (),
- TAO_TRY_ENV);
- TAO_CHECK_ENV;
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("Command_Handler::init");
- return -1;
- }
- TAO_ENDTRY;
- return 0;
-}
-
-int
-Command_Handler::resolve_server_reference (void)
-{
- TAO_TRY
- {
- CORBA::Object_var naming_obj =
- this->orb_manager_->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);
- CosNaming::NamingContext_var naming_context =
- CosNaming::NamingContext::_narrow (naming_obj.in (),
- TAO_TRY_ENV);
- TAO_CHECK_ENV;
-
- CosNaming::Name Video_Control_name (1);
-
- Video_Control_name.length (1);
- Video_Control_name [0].id = CORBA::string_dup ("Video_Control");
- CORBA::Object_var Video_Control_obj =
- naming_context->resolve (Video_Control_name,
- TAO_TRY_ENV);
- TAO_CHECK_ENV;
-
- this->video_control_ =
- Video_Control::_narrow (Video_Control_obj.in (),
- TAO_TRY_ENV);
- TAO_CHECK_ENV;
-
- if (CORBA::is_nil (this->video_control_.in ()))
- ACE_ERROR_RETURN ((LM_ERROR,
- " could not resolve Video_Control in Naming service <%s>\n"),
- -1);
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("Command_Handler::resolve_server_reference");
- return -1;
- }
- TAO_ENDTRY;
-
- return 0;
-}
-
-
-ACE_HANDLE
-Command_Handler::get_handle (void) const
-{
- return this->command_handle_;
-}
-
-
-// handle the command sent to us by the GUI process
-// this is a reactor callback method
-int
-Command_Handler::handle_input (ACE_HANDLE fd)
-{
-
- unsigned char cmd;
- int val;
- val = OurCmdRead ((char*)&cmd, 1);
- ::TimerProcessing ();
-
- // if we get an interrupt while reading we go back to the event loop
- if (val == 1)
- return 0;
-
- FILE * fp = NULL; /* file pointer for experiment plan */
- usr1_flag = 0;
-
- // fprintf(stderr, "CTR: cmd received - %d\n", cmd);
- TAO_TRY
- {
- switch (cmd)
- {
- case CmdINIT:
- this->init_video ();
- // automatic experiment code zapped :-)
- fp = NULL;
- break;
- case CmdSTOP:
- this->stop();
- break;
- case CmdFF:
- this->fast_forward ();
- break;
- case CmdFB:
- this->fast_backward ();
- break;
- case CmdSTEP:
- this->step ();
- break;
- case CmdPLAY:
- // automatic experiment code zapped :-)
- this->play (fp != NULL,
- TAO_TRY_ENV);
- TAO_CHECK_ENV;
- break;
- case CmdPOSITION:
- this->position ();
- break;
- case CmdPOSITIONrelease:
- this->position_release ();
- break;
- case CmdVOLUME:
- this->volume ();
- break;
- case CmdBALANCE:
- this->balance ();
- break;
- case CmdSPEED:
- this->speed ();
- break;
- case CmdLOOPenable:
- {
- shared->loopBack = 1;
- break;
- }
- case CmdLOOPdisable:
- {
- shared->loopBack = 0;
- break;
- }
- default:
- fprintf(stderr, "CTR: unexpected command from UI: cmd = %d.\n", cmd);
- exit(1);
- break;
- }
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("Command_Handler::handle_input ()");
- return -1;
- }
- TAO_ENDTRY;
- return 0;
-}
-
-CORBA::Boolean
-Command_Handler::init_video (void)
-{
-
- // :: init ();
- // return 0;
-
- int i, j;
-
- /* try to stop and close previous playing */
- if (audioSocket >= 0 || videoSocket >= 0)
- {
- unsigned char tmp = CmdCLOSE;
- int result =
- this->stop_playing();
- if (result < 0)
- return result;
-
- if (audioSocket >= 0)
- {
- if (ABpid > 0) {
- kill(ABpid, SIGUSR1);
- ABpid = -1;
- }
- usleep(10000);
- AudioWrite(&tmp, 1);
- ComCloseConn(audioSocket);
- audioSocket = -1;
- }
-
- if (videoSocket >= 0)
- {
- if (VBpid > 0) {
- kill(VBpid, SIGUSR1);
- VBpid = -1;
- }
- usleep(10000);
- this->close ();
- ComCloseConn(videoSocket);
- videoSocket = -1;
- while ((!VBbufEmpty()) || !VDbufEmpty()) {
- while (VDpeekMsg() != NULL) {
- VDreclaimMsg(VDgetMsg());
- }
- usleep(10000);
- }
- usleep(10000);
- }
- }
-
- /* read in video/audio files */
- NewCmd(CmdINIT);
- CmdRead((char*)&i, 4);
- CmdRead(vh, i);
- vh[i] = 0;
- CmdRead((char*)&i, 4);
- CmdRead(vf, i);
- vf[i] = 0;
- CmdRead((char*)&i, 4);
- CmdRead(ah, i);
- ah[i] = 0;
- CmdRead((char*)&i, 4);
- CmdRead(af, i);
- af[i] = 0;
- /*
- fprintf(stderr, "INIT: vh-%s, vf-%s, ah-%s, af-%s\n", vh, vf, ah, af);
- */
-
- shared->live = 0;
- shared->audioMaxPktSize = !shared->config.audioConn;
- shared->videoMaxPktSize = !shared->config.videoConn;
-
- if (af[0] != 0)
- {
- if (InitAudioChannel(ah, af))
- {
- audioSocket = -1;
- shared->totalSamples = 0;
- }
- else
- {
- shared->nextSample = 0;
- if (shared->config.maxSPS < shared->audioPara.samplesPerSecond)
- shared->config.maxSPS < shared->audioPara.samplesPerSecond;
- }
- }
- else
- {
- shared->totalSamples = 0;
- audioSocket = -1;
- }
- if (vf[0] != 0)
- {
-
- if (this->init_video_channel(vh, vf))
- {
- shared->totalFrames = 0; /* disable video channel */
- videoSocket = -1;
- }
- else
- {
- ACE_DEBUG ((LM_DEBUG,
- "%s %d\n",
- __FILE__,__LINE__));
- shared->nextFrame = 1;
- shared->nextGroup = 0;
- shared->currentFrame = shared->currentGroup = shared->currentDisplay = 0;
- if (shared->config.maxFPS < shared->framesPerSecond)
- shared->config.maxFPS = shared->framesPerSecond;
- }
- }
- else
- {
- videoSocket = -1;
- shared->totalFrames = 0; /* disable video channel */
- }
- if (audioSocket < 0 && videoSocket < 0) /* none of video/audio channels is setup */
- {
- unsigned char tmp = CmdFAIL;
- CmdWrite(&tmp, 1);
- /*
- fprintf(stderr, "CTR initialization failed.\n");
- */
- return 0;
- }
- else
- {
- unsigned char tmp = CmdDONE;
- set_speed();
- if (videoSocket >= 0)
- wait_display();
- CmdWrite(&tmp, 1);
- if (videoSocket < 0)
- {
- tmp = CmdVPclearScreen;
- CmdWrite(&tmp, 1);
- }
- return 0;
- }
- return 0;
-}
-
-int
-Command_Handler::init_video_channel (char *phostname, char *videofile)
-{
- ACE_DEBUG ((LM_DEBUG, "(%P|%t) Reached line %d in %s\n", __LINE__, __FILE__));
- int dataSocket = -1;
-
- // if (ComOpenConnPair(phostname, &videoSocket,
- // &dataSocket, &shared->videoMaxPktSize) == -1) {
- // return -1;
- // }
- if (this->connect_to_server (phostname,
- &videoSocket,
- &dataSocket,
- &shared->videoMaxPktSize) == -1)
- return -1;
-
-
- /* Initialize with VS */
- {
- ACE_DEBUG ((LM_DEBUG, "(%P|%t) Reached line %d in %s\n", __LINE__, __FILE__));
- Video_Control::INITvideoPara_var para (new Video_Control::INITvideoPara);
- Video_Control::INITvideoReply_var reply (new Video_Control::INITvideoReply);
-
- para->sn = shared->cmdsn;
- para->version = VERSION;
- para->videofile.length (strlen(videofile));
-
- // string to sequence <char>
- for (int i=0;i<para->videofile.length ();i++)
- para->videofile [i] = videofile [i];
-
- // CORBA call
- TAO_TRY
- {
- CORBA::Boolean result;
- result = this->video_control_->init_video (para.in (),
- reply.out (),
- TAO_TRY_ENV);
- TAO_CHECK_ENV;
- if (result == (CORBA::B_FALSE))
- return -1;
- else
- ACE_DEBUG ((LM_DEBUG,"(%P|%t) init_video success \n"));
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("video_control_->init_video (..)");
- return -1;
- }
- TAO_ENDTRY;
- shared->live += reply->live;
- shared->videoFormat = reply->format;
- shared->totalHeaders = reply->totalHeaders;
- shared->totalFrames = reply->totalFrames;
- shared->totalGroups = reply->totalGroups;
- shared->averageFrameSize = reply->averageFrameSize;
- shared->horizontalSize = reply->horizontalSize;
- shared->verticalSize = reply->verticalSize;
- shared->pelAspectRatio = reply->pelAspectRatio;
- shared->pictureRate = ((double)reply->pictureRate1000) / 1000.0;
- shared->vbvBufferSize = reply->vbvBufferSize;
- shared->firstGopFrames = reply->firstGopFrames;
- shared->patternSize = reply->pattern.length ();
- if (shared->patternSize == 0) {
-
- Fprintf(stderr, "CTR warning: patternsize %d\n", shared->patternSize);
-
- shared->patternSize = 1;
- shared->pattern[0] = 'I';
- shared->pattern[1] = 0;
- shared->IframeGap = 1;
- }
- else if (shared->patternSize < PATTERN_SIZE)
- {
- int i;
- char * ptr = shared->pattern + shared->patternSize;
- // strncpy(shared->pattern, reply->pattern, shared->patternSize);
- for (i=0;i<shared->patternSize;i++)
- shared->pattern[i] = reply->pattern [i];
- for (i = 1; i < PATTERN_SIZE / shared->patternSize; i ++) {
- // memcpy(ptr, shared->pattern, shared->patternSize);
- for (int j=0; j < shared->patternSize ;j++)
- ptr [j] = shared->pattern [j];
- ptr += shared->patternSize;
- }
- shared->IframeGap = 1;
- while (shared->IframeGap < shared->patternSize)
- {
- if (shared->pattern[shared->IframeGap] == 'I')
- break;
- else
- shared->IframeGap ++;
- }
- }
- else
- {
- fprintf(stderr, "CTR Error: patternSize %d greater than PATTERN_SIZE %d.\n",
- shared->patternSize, PATTERN_SIZE);
- exit(1);
- }
- fprintf(stderr, "Video: %s, %s\n",
- shared->videoFormat == VIDEO_SIF ? "SIF" :
- shared->videoFormat == VIDEO_JPEG ? "JPEG" :
- shared->videoFormat == VIDEO_MPEG1 ? "MPEG1" :
- shared->videoFormat == VIDEO_MPEG2 ? "MPEG2" : "UNKOWN format",
- reply->live ? "live source" : "stored source");
-
- fprintf(stderr, "Video: numS-%d, numG-%d, numF-%d, aveFrameSize-%d\n",
- reply->totalHeaders, reply->totalGroups, reply->totalFrames,
- reply->averageFrameSize);
- fprintf(stderr, "Video: maxS-%d, maxG-%d, maxI-%d, maxP-%d, maxB-%d\n",
- reply->sizeSystemHeader, reply->sizeGop,
- reply->sizeIFrame, reply->sizePFrame, reply->sizeBFrame);
- fprintf(stderr,
- "Video: SHinfo: hsize-%d, vsize-%d, pelAspect-%d, rate-%f, vbv-%d.\n",
- reply->horizontalSize, reply->verticalSize, reply->pelAspectRatio,
- shared->pictureRate, reply->vbvBufferSize);
- shared->pattern[shared->patternSize] = 0;
- fprintf(stderr, "Video: firstGopFrames %d, IframeGap %d\n",
- reply->firstGopFrames, shared->IframeGap);
- shared->pattern[shared->patternSize] = 'I';
- if (reply->totalFrames > MAX_FRAMES && (!shared->live))
- {
- fprintf(stderr,
- "Error: totalFrames %d > MAX_FRAMES %d, needs change and recompile.\n",
- reply->totalFrames, MAX_FRAMES);
- ComCloseConn(dataSocket);
- ComCloseConn(videoSocket);
- videoSocket = -1;
- return -1;
- }
- ACE_DEBUG ((LM_DEBUG, "(%P|%t) Reached line %d in %s\n", __LINE__, __FILE__));
-
- /* create VB, and put INIT frame to VB*/
- {
- int sp[2]; /* sp[0] is for CTR and sp[1] is for VB */
-
- /* create command socket pair for sending INIT frame to VB, the pipe
- should be discard/non-discard in consistent with videoSocket*/
- if (socketpair(AF_UNIX,
- shared->videoMaxPktSize >= 0 ? SOCK_STREAM :
- SOCK_DGRAM, 0, sp) == -1)
- {
- perror("CTR error on open CTR-VB socketpair");
- exit(1);
- }
-
- switch (VBpid = fork())
- {
- case -1:
- perror("CTR error on forking VB process");
- exit(1);
- break;
- case 0:
- ACE_DEBUG ((LM_DEBUG, "(%P|%t) Reached line %d in %s\n", __LINE__, __FILE__));
- if (realTimeFlag) {
- SetRTpriority("VB", -1);
- }
- free(vh);
- free(videofile);
- free(ah);
- free(af);
- ::close(sp[0]);
- // ::close (videoSocket);
- if (audioSocket >= 0)
- ComCloseFd(audioSocket);
- ABdeleteBuf();
- VDdeleteBuf();
- if (cmdSocket >= 0)
- ::close(cmdSocket);
- if (realTimeFlag >= 2) {
-#ifdef __svr4__
- if (SetRTpriority("VB", 0)) realTimeFlag = 0;
-#elif defined(_HPUX_SOURCE)
- if (SetRTpriority("VB", 1)) realTimeFlag = 0;
-#endif
- }
- VBprocess(sp[1], dataSocket);
- break;
- default:
- ::close(sp[1]);
- // ::close(dataSocket);
- {
- int bytes, res;
- /* passing all messages of INIT frame to VB here. */
- char * buf = (char *)malloc(INET_SOCKET_BUFFER_SIZE);
- VideoMessage *msg = (VideoMessage *)buf;
- int pkts = 1, msgo = 0, msgs = 0;
-
- if (buf == NULL) {
- perror("CTR error on malloc() for INIT frame");
- exit(1);
- }
- while (msgo + msgs < pkts) {
- ACE_DEBUG ((LM_DEBUG, "(%P|%t) Reached line %d in %s\n", __LINE__, __FILE__));
- cerr << "expecting a packet of size " << sizeof (*msg)
- << endl;
- VideoRead(buf, sizeof(*msg));
- //~~ we need to read the first frame from the
- // data socket instead of control socket.
- // SocketRecv(dataSocket, buf, size);
- pkts = ntohl(msg->packetSize);
- msgo = ntohl(msg->msgOffset);
- msgs = ntohl(msg->msgSize);
- if (shared->videoMaxPktSize >= 0) { /* non-discard mode */
- ACE_DEBUG ((LM_DEBUG, "(%P|%t) Reached line %d in %s\n", __LINE__, __FILE__));
- write_bytes(sp[0], buf, sizeof(*msg));
- bytes = msgs;
- while (bytes > 0) {
- int size = min(bytes, INET_SOCKET_BUFFER_SIZE);
- VideoRead(buf, size);
- write_bytes(sp[0], buf, size);
- bytes -= size;
- }
- }
- else {
- cerr << "expecting a packet of size " << msgs
- << endl;
- VideoRead(buf + sizeof(*msg), msgs);
- bytes = sizeof(*msg) + msgs;
- while ((res = write(sp[0], buf, bytes)) == -1) {
- if (errno == EINTR || errno == ENOBUFS) continue;
- perror("CTR error on sending INIT frame to VB");
- exit(1);
- }
- if (res < bytes) {
- fprintf(stderr, "CTR warn: send() res %dB < bytes %dB\n", res, bytes);
- }
- /*
- Fprintf(stderr,
- "CTR transferred INIT frame to VB: pkts %d, msgo %d, msgs %d\n",
- pkts, msgo, msgs);
- */
- }
- }
- read(sp[0], buf, 1); /* read a garbage byte, to sync with VB */
- ::close(sp[0]);
- free(buf);
- }
- break;
- }
- }
- }
- return 0;
-}
-
-CORBA::Boolean
-Command_Handler::stat_stream (CORBA::Char_out ch,
- CORBA::Long_out size)
-{
- return 0;
-}
-
-
-CORBA::Boolean
-Command_Handler::close (void)
-{
- TAO_TRY
- {
- CORBA::Boolean result;
- result = this->video_control_->close (TAO_TRY_ENV);
- TAO_CHECK_ENV;
- if (result == (CORBA::B_FALSE))
- return CORBA::B_FALSE;
- ACE_DEBUG ((LM_DEBUG,"(%P|%t) close done \n"));
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("video_control_->close (..)");
- return CORBA::B_FALSE;
- }
- TAO_ENDTRY;
-}
-
-
-CORBA::Boolean
-Command_Handler::stat_sent (void)
-{
- return 0;
-}
-
-
-CORBA::Boolean
-Command_Handler::fast_forward (void)
-
-{
- // ::ff ();
- // CORBA call
- unsigned char tmp;
- Video_Control::FFpara_var para (new Video_Control::FFpara);
- /*
- fprintf(stderr, "CTR: FF . . .\n");
- */
- if (shared->live) {
- beep();
- }
- else {
- this->stop_playing ();
- if (shared->nextGroup < 0)
- shared->nextGroup = 0;
- if (videoSocket >= 0 && shared->nextGroup < shared->totalGroups)
- {
- NewCmd(CmdFF);
- shared->needHeader = 0;
- shared->framesPerSecond = shared->config.ffFPS /
- shared->patternSize;
- shared->usecPerFrame = (int)(1000000.0 / (float)shared->config.ffFPS) *
- shared->patternSize;
-
- shared->VStimeAdvance =
- max(shared->config.VStimeAdvance, DEFAULT_VStimeAdvance) * 1000;
- if (shared->VStimeAdvance < shared->usecPerFrame)
- shared->VStimeAdvance = shared->usecPerFrame;
-
- para->VStimeAdvance = shared->VStimeAdvance;
- para->sn = shared->cmdsn;
- para->nextGroup = shared->nextGroup;
- para->usecPerFrame = shared->usecPerFrame;
- para->framesPerSecond = shared->framesPerSecond;
- startTime = get_usec();
- TAO_TRY
- {
- CORBA::Boolean result;
- result = this->video_control_->fast_forward (para.in (),
- TAO_TRY_ENV);
- TAO_CHECK_ENV;
- if (result == (CORBA::B_FALSE))
- return CORBA::B_FALSE;
- ACE_DEBUG ((LM_DEBUG,"(%P|%t) fast_forward done \n"));
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("video_control_->fast_forward_video (..)");
- return CORBA::B_FALSE;
- }
- TAO_ENDTRY;
- start_timer();
- }
- }
- tmp = CmdDONE;
- CmdWrite(&tmp, 1);
- return CORBA::B_TRUE;
-}
-
-
-CORBA::Boolean
-Command_Handler::fast_backward (void)
-
-{
- // ::fb ();
- // return 0;
- unsigned char tmp;
- Video_Control::FBpara_var para (new Video_Control::FBpara);
- /*
- fprintf(stderr, "CTR: FB . . .\n");
- */
- if (shared->live) {
- beep();
- }
- else {
- this->stop_playing();
- if (shared->nextGroup >= shared->totalGroups)
- shared->nextGroup = shared->totalGroups - 1;
- if (videoSocket >= 0 && shared->nextGroup >= 0)
- {
- NewCmd(CmdFB);
- shared->needHeader = 0;
- shared->framesPerSecond = shared->config.fbFPS /
- shared->patternSize;
- shared->usecPerFrame = (int)(1000000.0 / (float)shared->config.fbFPS) *
- shared->patternSize;
-
- shared->VStimeAdvance =
- max(shared->config.VStimeAdvance, DEFAULT_VStimeAdvance) * 1000;
- if (shared->VStimeAdvance < shared->usecPerFrame)
- shared->VStimeAdvance = shared->usecPerFrame;
-
- para->VStimeAdvance = shared->VStimeAdvance;
- para->sn = shared->cmdsn;
- para->nextGroup = shared->nextGroup;
- para->usecPerFrame = shared->usecPerFrame;
- para->framesPerSecond = shared->framesPerSecond;
- startTime = get_usec();
- TAO_TRY
- {
- CORBA::Boolean result;
- result = this->video_control_->fast_backward (para.in (),
- TAO_TRY_ENV);
- TAO_CHECK_ENV;
- if (result == (CORBA::B_FALSE))
- return CORBA::B_FALSE;
- ACE_DEBUG ((LM_DEBUG,"(%P|%t) fast_backward done \n"));
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("video_control_->fast_forward_video (..)");
- return CORBA::B_FALSE;
- }
- TAO_ENDTRY;
-
- start_timer();
- }
- }
- tmp = CmdDONE;
- CmdWrite(&tmp, 1);
- return CORBA::B_TRUE;
-}
-
-
-CORBA::Boolean
-Command_Handler::step (void)
-
-{
- // ::step ();
- ACE_DEBUG ((LM_DEBUG,
- "(%P|%t) Command_Handler::step ()\n"));
- Video_Control::STEPpara_var para (new Video_Control::STEPpara);
- this->stop_playing ();
- NewCmd (CmdSTEP);
- if (videoSocket >= 0 && shared->nextFrame <= shared->totalFrames)
- { /* when shared->nextFrame == shared->totalFrame, it will force VS to send a ENDSEQ,
- to let VD give out the remaining frame in its ring[] buffer */
- para->sn = shared->cmdsn;
- para->nextFrame = shared->nextFrame;
- TAO_TRY
- {
- CORBA::Boolean result;
- result = this->video_control_->step (para.in (),
- TAO_TRY_ENV);
- ACE_DEBUG ((LM_DEBUG,"(%P|%t) step done \n"));
- TAO_CHECK_ENV;
- if (result == (CORBA::B_FALSE))
- return CORBA::B_FALSE;
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("video_control_->step (..)");
- return CORBA::B_FALSE;
- }
- TAO_ENDTRY;
- /*
- fprintf(stderr, "CTR: STEP . . . frame-%d\n", para.nextFrame);
- */
- ::wait_display ();
- }
- unsigned char tmp = CmdDONE;
- CmdWrite(&tmp, 1);
- return CORBA::B_TRUE;
-}
-
-CORBA::Boolean
-Command_Handler::play (int auto_exp,
- CORBA::Environment& env)
-{
- /*
- ::play (auto_exp);
- return 0;
- */
-
- CORBA::Long vts;
- unsigned char tmp;
- unsigned int ats;
- int cmdstarted = 0;
- int stuffsamples = 0;
- /*
- fprintf (stderr, "CTR: PLAY . . .\n");
- */
- this->stop_playing ();
-
- if (!shared->live && !shared->config.rt && videoSocket >= 0) {
- /* rtplay turned off only when video avaible and not want RT play */
- rtplay = 0;
- fprintf (stderr, "VCR is not playing at in realtime mode, audio disabled\n");
- }
- else {
- rtplay = 1;
- }
-
- if (shared->live) {
- rtplay = 1;
- shared->nextFrame = 0;
- shared->nextSample = 0;
- }
-
- shared->rtplay = rtplay;
-
- if (shared->nextFrame < 0)
- shared->nextFrame = 0;
- else if (shared->nextFrame >= shared->totalFrames)
- shared->nextFrame = shared->totalFrames - 1;
-
- if (audioSocket >= 0 && shared->nextSample < shared->totalSamples && rtplay)
- {
- PLAYaudioPara para;
- if (cmdstarted == 0)
- {
- NewCmd (CmdPLAY);
- if (!auto_exp) set_speed ();
- cmdstarted = 1;
- }
-
- if (videoSocket >= 0 && rtplay && !shared->live) {
- /* video channel also active, recompute nextSample */
- shared->nextSample = (int) ( (double)shared->audioPara.samplesPerSecond *
- ( (double)shared->nextFrame / shared->pictureRate));
- shared->nextSample += shared->config.audioOffset;
- if (shared->nextSample < 0) {
- stuffsamples = (- shared->nextSample);
- shared->nextSample = 0;
- }
- else if (shared->nextSample >= shared->totalSamples)
- shared->nextSample = shared->totalSamples - 1;
- }
-
- ABflushBuf (shared->nextSample);
-
- para.sn = htonl (shared->cmdsn);
- para.nextSample = htonl (shared->nextSample);
- para.samplesPerSecond = htonl (shared->samplesPerSecond);
- para.samplesPerPacket = htonl (1024 / shared->audioPara.bytesPerSample);
- para.ABsamples = htonl (AB_BUF_SIZE / shared->audioPara.bytesPerSample);
- para.spslimit = htonl (32000);
-
- startTime = get_usec ();
- tmp = CmdPLAY;
- AudioWrite (&tmp, 1);
- AudioWrite (&para, sizeof (para));
- read_int (audioSocket, (int *)&ats);
- }
-
- if (videoSocket >= 0 && shared->nextFrame < shared->totalFrames)
- {
- Video_Control::PLAYpara_var para (new Video_Control::PLAYpara);
-
- if (cmdstarted == 0)
- {
- NewCmd (CmdPLAY);
- if (!auto_exp) set_speed ();
- cmdstarted = 1;
- }
- shared->VBheadFrame = -1;
- shared->needHeader = 0;
- {
- int i = shared->config.maxSPframes;
- i = (int) ( (double)i * (1000000.0 / (double)shared->usecPerFrame) /
- shared->pictureRate);
- shared->sendPatternGops = max (min (i, PATTERN_SIZE) / shared->patternSize, 1);
- }
- cmdstarted = 1;
-#ifdef STAT
- shared->collectStat = (shared->config.collectStat && (!shared->live));
- if (shared->collectStat)
- {
- int i;
- memset (& (shared->stat), 0, sizeof (shared->stat));
- shared->stat.VDlastFrameDecoded = (unsigned)-1;
- for (i = 0; i < MAX_FRAMES; i++)
- shared->stat.VBfillLevel[i] = SHRT_MIN;
- speedPtr = 0;
- }
-#endif
- shared->VStimeAdvance =
- max (shared->config.VStimeAdvance, DEFAULT_VStimeAdvance) * 1000;
- if (shared->VStimeAdvance < shared->usecPerFrame)
- shared->VStimeAdvance = shared->usecPerFrame;
-
- para->VStimeAdvance = shared->VStimeAdvance;
- para->sn = shared->cmdsn;
- para->nextFrame = shared->nextFrame;
- para->usecPerFrame = shared->usecPerFrame;
- para->framesPerSecond = shared->framesPerSecond;
- para->collectStat = shared->collectStat;
- frate = shared->config.frameRateLimit;
- if (frate <= 0.0) {
- frate = 1.0;
- }
- shared->frameRateLimit = frate;
- para->frameRateLimit1000 =
- (long) (shared->frameRateLimit * 1000.0);
- compute_sendPattern ();
- para->sendPatternGops = shared->sendPatternGops;
- // memcpy (para->sendPattern, shared->sendPattern, PATTERN_SIZE);
-
- // Sequence of chars
-
- para->sendPattern.length (PATTERN_SIZE);
-
- for (int i=0; i<PATTERN_SIZE ; i++)
- para->sendPattern [i] = shared->sendPattern [i];
-
- startTime = get_usec ();
- /*
- tmp = CmdPLAY;
- VideoWrite (&tmp, 1);
- VideoWrite (&para, sizeof (para));
- read_int (videoSocket, (int *)&vts);
- */
- // CORBA call
- this->video_control_->play (para,
- vts,
- env);
-
- if (shared->config.qosEffective) {
- /*
- fprintf (stderr, "CTR start FeedBack with init frameRateLimit %lf\n",
- frate);
- */
- maxfr = frate; /* max frame rate all the time during one playback */
- minupf = (int) (1000000.0 / maxfr); /* min usec-per-frame all the time
- during one playback */
- maxrate = (double)minupf / (double)max (shared->usecPerFrame, minupf);
- /* this is current max frame rate in percentage against 'maxfr',
- current max frame rate is the lower of 'maxfr' and play speed */
- frate = 1.0; /* current sending frame rate, in percentage against 'maxfr'
- This value is set with init value as 1.0, so that if current
- speed is lower than frameRateLimit, no frames are dropped,
- then when play speed increases frame rate will increase
- accordingly until frames are dropped*/
- adjstep = ( (double)minupf / (double)shared->usecPerFrame) /
- (double)max (shared->patternSize * shared->sendPatternGops, 5);
- /* adjust step for current play speed, in percentage against
- 'maxfr' */
-
- fbstate = 1;
- fb_startup = 1;
-
- /*
- fprintf (stderr, "CTR init frate: %lf minupf %d, shared->upf %d\n",
- frate, minupf, shared->usecPerFrame);
- */
- }
- }
-
- if (shared->live && (videoSocket >= 0) && (audioSocket >= 0)) {
- int gap = get_duration (ats, vts);
- if (gap < 0 || gap >= 5000000) {
- Fprintf (stderr, "Error for live source: ats %u, vts %u, gap %d\n",
- ats, vts, gap);
- }
- else {
- int skipped = gap * shared->audioPara.samplesPerSecond / 1000000;
- skipped += shared->config.audioOffset;
- ABskipSamples (skipped);
- Fprintf (stderr, "Live source: skipped %d audio samples\n", skipped);
- }
- }
- else if (stuffsamples) {
- ABskipSamples (-stuffsamples);
- }
- if (cmdstarted)
- start_timer ();
- tmp = CmdDONE;
- CmdWrite (&tmp, 1);
- return 0;
-}
-
-int
-Command_Handler::position_action (int operation_tag)
-{
- int val;
- unsigned char tmp = CmdDONE;
- CmdRead ((char*)&val, 4);
- if (shared->live) {
- beep();
- }
- else {
- shared->locationPosition = val;
- this->stop_playing ();
- NewCmd(CmdPOSITION);
- if (videoSocket >= 0)
- {
- int gop = shared->nextGroup;
- Video_Control::POSITIONpara_var para (new Video_Control::POSITIONpara);
- shared->nextGroup = ((shared->totalGroups-1) * val) / POSITION_RANGE;
- /*
- fprintf(stderr, "CTR: POSITION%s %d (nextGop %d). . .\n",
- operation_tag ? "_released" : "", val, shared->nextGroup);
- */
- if (gop != shared->nextGroup || operation_tag)
- {
- shared->nextFrame = ((shared->totalFrames-1) * val) / POSITION_RANGE;
- para->sn = htonl(shared->cmdsn);
- para->nextGroup = htonl(shared->nextGroup);
- tmp = CmdPOSITION;
- TAO_TRY
- {
- CORBA::Boolean result;
- result = this->video_control_->position (para.in (),
- TAO_TRY_ENV);
- TAO_CHECK_ENV;
- if (result == (CORBA::B_FALSE))
- return -1;
- ACE_DEBUG ((LM_DEBUG,"(%P|%t) position done \n"));
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("video_control_->position (..)");
- return -1;
- }
- TAO_ENDTRY;
- if (operation_tag) /* release or LOOPrewind */
- wait_display();
- }
- if (operation_tag && audioSocket >= 0) /* needs to adjust audio position */
- {
- shared->nextSample = (int)((double)shared->audioPara.samplesPerSecond *
- ((double)shared->nextFrame / shared->pictureRate));
- }
- }
- else if (audioSocket >= 0)
- shared->nextSample = (shared->totalSamples-1) * val / POSITION_RANGE;
- }
- tmp = CmdDONE;
- CmdWrite(&tmp, 1);
- return 0;
-}
-
-int
-Command_Handler::position (void)
-
-{
- return this->position_action (0);
-}
-
-int
-Command_Handler::position_release (void)
-
-{
- return this->position_action (1);
-}
-
-int
-Command_Handler::volume (void)
-
-{
- CmdRead((char *)&shared->volumePosition, 4);
- if (audioSocket >= 0) {
- SetAudioGain();
- }
- /*
- unsigned char tmp = CmdDONE;
- tmp = CmdDONE;
- CmdWrite(&tmp, 1);
- */
- return 0;
-}
-
-int
-Command_Handler::balance (void)
-
-{
- CmdRead((char *)&shared->balancePosition, 4);
- /*
- unsigned char tmp = CmdDONE;
- tmp = CmdDONE;
- CmdWrite(&tmp, 1);
- */
- return 0;
-}
-
-CORBA::Boolean
-Command_Handler::speed (void)
-
-{
-
- // ::speed ();
- // return 0;
-
- unsigned char tmp;
- CmdRead((char *)&shared->speedPosition, 4);
- set_speed();
- if (!shared->live && shared->cmd == CmdPLAY)
- {
- if (videoSocket >= 0) {
- Video_Control::SPEEDpara_var para (new Video_Control::SPEEDpara);
- para->sn = shared->cmdsn;
- para->usecPerFrame = shared->usecPerFrame;
- para->framesPerSecond = shared->framesPerSecond;
- para->frameRateLimit1000 =
- (long)(shared->frameRateLimit * 1000.0);
- {
- int i = shared->config.maxSPframes;
- i = (int) ((double)i * (1000000.0 / (double)shared->usecPerFrame) /
- shared->pictureRate);
- shared->sendPatternGops = max(min(i, PATTERN_SIZE) / shared->patternSize, 1);
- }
- compute_sendPattern();
- para->sendPatternGops = shared->sendPatternGops;
-
- // memcpy(para.sendPattern, shared->sendPattern, PATTERN_SIZE);
- para->sendPattern.length (PATTERN_SIZE);
- for (int i=0; i< PATTERN_SIZE ; i++)
- para->sendPattern[i]=shared->sendPattern[i];
- // CORBA call
- TAO_TRY
- {
- CORBA::Boolean result =
- this->video_control_->speed (para.in (),
- TAO_TRY_ENV);
- TAO_CHECK_ENV;
- ACE_DEBUG ((LM_DEBUG,
- "(%P|%t) CORBA call returned %d\n",
- result));
- if (result == (CORBA::B_FALSE))
- // ~~ what about audio if video fails
- // ~~ Eventually audio will have a separate audio command handler and
- // hence this shouldn't be a problem.
- return -1;
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("video_control->speed ()");
- return -1;
- }
- TAO_ENDTRY;
-
- if (fbstate) {
- maxrate = (double)minupf / (double)max(shared->usecPerFrame, minupf);
- adjstep = ((double)minupf / (double)shared->usecPerFrame) /
- (double)max(shared->patternSize * shared->sendPatternGops, 5);
- fbstate = 1;
- }
- }
- if (audioSocket >= 0) {
- SPEEDaudioPara para;
- para.sn = htonl(shared->cmdsn);
- para.samplesPerSecond = htonl(shared->samplesPerSecond);
- para.samplesPerPacket = htonl(1024 / shared->audioPara.bytesPerSample);
- para.spslimit = htonl(32000);
- tmp = CmdSPEED;
- AudioWrite(&tmp, 1);
- AudioWrite(&para, sizeof(para));
- }
- }
- return 0;
-
-}
-
-
-CORBA::Boolean
-Command_Handler::stop (void)
-
-{
- /*
- ::stop ();
- return 0;
- */
-#ifdef STAT
- unsigned char preCmd = shared->cmd;
-#endif
- /*
- fprintf(stderr, "CTR: STOP . . .\n");
- */
- this->stop_playing ();
-
- if (shared->live && videoSocket >= 0) {
- Fprintf(stderr, "CTR live video stat: average disp frame rate: %5.2f fps\n",
- shared->pictureRate * displayedFrames / shared->nextFrame);
- }
- unsigned char tmp = CmdDONE;
- CmdWrite(&tmp, 1);
-
- return CORBA::B_TRUE;
-}
-
-int
-Command_Handler::stop_playing (void)
-{
- unsigned char precmd = shared->cmd;
-
- if (precmd == CmdFF || precmd == CmdFB || precmd == CmdPLAY)
- {
- unsigned char tmp = CmdSTOP;
- NewCmd(CmdSTOP);
-
- /* notify AS and/or VS */
- if (audioSocket >= 0 && precmd == CmdPLAY && rtplay)
- {
- int cmdsn = htonl(shared->cmdsn);
- AudioWrite(&tmp, 1);
- AudioWrite(&cmdsn, 4);
- }
- if (videoSocket >= 0)
- {
- // CORBA call
- TAO_TRY
- {
- CORBA::Boolean result =
- this->video_control_->stop (shared->cmdsn,
- TAO_TRY_ENV);
- if (result == (CORBA::B_FALSE))
- return -1;
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("video_control_->stop(..)");
- return -1;
- }
- TAO_ENDTRY;
- }
-
- /* stop timer and sleep for a while */
- stop_timer();
- usleep(100000);
-
- /* purge VDbuf and audio channel from AS*/
- if (videoSocket >= 0)
- {
- while (VDpeekMsg() != NULL)
- VDreclaimMsg(VDgetMsg());
- /*
- Fprintf(stderr, "CTR: VDbuf purged.\n");
- */
- fbstate = 0;
-
- }
-
- /* adjust some info */
- if (precmd == CmdPLAY && videoSocket >= 0)
- shared->nextFrame = shared->currentFrame+1;
- else
- shared->nextGroup = shared->currentGroup + 1;
- }
-}
-
-// connects and handshakes with the server
-int
-Command_Handler::connect_to_server (char *address,
- int *ctr_fd,
- int *data_fd,
- int *max_pkt_size)
-{
-
- // set the pointers to the correct values
- *max_pkt_size = -INET_SOCKET_BUFFER_SIZE;
-
- // construct the server addr
- ACE_INET_Addr server_addr (VCR_TCP_PORT,
- address);
-
- if (this->connector_.connect (this->stream_,
- server_addr) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "(%P|%t) Connection to server failed: %p\n",
- "connect"),
- -1);
- // Write the CmdINITvideo to tell the server that this is a video
- // client.
- unsigned char tmp;
- tmp = CmdINITvideo;
- this->stream_.send_n (&tmp, sizeof (tmp));
- int ack;
- this->stream_.recv_n (&ack, sizeof (ack));
-
- ACE_DEBUG ((LM_DEBUG,
- "(%P|%t) got ack :%d\n",
- ack));
-
- // initialize the command handler , ORB
- if (this->resolve_server_reference () == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "(%P|%t) command_handler: resolve_server_reference returned -1"),
- -1);
-
- ACE_DEBUG ((LM_DEBUG, "(%P|%t) %s:%d\n", __FILE__, __LINE__));
- // Resolve the video control object reference.
-// int i = sizeof (sockaddr_in);
-// struct sockaddr_in addressIn;
-// if (::getsockname(*data_fd,
-// (struct sockaddr *)&addressIn,
-// &i) == -1)
-// ACE_ERROR_RETURN ((LM_ERROR,
-// "(%P|%t) Command_Handler::connect_to_server"
-// " failed to getsocketname on TCP dfd:"),
-// -1);
-//
- ACE_DEBUG ((LM_DEBUG, "(%P|%t) %s:%d\n", __FILE__, __LINE__));
- CORBA::Short server_port;
- ACE_INET_Addr local_addr;
- CORBA::String client_address_string;
- TAO_TRY
- {
- ACE_NEW_RETURN (client_address_string,
- char [BUFSIZ],
- -1);
- // Get the local UDP address
- this->dgram_.open (ACE_Addr::sap_any,
- ACE_Addr::sap_any);
-
- this->dgram_.get_local_addr (local_addr);
- // form a string
- ::sprintf (client_address_string,
- "%s:%d",
- local_addr.get_host_name (),
- local_addr.get_port_number ());
-
- ACE_DEBUG ((LM_DEBUG,
- "(%P|%t) Client string is %s\n",
- client_address_string));
-
- server_port = this->video_control_->set_peer (client_address_string,
- TAO_TRY_ENV);
- TAO_CHECK_ENV;
- if (server_port == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "(%P|%t) set_peer failed\n"),
- -1);
- ACE_DEBUG ((LM_DEBUG,"(%P|%t) set_peer done\n"));
- }
- TAO_CATCHANY
- {
- TAO_TRY_ENV.print_exception ("video_control_->fast_forward_video (..)");
- return CORBA::B_FALSE;
- }
- TAO_ENDTRY;
-
- // ACE_INET_Addr server_udp_addr (server_port,
- // address);
-
- // if (this->dgram_.open (server_udp_addr,
- // local_addr) == -1)
- // ACE_ERROR_RETURN ((LM_ERROR,
- // "(%P|%t) Command_Handler::connect_to_server:%p\n",
- // "dgram.open "),
- // -1);
-
- this->dgram_.get_local_addr (local_addr);
- // form a string
- ::sprintf (client_address_string,
- "%s:%d",
- local_addr.get_host_name (),
- local_addr.get_port_number ());
-
- ACE_DEBUG ((LM_DEBUG,
- "(%P|%t) Client string is %s\n",
- client_address_string));
- // set the pointers to the correct values
-
- // *ctr_fd = this->stream_.get_handle ();
- *ctr_fd = *data_fd = this->dgram_.get_handle ();
- // set both the control and data socket the same UDP socket.
- ACE_DEBUG ((LM_DEBUG,
- "Control and data fd = %d\n",
- *ctr_fd));
- return 0;
-}
-
-// ----------------------------------------------------------------------
-
-// Client_Sig_Handler methods
-// handles the timeout SIGALRM signal
-Client_Sig_Handler::Client_Sig_Handler (Command_Handler *command_handler)
- : command_handler_ (command_handler)
-{
-}
-
-int
-Client_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);
-
- // 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 (ACE_Reactor::instance ()->register_handler
- (this, ACE_Event_Handler::NULL_MASK) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "register_handler"),
- -1);
-
- // Create a sigset_t corresponding to the signals we want to catch.
- ACE_Sig_Set sig_set;
-
- sig_set.sig_add (SIGINT);
- sig_set.sig_add (SIGQUIT);
- sig_set.sig_add (SIGALRM);
- sig_set.sig_add (SIGUSR1);
- sig_set.sig_add (SIGUSR2);
-
- // Register the signal handler object to catch the signals.
- if (ACE_Reactor::instance ()->register_handler (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
-Client_Sig_Handler::get_handle (void) const
-{
- return this->handle_;
-}
-
-int
-Client_Sig_Handler::handle_input (ACE_HANDLE)
-{
- ACE_DEBUG ((LM_DEBUG, "(%t) handling asynchonrous input...\n"));
- return 0;
-}
-
-int
-Client_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
-Client_Sig_Handler::handle_signal (int signum, siginfo_t *, ucontext_t *)
-{
- int status;
- pid_t pid;
- // ACE_DEBUG ((LM_DEBUG, "(%t) received signal %S\n", signum));
-
- switch (signum)
- {
- case SIGALRM:
- // Handle the timeout
- ::TimerHandler (signum);
- // %% ??!!!
- break;
- case SIGUSR1:
- usr1_handler (signum);
- break;
- case SIGUSR2:
- default_usr2_handler (signum);
- break;
- case SIGCHLD:
- ACE_DEBUG ((LM_DEBUG, "(%P|%t) received signal %S\n", signum));
- pid = ACE_OS::wait (&status);
- if (pid == UIpid)
- {
- cerr << "ui exited, im ending the event loop!" << endl;
- ACE_Reactor::instance ()->end_event_loop ();
- }
- return 0;
- case SIGINT:
- ACE_DEBUG ((LM_DEBUG, "(%P|%t) received signal %S\n", signum));
- ACE_Reactor::instance ()->end_event_loop ();
- this->command_handler_->close ();
- return 0;
- default:
- ACE_DEBUG ((LM_DEBUG,
- "(%t) %S: not handled, returning to program\n",
- signum));
- break;
- }
- TimerProcessing ();
- return 0;
-}
View Lorry Controller Status