| Index: webrtc/modules/rtp_rtcp/test/BWEStandAlone/BWEStandAlone.cc
|
| diff --git a/webrtc/modules/rtp_rtcp/test/BWEStandAlone/BWEStandAlone.cc b/webrtc/modules/rtp_rtcp/test/BWEStandAlone/BWEStandAlone.cc
|
| deleted file mode 100644
|
| index 2d70289d3a274f45d102b6aafcb1a58b84280fda..0000000000000000000000000000000000000000
|
| --- a/webrtc/modules/rtp_rtcp/test/BWEStandAlone/BWEStandAlone.cc
|
| +++ /dev/null
|
| @@ -1,199 +0,0 @@
|
| -/*
|
| - * Copyright (c) 2011 The WebRTC project authors. All Rights Reserved.
|
| - *
|
| - * Use of this source code is governed by a BSD-style license
|
| - * that can be found in the LICENSE file in the root of the source
|
| - * tree. An additional intellectual property rights grant can be found
|
| - * in the file PATENTS. All contributing project authors may
|
| - * be found in the AUTHORS file in the root of the source tree.
|
| - */
|
| -
|
| -// BWEStandAlone.cpp : Defines the entry point for the console application.
|
| -//
|
| -
|
| -#include <stdio.h>
|
| -#include <string>
|
| -
|
| -#include "webrtc/modules/rtp_rtcp/include/rtp_rtcp.h"
|
| -#include "webrtc/system_wrappers/include/event_wrapper.h"
|
| -#include "webrtc/system_wrappers/include/trace.h"
|
| -#include "webrtc/test/channel_transport/udp_transport.h"
|
| -
|
| -#include "webrtc/modules/rtp_rtcp/test/BWEStandAlone/TestLoadGenerator.h"
|
| -#include "webrtc/modules/rtp_rtcp/test/BWEStandAlone/TestSenderReceiver.h"
|
| -
|
| -#include "webrtc/modules/rtp_rtcp/test/BWEStandAlone/MatlabPlot.h"
|
| -
|
| -//#include "vld.h"
|
| -
|
| -class myTransportCB: public UdpTransportData
|
| -{
|
| -public:
|
| - myTransportCB (RtpRtcp *rtpMod) : _rtpMod(rtpMod) {};
|
| -protected:
|
| - // Inherited from UdpTransportData
|
| - void IncomingRTPPacket(const int8_t* incomingRtpPacket,
|
| - const size_t rtpPacketLength,
|
| - const int8_t* fromIP,
|
| - const uint16_t fromPort) override;
|
| -
|
| - void IncomingRTCPPacket(const int8_t* incomingRtcpPacket,
|
| - const size_t rtcpPacketLength,
|
| - const int8_t* fromIP,
|
| - const uint16_t fromPort) override;
|
| -
|
| -private:
|
| - RtpRtcp *_rtpMod;
|
| -};
|
| -
|
| -void myTransportCB::IncomingRTPPacket(const int8_t* incomingRtpPacket,
|
| - const size_t rtpPacketLength,
|
| - const int8_t* fromIP,
|
| - const uint16_t fromPort)
|
| -{
|
| - printf("Receiving RTP from IP %s, port %u\n", fromIP, fromPort);
|
| - _rtpMod->IncomingPacket((uint8_t *) incomingRtpPacket, rtpPacketLength);
|
| -}
|
| -
|
| -void myTransportCB::IncomingRTCPPacket(const int8_t* incomingRtcpPacket,
|
| - const size_t rtcpPacketLength,
|
| - const int8_t* fromIP,
|
| - const uint16_t fromPort)
|
| -{
|
| - printf("Receiving RTCP from IP %s, port %u\n", fromIP, fromPort);
|
| - _rtpMod->IncomingPacket((uint8_t *) incomingRtcpPacket, rtcpPacketLength);
|
| -}
|
| -
|
| -
|
| -int main(int argc, char* argv[])
|
| -{
|
| - bool isSender = false;
|
| - bool isReceiver = false;
|
| - uint16_t port;
|
| - std::string ip;
|
| - TestSenderReceiver *sendrec = new TestSenderReceiver();
|
| - TestLoadGenerator *gen;
|
| -
|
| - if (argc == 2)
|
| - {
|
| - // receiver only
|
| - isReceiver = true;
|
| -
|
| - // read port
|
| - port = atoi(argv[1]);
|
| - }
|
| - else if (argc == 3)
|
| - {
|
| - // sender and receiver
|
| - isSender = true;
|
| - isReceiver = true;
|
| -
|
| - // read IP
|
| - ip = argv[1];
|
| -
|
| - // read port
|
| - port = atoi(argv[2]);
|
| - }
|
| -
|
| - Trace::CreateTrace();
|
| - Trace::SetTraceFile("BWEStandAloneTrace.txt");
|
| - Trace::set_level_filter(webrtc::kTraceAll);
|
| -
|
| - sendrec->InitReceiver(port);
|
| -
|
| - sendrec->Start();
|
| -
|
| - if (isSender)
|
| - {
|
| - const uint32_t startRateKbps = 1000;
|
| - //gen = new CBRGenerator(sendrec, 1000, 500);
|
| - gen = new CBRFixFRGenerator(sendrec, startRateKbps, 90000, 30, 0.2);
|
| - //gen = new PeriodicKeyFixFRGenerator(sendrec, startRateKbps, 90000, 30, 0.2, 7, 300);
|
| - //const uint16_t numFrameRates = 5;
|
| - //const uint8_t frameRates[numFrameRates] = {30, 15, 20, 23, 25};
|
| - //gen = new CBRVarFRGenerator(sendrec, 1000, frameRates, numFrameRates, 90000, 4.0, 0.1, 0.2);
|
| - //gen = new CBRFrameDropGenerator(sendrec, startRateKbps, 90000, 0.2);
|
| - sendrec->SetLoadGenerator(gen);
|
| - sendrec->InitSender(startRateKbps, ip.c_str(), port);
|
| - gen->Start();
|
| - }
|
| -
|
| - while (1)
|
| - {
|
| - }
|
| -
|
| - if (isSender)
|
| - {
|
| - gen->Stop();
|
| - delete gen;
|
| - }
|
| -
|
| - delete sendrec;
|
| -
|
| - //uint8_t numberOfSocketThreads = 1;
|
| - //UdpTransport* transport = UdpTransport::Create(0, numberOfSocketThreads);
|
| -
|
| - //RtpRtcp* rtp = RtpRtcp::CreateRtpRtcp(1, false);
|
| - //if (rtp->InitSender() != 0)
|
| - //{
|
| - // exit(1);
|
| - //}
|
| - //if (rtp->RegisterSendTransport(transport) != 0)
|
| - //{
|
| - // exit(1);
|
| - //}
|
| -
|
| -// transport->InitializeSendSockets("192.168.200.39", 8000);
|
| - //transport->InitializeSendSockets("127.0.0.1", 10000);
|
| - //transport->InitializeSourcePorts(8000);
|
| -
|
| -
|
| - return(0);
|
| - // myTransportCB *tp = new myTransportCB(rtp);
|
| - // transport->InitializeReceiveSockets(tp, 10000, "0.0.0.0");
|
| - // transport->StartReceiving(500);
|
| -
|
| - // int8_t data[100];
|
| - // for (int i = 0; i < 100; data[i] = i++);
|
| -
|
| - // for (int i = 0; i < 100; i++)
|
| - // {
|
| - // transport->SendRaw(data, 100, false);
|
| - // }
|
| -
|
| -
|
| -
|
| - // int32_t totTime = 0;
|
| - // while (totTime < 10000)
|
| - // {
|
| - // transport->Process();
|
| - // int32_t wTime = transport->TimeUntilNextProcess();
|
| - // totTime += wTime;
|
| - // Sleep(wTime);
|
| - // }
|
| -
|
| -
|
| - //if (transport)
|
| - //{
|
| - // // Destroy the Socket Transport module
|
| - // transport->StopReceiving();
|
| - // transport->InitializeReceiveSockets(NULL,0);// deregister callback
|
| - // UdpTransport::Destroy(transport);
|
| - // transport = NULL;
|
| - // }
|
| -
|
| - // if (tp)
|
| - // {
|
| - // delete tp;
|
| - // tp = NULL;
|
| - // }
|
| -
|
| - // if (rtp)
|
| - // {
|
| - // RtpRtcp::DestroyRtpRtcp(rtp);
|
| - // rtp = NULL;
|
| - // }
|
| -
|
| -
|
| - //return 0;
|
| -}
|
|
|