Changeset e89e3a9f913487576810f637649ecb7c140406f4 for src/org/red5/rg/recorder/Application.java

Timestamp:

04/14/09 18:19:59 (3 years ago)

Author:

Robin Gareus <robin@…>

Parents:

3b91569fdc9315612c62458ca02a2ef74b7c7970

Children:

f260f21876d739831315b71cf713e64cfbab9660

git-committer:

Robin Gareus <robin@gareus.org> / 2009-04-14T20:19:59Z+0200

Message:

deployed this.

Files:

• src/org/red5/rg/recorder/Application.java (modified) (3 diffs)

src/org/red5/rg/recorder/Application.java

@@ -17 +17 @@
 import org.slf4j.Logger;
 
+import java.util.HashMap;
+import java.util.Iterator;
+
 public class Application extends ApplicationAdapter {
 
         private static Logger log = Red5LoggerFactory.getLogger(Application.class, "recorder");
+        private HashMap streams = new HashMap();
         
-        private IScope appScope;
-
         {
                 log.info("recorder created");
@@ -28 +30 @@
         }
         
+        private boolean checkPass(String u, String p) {
+                if (u.equals("4dc84c9279d0fcaa793eecfbc544cdbe7ea5f6e4") 
+                 && p.equals("f78b64c9e0f2ea24fddce2b0d809cb2855fed1a6"))
+                         return true;
+                return false;
+        }
+
     @Override
         public boolean appStart(IScope app) {
                 log.info("recorder appStart");
-                System.out.println("recorder appStart");        
-                appScope = app;
+//              System.out.println("recorder appStart");        
                 return true;
         }
 
 
-        private boolean checkPass(String u, String p) {
-                if (u.equals("secret")) return true;
-                return false;
-        }
-
     @Override
         public boolean appConnect(IConnection conn, Object[] params) {
-                log.info("recorder appConnect" + conn.getClient().getId() );
+                String id = conn.getClient().getId();
+                log.info("recorder appConnect: " + id + "(" + streams.get("file_"+id)+ ")");
+/*
+                log.info("recorder host=" + conn.getHost());
+                log.info("recorder remote=" + conn.getRemoteAddress());
+                log.info("recorder clientAtt=" + conn.getClient().getAttributeNames());
+                log.info("recorder connectParams=" + conn.getConnectParams().toString());
+//              log.info("recorder file=" + conn.getPublishedName());
+                log.info("recorder file=" + params[2].toString());
+*/
+
+                streams.put("file_"+id,params[2].toString());
+                streams.put("host_"+id,conn.getRemoteAddress());
+//              streams.put("host_"+id,conn.getHost());
+
                 // Trigger calling of "onBWDone", required for some FLV players
                 measureBandwidth(conn);
                 if (conn instanceof IStreamCapableConnection) {
                         IStreamCapableConnection streamConn = (IStreamCapableConnection) conn;
+        //              log.info("recorder path=" + streamConn.getStreamById(0).getPublishedName());
                         SimpleConnectionBWConfig bwConfig = new SimpleConnectionBWConfig();
                         bwConfig.getChannelBandwidth()[IBandwidthConfigure.OVERALL_CHANNEL] =
@@ -66 +84 @@
         }
 
-        /** {@inheritDoc} */
     @Override
         public void appDisconnect(IConnection conn) {
-                log.info("recorder appDisconnect" + conn.getClient().getId() );
+                String id = conn.getClient().getId();
+                log.info("recorder appDisconnect: " + id + "(" + streams.get("file_"+id)+ ")");
+
                 try{
-                        Runtime.getRuntime().exec("/tmp/test.sh");
+                        Runtime.getRuntime().exec("/usr/local/bin/cfvb-transcode.sh "+streams.get("file_"+id)+" "+streams.get("host_"+id));
                  } catch (IOException e) {}
+
+                streams.remove("file_"+id);
+                streams.remove("host_"+id);
                 super.appDisconnect(conn);
         }