wms-httpstreamer-directstreaming

16:54:03.727 INFO  jd.cli.Main - Decompiling wms-httpstreamer-directstreaming.jar
package com.wowza.wms.httpstreamer.directstreaming.httpstreamer;

import com.wowza.util.Base64;
import com.wowza.util.JSON;
import com.wowza.wms.logging.WMSLogger;
import com.wowza.wms.logging.WMSLoggerFactory;
import com.wowza.wms.rtsp.RTSPResponseMessage;
import java.net.URI;
import java.util.ArrayList;
import java.util.List;

public class DirectStreamingURL
{
  private String a = null;
  private String b = "";
  private String c;
  private String d;
  private String e;
  private String f;
  private String g;
  
  public DirectStreamingURL(String paramString)
  {
    c = Base64.endsWith(73 + 74, "LpppvhiE");
    d = Base64.endsWith(9 * 33, "Vnnjd`|dN");
    e = "";
    f = null;
    g = null;
    
    a = paramString;
    decode(false);
  }
  
  public DirectStreamingURL(String paramString, boolean paramBoolean)
  {
    c = Base64.endsWith(60 + -56, "[acaiyzT");
    d = Base64.endsWith(45 - 36, "Vnnjd`|dN");
    e = "";
    f = null;
    g = null;
    if (paramString.indexOf(JSON.copyValueOf("9+*", '?' / 80)) >= 0)
    {
      a = paramString;
      
      decode(paramBoolean);
    }
    else
    {
      for (;; paramString.indexOf(JSON.copyValueOf(");", 15 + 4)) < 0)
      {
        paramString = paramString.replace(Base64.endsWith(49 * 5, "oy"), "://127.0.0.1/"); break;
      }
    }
  }
  
  public void decode(boolean paramBoolean)
  {
    if (a.indexOf(Base64.endsWith(35 - 20, "5?>")) >= 0) {
      break label32;
    }
    for (;;)
    {
      return;decodeNonURL(paramBoolean); continue;
      label32:
      decodeURL(paramBoolean);
    }
  }
  
  public void decodeNonURL(boolean paramBoolean)
  {
    String str = a;
    if (!str.startsWith("/")) {}
    for (;; str = str.substring(1))
    {
      decodePath(str, paramBoolean); return;
    }
  }
  
  public void decodePath(String paramString, boolean paramBoolean)
  {
    int j;
    String[] arrayOfString;
    ArrayList localArrayList;
    label41:
    label54:
    label63:
    int k;
    label149:
    int i;
    if (paramString != null)
    {
      break label149;
      if (j >= arrayOfString.length) {
        break label288;
      }
      break label267;
      for (;;)
      {
        arrayOfString = paramString.split("/");
        localArrayList = new ArrayList();
        j = 0; break;
        if (b.length() <= 0) {
          break label225;
        }
        if (j == 2)
        {
          break label313;
          j++; break;
          
          b += "/";
          break label225;
        }
        for (;; j <= 2)
        {
          c = ((String)localArrayList.get(0));
          d = ((String)localArrayList.get(1));
          b = "";
          k = 2;
          break label188;
        }
        i = paramString.indexOf("?");
        if (i >= 0) {
          break label198;
        }
      }
    }
    for (;;)
    {
      label163:
      return;
      label172:
      label188:
      label198:
      label219:
      label225:
      label267:
      label286:
      label288:
      do
      {
        if (j <= 0) {
          break label304;
        }
        break label219;
        localArrayList.add(k);
        break label63;
        for (;;)
        {
          break label63;
          for (;; k++)
          {
            if (k >= j) {
              break label286;
            }
            break label41;
            e = paramString.substring(i + 1);
            paramString = paramString.substring(0, i); break;
            
            j--;
            break label304;
            b += (String)localArrayList.get(k);
          }
          String str = arrayOfString[j].trim();
          if (str.length() != 0) {
            break label172;
          }
        }
        break label163;
        j = localArrayList.size();
      } while (paramBoolean);
      label304:
      if (j != 1) {
        break label54;
      }
      break label346;
      label313:
      c = ((String)localArrayList.get(0));
      b = ((String)localArrayList.get(1)); continue;
      label346:
      b = ((String)localArrayList.get(0));
    }
  }
  
  public void decodeURL(boolean paramBoolean)
  {
    URI localURI = null;
    for (;; localURI.getQuery() == null)
    {
      e = localURI.getQuery();
      break label117;
      b = "";
      c = JSON.copyValueOf("Zbbnhz{S", '?' / '�');
      d = Base64.endsWith(55 * 9, "\020444::&\"\b");
      
      String str = localURI.getPath();
      decodePath(str, paramBoolean);
      break label143;
      for (;;)
      {
        g = (g + ":" + localURI.getPort()); break;
        try
        {
          localURI = new URI(a);
        }
        catch (Exception localException)
        {
          for (;;)
          {
            label117:
            WMSLoggerFactory.getLogger(RTSPResponseMessage.class).warn(JSON.copyValueOf("ELJJXso{1!/,,1+%\"ri)$\"9+7$q'!8u?$x;;?|;1-- 6k", 21 * 27) + a + JSON.copyValueOf("xr", -62 - -15), localException);
          }
        }
        f = localURI.getHost();
        g = localURI.getHost();
        if (localURI.getPort() <= 0) {
          break;
        }
      }
      label143:
      return;
    }
  }
  
  public String getUrl()
  {
    return a;
  }
  
  public void setUrl(String paramString)
  {
    a = paramString;
  }
  
  public String getStreamName()
  {
    return b;
  }
  
  public void setStreamName(String paramString)
  {
    b = paramString;
  }
  
  public String getAppName()
  {
    return c;
  }
  
  public void setAppName(String paramString)
  {
    c = paramString;
  }
  
  public String getAppInstanceName()
  {
    return d;
  }
  
  public void setAppInstanceName(String paramString)
  {
    d = paramString;
  }
  
  public String getUrlId()
  {
    return getAppName() + "/" + getAppInstanceName() + "/" + b;
  }
  
  public synchronized String getQueryStr()
  {
    return e;
  }
  
  public synchronized void setQueryStr(String paramString)
  {
    e = paramString;
  }
  
  public String getHost()
  {
    return f;
  }
  
  public String getDomain()
  {
    return g;
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.httpstreamer.directstreaming.httpstreamer.DirectStreamingURL
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.httpstreamer.directstreaming.httpstreamer;

import com.wowza.util.Base64;
import com.wowza.util.JSON;
import com.wowza.wms.application.WMSProperties;
import com.wowza.wms.httpstreamer.model.HTTPStreamerAdapterBase;
import com.wowza.wms.httpstreamer.model.HTTPStreamerRequest;
import com.wowza.wms.httpstreamer.model.HTTPStreamerResponse;
import com.wowza.wms.httpstreamer.model.IHTTPSessionFactory;
import com.wowza.wms.httpstreamer.model.IHTTPStreamerSession;
import com.wowza.wms.logging.WMSLogger;
import com.wowza.wms.logging.WMSLoggerFactory;
import com.wowza.wms.vhost.IVHost;

public class HTTPStreamerAdapterDirectStreamer
  extends HTTPStreamerAdapterBase
  implements IHTTPSessionFactory
{
  private static final Class<HTTPStreamerAdapterDirectStreamer> a = HTTPStreamerAdapterDirectStreamer.class;
  protected boolean debugLog = false;
  protected int maxWrittenIdleTimeout = 8000;
  protected int maxPendingWriteBytes = 2097152;
  
  public void init()
  {
    super.init();
    
    setSessionProtocol(6);
    
    maxWrittenIdleTimeout = getProperties().getPropertyInt(Base64.endsWith('?' / 116, "ne}Qua}~nbDjcuE{~qzcc"), maxWrittenIdleTimeout);
    maxPendingWriteBytes = getProperties().getPropertyInt(Base64.endsWith('?' / 52, "kfpYoehd`hGc{gqWoc}j"), maxPendingWriteBytes);
    
    debugLog = getProperties().getPropertyBoolean(JSON.copyValueOf("qsum~Vt{", 51 * 23), debugLog);
    debugLog = vhost.getProperties().getPropertyBoolean(JSON.copyValueOf(".3<9\013/-=:*\"\02571!2\0328?", 72 + 126), debugLog);
    debugLog = vhost.getProperties().getPropertyBoolean(JSON.copyValueOf("aoumj~Jhl~{ucVvv`q[w~", '?' / '�'), debugLog);
    if (!WMSLoggerFactory.getLogger(a).isDebugEnabled()) {}
    for (;; debugLog = true) {
      return;
    }
  }
  
  public boolean canHandle(String paramString)
  {
    int i = paramString.indexOf("?");
    boolean bool;
    if (i >= 0)
    {
      break label90;
      label16:
      for (;; WMSLoggerFactory.getLogger(a).debug(JSON.copyValueOf("KPQVT|{ojah|NtpbgqgR~j|yoOilzalgq*fgi@hdo`hU", '?' / '�') + paramString + Base64.endsWith(55 + 9, "\035{b") + bool)) {
        return bool;
      }
    }
    label90:
    for (;; paramString = paramString.substring(0, i))
    {
      bool = super.canHandle(paramString);
      if (!debugLog) {
        break;
      }
      break label16;
    }
  }
  
  /* Error */
  public void service(org.apache.mina.common.IoSession paramIoSession, com.wowza.wms.server.RtmpRequestMessage paramRtmpRequestMessage, com.wowza.wms.server.RtmpResponseMessage paramRtmpResponseMessage)
  {
    // Byte code:
    //   0: invokestatic 138	java/lang/System:currentTimeMillis	()J
    //   3: lstore 4
    //   5: goto +33 -> 38
    //   8: return
    //   9: astore 6
    //   11: getstatic 78	com/wowza/wms/httpstreamer/directstreaming/httpstreamer/HTTPStreamerAdapterDirectStreamer:a	Ljava/lang/Class;
    //   14: invokestatic 84	com/wowza/wms/logging/WMSLoggerFactory:getLogger	(Ljava/lang/Class;)Lcom/wowza/wms/logging/WMSLogger;
    //   17: bipush 72
    //   19: bipush 118
    //   21: iadd
    //   22: ldc -116
    //   24: invokestatic 45	com/wowza/util/Base64:endsWith	(ILjava/lang/String;)Ljava/lang/String;
    //   27: aload 6
    //   29: invokevirtual 144	com/wowza/wms/logging/WMSLogger:error	(Ljava/lang/String;Ljava/lang/Throwable;)V
    //   32: goto -24 -> 8
    //   35: goto -27 -> 8
    //   38: aload_1
    //   39: iconst_3
    //   40: bipush 35
    //   42: imul
    //   43: ldc -110
    //   45: invokestatic 45	com/wowza/util/Base64:endsWith	(ILjava/lang/String;)Ljava/lang/String;
    //   48: invokeinterface 152 2 0
    //   53: checkcast 154	com/wowza/wms/server/RtmpSessionInfo
    //   56: astore 6
    //   58: aload_2
    //   59: invokevirtual 160	com/wowza/wms/server/RtmpRequestMessage:getVHost	()Lcom/wowza/wms/vhost/IVHost;
    //   62: astore 7
    //   64: aload_2
    //   65: invokevirtual 164	com/wowza/wms/server/RtmpRequestMessage:getType	()I
    //   68: iconst_3
    //   69: if_icmpne +75 -> 144
    //   72: goto +83 -> 155
    //   75: getstatic 168	java/lang/System:out	Ljava/io/PrintStream;
    //   78: bipush 41
    //   80: bipush -7
    //   82: isub
    //   83: ldc -86
    //   85: invokestatic 45	com/wowza/util/Base64:endsWith	(ILjava/lang/String;)Ljava/lang/String;
    //   88: invokevirtual 175	java/io/PrintStream:println	(Ljava/lang/String;)V
    //   91: new 177	com/wowza/wms/httpstreamer/model/HTTPStreamerRequest
    //   94: dup
    //   95: aload_2
    //   96: invokespecial 180	com/wowza/wms/httpstreamer/model/HTTPStreamerRequest:<init>	(Lcom/wowza/wms/server/RtmpRequestMessage;)V
    //   99: astore 8
    //   101: new 182	com/wowza/wms/httpstreamer/model/HTTPStreamerResponse
    //   104: dup
    //   105: aload_3
    //   106: invokespecial 185	com/wowza/wms/httpstreamer/model/HTTPStreamerResponse:<init>	(Lcom/wowza/wms/server/RtmpResponseMessage;)V
    //   109: astore 9
    //   111: aload_0
    //   112: aload 8
    //   114: aload 9
    //   116: invokevirtual 189	com/wowza/wms/httpstreamer/directstreaming/httpstreamer/HTTPStreamerAdapterDirectStreamer:checkValidRequest	(Lcom/wowza/wms/httpstreamer/model/HTTPStreamerRequest;Lcom/wowza/wms/httpstreamer/model/HTTPStreamerResponse;)Z
    //   119: ifeq +55 -> 174
    //   122: goto +55 -> 177
    //   125: getstatic 168	java/lang/System:out	Ljava/io/PrintStream;
    //   128: ldc -65
    //   130: bipush 40
    //   132: bipush 12
    //   134: isub
    //   135: invokestatic 61	com/wowza/util/JSON:copyValueOf	(Ljava/lang/String;I)Ljava/lang/String;
    //   138: invokevirtual 175	java/io/PrintStream:println	(Ljava/lang/String;)V
    //   141: goto -106 -> 35
    //   144: aload_2
    //   145: invokevirtual 164	com/wowza/wms/server/RtmpRequestMessage:getType	()I
    //   148: iconst_2
    //   149: if_icmpne -24 -> 125
    //   152: goto -77 -> 75
    //   155: getstatic 168	java/lang/System:out	Ljava/io/PrintStream;
    //   158: bipush -41
    //   160: bipush -17
    //   162: isub
    //   163: ldc -63
    //   165: invokestatic 45	com/wowza/util/Base64:endsWith	(ILjava/lang/String;)Ljava/lang/String;
    //   168: invokevirtual 175	java/io/PrintStream:println	(Ljava/lang/String;)V
    //   171: goto -136 -> 35
    //   174: goto -139 -> 35
    //   177: aload_0
    //   178: lload 4
    //   180: aload_1
    //   181: aload 7
    //   183: aload 8
    //   185: aload 9
    //   187: invokevirtual 197	com/wowza/wms/httpstreamer/directstreaming/httpstreamer/HTTPStreamerAdapterDirectStreamer:onRequest	(JLorg/apache/mina/common/IoSession;Lcom/wowza/wms/vhost/IVHost;Lcom/wowza/wms/httpstreamer/model/HTTPStreamerRequest;Lcom/wowza/wms/httpstreamer/model/HTTPStreamerResponse;)V
    //   190: goto -16 -> 174
    // Line number table:
    //   Java source line #56	-> byte code offset #0
    //   Java source line #85	-> byte code offset #8
    //   Java source line #81	-> byte code offset #9
    //   Java source line #83	-> byte code offset #11
    //   Java source line #84	-> byte code offset #35
    //   Java source line #60	-> byte code offset #38
    //   Java source line #62	-> byte code offset #58
    //   Java source line #64	-> byte code offset #64
    //   Java source line #70	-> byte code offset #75
    //   Java source line #71	-> byte code offset #91
    //   Java source line #72	-> byte code offset #101
    //   Java source line #73	-> byte code offset #111
    //   Java source line #78	-> byte code offset #125
    //   Java source line #68	-> byte code offset #144
    //   Java source line #66	-> byte code offset #155
    //   Java source line #75	-> byte code offset #174
    //   Java source line #74	-> byte code offset #177
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	193	0	this	HTTPStreamerAdapterDirectStreamer
    //   0	193	1	paramIoSession	org.apache.mina.common.IoSession
    //   0	193	2	paramRtmpRequestMessage	com.wowza.wms.server.RtmpRequestMessage
    //   0	193	3	paramRtmpResponseMessage	com.wowza.wms.server.RtmpResponseMessage
    //   3	176	4	l	long
    //   9	19	6	localException	Exception
    //   56	1	6	localRtmpSessionInfo	com.wowza.wms.server.RtmpSessionInfo
    //   62	120	7	localIVHost	IVHost
    //   99	85	8	localHTTPStreamerRequest	HTTPStreamerRequest
    //   109	77	9	localHTTPStreamerResponse	HTTPStreamerResponse
    // Exception table:
    //   from	to	target	type
    //   38	193	9	java/lang/Exception
  }
  
  protected boolean checkValidRequest(HTTPStreamerRequest paramHTTPStreamerRequest, HTTPStreamerResponse paramHTTPStreamerResponse)
  {
    boolean bool = true;
    if (paramHTTPStreamerRequest.getHeader(JSON.copyValueOf("jb(tffno", '?' / '�')) == null)
    {
      break label95;
      if (paramHTTPStreamerRequest.getHeader(Base64.endsWith(78 + 73, "~~4ttrx3rauak")) != null) {}
    }
    for (goto 127;; paramHTTPStreamerRequest.getHeader(Base64.endsWith(55 * 43, "tx25//, , .--g8%#-*")) != null)
    {
      if (paramHTTPStreamerRequest.getHeader(JSON.copyValueOf("mc+ji}ic", '?' / '?')) != null) {
        break label115;
      }
      for (;;)
      {
        paramHTTPStreamerResponse.setHeader(Base64.endsWith(17 * 35, "\022763',t\b:2:;,"), "bytes");
        return bool;paramHTTPStreamerResponse.setHeadResponse(paramHTTPStreamerRequest.isHeadRequest()); continue;
        label95:
        if (paramHTTPStreamerRequest.getHeader(Base64.endsWith(10 - 48, "3=q01;)'+& h5.&*/")) == null) {
          break;
        }
        label115:
        paramHTTPStreamerResponse.setResponseCode(501);
        bool = false;
      }
    }
  }
  
  /* Error */
  protected void onRequest(long paramLong, org.apache.mina.common.IoSession paramIoSession, IVHost paramIVHost, HTTPStreamerRequest paramHTTPStreamerRequest, HTTPStreamerResponse paramHTTPStreamerResponse)
  {
    // Byte code:
    //   0: iconst_0
    //   1: istore 7
    //   3: iconst_0
    //   4: istore 8
    //   6: aload_3
    //   7: ldc -21
    //   9: bipush 24
    //   11: bipush 56
    //   13: iadd
    //   14: invokestatic 61	com/wowza/util/JSON:copyValueOf	(Ljava/lang/String;I)Ljava/lang/String;
    //   17: invokeinterface 152 2 0
    //   22: checkcast 154	com/wowza/wms/server/RtmpSessionInfo
    //   25: astore 9
    //   27: ldc2_w 236
    //   30: lstore 10
    //   32: ldc2_w 236
    //   35: lstore 12
    //   37: aconst_null
    //   38: astore 14
    //   40: goto +32 -> 72
    //   43: return
    //   44: astore 15
    //   46: getstatic 78	com/wowza/wms/httpstreamer/directstreaming/httpstreamer/HTTPStreamerAdapterDirectStreamer:a	Ljava/lang/Class;
    //   49: invokestatic 84	com/wowza/wms/logging/WMSLoggerFactory:getLogger	(Ljava/lang/Class;)Lcom/wowza/wms/logging/WMSLogger;
    //   52: ldc -17
    //   54: iconst_2
    //   55: bipush 101
    //   57: iadd
    //   58: invokestatic 61	com/wowza/util/JSON:copyValueOf	(Ljava/lang/String;I)Ljava/lang/String;
    //   61: aload 15
    //   63: invokevirtual 144	com/wowza/wms/logging/WMSLogger:error	(Ljava/lang/String;Ljava/lang/Throwable;)V
    //   66: goto -23 -> 43
    //   69: goto -26 -> 43
    //   72: aload 5
    //   74: ldc -15
    //   76: bipush 7
    //   78: bipush -49
    //   80: isub
    //   81: invokestatic 61	com/wowza/util/JSON:copyValueOf	(Ljava/lang/String;I)Ljava/lang/String;
    //   84: invokevirtual 207	com/wowza/wms/httpstreamer/model/HTTPStreamerRequest:getHeader	(Ljava/lang/String;)Ljava/lang/String;
    //   87: astore 15
    //   89: aload 15
    //   91: ifnonnull +75 -> 166
    //   94: goto +176 -> 270
    //   97: getstatic 78	com/wowza/wms/httpstreamer/directstreaming/httpstreamer/HTTPStreamerAdapterDirectStreamer:a	Ljava/lang/Class;
    //   100: invokestatic 84	com/wowza/wms/logging/WMSLoggerFactory:getLogger	(Ljava/lang/Class;)Lcom/wowza/wms/logging/WMSLogger;
    //   103: new 102	java/lang/StringBuilder
    //   106: dup
    //   107: invokespecial 103	java/lang/StringBuilder:<init>	()V
    //   110: sipush 245
    //   113: bipush 39
    //   115: idiv
    //   116: ldc -13
    //   118: invokestatic 45	com/wowza/util/Base64:endsWith	(ILjava/lang/String;)Ljava/lang/String;
    //   121: invokevirtual 109	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   124: aload 15
    //   126: invokevirtual 109	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   129: ldc -11
    //   131: bipush 47
    //   133: bipush 23
    //   135: imul
    //   136: invokestatic 61	com/wowza/util/JSON:copyValueOf	(Ljava/lang/String;I)Ljava/lang/String;
    //   139: invokevirtual 109	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   142: aload 17
    //   144: invokevirtual 109	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   147: ldc -9
    //   149: invokevirtual 109	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   152: aload 18
    //   154: invokevirtual 109	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   157: invokevirtual 118	java/lang/StringBuilder:toString	()Ljava/lang/String;
    //   160: invokevirtual 250	com/wowza/wms/logging/WMSLogger:warn	(Ljava/lang/String;)V
    //   163: goto -94 -> 69
    //   166: aload 15
    //   168: invokestatic 255	com/wowza/wms/httpstreamer/util/HTTPStreamerUtils:urlDecode	(Ljava/lang/String;)Ljava/lang/String;
    //   171: astore 15
    //   173: new 257	com/wowza/wms/httpstreamer/webmstreaming/httpstreamer/WebMStreamingURL
    //   176: dup
    //   177: aload 15
    //   179: iconst_1
    //   180: invokespecial 260	com/wowza/wms/httpstreamer/webmstreaming/httpstreamer/WebMStreamingURL:<init>	(Ljava/lang/String;Z)V
    //   183: astore 16
    //   185: getstatic 168	java/lang/System:out	Ljava/io/PrintStream;
    //   188: new 102	java/lang/StringBuilder
    //   191: dup
    //   192: invokespecial 103	java/lang/StringBuilder:<init>	()V
    //   195: ldc_w 262
    //   198: sipush 577
    //   201: bipush 91
    //   203: idiv
    //   204: invokestatic 61	com/wowza/util/JSON:copyValueOf	(Ljava/lang/String;I)Ljava/lang/String;
    //   207: invokevirtual 109	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   210: aload 15
    //   212: invokevirtual 109	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   215: invokevirtual 118	java/lang/StringBuilder:toString	()Ljava/lang/String;
    //   218: invokevirtual 175	java/io/PrintStream:println	(Ljava/lang/String;)V
    //   221: aload 16
    //   223: invokevirtual 265	com/wowza/wms/httpstreamer/webmstreaming/httpstreamer/WebMStreamingURL:getAppName	()Ljava/lang/String;
    //   226: astore 17
    //   228: aload 16
    //   230: invokevirtual 268	com/wowza/wms/httpstreamer/webmstreaming/httpstreamer/WebMStreamingURL:getAppInstanceName	()Ljava/lang/String;
    //   233: astore 18
    //   235: aload 16
    //   237: invokevirtual 271	com/wowza/wms/httpstreamer/webmstreaming/httpstreamer/WebMStreamingURL:getStreamName	()Ljava/lang/String;
    //   240: astore 19
    //   242: aload 5
    //   244: sipush 1007
    //   247: sipush 251
    //   250: idiv
    //   251: ldc_w 273
    //   254: invokestatic 45	com/wowza/util/Base64:endsWith	(ILjava/lang/String;)Ljava/lang/String;
    //   257: invokevirtual 207	com/wowza/wms/httpstreamer/model/HTTPStreamerRequest:getHeader	(Ljava/lang/String;)Ljava/lang/String;
    //   260: astore 20
    //   262: aload 20
    //   264: ifnull +61 -> 325
    //   267: goto +66 -> 333
    //   270: goto -201 -> 69
    //   273: aload 14
    //   275: invokeinterface 279 1 0
    //   280: astore 23
    //   282: aload_0
    //   283: aload 23
    //   285: invokevirtual 283	com/wowza/wms/httpstreamer/directstreaming/httpstreamer/HTTPStreamerAdapterDirectStreamer:setThreadContext	(Lcom/wowza/wms/application/IApplicationInstance;)V
    //   288: getstatic 168	java/lang/System:out	Ljava/io/PrintStream;
    //   291: new 102	java/lang/StringBuilder
    //   294: dup
    //   295: invokespecial 103	java/lang/StringBuilder:<init>	()V
    //   298: ldc_w 285
    //   301: bipush 27
    //   303: iconst_3
    //   304: imul
    //   305: invokestatic 61	com/wowza/util/JSON:copyValueOf	(Ljava/lang/String;I)Ljava/lang/String;
    //   308: invokevirtual 109	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   311: aload 19
    //   313: invokevirtual 109	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   316: invokevirtual 118	java/lang/StringBuilder:toString	()Ljava/lang/String;
    //   319: invokevirtual 175	java/io/PrintStream:println	(Ljava/lang/String;)V
    //   322: goto -253 -> 69
    //   325: ldc_w 287
    //   328: astore 20
    //   330: goto +33 -> 363
    //   333: new 102	java/lang/StringBuilder
    //   336: dup
    //   337: invokespecial 103	java/lang/StringBuilder:<init>	()V
    //   340: bipush 58
    //   342: iconst_5
    //   343: isub
    //   344: ldc_w 289
    //   347: invokestatic 45	com/wowza/util/Base64:endsWith	(ILjava/lang/String;)Ljava/lang/String;
    //   350: invokevirtual 109	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   353: aload 20
    //   355: invokevirtual 109	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   358: invokevirtual 118	java/lang/StringBuilder:toString	()Ljava/lang/String;
    //   361: astore 20
    //   363: aload 16
    //   365: invokevirtual 292	com/wowza/wms/httpstreamer/webmstreaming/httpstreamer/WebMStreamingURL:getQueryStr	()Ljava/lang/String;
    //   368: astore 21
    //   370: aload 21
    //   372: invokestatic 298	com/wowza/util/HTTPUtils:splitQueryStr	(Ljava/lang/String;)Ljava/util/Map;
    //   375: astore 22
    //   377: aload_0
    //   378: aload 4
    //   380: aload 17
    //   382: aload 18
    //   384: aload_0
    //   385: invokevirtual 301	com/wowza/wms/httpstreamer/directstreaming/httpstreamer/HTTPStreamerAdapterDirectStreamer:getAdapterName	()Ljava/lang/String;
    //   388: iconst_1
    //   389: invokevirtual 305	com/wowza/wms/httpstreamer/directstreaming/httpstreamer/HTTPStreamerAdapterDirectStreamer:getHTTPStreamerAppContext	(Lcom/wowza/wms/vhost/IVHost;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Z)Lcom/wowza/wms/httpstreamer/model/IHTTPStreamerApplicationContext;
    //   392: astore 14
    //   394: aload 14
    //   396: ifnonnull -123 -> 273
    //   399: goto -302 -> 97
    // Line number table:
    //   Java source line #105	-> byte code offset #0
    //   Java source line #106	-> byte code offset #3
    //   Java source line #107	-> byte code offset #6
    //   Java source line #111	-> byte code offset #27
    //   Java source line #112	-> byte code offset #32
    //   Java source line #113	-> byte code offset #37
    //   Java source line #157	-> byte code offset #43
    //   Java source line #153	-> byte code offset #44
    //   Java source line #155	-> byte code offset #46
    //   Java source line #156	-> byte code offset #69
    //   Java source line #119	-> byte code offset #72
    //   Java source line #120	-> byte code offset #89
    //   Java source line #142	-> byte code offset #97
    //   Java source line #143	-> byte code offset #163
    //   Java source line #123	-> byte code offset #166
    //   Java source line #124	-> byte code offset #173
    //   Java source line #126	-> byte code offset #185
    //   Java source line #128	-> byte code offset #221
    //   Java source line #129	-> byte code offset #228
    //   Java source line #130	-> byte code offset #235
    //   Java source line #131	-> byte code offset #242
    //   Java source line #132	-> byte code offset #262
    //   Java source line #121	-> byte code offset #270
    //   Java source line #146	-> byte code offset #273
    //   Java source line #147	-> byte code offset #282
    //   Java source line #149	-> byte code offset #288
    //   Java source line #150	-> byte code offset #322
    //   Java source line #135	-> byte code offset #325
    //   Java source line #133	-> byte code offset #333
    //   Java source line #136	-> byte code offset #363
    //   Java source line #137	-> byte code offset #370
    //   Java source line #139	-> byte code offset #377
    //   Java source line #140	-> byte code offset #394
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	402	0	this	HTTPStreamerAdapterDirectStreamer
    //   0	402	1	paramLong	long
    //   0	402	3	paramIoSession	org.apache.mina.common.IoSession
    //   0	402	4	paramIVHost	IVHost
    //   0	402	5	paramHTTPStreamerRequest	HTTPStreamerRequest
    //   0	402	6	paramHTTPStreamerResponse	HTTPStreamerResponse
    //   1	1	7	i	int
    //   4	1	8	j	int
    //   25	1	9	localRtmpSessionInfo	com.wowza.wms.server.RtmpSessionInfo
    //   30	1	10	l1	long
    //   35	1	12	l2	long
    //   38	357	14	localIHTTPStreamerApplicationContext	com.wowza.wms.httpstreamer.model.IHTTPStreamerApplicationContext
    //   44	18	15	localException	Exception
    //   87	124	15	str1	String
    //   183	181	16	localWebMStreamingURL	com.wowza.wms.httpstreamer.webmstreaming.httpstreamer.WebMStreamingURL
    //   142	239	17	str2	String
    //   152	231	18	str3	String
    //   240	72	19	str4	String
    //   260	102	20	str5	String
    //   368	3	21	str6	String
    //   375	1	22	localMap	java.util.Map
    //   280	4	23	localIApplicationInstance	com.wowza.wms.application.IApplicationInstance
    // Exception table:
    //   from	to	target	type
    //   72	402	44	java/lang/Exception
  }
  
  public IHTTPStreamerSession createHTTPSessionInstance()
  {
    return new HTTPStreamerSessionDirect();
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.httpstreamer.directstreaming.httpstreamer.HTTPStreamerAdapterDirectStreamer
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.httpstreamer.directstreaming.httpstreamer;

import com.wowza.util.Base64;
import com.wowza.util.JSON;
import com.wowza.wms.application.IApplicationInstance;
import com.wowza.wms.application.WMSProperties;
import com.wowza.wms.httpstreamer.model.HTTPStreamerApplicationContextBase;
import com.wowza.wms.httpstreamer.model.HTTPStreamerItem;

public class HTTPStreamerApplicationContextDirectStreamer
  extends HTTPStreamerApplicationContextBase
{
  public void init(IApplicationInstance paramIApplicationInstance, HTTPStreamerItem paramHTTPStreamerItem)
  {
    super.init(paramIApplicationInstance, paramHTTPStreamerItem);
    
    WMSProperties localWMSProperties = getProperties();
    
    cacheControlStatus4xx = localWMSProperties.getPropertyStr(JSON.copyValueOf("fjv`esKhiciNaadc}Gawcmj.cd", 6 - -28), cacheControlStatus4xx);
    responseOnIncompleteChunk = properties.getPropertyInt(Base64.endsWith(45 - 32, "ig}urfAqffxvjTrTp|olroaqcD`|d`"), responseOnIncompleteChunk);
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.httpstreamer.directstreaming.httpstreamer.HTTPStreamerApplicationContextDirectStreamer
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.httpstreamer.directstreaming.httpstreamer;

import com.wowza.wms.httpstreamer.model.HTTPStreamerSessionBase;

public class HTTPStreamerSessionDirect
  extends HTTPStreamerSessionBase
{}

/* Location:
 * Qualified Name:     com.wowza.wms.httpstreamer.directstreaming.httpstreamer.HTTPStreamerSessionDirect
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
1

Further reading...

For more information on Java 1.5 Tiger, you may find Java 1.5 Tiger, A developer's Notebook by D. Flanagan and B. McLaughlin from O'Reilly of interest.

New!JAR listings


Copyright 2006-2019. Infinite Loop Ltd