Revision: 9205
Author: oleg.kulikoff
Date: Fri Jan 1 23:49:23 2010
Log: Remove incorrect junit tests
http://code.google.com/p/mobicents/source/detail?r=9205
Deleted:
/trunk/servers/media/core/controllers/mgcp/src/test/java/org/mobicents/media/server/ctrl/mgcp/evt/ann/PlayAnnouncementTest.java
/trunk/servers/media/core/controllers/mgcp/src/test/java/org/mobicents/media/server/ctrl/mgcp/test/ann/AnnTestCase.java
/trunk/servers/media/core/controllers/mgcp/src/test/resources/org/mobicents/media/server/ctrl/mgcp/test/ann
=======================================
---
/trunk/servers/media/core/controllers/mgcp/src/test/java/org/mobicents/media/server/ctrl/mgcp/evt/ann/PlayAnnouncementTest.java
Mon Nov 30 21:58:37 2009
+++ /dev/null
@@ -1,190 +0,0 @@
-/*
- * To change this template, choose Tools | Templates
- * and open the template in the editor.
- */
-package org.mobicents.media.server.ctrl.mgcp.evt.ann;
-
-import jain.protocol.ip.mgcp.message.parms.NotifiedEntity;
-import jain.protocol.ip.mgcp.message.parms.RequestIdentifier;
-import java.io.IOException;
-import java.net.URL;
-import java.util.Hashtable;
-import java.util.concurrent.Semaphore;
-import java.util.concurrent.TimeUnit;
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.mobicents.media.Buffer;
-import org.mobicents.media.Component;
-import org.mobicents.media.ComponentFactory;
-import org.mobicents.media.Format;
-import org.mobicents.media.server.ConnectionFactory;
-import org.mobicents.media.server.EndpointImpl;
-import org.mobicents.media.server.ctrl.mgcp.MgcpController;
-import static org.junit.Assert.*;
-import org.mobicents.media.server.ctrl.mgcp.Request;
-import org.mobicents.media.server.impl.AbstractSink;
-import org.mobicents.media.server.impl.clock.TimerImpl;
-import org.mobicents.media.server.impl.resource.audio.AudioPlayerFactory;
-import org.mobicents.media.server.impl.rtp.sdp.AVProfile;
-import org.mobicents.media.server.resource.ChannelFactory;
-import org.mobicents.media.server.spi.Connection;
-import org.mobicents.media.server.spi.ConnectionMode;
-import org.mobicents.media.server.spi.Endpoint;
-import org.mobicents.media.server.spi.Timer;
-
-/**
- *
- * @author kulikov
- */
-public class PlayAnnouncementTest {
-
- private Timer timer;
- private EndpointImpl sender;
- private EndpointImpl receiver;
- private AudioPlayerFactory playerFactory;
- private TestSinkFactory sinkFactory;
- private ChannelFactory channelFactory;
- private Semaphore semaphore;
- private boolean res;
- private int pcmaCount;
- private MgcpController controller;
-
- public PlayAnnouncementTest() {
- }
-
- @BeforeClass
- public static void setUpClass() throws Exception {
- }
-
- @AfterClass
- public static void tearDownClass() throws Exception {
- }
-
- @Before
- public void setUp() throws Exception {
- semaphore = new Semaphore(0);
- res = false;
-
- timer = new TimerImpl();
- timer.start();
-
- playerFactory = new AudioPlayerFactory();
- playerFactory.setName("audio.player");
-
- sinkFactory = new TestSinkFactory();
-
- channelFactory = new ChannelFactory();
- channelFactory.start();
-
- sender = new EndpointImpl("test/announcement/sender");
- sender.setTimer(timer);
-
-
- Hashtable rxFactories = new Hashtable();
- rxFactories.put("audio", channelFactory);
-
- Hashtable txFactories = new Hashtable();
- txFactories.put("audio", channelFactory);
-
- ConnectionFactory connectionFactory = new ConnectionFactory();
- connectionFactory.setRxChannelFactory(rxFactories);
- connectionFactory.setTxChannelFactory(txFactories);
-
- Hashtable sources = new Hashtable();
- sources.put("audio", playerFactory);
-
- Hashtable sinks = new Hashtable();
- sinks.put("audio", sinkFactory);
-
- sender.setSourceFactory(sources);
- sender.setConnectionFactory(connectionFactory);
-
- sender.start();
-
- receiver = new EndpointImpl("test/announcement/receiver");
- receiver.setTimer(timer);
-
- receiver.setSinkFactory(sinks);
- receiver.setConnectionFactory(connectionFactory);
-
- receiver.start();
- }
-
- @After
- public void tearDown() {
- timer.stop();
- }
-
- /**
- * Test of doVerify method, of class PlayAnnouncement.
- */
- @Test
- public void testSignal() throws Exception {
-
- System.out.println("======1");
- Connection rxConnection =
receiver.createLocalConnection(ConnectionMode.RECV_ONLY);
- System.out.println("======2");
- Connection txConnection =
sender.createLocalConnection(ConnectionMode.SEND_ONLY);
-
- txConnection.setOtherParty(rxConnection);
-
- URL url =
PlayAnnouncementTest.class.getClassLoader().getResource("addf8-Alaw-GW.wav");
- String s = url.toExternalForm();
- RequestIdentifier id = new RequestIdentifier("1");
- NotifiedEntity ne = new NotifiedEntity("localhost");
- PlayAnnouncementFactory factory = new PlayAnnouncementFactory();
- factory.setResourceName("audio.player");
- PlayAnnouncement signal = (PlayAnnouncement)
factory.getInstance(controller, s);
-
- Request request = new Request(controller, id, null, sender, ne);
-
- signal.doVerify(sender);
- signal.start(request);
-
- System.out.println("Started");
- semaphore.tryAcquire(10, TimeUnit.SECONDS);
-
- System.out.println(pcmaCount);
- assertTrue("The amount of packets dos not match", Math.abs(150 -
pcmaCount) < 20);
-
- receiver.deleteConnection(rxConnection.getId());
- sender.deleteConnection(txConnection.getId());
-
- }
-
- private class TestSinkFactory implements ComponentFactory {
-
- public Component newInstance(Endpoint endpoint) {
- return new TestSink("test-sink");
- }
- }
-
- private class TestSink extends AbstractSink {
-
- public TestSink(String name) {
- super(name);
- }
-
- public Format[] getFormats() {
- return new Format[]{AVProfile.PCMA};
- }
-
- public boolean isAcceptable(Format format) {
- return true;
- }
-
- public void receive(Buffer buffer) {
- if (buffer.getFormat().equals(Endpoint.PCMA)) {
- pcmaCount++;
- }
- }
-
- @Override
- public void onMediaTransfer(Buffer buffer) throws IOException {
- throw new UnsupportedOperationException("Not supported yet.");
- }
- }
-}
=======================================
---
/trunk/servers/media/core/controllers/mgcp/src/test/java/org/mobicents/media/server/ctrl/mgcp/test/ann/AnnTestCase.java
Sun Sep 13 09:04:55 2009
+++ /dev/null
@@ -1,201 +0,0 @@
-package org.mobicents.media.server.ctrl.mgcp.test.ann;
-
-import jain.protocol.ip.mgcp.JainMgcpCommandEvent;
-import jain.protocol.ip.mgcp.JainMgcpEvent;
-import jain.protocol.ip.mgcp.JainMgcpResponseEvent;
-import jain.protocol.ip.mgcp.message.Constants;
-import jain.protocol.ip.mgcp.message.NotificationRequest;
-import jain.protocol.ip.mgcp.message.NotifyResponse;
-import jain.protocol.ip.mgcp.message.parms.ConnectionMode;
-import jain.protocol.ip.mgcp.message.parms.EndpointIdentifier;
-import jain.protocol.ip.mgcp.message.parms.EventName;
-import jain.protocol.ip.mgcp.message.parms.NotifiedEntity;
-import jain.protocol.ip.mgcp.message.parms.RequestIdentifier;
-import jain.protocol.ip.mgcp.message.parms.RequestedAction;
-import jain.protocol.ip.mgcp.message.parms.RequestedEvent;
-import jain.protocol.ip.mgcp.message.parms.ReturnCode;
-import jain.protocol.ip.mgcp.pkg.MgcpEvent;
-import jain.protocol.ip.mgcp.pkg.PackageName;
-
-import java.io.File;
-import java.net.URL;
-import java.util.concurrent.Semaphore;
-import java.util.concurrent.TimeUnit;
-
-import org.junit.Test;
-import org.mobicents.jain.protocol.ip.mgcp.pkg.AUMgcpEvent;
-import org.mobicents.jain.protocol.ip.mgcp.pkg.AUPackage;
-import org.mobicents.media.server.ctrl.mgcp.test.Connection;
-import org.mobicents.media.server.ctrl.mgcp.test.MgcpMicrocontainerTest;
-
-/**
- *
- * @author amit bhayani
- *
- */
-public class AnnTestCase extends MgcpMicrocontainerTest {
-
- private final static String AAP = "/mobicents/media/aap/$";
- private final static String IVR = "/mobicents/media/IVR/$";
-
- private Connection rxConnection;
- private Connection txConnection;
- private URL url = null;
- private Semaphore semaphore;
-
- private RequestIdentifier playbackID;
- private RequestIdentifier recordingID;
-
- private JainMgcpResponseEvent response;
- private boolean oc = false;
-
- public AnnTestCase(String name) {
- super(name);
- }
-
- @Override
- protected void setUp() throws Exception {
- super.setUp();
-
- semaphore = new Semaphore(0);
-
- txConnection = createConnection(AAP, ConnectionMode.SendOnly,
null);
- rxConnection = createConnection(IVR, ConnectionMode.RecvOnly,
txConnection.getLocalSdp());
-
- modifyConnection(txConnection, rxConnection.getLocalSdp());
-
- playbackID = new RequestIdentifier("1");
- recordingID = new RequestIdentifier("2");
- }
-
- @Override
- public void tearDown() throws Exception {
- deleteConnectionConnection(rxConnection);
- deleteConnectionConnection(txConnection);
-
- Thread.sleep(2000);
-
- super.tearDown();
- }
-
- private void startPlayer(String url) throws Exception {
- EndpointIdentifier endpointID = new
EndpointIdentifier(AAP, "127.0.0.1");
- NotificationRequest rqnt = new NotificationRequest(this,
txConnection.getEndpoint(), playbackID);
-
- EventName[] signalRequests = {new
EventName(PackageName.Announcement, MgcpEvent.ann.withParm(url), null)};
- rqnt.setSignalRequests(signalRequests);
-
- RequestedAction[] actions = new
RequestedAction[]{RequestedAction.NotifyImmediately};
-
- RequestedEvent[] requestedEvents = {new RequestedEvent(new
EventName(PackageName.Announcement,
- MgcpEvent.oc, null), actions)
- };
-
- rqnt.setRequestedEvents(requestedEvents);
- NotifiedEntity notifiedEntity = new
NotifiedEntity(caIPAddress.getHostName(), caIPAddress.getHostAddress(),
caStack.getPort());
- rqnt.setNotifiedEntity(notifiedEntity);
-
-
rqnt.setTransactionHandle(caProvider.getUniqueTransactionHandler());
-
- response = null;
- caProvider.sendMgcpEvents(new JainMgcpCommandEvent[]{rqnt});
- semaphore.tryAcquire(5, TimeUnit.SECONDS);
-
- if (response == null) {
- throw new Exception("Time out");
- }
-
- if (response.getReturnCode().getValue() !=
ReturnCode.TRANSACTION_EXECUTED_NORMALLY) {
- throw new Exception("Could not start player:" +
response.getReturnCode().getComment());
- }
- }
-
- private void startRecording(String url) throws Exception {
- EndpointIdentifier endpointID = new
EndpointIdentifier(IVR, "127.0.0.1");
- NotificationRequest rqnt = new NotificationRequest(this,
rxConnection.getEndpoint(), recordingID);
-
- EventName[] signalRequests = {new EventName(AUPackage.AU,
AUMgcpEvent.aupr.withParm(url), null)};
- rqnt.setSignalRequests(signalRequests);
-
- NotifiedEntity notifiedEntity = new
NotifiedEntity(caIPAddress.getHostName(), caIPAddress.getHostAddress(),
caStack.getPort());
- rqnt.setNotifiedEntity(notifiedEntity);
-
-
rqnt.setTransactionHandle(caProvider.getUniqueTransactionHandler());
-
- response = null;
- caProvider.sendMgcpEvents(new JainMgcpCommandEvent[]{rqnt});
- semaphore.tryAcquire(5, TimeUnit.SECONDS);
-
- if (response == null) {
- throw new Exception("Time out");
- }
-
- if (response.getReturnCode().getValue() !=
ReturnCode.TRANSACTION_EXECUTED_NORMALLY) {
- throw new Exception("Could not start player:" +
response.getReturnCode().getComment());
- }
- }
-
-
- @Test
- public void testSimpleTransmission() throws Exception {
- Thread.currentThread().sleep(1000);
- url =
AnnTestCase.class.getClassLoader().getResource("org/mobicents/media/server/ctrl/mgcp/test/ann/8kulaw.wav");
- String path = url.getPath();
- path = path.substring(0, path.lastIndexOf("/"));
-
- startRecording(path + "/test-record.wav");
- Thread.currentThread().sleep(1000);
- startPlayer("file:" + url.getPath());
-
- semaphore.tryAcquire(15, TimeUnit.SECONDS);
-
- assertEquals(true, oc);
- File file = new File(path + "/test-record.wav");
-
- assertEquals(true, file.exists());
- file.delete();
-
- //netx run on event
- playbackID = new RequestIdentifier("10");
- recordingID = new RequestIdentifier("20");
- response = null;
- oc = false;
-
- System.out.println(">>>>> Staring recording 2");
- startRecording(path + "/test-record.wav");
- System.out.println(">>>>> SLIPPING");
- Thread.currentThread().sleep(1000);
-
- System.out.println(">>>>> Staring player 2");
- startPlayer("file:" + url.getPath());
-
- semaphore.tryAcquire(15, TimeUnit.SECONDS);
-
- assertEquals(true, oc);
- file = new File(path + "/test-record.wav");
-
- assertEquals(true, file.exists());
-
- }
-
- //@Override
- public void processMgcpCommandEvent(JainMgcpCommandEvent event) {
- if (event.getObjectIdentifier() == Constants.CMD_NOTIFY) {
- oc = true;
-
- NotifyResponse res = new NotifyResponse(this,
ReturnCode.Transaction_Executed_Normally);
- res.setTransactionHandle(event.getTransactionHandle());
- caProvider.sendMgcpEvents(new JainMgcpEvent[]{res});
-
- System.out.println("RELEASING SEMAPHORE");
- semaphore.release();
- }
- }
-
- @Override
- public void processMgcpResponseEvent(JainMgcpResponseEvent event) {
- super.processMgcpResponseEvent(event);
- response = event;
-// semaphore.release();
- }
-}
