1 files changed, 80 insertions, 0 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/as.cpp b/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/as.cpp
new file mode 100644
index 00000000000..4105e5d2e9e
--- /dev/null
+++ b/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/as.cpp
@@ -0,0 +1,80 @@
+// $Id$
+
+#include "ace/OS.h"
+#include "mpeg_server/Audio_Server.h"
+#include "as.h"
+
+ACE_RCSID(server, as, "$Id$")
+
+int
+Audio_Child_Process::init (int argc,
+                           char **argv)
+{
+  if (TAO_AV_Child_Process_B<Audio_Server_StreamEndPoint,TAO_VDev,Audio_Control_i>::init (argc,argv) == -1)
+    return -1;
+
+  int max_pkt_size = -INET_SOCKET_BUFFER_SIZE;
+  AUDIO_GLOBAL::instance ()->serviceSocket = -1;
+    
+  AUDIO_GLOBAL::instance ()->conn_tag = max_pkt_size;
+
+  if (max_pkt_size < 0) 
+    max_pkt_size = -max_pkt_size;
+  else if (max_pkt_size == 0)
+    max_pkt_size = 1024 * 1024;
+    
+  AUDIO_GLOBAL::instance ()->start_time =ACE_OS::time (NULL);
+
+  AUDIO_GLOBAL::instance ()->fbpara = (AudioFeedBackPara *)ACE_OS::malloc(FBBUF_SIZE);
+  if (AUDIO_GLOBAL::instance ()->fbpara == NULL) {
+   ACE_OS::perror ("AS failed to allocate mem for fbpara");
+    return (-1);
+  }
+
+  AUDIO_GLOBAL::instance ()->databuf_size = max_pkt_size - sizeof(AudioPacket);
+  if (AUDIO_GLOBAL::instance ()->databuf_size > DATABUF_SIZE)
+    AUDIO_GLOBAL::instance ()->databuf_size = DATABUF_SIZE;
+  
+  AUDIO_GLOBAL::instance ()->pktbuf = (AudioPacket *)ACE_OS::malloc(sizeof(AudioPacket) + 
+                                                     AUDIO_GLOBAL::instance ()->databuf_size);
+  if (AUDIO_GLOBAL::instance ()->pktbuf == NULL) {
+   ACE_OS::perror ("AS failed to allocate mem for pktbuf");
+    return(-1);
+  }
+}
+
+int
+Audio_Child_Process::make_mediactrl (Audio_Control_i *& media_ctrl)
+{
+  ACE_DEBUG ((LM_DEBUG,"(%P|%t) Audio_Child_Process::make_mediactrl ()\n"));
+  media_ctrl = AUDIO_CONTROL_I::instance ();
+  return 0;
+}
+
+
+int
+main (int argc,char **argv)
+{
+  Audio_Child_Process audio_child;
+
+
+  if (audio_child.init (argc,argv) == -1)
+    return 1;
+//   while  (1)
+//     {
+      int result = audio_child.run () ;
+//       if (errno == EINTR)
+//         continue;
+//       else
+//         break;
+//     }
+  return 0;
+}
+
+#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
+template class TAO_AV_Child_Process<Audio_Server_StreamEndPoint, TAO_VDev, Audio_Control_i>;
+template class TAO_AV_Child_Process_B<Audio_Server_StreamEndPoint, TAO_VDev, Audio_Control_i>;
+#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
+#pragma instantiate TAO_AV_Child_Process<Audio_Server_StreamEndPoint, TAO_VDev, Audio_Control_i>
+#pragma instantiate TAO_AV_Child_Process_B<Audio_Server_StreamEndPoint, TAO_VDev, Audio_Control_i>
+#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */