[Madsserv-commit] madsserv/src/server/streaming Streaming.java,1.2,1.3

SourceForge Headquarters 1320 Columbia Street Suite 310 San Diego, CA 92101 +1 (858) 422-6466

Update of /cvsroot/madsserv/madsserv/src/server/streaming
In directory sc8-pr-cvs1:/tmp/cvs-serv11418/streaming

Modified Files:
	Streaming.java 
Log Message:
on approche des transitions

Index: Streaming.java
===================================================================
RCS file: /cvsroot/madsserv/madsserv/src/server/streaming/Streaming.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -C2 -d -r1.2 -r1.3
*** Streaming.java	14 Mar 2003 03:26:19 -0000	1.2
--- Streaming.java	18 Mar 2003 03:20:27 -0000	1.3
***************
*** 1,248 ****
! // La classe Streaming met en place le module Streaming RTP du projet Madsserv
! // Elle reçoit en entrée une DataSource à diffuser vers une adresse client
! // Elle utilise les RTPManager de JMF pour la diffusion
! 
! import java.awt.*;
! import java.io.*;
! import java.util.Vector;
! import java.net.InetAddress;
! import javax.media.*;
! import javax.media.protocol.*;
! import javax.media.protocol.DataSource;
! import javax.media.format.*;
! import javax.media.control.TrackControl;
! import javax.media.control.QualityControl;
! import javax.media.rtp.*;
! import javax.media.rtp.rtcp.*;
! import com.sun.media.rtp.*;
! import javax.media.rtp.event.*;
! 
! public class Streaming
!     implements SendStreamListener {
! 
!   // Adresse IP et port du client
!   private String clientIPAddress;
!   private int clientPort;
!   private int clientID;
! 
!   private ServerInit serverInit;
! 
!   // Variables de controle
!   private int nbManager = 2;
!   private Boolean alreadyStarted = null;
! 
!   // Tableau des RTPManager
!   private RTPManager rtpMgrs[];
!   // Tableau des vectors contenant chacun les SendStream d'un RTPManager
!   private Vector[] sendStreamVectors = new Vector[nbManager];
!   // La DataSource en entrée du module de streaming RTP
!   private DataSource dataInput = null;
! 
!   private Reencode reencode=null;
!   private Transition transition=null;
! 
!   // Constructeur sans arguments
!   public Streaming(int _clientID, ServerInit _serverInit) {
!     serverInit = _serverInit;
!     clientID = _clientID;
!     clientIPAddress = "";
!     clientPort = 40000;
!     alreadyStarted = Boolean.valueOf(false);
!   }
! 
!   // Constructeur avec l'adresse IP et le port du client
!   public Streaming(int _clientID, String _clientIPAddress, String _clientPort,
!                    ServerInit _serverInit) {
!     serverInit = _serverInit;
!     clientID = _clientID;
!     clientIPAddress = _clientIPAddress;
!     Integer integer = Integer.valueOf(_clientPort);
!     if (integer != null) {
!       clientPort = integer.intValue();
!     }
!   }
! 
!   public void setReencode(Reencode _reencode) {
!     reencode = _reencode;
!   }
! 
!   public void setTransition(Transition _transition) {
!     transition = _transition;
!   }
! 
!   public void initialize() {
!     rtpMgrs = new RTPManager[nbManager];
!     SessionAddress localAddr, destAddr;
!     InetAddress ipAddr;
!     int port;
!     String cname = SourceDescription.generateCNAME();
!     SourceDescription sourceDesc;
! 
!     // Initialisation des vectors de SendStreams
!     for (int i = 0; i < nbManager; i++) {
!       sendStreamVectors[i] = new Vector();
!     }
! 
!     // Creation des RTPManager (on passe les adresses locale et destination)
!     for (int i = 0; i < nbManager; i++) {
!       try {
!         rtpMgrs[i] = RTPManager.newInstance();
!         rtpMgrs[i].addSendStreamListener(this);
! 
!         port = clientPort + 2 * i;
!         ipAddr = InetAddress.getByName(clientIPAddress);
!         localAddr = new SessionAddress(InetAddress.getLocalHost(),
!                                        port);
!         destAddr = new SessionAddress(ipAddr, port);
!         sourceDesc = new SourceDescription(SourceDescription
!                                            .SOURCE_DESC_CNAME,
!                                            cname,
!                                            1,
!                                            false);
!         rtpMgrs[i].initialize(localAddr /*, sourceDesc, 0.05, 0.25*/);
!         rtpMgrs[i].addTarget(destAddr);
!         System.err.println("Created RTP session: " + clientIPAddress + " " +
!                            port);
!       }
!       catch (Exception e) {
!         System.err.println(e.getMessage());
!       }
!     }
!   }
! 
!   // Méthode publique pour modifier la DataSource en cours de diffusion
!   public synchronized void setNewStreams(DataSource _dataInput) {
! 
!     SendStream sendStream;
! 
!     PushBufferDataSource ds = null;
!     PushBufferStream ss[];
! 
!     int nbStreams, vectSize;
!     if (alreadyStarted.booleanValue()) {
!       for (int i = 0; i < nbManager; i++) {
!         vectSize = sendStreamVectors[i].size();
!         System.err.println("Taille du vecteur sendStream " + i + " : " +
!                            vectSize);
!         if (vectSize > 0) {
!           for (int j = 0; j < vectSize; j++) {
!             ( (SendStream) sendStreamVectors[i].get(j)).close();
!             sendStreamVectors[i].remove(j);
!             System.err.println("suppression du sendstream " + i + "," + j);
!           }
!         }
!       }
!     }
! 
!     // Mise à jour de la DataSource à diffuser
!     dataInput = _dataInput;
! 
!     // Identification des Streams contenus dans la DataSource
!     ds = (PushBufferDataSource) dataInput;
!     if (ds == null) {
!       System.err.println("source vide");
!     }
!     ss = ds.getStreams();
!     System.err.println("Nombre de streams " + ss.length);
! 
!     // Lancer la diffusion des nouveaux Streams
!     for (int i = 0; i < ss.length; i++) {
!       try {
!         sendStream = rtpMgrs[i].createSendStream(dataInput, i);
!         sendStreamVectors[i].add(sendStream);
!         sendStream.start();
!         alreadyStarted = Boolean.valueOf(true);
!       }
!       catch (Exception e) {
!         System.err.println("message erreur sendstreams " + e.getMessage());
!       }
!     }
!   }
! 
!   public void setClientIP(String _clientIPAddress) {
!     clientIPAddress = _clientIPAddress;
!   }
! 
!   public void setClientPort(int _clientPort) {
!     clientPort = _clientPort;
!   }
! 
!   public boolean isInitialized() {
!     return alreadyStarted.booleanValue();
!   }
! 
!   public void endOfMedia() {
!     int nbStreams, vectSize;
!     if (alreadyStarted.booleanValue()) {
!       for (int i = 0; i < nbManager; i++) {
!         vectSize = sendStreamVectors[i].size();
!         System.err.println("Taille du vecteur sendStream n°" + i + " : " +
!                            vectSize);
!         if (vectSize > 0) {
!           for (int j = 0; j < vectSize; j++) {
!             ( (SendStream) sendStreamVectors[i].get(j)).close();
!             sendStreamVectors[i].remove(j);
!             System.err.println("suppression du sendstream " + i + "," + j);
!           }
!         }
!       }
!       serverInit.endConnexion(clientID);
!       //stop();
!       System.err.println("Je fais un stop sur streaming");
!       synchronized (alreadyStarted) {
!         alreadyStarted = Boolean.valueOf(false);
!       }
!     }
! 
!   }
! 
!   // Méthode permettant de stopper la diffusion et de détruire la seesion RTP
!   public void stop() {
!     synchronized (this) {
!       for (int i = 0; i < rtpMgrs.length; i++) {
!         rtpMgrs[i].removeTargets("Session ended.");
!         rtpMgrs[i].dispose();
!         rtpMgrs[i] = null;
!       }
!       System.err.println("J'ai supprime les rtpmanager");
!     }
!   }
! 
!   /**
!    * SendStreamListener
!    */
!   public synchronized void update(SendStreamEvent evt) {
! 
!     int nbStreams, vectSize;
!     //System.out.println("Evenement SendStream : " + evt.toString());
!     /*   RTPManager mgr = (RTPManager)evt.getSource();
!        Participant participant = evt.getParticipant();	// could be null.
!        ReceiveStream stream = evt.getReceiveStream();  // could be null.
!      */
!     if (evt instanceof InactiveSendStreamEvent) {
!       System.out.println("J'ai un evenement Inactive");
! 
!       // Annuler la diffusion des SendStreams en cours (alreadyStarted permet de savoir si une diffusion est deja commencee
!       if (alreadyStarted.booleanValue()) {
!         for (int i = 0; i < nbManager; i++) {
!           vectSize = sendStreamVectors[i].size();
!           System.err.println("Taille du vecteur sendStream " + i + " : " +
!                              vectSize);
!           if (vectSize > 0) {
!             for (int j = 0; j < vectSize; j++) {
!               ( (SendStream) sendStreamVectors[i].get(j)).close();
!               sendStreamVectors[i].remove(j);
!               System.err.println("suppression du sendstream " + i + "," + j);
!             }
!           }
!         }
!       }
! 
!       /*  System.err.println("  - Received an RTP PayloadChangeEvent.");
!         System.err.println("Sorry, cannot handle payload change.");
!         System.exit(0);*/
! 
!     }
!   }
! 
! }
--- 1,270 ----
! // La classe Streaming met en place le module Streaming RTP du projet Madsserv
! // Elle recoit en entree une DataSource a diffuser vers une adresse client
! // Elle utilise les RTPManager de JMF pour la diffusion
! 
! import java.awt.*;
! import java.io.*;
! import java.util.Vector;
! import java.net.InetAddress;
! import javax.media.*;
! import javax.media.protocol.*;
! import javax.media.protocol.DataSource;
! import javax.media.format.*;
! import javax.media.control.TrackControl;
! import javax.media.control.QualityControl;
! import javax.media.rtp.*;
! import javax.media.rtp.rtcp.*;
! import com.sun.media.rtp.*;
! import javax.media.rtp.event.*;
! 
! public class Streaming
!     implements SendStreamListener {
! 
!   // Adresse IP et port du client
!   private String clientIPAddress;
!   private int clientPort;
!   private int clientID;
! 
!   private ServerInit serverInit;
! 
!   // Variables de controle
!   private int nbManager = 2;
!   private Boolean alreadyStarted = null;
! 
!   // Tableau des RTPManager
!   private RTPManager rtpMgrs[];
!   // Tableau des vectors contenant chacun les SendStream d'un RTPManager
!   private Vector[] sendStreamVectors = new Vector[nbManager];
!   // La DataSource en entree du module de streaming RTP
!   private DataSource dataInput = null;
! 
!   private Reencode reencode = null;
!   private Transition transition = null;
! 
!   // Constructeur sans arguments
!   public Streaming(int _clientID, ServerInit _serverInit) {
!     serverInit = _serverInit;
!     clientID = _clientID;
!     clientIPAddress = "";
!     clientPort = 40000;
!     alreadyStarted = Boolean.valueOf(false);
!   }
! 
!   // Constructeur avec l'adresse IP et le port du client
!   public Streaming(int _clientID, String _clientIPAddress, String _clientPort,
!                    ServerInit _serverInit) {
!     serverInit = _serverInit;
!     clientID = _clientID;
!     clientIPAddress = _clientIPAddress;
!     Integer integer = Integer.valueOf(_clientPort);
!     if (integer != null) {
!       clientPort = integer.intValue();
!     }
!   }
! 
!   public void setReencode(Reencode _reencode) {
!     reencode = _reencode;
!   }
! 
!   public void setTransition(Transition _transition) {
!     transition = _transition;
!   }
! 
!   public void initialize() {
!     rtpMgrs = new RTPManager[nbManager];
!     SessionAddress localAddr, destAddr;
!     InetAddress ipAddr;
!     int port;
!     String cname = SourceDescription.generateCNAME();
!     SourceDescription sourceDesc;
! 
!     // Initialisation des vectors de SendStreams
!     for (int i = 0; i < nbManager; i++) {
!       sendStreamVectors[i] = new Vector();
!     }
! 
!     // Creation des RTPManager (on passe les adresses locale et destination)
!     for (int i = 0; i < nbManager; i++) {
!       try {
!         rtpMgrs[i] = RTPManager.newInstance();
!         rtpMgrs[i].addSendStreamListener(this);
! 
!         port = clientPort + 2 * i;
!         ipAddr = InetAddress.getByName(clientIPAddress);
!         localAddr = new SessionAddress(InetAddress.getLocalHost(),
!                                        port);
!         destAddr = new SessionAddress(ipAddr, port);
!         sourceDesc = new SourceDescription(SourceDescription
!                                            .SOURCE_DESC_CNAME,
!                                            cname,
!                                            1,
!                                            false);
!         rtpMgrs[i].initialize(localAddr /*, sourceDesc, 0.05, 0.25*/);
!         rtpMgrs[i].addTarget(destAddr);
!         System.err.println("Created RTP session: " + clientIPAddress + " " +
!                            port);
!       }
!       catch (Exception e) {
!         System.err.println(e.getMessage());
!       }
!     }
!   }
! 
!   // Methode publique pour modifier la DataSource en cours de diffusion
!   public synchronized void setNewStreams(DataSource _dataInput) {
!     SendStream sendStream;
! 
!     PushBufferDataSource ds = null;
!     PushBufferStream ss[];
!     int nbStreams, vectSize;
! 
!     System.out.println("Le streaming a recu les nouveaux streams");
! 
!     if (alreadyStarted.booleanValue()) {
!       for (int i = 0; i < nbManager; i++) {
!         vectSize = sendStreamVectors[i].size();
!         System.err.println("Taille du vecteur sendStream " + i + " : " +
!                            vectSize);
!         if (vectSize > 0) {
!           for (int j = 0; j < vectSize; j++) {
!             ( (SendStream) sendStreamVectors[i].get(j)).close();
!             sendStreamVectors[i].remove(j);
!             System.err.println("suppression du sendstream " + i + "," + j);
!           }
!         }
!       }
!     }
! 
!     // Mise a jour de la DataSource a diffuser
!     dataInput = _dataInput;
! 
!     // Identification des Streams contenus dans la DataSource
!     ds = (PushBufferDataSource) dataInput;
!     if (ds == null) {
!       System.err.println("source vide");
!     }
!     ss = ds.getStreams();
!     System.err.println("Nombre de streams " + ss.length);
!     try {
!       Thread.sleep(2000);
!     }
!     catch (Exception e) {
! 
!     }
!     String[] messageToSend = new String[2];
!     messageToSend[0] = "Connexion du client " + String.valueOf(clientID);
!     messageToSend[1] = String.valueOf(ss.length);
!     serverInit.sendMessage(clientID, 3, messageToSend);
! 
!     try {
!       Thread.sleep(2000);
!     }
!     catch (Exception e) {
! 
!     }
! 
!     // Lancer la diffusion des nouveaux Streams
!     for (int i = 0; i < ss.length; i++) {
!       try {
!         System.err.println("Streaming : j'envoie le stream " + i);
!         sendStream = rtpMgrs[i].createSendStream(dataInput, i);
!         sendStreamVectors[i].add(sendStream);
!         sendStream.start();
!         System.err.println("Streaming : stream envoye " + i);
!         alreadyStarted = Boolean.valueOf(true);
!         serverInit.setStatus(clientID, "Diffusion");
!       }
!       catch (Exception e) {
!         System.err.println("message erreur sendstreams " + e.getMessage());
!       }
!     }
!   }
! 
!   public void setClientIP(String _clientIPAddress) {
!     clientIPAddress = _clientIPAddress;
!   }
! 
!   public void setClientPort(int _clientPort) {
!     clientPort = _clientPort;
!   }
! 
!   public boolean isInitialized() {
!     return alreadyStarted.booleanValue();
!   }
! 
!   public void endOfMedia() {
!     int nbStreams, vectSize;
!     if (alreadyStarted.booleanValue()) {
!       for (int i = 0; i < nbManager; i++) {
!         vectSize = sendStreamVectors[i].size();
!         System.err.println("Taille du vecteur sendStream num" + i + " : " +
!                            vectSize);
!         if (vectSize > 0) {
!           for (int j = 0; j < vectSize; j++) {
!             ( (SendStream) sendStreamVectors[i].get(j)).close();
!             sendStreamVectors[i].remove(j);
!             System.err.println("suppression du sendstream " + i + "," + j);
!           }
!         }
!       }
!       serverInit.endConnexionClient(clientID);
!       //stop();
!       System.err.println("Je fais un stop sur streaming");
!       synchronized (alreadyStarted) {
!         alreadyStarted = Boolean.valueOf(false);
!       }
!     }
! 
!   }
! 
!   // Methode permettant de stopper la diffusion et de detruire la seesion RTP
!   public void stop() {
!     synchronized (this) {
!       for (int i = 0; i < rtpMgrs.length; i++) {
!         rtpMgrs[i].removeTargets("Session ended.");
!         rtpMgrs[i].dispose();
!         rtpMgrs[i] = null;
!         alreadyStarted = Boolean.valueOf(false);
!       }
!       System.err.println("J'ai supprime les rtpmanager");
!     }
!   }
! 
!   /**
!    * SendStreamListener
!    */
!   public synchronized void update(SendStreamEvent evt) {
! 
!     int nbStreams, vectSize;
!     //System.out.println("Evenement SendStream : " + evt.toString());
!     /*   RTPManager mgr = (RTPManager)evt.getSource();
!        Participant participant = evt.getParticipant();	// could be null.
!        ReceiveStream stream = evt.getReceiveStream();  // could be null.
!      */
!     if (evt instanceof InactiveSendStreamEvent) {
!       System.out.println("J'ai un evenement Inactive");
! 
!       // Annuler la diffusion des SendStreams en cours (alreadyStarted permet de savoir si une diffusion est deja commencee
!       if (alreadyStarted.booleanValue()) {
!         for (int i = 0; i < nbManager; i++) {
!           vectSize = sendStreamVectors[i].size();
!           System.err.println("Taille du vecteur sendStream " + i + " : " +
!                              vectSize);
!           if (vectSize > 0) {
!             for (int j = 0; j < vectSize; j++) {
!               ( (SendStream) sendStreamVectors[i].get(j)).close();
!               sendStreamVectors[i].remove(j);
!               System.err.println("suppression du sendstream " + i + "," + j);
!             }
!           }
!         }
!       }
! 
!       /*  System.err.println("  - Received an RTP PayloadChangeEvent.");
!         System.err.println("Sorry, cannot handle payload change.");
!         System.exit(0);*/
! 
!     }
!   }
! 
! }
\ No newline at end of file