开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 多媒体 > 流媒体/Mpeg4/MP4 > 查看源码
agent.cxx
资源名称：rtsp-1.0.1.tar.gz　[点击查看]
上传用户：sy_wanhua
上传日期：2013-07-25
资源大小：3048k
文件大小：8k
源码类别：

流媒体/Mpeg4/MP4

开发平台：

C/C++

agent.cxx：源码内容
  1. /* ====================================================================
  2.  * The Vovida Software License, Version 1.0 
  3.  * 
  4.  * Copyright (c) 2000 Vovida Networks, Inc.  All rights reserved.
  5.  * 
  6.  * Redistribution and use in source and binary forms, with or without
  7.  * modification, are permitted provided that the following conditions
  8.  * are met:
  9.  * 
  10.  * 1. Redistributions of source code must retain the above copyright
  11.  *    notice, this list of conditions and the following disclaimer.
  12.  * 
  13.  * 2. Redistributions in binary form must reproduce the above copyright
  14.  *    notice, this list of conditions and the following disclaimer in
  15.  *    the documentation and/or other materials provided with the
  16.  *    distribution.
  17.  * 
  18.  * 3. The names "VOCAL", "Vovida Open Communication Application Library",
  19.  *    and "Vovida Open Communication Application Library (VOCAL)" must
  20.  *    not be used to endorse or promote products derived from this
  21.  *    software without prior written permission. For written
  22.  *    permission, please contact vocal@vovida.org.
  23.  *
  24.  * 4. Products derived from this software may not be called "VOCAL", nor
  25.  *    may "VOCAL" appear in their name, without prior written
  26.  *    permission of Vovida Networks, Inc.
  27.  * 
  28.  * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED
  29.  * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  30.  * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, TITLE AND
  31.  * NON-INFRINGEMENT ARE DISCLAIMED.  IN NO EVENT SHALL VOVIDA
  32.  * NETWORKS, INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT DAMAGES
  33.  * IN EXCESS OF $1,000, NOR FOR ANY INDIRECT, INCIDENTAL, SPECIAL,
  34.  * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
  35.  * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
  36.  * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
  37.  * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  38.  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
  39.  * USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH
  40.  * DAMAGE.
  41.  * 
  42.  * ====================================================================
  43.  * 
  44.  * This software consists of voluntary contributions made by Vovida
  45.  * Networks, Inc. and many individuals on behalf of Vovida Networks,
  46.  * Inc.  For more information on Vovida Networks, Inc., please see
  47.  * <http://www.vovida.org/>.
  48.  *
  49.  */
  51. // $Id: agent.cxx,v 1.4 2001/05/13 10:54:01 icahoon Exp $
  54. #include <sys/time.h>
  55. #include <sys/resource.h>
  56. #include <unistd.h>
  57. #include "mgc.hxx"
  59. #if 0
  60. char* getHost()
  61. {
  62.     static char buf[256];
  64.     gethostname(buf, 256);
  66.     return buf;
  67. }
  69. void waitForAck(UdpReceiver& receiver)
  70. {
  71.     UdpPacket* data = 0;
  72.     MgcpCommand* test_item;
  74.     bool gotResponse(false);
  76.     while (!gotResponse)
  77.     {
  78.         data = receiver.receive();
  80.         test_item = parseMessage(data->getMessageLocation(), 0);
  82.         if (dynamic_cast < MgcpResponse* > (test_item) != NULL)
  83.         {
  84.             // this is not a proper response
  85.             gotResponse = true;
  86.         }
  87.         free (test_item);
  88.         free (data);
  89.     }
  90. }
  92. #endif
  94. int main()
  95. {
  96. #if 0
  97.     UdpReceiver server(5010);
  98.     CreateConnection test;
  99. #endif
  101.     MgcEndpointConfiguration config ("testID", MgcpBearerInformation());
  103. #if 0
  104.     EndpointId id("testID");
  105.     BearerInformation bearer;
  106.     Entity myself("callagent@foo.bar.com");
  107.     EndpointConfiguration msg0(id, bearer);
  108.     EndpointConfiguration msg1(id, bearer);
  109.     EndpointConfiguration msg2(id, bearer);
  110.     EndpointConfiguration msg3(id, bearer);
  111.     EndpointConfiguration msg4(id, bearer);
  112.     EndpointConfiguration msg5(id, bearer);
  113. #endif
  115.     MgcNotificationRequest request ("testID", "215781728");
  117.     request.addRequestedEvents(MgcRequestEvent());
  118.     request.addRequestedEvents(MgcRequestEvent());
  119.     request.addRequestedEvents(MgcRequestEvent());
  120.     request.addRequestedEvents(MgcRequestEvent());
  121.     request.addRequestedEvents(MgcRequestEvent());
  123. #if 0
  124.     NotificationRequest msg6(id);
  126.     LineEventOffHook offHook;
  127.     LineEventOnHook onHook;
  128.     LineEventHookFlash hookFlash;
  130.     RequestedEvents events6;
  132.     DigitMap temp("[0-9]");
  134.     events6.insert(offHook);
  137.     SignalRequests signals_6;
  139.     SignalRingback ringback;
  141.     SignalRing ring;
  143.     signals_6.insert(ring);
  144.     signals_6.insert(ringback);
  148.     msg6.insert(&myself);
  149.     msg6.insert(&temp);
  150.     msg6.insert(&events6);
  151.     msg6.insert(&signals_6);
  153.     cout << msg6;
  155.     NotificationRequest msg7(id);
  156.     msg7.insert(&myself);
  157.     msg7.insert(&temp);
  158.     RequestedEvents events7;
  160.     events7.insert(offHook);
  161.     events7.insert(onHook);
  162.     events7.insert(hookFlash);
  163.     msg7.insert(&events7);
  165.     // message 8
  167.     Notify msg8(id);
  168.     msg8.insert(&myself);
  169.     //    msg8.insert(&temp);
  170.     ObservedEvents events8;
  172.     events8.insert(offHook);
  173.     events8.insert(onHook);
  174.     events8.insert(hookFlash);
  175.     msg8.insert(&events8);
  179.     //    cerr << events;
  181.     msg6.printData(cout);
  183.     MgcpTransmitter gateway("localhost");
  185.     EndpointConfiguration* test2;
  187.     test2 = new EndpointConfiguration;
  188.     delete (test2);
  191.     msg0.send(gateway);
  192.     waitForAck(server);
  193.     msg1.send(gateway);
  194.     waitForAck(server);
  195.     msg1.send(gateway);
  196.     waitForAck(server);
  197.     msg1.send(gateway);
  198.     waitForAck(server);
  199.     msg1.send(gateway);
  200.     waitForAck(server);
  201.     msg1.send(gateway);
  202.     waitForAck(server);
  203.     msg2.send(gateway);
  204.     waitForAck(server);
  205.     msg3.send(gateway);
  206.     waitForAck(server);
  207.     msg4.send(gateway);
  208.     waitForAck(server);
  209.     msg5.send(gateway);
  210.     waitForAck(server);
  211.     msg1.send(gateway);
  212.     waitForAck(server);
  213.     msg6.send(gateway);
  214.     waitForAck(server);
  215.     msg7.send(gateway);
  216.     waitForAck(server);
  217.     msg8.send(gateway);
  218.     waitForAck(server);
  221.     CreateConnection msg9;
  222.     CallId msg9_id("0123456789ABCDEF");
  223.     ConnectionId msg9_connection("FEDCBA9876543210");
  224.     //    Entity msg9_entity("foo@bar.com");
  225.     //    Options msg9_options;
  227.     cout << "callid: " << msg9_id << "n";
  229.     cout << "connectionid: " << msg9_connection << "n";
  231.     ConnectionMode msg9_mode(ConnectionSendRecv);
  232.     RemoteConnectionDescriptor msg9_rcd;
  234.     msg9.insert(&msg9_id);
  235.     msg9.insert(&msg9_connection);
  236.     msg9.insert(&msg9_mode);
  237.     msg9.insert(&myself);
  238.     msg9.insert(&id);
  240.     SDPDescriptor foo;
  242.     foo.setSessionName("test session");
  243.     foo.setUserName("bogawa");
  244.     foo.setAddress(getHost());
  245.     foo.setSessionId(128538);
  246.     foo.setVersion(1000);
  247.     foo.setPort(6502);
  248.     foo.addFormat(1);
  250.     RemoteConnectionDescriptor msg9_rd(foo);
  252.     msg9.insert(&msg9_rd);
  254.     cout << msg9 << "n";
  256.     msg9.send(gateway);
  257.     waitForAck(server);
  260.     ModifyConnection msg10;
  262.     msg10.insert(&msg9_id);
  263.     msg10.insert(&msg9_connection);
  264.     msg10.insert(&msg9_mode);
  265.     msg10.insert(&myself);
  266.     msg10.insert(&id);
  268.     cout << msg10 << "n";
  270.     msg10.send(gateway);
  271.     waitForAck(server);
  273.     cout << "--------------------- local test ------------------n";
  275.     SDPDescriptor bar;
  277.     bar.setSessionName("test session");
  278.     bar.setUserName("bogawa");
  279.     bar.setAddress(getHost());
  280.     bar.setSessionId(128538);
  281.     bar.setVersion(1000);
  282.     bar.setPort(6502);
  283.     bar.addFormat(1);
  285.     LocalConnectionDescriptor local(bar);
  287.     cout << "local: " << local << "n";
  289.     MgcpResponse response00(200, 500, "OK");
  291.     response00.insert(&events8);
  292.     response00.insert(&local);
  294.     cout << response00 << "n";
  295.     response00.send(gateway);
  298.     DeleteConnection delconn;
  300. #if 0
  301.     struct rusage usage;
  303.     getrusage (RUSAGE_SELF, &usage);
  304.     cout << "ru_maxrss: " << usage.ru_maxrss << "n";
  305.     cout << "ru_ixrss: " << usage.ru_ixrss << "n";
  306.     cout << "ru_idrss: " << usage.ru_idrss << "n";
  307.     cout << "ru_isrss: " << usage.ru_isrss << "n";
  308. #endif
  310. #endif 
  311.     return 0;
  312. }