wms-dvr

16:54:02.088 INFO  jd.cli.Main - Decompiling wms-dvr.jar
package com.wowza.wms.dvr.impl;

import com.wowza.util.Base64;
import com.wowza.util.JSON;
import com.wowza.wms.application.WMSProperties;
import com.wowza.wms.dvr.IDvrStreamManager;
import com.wowza.wms.dvr.IDvrStreamStore;
import java.io.PrintStream;
import java.util.SortedSet;
import java.util.TreeSet;
import org.apache.commons.lang.StringUtils;

public class ChunkTosserInterceptorDelegate
  implements IDvrChunkInterceptorDelegate
{
  public class ChunkSkipper
  {
    private String a;
    private SortedSet<Integer> b = new TreeSet();
    
    ChunkSkipper(String paramString)
    {
      a = paramString;
    }
    
    public void addSkippedChunkNumber(int paramInt)
    {
      b.add(Integer.valueOf(paramInt));
    }
    
    public boolean shouldSkipChunk(int paramInt)
    {
      return b.contains(Integer.valueOf(paramInt));
    }
    
    public String toString()
    {
      return String.format(JSON.copyValueOf("}D`|d`_fg`t`)423d?9 ;9nc", '?' / 79), new Object[] { a, b });
    }
  }
  
  protected int chunkCount = 0;
  protected IDvrStreamStore store;
  protected String streamName;
  protected ChunkSkipper matcher = null;
  
  public void init(IDvrStreamStore paramIDvrStreamStore)
  {
    store = paramIDvrStreamStore;
    if (paramIDvrStreamStore == null) {}
    for (;;)
    {
      return;streamName = paramIDvrStreamStore.getDvrManager().getStreamBaseName();WMSProperties localWMSProperties = paramIDvrStreamStore.getProperties();String str = localWMSProperties.getPropertyStr(Base64.endsWith(108 + -22, "2!*\035?9):\03575/)\027+65\":\033?')>"), "");a(str);
    }
  }
  
  private final void a(String paramString)
  {
    String[] arrayOfString1 = paramString.split(Base64.endsWith(25 * 35, "\0200\020"));
    String[] arrayOfString2 = arrayOfString1;int i = arrayOfString2.length;int j = 0;
    break label174;
    String[] arrayOfString4;
    int k;
    for (;;)
    {
      String str2 = arrayOfString3[0];
      if (!d(str2)) {
        break label208;
      }
      break label118;
      System.out.println(Base64.endsWith(-11 - -39, "Q|j|hdp9$") + matcher);
      break label196;
      label96:
      for (;; !arrayOfString4[k].contains("-"))
      {
        c(arrayOfString4[k]); break;
      }
      label112:
      k++;
      break label197;
      label118:
      matcher = new ChunkSkipper(str2);
      arrayOfString4 = arrayOfString3[1].split(",");
      k = 0;
      break label197;
      label149:
      String str1 = arrayOfString2[j];
      String[] arrayOfString3 = str1.split(":");
      if (arrayOfString3.length != 2) {
        break label208;
      }
    }
    label174:
    label196:
    label197:
    label208:
    for (;; j++)
    {
      if (j < i)
      {
        break label149;
        b(arrayOfString4[k]);
        break label112;
      }
      return;
      if (k >= arrayOfString4.length) {
        break;
      }
      break label96;
    }
  }
  
  private final void b(String paramString)
  {
    try
    {
      int i = Integer.parseInt(paramString);
      matcher.addSkippedChunkNumber(i);
      break label54;
      return;
    }
    catch (Exception localException)
    {
      label54:
      for (;;)
      {
        System.out.println(Base64.endsWith(25 - -35, "Yolp2a2\"66/)/ipk") + paramString);
      }
    }
  }
  
  private final void c(String paramString)
  {
    String[] arrayOfString = paramString.split("-");
    for (;;)
    {
      return;
      try
      {
        int i = Integer.parseInt(arrayOfString[0]);
        int j = Integer.parseInt(arrayOfString[1]);
        int k = i;
        for (goto 45;; k > j)
        {
          matcher.addSkippedChunkNumber(k);k++;
        }
      }
      catch (Exception localException) {}
      System.out.println(Base64.endsWith(98 + 46, "Uc`|f5fvjjsu{=$?") + paramString);
    }
  }
  
  private final boolean d(String paramString)
  {
    if (StringUtils.isEmpty(paramString)) {
      break label26;
    }
    for (;;)
    {
      return true;
      if (!streamName.startsWith(paramString)) {
        for (goto 30; !streamName.matches(paramString);) {
          label26:
          return false;
        }
      }
    }
  }
  
  /* Error */
  public boolean shouldStoreChunk(int arg1, com.wowza.wms.dvr.DvrPacketHolder arg2, int arg3, com.wowza.wms.dvr.DvrPacketHolder arg4, int arg5, com.wowza.wms.dvr.DvrPacketHolder arg6)
  {
    // Byte code:
    //   0: iconst_1
    //   1: istore 7
    //   3: aload_0
    //   4: getfield 26	com/wowza/wms/dvr/impl/ChunkTosserInterceptorDelegate:matcher	Lcom/wowza/wms/dvr/impl/ChunkTosserInterceptorDelegate$ChunkSkipper;
    //   7: ifnull +6 -> 13
    //   10: goto +16 -> 26
    //   13: aload_0
    //   14: dup
    //   15: getfield 24	com/wowza/wms/dvr/impl/ChunkTosserInterceptorDelegate:chunkCount	I
    //   18: iconst_1
    //   19: iadd
    //   20: putfield 24	com/wowza/wms/dvr/impl/ChunkTosserInterceptorDelegate:chunkCount	I
    //   23: iload 7
    //   25: ireturn
    //   26: aload_0
    //   27: getfield 26	com/wowza/wms/dvr/impl/ChunkTosserInterceptorDelegate:matcher	Lcom/wowza/wms/dvr/impl/ChunkTosserInterceptorDelegate$ChunkSkipper;
    //   30: aload_0
    //   31: getfield 24	com/wowza/wms/dvr/impl/ChunkTosserInterceptorDelegate:chunkCount	I
    //   34: invokevirtual 160	com/wowza/wms/dvr/impl/ChunkTosserInterceptorDelegate$ChunkSkipper:shouldSkipChunk	(I)Z
    //   37: ifne +11 -> 48
    //   40: goto +12 -> 52
    //   43: istore 7
    //   45: goto -32 -> 13
    //   48: iconst_0
    //   49: goto -6 -> 43
    //   52: iconst_1
    //   53: goto -10 -> 43
    // Line number table:
    //   Java source line #112	-> byte code offset #0
    //   Java source line #115	-> byte code offset #3
    //   Java source line #119	-> byte code offset #13
    //   Java source line #121	-> byte code offset #23
    //   Java source line #116	-> byte code offset #26
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.dvr.impl.ChunkTosserInterceptorDelegate
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.dvr.impl;

import com.wowza.util.JSON;
import java.util.SortedSet;
import java.util.TreeSet;

public class ChunkTosserInterceptorDelegate$ChunkSkipper
{
  private String a;
  private SortedSet<Integer> b = new TreeSet();
  
  ChunkTosserInterceptorDelegate$ChunkSkipper(ChunkTosserInterceptorDelegate paramChunkTosserInterceptorDelegate, String paramString)
  {
    a = paramString;
  }
  
  public void addSkippedChunkNumber(int paramInt)
  {
    b.add(Integer.valueOf(paramInt));
  }
  
  public boolean shouldSkipChunk(int paramInt)
  {
    return b.contains(Integer.valueOf(paramInt));
  }
  
  public String toString()
  {
    return String.format(JSON.copyValueOf("}D`|d`_fg`t`)423d?9 ;9nc", '?' / 79), new Object[] { a, b });
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.dvr.impl.ChunkTosserInterceptorDelegate.ChunkSkipper
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.dvr.impl;

import com.wowza.util.PacketFragment;

public class DvrChunkHeader
{
  private PacketFragment a = null;
  
  public PacketFragment getHeaderData()
  {
    return a;
  }
  
  public void setHeaderData(PacketFragment paramPacketFragment)
  {
    a = paramPacketFragment;
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.dvr.impl.DvrChunkHeader
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.dvr.impl;

public class DvrChunkInterceptorFactory
{
  private static final Class<DvrChunkInterceptorFactory> a = DvrChunkInterceptorFactory.class;
  
  /* Error */
  public static IDvrChunkInterceptorDelegate createInstance(com.wowza.wms.dvr.IDvrStreamStore paramIDvrStreamStore, String paramString)
  {
    // Byte code:
    //   0: aconst_null
    //   1: astore_2
    //   2: goto +27 -> 29
    //   5: astore_3
    //   6: getstatic 18	com/wowza/wms/dvr/impl/DvrChunkInterceptorFactory:a	Ljava/lang/Class;
    //   9: invokestatic 24	com/wowza/wms/logging/WMSLoggerFactory:getLogger	(Ljava/lang/Class;)Lcom/wowza/wms/logging/WMSLogger;
    //   12: bipush 21
    //   14: bipush 7
    //   16: iadd
    //   17: ldc 26
    //   19: invokestatic 32	com/wowza/util/Base64:endsWith	(ILjava/lang/String;)Ljava/lang/String;
    //   22: aload_3
    //   23: invokevirtual 38	com/wowza/wms/logging/WMSLogger:error	(Ljava/lang/String;Ljava/lang/Throwable;)V
    //   26: goto +103 -> 129
    //   29: aload_1
    //   30: invokestatic 44	java/lang/Class:forName	(Ljava/lang/String;)Ljava/lang/Class;
    //   33: astore_3
    //   34: aload_3
    //   35: invokevirtual 48	java/lang/Class:newInstance	()Ljava/lang/Object;
    //   38: astore 4
    //   40: aload 4
    //   42: instanceof 50
    //   45: ifne +16 -> 61
    //   48: goto +26 -> 74
    //   51: aload_2
    //   52: aload_0
    //   53: invokeinterface 54 2 0
    //   58: goto +73 -> 131
    //   61: aload 4
    //   63: checkcast 50	com/wowza/wms/dvr/impl/IDvrChunkInterceptorDelegate
    //   66: astore_2
    //   67: aload_2
    //   68: ifnull +63 -> 131
    //   71: goto -20 -> 51
    //   74: getstatic 18	com/wowza/wms/dvr/impl/DvrChunkInterceptorFactory:a	Ljava/lang/Class;
    //   77: invokestatic 24	com/wowza/wms/logging/WMSLoggerFactory:getLogger	(Ljava/lang/Class;)Lcom/wowza/wms/logging/WMSLogger;
    //   80: new 56	java/lang/StringBuilder
    //   83: dup
    //   84: invokespecial 57	java/lang/StringBuilder:<init>	()V
    //   87: ldc 59
    //   89: bipush -22
    //   91: bipush 58
    //   93: isub
    //   94: invokestatic 65	com/wowza/util/JSON:copyValueOf	(Ljava/lang/String;I)Ljava/lang/String;
    //   97: invokevirtual 69	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   100: aload_1
    //   101: invokevirtual 69	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   104: ldc 71
    //   106: bipush 33
    //   108: bipush 9
    //   110: imul
    //   111: invokestatic 65	com/wowza/util/JSON:copyValueOf	(Ljava/lang/String;I)Ljava/lang/String;
    //   114: invokevirtual 69	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   117: invokevirtual 75	java/lang/StringBuilder:toString	()Ljava/lang/String;
    //   120: invokevirtual 78	com/wowza/wms/logging/WMSLogger:error	(Ljava/lang/String;)V
    //   123: aconst_null
    //   124: astore 4
    //   126: goto -65 -> 61
    //   129: aload_2
    //   130: areturn
    //   131: goto -2 -> 129
    // Line number table:
    //   Java source line #19	-> byte code offset #0
    //   Java source line #37	-> byte code offset #5
    //   Java source line #39	-> byte code offset #6
    //   Java source line #24	-> byte code offset #29
    //   Java source line #25	-> byte code offset #34
    //   Java source line #26	-> byte code offset #40
    //   Java source line #34	-> byte code offset #51
    //   Java source line #30	-> byte code offset #61
    //   Java source line #32	-> byte code offset #67
    //   Java source line #27	-> byte code offset #74
    //   Java source line #28	-> byte code offset #123
    //   Java source line #42	-> byte code offset #129
    //   Java source line #40	-> byte code offset #131
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	134	0	paramIDvrStreamStore	com.wowza.wms.dvr.IDvrStreamStore
    //   0	134	1	paramString	String
    //   1	129	2	localIDvrChunkInterceptorDelegate	IDvrChunkInterceptorDelegate
    //   5	18	3	localException	Exception
    //   33	2	3	localClass	Class
    //   38	87	4	localObject	Object
    // Exception table:
    //   from	to	target	type
    //   29	129	5	java/lang/Exception
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.dvr.impl.DvrChunkInterceptorFactory
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.dvr.impl;

import com.wowza.util.JSON;
import com.wowza.wms.dvr.IDvrChunkUtcDelegate;
import com.wowza.wms.dvr.IDvrStreamStore;
import com.wowza.wms.logging.WMSLogger;
import com.wowza.wms.logging.WMSLoggerFactory;

public class DvrChunkUtcDelegateFactory
{
  private static final Class<DvrChunkUtcDelegateFactory> a = DvrChunkUtcDelegateFactory.class;
  
  public static IDvrChunkUtcDelegate createInstance(IDvrStreamStore paramIDvrStreamStore, String paramString)
  {
    IDvrChunkUtcDelegate localIDvrChunkUtcDelegate = null;
    for (;;)
    {
      return localIDvrChunkUtcDelegate;
      Class localClass;
      Object localObject;
      for (;; ) {
        break;
      }
      WMSLoggerFactory.getLogger(a).error(JSON.copyValueOf("UdaW}cysLnxXxrz' 6&\002$%3';3e/?+.$4\033='!79;<z", tmp121_119 * tmp121_119), localException);
    }
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.dvr.impl.DvrChunkUtcDelegateFactory
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.dvr.impl;

import com.wowza.util.Base64;
import com.wowza.util.DebugUtils;
import com.wowza.util.IPacketFragment;
import com.wowza.util.JSON;
import com.wowza.util.PacketFragmentList;
import com.wowza.wms.dvr.DvrPacketHolder;
import com.wowza.wms.httpstreamer.smoothstreaming.livestreampacketizer.SmoothStreamingFragment;
import com.wowza.wms.httpstreamer.smoothstreaming.livestreampacketizer.SmoothStreamingMediaPacket;
import com.wowza.wms.logging.WMSLogger;
import com.wowza.wms.logging.WMSLoggerFactory;
import java.util.Iterator;
import java.util.List;
import org.apache.log4j.Level;

public class DvrDebugUtils
{
  public static void logChunk(WMSLogger paramWMSLogger, Level paramLevel, String paramString, int paramInt1, DvrPacketHolder paramDvrPacketHolder1, int paramInt2, DvrPacketHolder paramDvrPacketHolder2, int paramInt3, DvrPacketHolder paramDvrPacketHolder3)
  {
    paramWMSLogger.log(paramLevel, String.format(JSON.copyValueOf("o8l;\n:\"kw7t4\022\"*c?|9\032*r;'g", -57 - -35), new Object[] { paramString, Integer.valueOf(paramInt1), Integer.valueOf(paramInt2), Integer.valueOf(paramInt3) }));
    if (paramDvrPacketHolder1 != null)
    {
      break label175;
      paramWMSLogger.log(paramLevel, String.format(JSON.copyValueOf("p%w\0348.:|\r?<kdvp>%vs2,n+yym55u2", -52 - -41), new Object[] { paramString, Long.valueOf(paramDvrPacketHolder3.getPacketTimecode()), Long.valueOf(paramDvrPacketHolder3.getUtcTimecode()) }));
      logPacketHolder(paramWMSLogger, paramLevel, paramString, paramDvrPacketHolder3);
    }
    for (;; paramDvrPacketHolder2 == null)
    {
      paramWMSLogger.log(paramLevel, String.format(JSON.copyValueOf("r+y\033.841\020 !(!15}h9>qi)n:$2hv0u", 21 * 59), new Object[] { paramString, Long.valueOf(paramDvrPacketHolder2.getPacketTimecode()), Long.valueOf(paramDvrPacketHolder2.getUtcTimecode()) }));
      logPacketHolder(paramWMSLogger, paramLevel, paramString, paramDvrPacketHolder2);
      break label236;
      label175:
      paramWMSLogger.log(paramLevel, String.format(JSON.copyValueOf("!v&Qamod,]ol{tf`.5fc\"<~;ii}%%e\"", '?' / 124), new Object[] { paramString, Long.valueOf(paramDvrPacketHolder1.getPacketTimecode()), Long.valueOf(paramDvrPacketHolder1.getUtcTimecode()) }));
      logPacketHolder(paramWMSLogger, paramLevel, paramString, paramDvrPacketHolder1); continue;
      label236:
      while (paramDvrPacketHolder3 == null) {
        return;
      }
      break;
    }
  }
  
  public static void logPacketHolder(WMSLogger paramWMSLogger, Level paramLevel, String paramString1, String paramString2, DvrPacketHolder paramDvrPacketHolder)
  {
    if (paramString1 == null) {}
    for (;; paramWMSLogger.log(paramLevel, paramString1 + ":"))
    {
      logPacketHolder(paramWMSLogger, paramLevel, paramString2, paramDvrPacketHolder); return;
    }
  }
  
  public static void logPartialPacketHolder(WMSLogger paramWMSLogger, Level paramLevel, String paramString, int paramInt, DvrPacketHolder paramDvrPacketHolder)
  {
    int i = paramDvrPacketHolder.getHolders().size();
    if (paramDvrPacketHolder.isGroup()) {}else {
      label24:
      logPacketHolder(paramWMSLogger, paramLevel, paramString, paramDvrPacketHolder);
    }
    for (;;)
    {
      int j;
      List localList;
      if (j < paramInt)
      {
        break label158;
        localDvrPacketHolder = (DvrPacketHolder)localList.get(j);
        logPacketHolder(paramWMSLogger, paramLevel, paramString, localDvrPacketHolder);j++;
        break label96;
        label72:
        localList = paramDvrPacketHolder.getHolders();
        j = 0; continue;
        label85:
        if (i <= paramInt << 1) {
          break label24;
        }
      }
      for (;;)
      {
        label96:
        if (j >= i) {
          break label156;
        }
        break;
        if (!paramDvrPacketHolder.isGroup()) {
          break label72;
        }
        break label85;
        break label72;
        paramWMSLogger.log(paramLevel, paramString + JSON.copyValueOf("klc`a", 30 - -45));
        
        j = i - paramInt;
      }
      label156:
      break;
      label158:
      DvrPacketHolder localDvrPacketHolder = (DvrPacketHolder)localList.get(j);
      logPacketHolder(paramWMSLogger, paramLevel, paramString, localDvrPacketHolder);j++;
    }
  }
  
  public static void logPacketHolder(WMSLogger paramWMSLogger, Level paramLevel, String paramString, DvrPacketHolder paramDvrPacketHolder)
  {
    Iterator localIterator;
    if (paramWMSLogger != null) {
      for (;;)
      {
        if (!paramDvrPacketHolder.isGroup()) {
          if (paramDvrPacketHolder == null)
          {
            break;
            for (;; !localIterator.hasNext())
            {
              DvrPacketHolder localDvrPacketHolder = (DvrPacketHolder)localIterator.next();
              logPacketHolder(paramWMSLogger, paramLevel, paramString, localDvrPacketHolder);
            }
            paramWMSLogger.log(paramLevel, paramString + paramDvrPacketHolder.toString());
            label83:
            return;
          }
        }
      }
    }
    for (;;)
    {
      localIterator = localList.iterator(); break;return;paramWMSLogger.log(paramLevel, paramString + paramDvrPacketHolder.toString());paramString = paramString + Base64.endsWith(33 * 47, "/0");List localList = paramDvrPacketHolder.getHolders();
      if (localList == null) {
        break label83;
      }
    }
  }
  
  public static String packetHoldersToString(String paramString, int paramInt, DvrPacketHolder paramDvrPacketHolder)
  {
    int i = paramDvrPacketHolder.getHolders().size();
    if (paramDvrPacketHolder.isGroup()) {
      break label100;
    }
    List localList;
    int j;
    DvrPacketHolder localDvrPacketHolder;
    PrefixStringBuffer localPrefixStringBuffer;
    for (;;)
    {
      localDvrPacketHolder = (DvrPacketHolder)localList.get(j);
      localPrefixStringBuffer.a(localDvrPacketHolder.toString());j++;
      break label56;
      return packetHoldersToString(paramString, paramDvrPacketHolder);
      label56:
      if (j >= i) {
        break;
      }
    }
    label100:
    label172:
    for (;;)
    {
      localPrefixStringBuffer.a(JSON.copyValueOf("$%()&'", '?' / '�'));
      
      j = i - paramInt;
      break label56;
      for (;;)
      {
        if (i <= paramInt << 1)
        {
          break;
          if (paramDvrPacketHolder.isGroup())
          {
            continue;localDvrPacketHolder = (DvrPacketHolder)localList.get(j);
            localPrefixStringBuffer.a(localDvrPacketHolder.toString());
          }
        }
      }
      for (j++;; j = 0)
      {
        if (j >= paramInt) {
          break label172;
        }
        break;return localPrefixStringBuffer.toString();localPrefixStringBuffer = new PrefixStringBuffer(paramString);localList = paramDvrPacketHolder.getHolders();
      }
    }
  }
  
  public static String packetHoldersToString(String paramString, DvrPacketHolder paramDvrPacketHolder)
  {
    PrefixStringBuffer localPrefixStringBuffer = new PrefixStringBuffer(paramString);
    if (!paramDvrPacketHolder.isGroup()) {
      break label71;
    }
    List localList;
    Iterator localIterator;
    do
    {
      localIterator = localList.iterator(); break;localList = paramDvrPacketHolder.getHolders();
    } while (localList != null);
    return localPrefixStringBuffer.toString();
    for (;;)
    {
      DvrPacketHolder localDvrPacketHolder = (DvrPacketHolder)localIterator.next();
      localPrefixStringBuffer.a(localDvrPacketHolder.toString());
      break label82;
      label71:
      localPrefixStringBuffer.a(paramDvrPacketHolder.toString());
      break;
      label82:
      if (!localIterator.hasNext()) {
        break;
      }
    }
  }
  
  private static String a(String paramString, List<SmoothStreamingMediaPacket> paramList)
  {
    PrefixStringBuffer localPrefixStringBuffer = new PrefixStringBuffer(paramString);
    Iterator localIterator = paramList.iterator();
    break label44;
    return localPrefixStringBuffer.toString();
    label44:
    for (;; !localIterator.hasNext())
    {
      SmoothStreamingMediaPacket localSmoothStreamingMediaPacket = (SmoothStreamingMediaPacket)localIterator.next();
      localPrefixStringBuffer.a(mediaPacketToString(localSmoothStreamingMediaPacket));
    }
  }
  
  private static String a(String paramString, int paramInt, List<SmoothStreamingMediaPacket> paramList)
  {
    int i = paramList.size();
    int j;
    if (i <= paramInt << 1)
    {
      break label79;
      if (j < i) {
        break label91;
      }
    }
    label79:
    label91:
    label120:
    label143:
    for (;;)
    {
      PrefixStringBuffer localPrefixStringBuffer;
      localPrefixStringBuffer.a(Base64.endsWith(34 + 79, "qr}z{"));
      j = i - paramInt; break;SmoothStreamingMediaPacket localSmoothStreamingMediaPacket = (SmoothStreamingMediaPacket)paramList.get(j);localPrefixStringBuffer.a(mediaPacketToString(localSmoothStreamingMediaPacket));j++;
      break label120;
      return a(paramString, paramList);
      
      return localPrefixStringBuffer.toString();localSmoothStreamingMediaPacket = (SmoothStreamingMediaPacket)paramList.get(j);localPrefixStringBuffer.a(mediaPacketToString(localSmoothStreamingMediaPacket));j++; break;
      for (;;)
      {
        if (j >= paramInt) {
          break label143;
        }
        break;localPrefixStringBuffer = new PrefixStringBuffer(paramString);
        
        j = 0;
      }
    }
  }
  
  public static String mediaPacketToString(SmoothStreamingMediaPacket paramSmoothStreamingMediaPacket)
  {
    String str = Base64.endsWith(59 * 17, "w\"8\"#p!9'j");
    if (paramSmoothStreamingMediaPacket == null) {}
    for (;; str = String.format(JSON.copyValueOf("\006\005\032\by\001/ax:tx?&`%es|z7.h-}u-4vN", 48 - 59), new Object[] { Long.valueOf(paramSmoothStreamingMediaPacket.getTimecode()), Integer.valueOf(paramSmoothStreamingMediaPacket.getType()), Integer.valueOf(paramSmoothStreamingMediaPacket.getCTTS()), Integer.valueOf(paramSmoothStreamingMediaPacket.getSize()) })) {
      return str;
    }
  }
  
  public static void dumpPartialMediaPackets(String paramString, int paramInt, List<SmoothStreamingMediaPacket> paramList)
  {
    WMSLogger localWMSLogger = WMSLoggerFactory.getLogger(DvrPacketHandler.class);
    localWMSLogger.info("\n" + a(paramString, paramInt, paramList));
  }
  
  public static void dumpMediaPackets(String paramString, List<SmoothStreamingMediaPacket> paramList)
  {
    WMSLogger localWMSLogger = WMSLoggerFactory.getLogger(DvrPacketHandler.class);
    localWMSLogger.info("\n" + a(paramString, paramList));
  }
  
  public static String smoothStreamingFragmentToString(String paramString, int paramInt, SmoothStreamingFragment paramSmoothStreamingFragment)
  {
    PrefixStringBuffer localPrefixStringBuffer = new PrefixStringBuffer(paramString);
    localPrefixStringBuffer.a(String.format(Base64.endsWith(15 * 9, "Tefed^z}upzzrPey~w~ri>lt`pw9 b'mgn6)i.kec/6p"), new Object[] { Long.valueOf(paramSmoothStreamingFragment.getStartTimecode()), Long.valueOf(paramSmoothStreamingFragment.getStopTimecode()), Long.valueOf(paramSmoothStreamingFragment.getStopTimecode() - paramSmoothStreamingFragment.getStartTimecode()) }));
    
    PacketFragmentList localPacketFragmentList = paramSmoothStreamingFragment.getFragmentList();
    localPrefixStringBuffer.a(rtpPacketFragmentListToString(null, paramInt, localPacketFragmentList));
    
    return localPrefixStringBuffer.toString();
  }
  
  public static String rtpPacketFragmentListToString(String paramString, int paramInt, PacketFragmentList paramPacketFragmentList)
  {
    List localList = paramPacketFragmentList.getFragments();
    int i = localList.size();
    if (i <= paramInt << 1) {
      break label156;
    }
    int j;
    for (;; j >= paramInt)
    {
      IPacketFragment localIPacketFragment = (IPacketFragment)localList.get(j);
      localPrefixStringBuffer.a(Base64.endsWith(-38 - 7, "stuv") + rtpPacketToString(null, localIPacketFragment));j++; continue;PrefixStringBuffer localPrefixStringBuffer = new PrefixStringBuffer(paramString);localPrefixStringBuffer.a(String.format(JSON.copyValueOf("`a$1%\"\n.;=pk?9/=$lw7t1#%e|>{/4$:=$f#'ctfoz7.h", 14 - 46), new Object[] { Long.valueOf(paramPacketFragmentList.getStartTime()), Long.valueOf(paramPacketFragmentList.getDuration()), Integer.valueOf(paramPacketFragmentList.size()), Integer.valueOf(i) }));j = 0; continue;
      label156:
      return rtpPacketFragmentListToString(paramString, paramPacketFragmentList);
      for (;;)
      {
        if (j >= i) {
          return localPrefixStringBuffer.toString();
        }
        localIPacketFragment = (IPacketFragment)localList.get(j);
        localPrefixStringBuffer.a(Base64.endsWith(23 + 5, "<=>?") + rtpPacketToString(null, localIPacketFragment));j++; continue;localPrefixStringBuffer.a(JSON.copyValueOf("mna~", 118 + 119));j = i - paramInt;
      }
    }
  }
  
  public static String rtpPacketFragmentListToString(String paramString, PacketFragmentList paramPacketFragmentList)
  {
    PrefixStringBuffer localPrefixStringBuffer = new PrefixStringBuffer(paramString);
    
    List localList = paramPacketFragmentList.getFragments();
    int i = localList.size();
    
    localPrefixStringBuffer.a(String.format(Base64.endsWith('?' / 112, "$%`uinFby4/cesa`(3s8}oi!8z?shxf9 b'+oxjk~3*t"), new Object[] { Long.valueOf(paramPacketFragmentList.getStartTime()), Long.valueOf(paramPacketFragmentList.getDuration()), Integer.valueOf(paramPacketFragmentList.size()), Integer.valueOf(i) }));
    Iterator localIterator = localList.iterator();
    break label146;
    return localPrefixStringBuffer.toString();
    label146:
    for (;; !localIterator.hasNext())
    {
      IPacketFragment localIPacketFragment = (IPacketFragment)localIterator.next();
      localPrefixStringBuffer.a(JSON.copyValueOf("?`ab", 16 + 47) + rtpPacketToString(null, localIPacketFragment));
    }
  }
  
  public static String rtpPacketToString(String paramString, IPacketFragment paramIPacketFragment)
  {
    PrefixStringBuffer localPrefixStringBuffer = new PrefixStringBuffer(paramString);
    
    String str = DebugUtils.formatBytes(paramIPacketFragment.getBuffer(), 0, 8);
    str = str.replace('\n', ' ');
    
    localPrefixStringBuffer.b(String.format(JSON.copyValueOf("\033\023\026\023\024$%,-=\f9-*#*>%r?1;kr<y5=:.;+=$f#f|rb{3*.P", -1 - 31), new Object[] { Integer.valueOf(paramIPacketFragment.getLen()), Integer.valueOf(paramIPacketFragment.getOffset()), str }));
    
    return localPrefixStringBuffer.toString();
  }
  
  public static void dumpStreamingFragment(String paramString, SmoothStreamingFragment paramSmoothStreamingFragment)
  {
    WMSLogger localWMSLogger = WMSLoggerFactory.getLogger(DvrPacketHandler.class);
    localWMSLogger.info("\n" + smoothStreamingFragmentToString(paramString, 3, paramSmoothStreamingFragment));
  }
  
  static class PrefixStringBuffer
  {
    private StringBuffer a;
    private String b;
    
    public PrefixStringBuffer(String paramString)
    {
      a = new StringBuffer();
      b = paramString;
    }
    
    final void a(String paramString)
    {
      if (b == null) {}
      for (;; a.append(b))
      {
        a.append(paramString).append("\n"); return;
      }
    }
    
    final void b(String paramString)
    {
      if (b == null) {}
      for (;; a.append(b))
      {
        a.append(paramString); return;
      }
    }
    
    public String toString()
    {
      return a.toString();
    }
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.dvr.impl.DvrDebugUtils
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.dvr.impl;

class DvrDebugUtils$PrefixStringBuffer
{
  private StringBuffer a;
  private String b;
  
  public DvrDebugUtils$PrefixStringBuffer(String paramString)
  {
    a = new StringBuffer();
    b = paramString;
  }
  
  final void a(String paramString)
  {
    if (b == null) {}
    for (;; a.append(b))
    {
      a.append(paramString).append("\n"); return;
    }
  }
  
  final void b(String paramString)
  {
    if (b == null) {}
    for (;; a.append(b))
    {
      a.append(paramString); return;
    }
  }
  
  public String toString()
  {
    return a.toString();
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.dvr.impl.DvrDebugUtils.PrefixStringBuffer
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.dvr.impl;

import com.wowza.util.Base64;
import com.wowza.util.JSON;
import com.wowza.wms.application.WMSProperties;
import com.wowza.wms.dvr.DvrChunk;
import com.wowza.wms.dvr.DvrManifestChunkEntry;
import com.wowza.wms.dvr.IDvrChunkMemoryCache;
import com.wowza.wms.dvr.IDvrStreamStore;
import java.util.HashMap;
import java.util.Map;

public class DvrDefaultChunkMemoryCache
  implements IDvrChunkMemoryCache
{
  private static final Object a = JSON.copyValueOf("BqzMommxb{Syg}XszwkcX}~vz", '?' / '�');
  Map<Integer, DvrDefaultSingleTypeMemoryCache> b = new HashMap();
  protected int size = 10;
  
  public void init(IDvrStreamStore paramIDvrStreamStore)
  {
    size = paramIDvrStreamStore.getProperties().getPropertyInt(Base64.endsWith(120 + -83, "fnrfbGnab|vSpq{qFm}"), size);
    
    b.put(Integer.valueOf(8), new DvrDefaultSingleTypeMemoryCache(8, size));
    b.put(Integer.valueOf(9), new DvrDefaultSingleTypeMemoryCache(9, size));
  }
  
  public synchronized DvrChunk retrieveRawChunk(DvrManifestChunkEntry paramDvrManifestChunkEntry)
  {
    DvrChunk localDvrChunk = null;
    
    int i = paramDvrManifestChunkEntry.getType();
    DvrDefaultSingleTypeMemoryCache localDvrDefaultSingleTypeMemoryCache = (DvrDefaultSingleTypeMemoryCache)b.get(Integer.valueOf(i));
    if (localDvrDefaultSingleTypeMemoryCache == null) {}
    for (;;)
    {
      return localDvrChunk;int j = paramDvrManifestChunkEntry.getIndex();localDvrChunk = localDvrDefaultSingleTypeMemoryCache.retrieveRawChunk(j);
    }
  }
  
  public void addToCache(DvrManifestChunkEntry paramDvrManifestChunkEntry, DvrChunk paramDvrChunk)
  {
    int i = paramDvrManifestChunkEntry.getType();
    DvrDefaultSingleTypeMemoryCache localDvrDefaultSingleTypeMemoryCache = (DvrDefaultSingleTypeMemoryCache)b.get(Integer.valueOf(i));
    if (localDvrDefaultSingleTypeMemoryCache == null) {}
    for (;;)
    {
      return;int j = paramDvrManifestChunkEntry.getIndex();localDvrDefaultSingleTypeMemoryCache.addToCache(j, paramDvrChunk);
    }
  }
  
  public String toString()
  {
    return String.format(Base64.endsWith(118 + 26, "k4a)45e~b|'>o`"), new Object[] { a, Integer.valueOf(size) });
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.dvr.impl.DvrDefaultChunkMemoryCache
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.dvr.impl;

import com.wowza.util.Base64;
import com.wowza.wms.dvr.DvrChunk;
import java.util.TreeMap;

public class DvrDefaultSingleTypeMemoryCache
{
  private static final Object a = Base64.endsWith('?' / '�', "GrwBbnhgx^gaw}wGmesZ}tuie^|hd");
  TreeMap<Integer, DvrChunk> b = new TreeMap();
  protected int maxSize;
  protected int type;
  
  public DvrDefaultSingleTypeMemoryCache(int paramInt1, int paramInt2)
  {
    type = paramInt1;
    maxSize = paramInt2;
  }
  
  public synchronized DvrChunk retrieveRawChunk(int paramInt)
  {
    return (DvrChunk)b.get(Integer.valueOf(paramInt));
  }
  
  public synchronized void addToCache(int paramInt, DvrChunk paramDvrChunk)
  {
    if (!containsChunk(paramInt)) {
      break label37;
    }
    for (;;)
    {
      b.put(Integer.valueOf(paramInt), paramDvrChunk);
      if (isCacheFull())
      {
        break label49;
        label37:
        if (shouldAddToCache(paramInt)) {
          break;
        }
        return;
        label49:
        int i = removeElementFromCache();
      }
    }
  }
  
  protected int removeElementFromCache()
  {
    Integer localInteger = (Integer)b.firstKey();
    b.remove(localInteger);
    return localInteger.intValue();
  }
  
  protected boolean containsChunk(int paramInt)
  {
    return b.containsKey(Integer.valueOf(paramInt));
  }
  
  /* Error */
  protected boolean shouldAddToCache(int arg1)
  {
    // Byte code:
    //   0: aload_0
    //   1: invokevirtual 55	com/wowza/wms/dvr/impl/DvrDefaultSingleTypeMemoryCache:isCacheFull	()Z
    //   4: ifne +17 -> 21
    //   7: goto +7 -> 14
    //   10: iconst_0
    //   11: goto +5 -> 16
    //   14: iconst_1
    //   15: ireturn
    //   16: ireturn
    //   17: iconst_1
    //   18: goto -2 -> 16
    //   21: iload_1
    //   22: aload_0
    //   23: getfield 23	com/wowza/wms/dvr/impl/DvrDefaultSingleTypeMemoryCache:b	Ljava/util/TreeMap;
    //   26: invokevirtual 79	java/util/TreeMap:lastKey	()Ljava/lang/Object;
    //   29: checkcast 31	java/lang/Integer
    //   32: invokevirtual 72	java/lang/Integer:intValue	()I
    //   35: if_icmple -25 -> 10
    //   38: goto -21 -> 17
    // Line number table:
    //   Java source line #62	-> byte code offset #0
    //   Java source line #66	-> byte code offset #10
    //   Java source line #63	-> byte code offset #14
    //   Java source line #66	-> byte code offset #16
  }
  
  /* Error */
  protected boolean isCacheFull()
  {
    // Byte code:
    //   0: aload_0
    //   1: getfield 23	com/wowza/wms/dvr/impl/DvrDefaultSingleTypeMemoryCache:b	Ljava/util/TreeMap;
    //   4: invokevirtual 82	java/util/TreeMap:size	()I
    //   7: aload_0
    //   8: getfield 27	com/wowza/wms/dvr/impl/DvrDefaultSingleTypeMemoryCache:maxSize	I
    //   11: if_icmplt +7 -> 18
    //   14: goto +8 -> 22
    //   17: ireturn
    //   18: iconst_0
    //   19: goto -2 -> 17
    //   22: iconst_1
    //   23: goto -6 -> 17
    // Line number table:
    //   Java source line #70	-> byte code offset #0
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.dvr.impl.DvrDefaultSingleTypeMemoryCache
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.dvr.impl;

public class DvrEncryptionInfoDelegateFactory
{
  private static final Class<DvrEncryptionInfoDelegateFactory> a = DvrEncryptionInfoDelegateFactory.class;
  
  /* Error */
  public static com.wowza.wms.dvr.DvrBaseEncryptionInfoDelegate createInstance(String paramString)
  {
    // Byte code:
    //   0: aconst_null
    //   1: astore_1
    //   2: goto +31 -> 33
    //   5: aload_1
    //   6: areturn
    //   7: astore_2
    //   8: getstatic 18	com/wowza/wms/dvr/impl/DvrEncryptionInfoDelegateFactory:a	Ljava/lang/Class;
    //   11: invokestatic 24	com/wowza/wms/logging/WMSLoggerFactory:getLogger	(Ljava/lang/Class;)Lcom/wowza/wms/logging/WMSLogger;
    //   14: ldc 26
    //   16: bipush 49
    //   18: dup
    //   19: imul
    //   20: invokestatic 32	com/wowza/util/JSON:copyValueOf	(Ljava/lang/String;I)Ljava/lang/String;
    //   23: aload_2
    //   24: invokevirtual 38	com/wowza/wms/logging/WMSLogger:error	(Ljava/lang/String;Ljava/lang/Throwable;)V
    //   27: goto -22 -> 5
    //   30: goto -25 -> 5
    //   33: aload_0
    //   34: invokestatic 44	java/lang/Class:forName	(Ljava/lang/String;)Ljava/lang/Class;
    //   37: astore_2
    //   38: aload_2
    //   39: invokevirtual 48	java/lang/Class:newInstance	()Ljava/lang/Object;
    //   42: astore_3
    //   43: aload_3
    //   44: instanceof 50
    //   47: ifne +6 -> 53
    //   50: goto +11 -> 61
    //   53: aload_3
    //   54: checkcast 50	com/wowza/wms/dvr/DvrBaseEncryptionInfoDelegate
    //   57: astore_1
    //   58: goto -28 -> 30
    //   61: getstatic 18	com/wowza/wms/dvr/impl/DvrEncryptionInfoDelegateFactory:a	Ljava/lang/Class;
    //   64: invokestatic 24	com/wowza/wms/logging/WMSLoggerFactory:getLogger	(Ljava/lang/Class;)Lcom/wowza/wms/logging/WMSLogger;
    //   67: new 52	java/lang/StringBuilder
    //   70: dup
    //   71: invokespecial 53	java/lang/StringBuilder:<init>	()V
    //   74: bipush -35
    //   76: bipush 28
    //   78: isub
    //   79: ldc 55
    //   81: invokestatic 61	com/wowza/util/Base64:endsWith	(ILjava/lang/String;)Ljava/lang/String;
    //   84: invokevirtual 65	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   87: aload_0
    //   88: invokevirtual 65	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   91: ldc 67
    //   93: bipush 42
    //   95: bipush -53
    //   97: isub
    //   98: invokestatic 32	com/wowza/util/JSON:copyValueOf	(Ljava/lang/String;I)Ljava/lang/String;
    //   101: invokevirtual 65	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   104: invokevirtual 71	java/lang/StringBuilder:toString	()Ljava/lang/String;
    //   107: invokevirtual 74	com/wowza/wms/logging/WMSLogger:error	(Ljava/lang/String;)V
    //   110: aconst_null
    //   111: astore_3
    //   112: goto -59 -> 53
    // Line number table:
    //   Java source line #24	-> byte code offset #0
    //   Java source line #43	-> byte code offset #5
    //   Java source line #38	-> byte code offset #7
    //   Java source line #40	-> byte code offset #8
    //   Java source line #41	-> byte code offset #30
    //   Java source line #29	-> byte code offset #33
    //   Java source line #30	-> byte code offset #38
    //   Java source line #31	-> byte code offset #43
    //   Java source line #35	-> byte code offset #53
    //   Java source line #32	-> byte code offset #61
    //   Java source line #33	-> byte code offset #110
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	115	0	paramString	String
    //   1	57	1	localDvrBaseEncryptionInfoDelegate	com.wowza.wms.dvr.DvrBaseEncryptionInfoDelegate
    //   7	17	2	localException	Exception
    //   37	2	2	localClass	Class
    //   42	70	3	localObject	Object
    // Exception table:
    //   from	to	target	type
    //   33	115	7	java/lang/Exception
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.dvr.impl.DvrEncryptionInfoDelegateFactory
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.dvr.impl;

import com.wowza.util.Base64;
import com.wowza.util.JSON;
import com.wowza.wms.application.IApplicationInstance;
import com.wowza.wms.dvr.DvrStreamManagerBase;
import com.wowza.wms.dvr.IDvrRecordingsLoader;
import com.wowza.wms.dvr.IDvrStreamManager;
import com.wowza.wms.dvr.IDvrStreamStore;
import com.wowza.wms.logging.WMSLogger;
import com.wowza.wms.logging.WMSLoggerFactory;
import com.wowza.wms.stream.livepacketizer.LiveStreamPacketizerBase;
import com.wowza.wms.stream.livepacketizer.LiveStreamPacketizerItem;

public class DvrLiveStreamManager
  extends DvrStreamManagerBase
  implements IDvrStreamManager
{
  private static final Class<DvrLiveStreamManager> a = DvrLiveStreamManager.class;
  
  public void init(String paramString1, String paramString2, IApplicationInstance paramIApplicationInstance, LiveStreamPacketizerItem paramLiveStreamPacketizerItem)
  {
    super.init(paramString1, paramString2, paramIApplicationInstance, paramLiveStreamPacketizerItem);
    if (!hasStorage) {}
    for 
1 2 3 4 5 6 7 8 9 10 11 12 13

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-2017. Infinite Loop Ltd