wms-pushpublish

16:54:13.270 INFO  jd.cli.Main - Decompiling wms-pushpublish.jar
package com.wowza.wms.pushpublish.model;

import com.wowza.wms.application.IApplicationInstance;
import com.wowza.wms.application.WMSProperties;
import com.wowza.wms.stream.IMediaStream;
import java.util.HashMap;

public abstract interface IPushPublish
{
  public static final int PUSHPUBLISH_TYPE_UNKNOWN = 0;
  public static final int PUSHPUBLISH_TYPE_RTMP = 1;
  public static final int PUSHPUBLISH_TYPE_RTP = 2;
  
  public abstract void connect();
  
  public abstract void disconnect();
  
  public abstract void resetConnection();
  
  public abstract WMSProperties getProperties();
  
  public abstract int getMapFileIndex();
  
  public abstract void setMapFileIndex(String paramString);
  
  public abstract String getSrcStreamName();
  
  public abstract void setSrcStreamName(String paramString);
  
  public abstract String getDstStreamName();
  
  public abstract void setDstStreamName(String paramString);
  
  public abstract void setStreamName(String paramString);
  
  public abstract String getHostname();
  
  public abstract void setHost(String paramString);
  
  public abstract void setHostname(String paramString);
  
  public abstract void setDebugLog(boolean paramBoolean);
  
  public abstract int getPort();
  
  public abstract void setPort(int paramInt);
  
  public abstract void setPort(String paramString);
  
  public abstract int getReconnectWaitTime();
  
  public abstract void setReconnectWaitTime(int paramInt);
  
  public abstract void init(IApplicationInstance paramIApplicationInstance, String paramString, IMediaStream paramIMediaStream, HashMap<String, String> paramHashMap1, HashMap<String, String> paramHashMap2, boolean paramBoolean);
  
  public abstract int getPushPublishType();
  
  public abstract IPushPublishSession createPushPublishSession();
  
  public abstract IMediaStream getSrcStream();
  
  public abstract void setSrcStream(IMediaStream paramIMediaStream);
  
  public abstract String getContextStr();
  
  public abstract boolean isConnected();
  
  public abstract long getMessagesAttemptedCount();
  
  public abstract long getMessagesRetriedCount();
  
  public abstract long getMessagesFailedCount();
}

/* Location:
 * Qualified Name:     com.wowza.wms.pushpublish.model.IPushPublish
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.pushpublish.model;

public abstract interface IPushPublishCrossSession
{
  public abstract boolean isSessionValid();
}

/* Location:
 * Qualified Name:     com.wowza.wms.pushpublish.model.IPushPublishCrossSession
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.pushpublish.model;

import java.util.List;

public abstract interface IPushPublishHTTPAdaptiveGroup
{
  public abstract Boolean groupPlaylistNeedsUpdating(long paramLong, List<List<IPushPublishHTTPAdaptiveGroup>> paramList1, List<List<IPushPublishHTTPAdaptiveGroup>> paramList2);
  
  public abstract String createGroupPlaylist(String paramString, List<List<IPushPublishHTTPAdaptiveGroup>> paramList1, List<List<IPushPublishHTTPAdaptiveGroup>> paramList2);
  
  public abstract String getPlaylistRenditionDescription();
  
  public abstract String sendAdaptiveGroupPlaylist(String paramString1, String paramString2);
  
  public abstract boolean isDebugLog();
  
  public abstract void addAdaptiveGroupItem(String paramString);
  
  public abstract List<String> getAdaptiveGroupItems();
  
  public abstract boolean isInAdaptiveGroup();
  
  public abstract boolean isInRedundancyPair();
  
  public abstract boolean isSendToBackupServer();
  
  public abstract String getGroupId();
  
  public abstract String getGroupMemberName();
  
  public abstract String getRedundancyPairId();
  
  public abstract String getSrcStreamName();
  
  public abstract String getDstStreamName();
}

/* Location:
 * Qualified Name:     com.wowza.wms.pushpublish.model.IPushPublishHTTPAdaptiveGroup
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.pushpublish.model;

import com.wowza.io.HTTPByteWriter;
import com.wowza.wms.application.IApplicationInstance;
import com.wowza.wms.stream.livepacketizer.ILiveStreamPacketizer;

public abstract interface IPushPublishHTTPOutputBuilder
{
  public abstract IApplicationInstance getAppInstance();
  
  public abstract boolean isDebugLog();
  
  public abstract boolean isHttpWriterDebug();
  
  public abstract String getSrcStreamName();
  
  public abstract String getDstStreamName();
  
  public abstract String getLiveStreamPacketizerName();
  
  public abstract Object getPacketizerLock(ILiveStreamPacketizer paramILiveStreamPacketizer);
  
  public abstract int getLastChunkId(ILiveStreamPacketizer paramILiveStreamPacketizer);
  
  public abstract int getChunkDurationTarget(ILiveStreamPacketizer paramILiveStreamPacketizer);
  
  public abstract String getIngressDomain();
  
  public abstract int getIngressPort();
  
  public abstract String getIngressPath();
  
  public abstract int getConnectionTimeout();
  
  public abstract int getReadWriteTimeout();
  
  public abstract int getMaxRetries();
  
  public abstract void resetNewPacketizer(ILiveStreamPacketizer paramILiveStreamPacketizer);
  
  public abstract PushPublishHTTPOutputItem createOutputItem(ILiveStreamPacketizer paramILiveStreamPacketizer, int paramInt);
  
  public abstract void sendOutput(PushPublishHTTPOutputItem paramPushPublishHTTPOutputItem, HTTPByteWriter paramHTTPByteWriter, int paramInt);
}

/* Location:
 * Qualified Name:     com.wowza.wms.pushpublish.model.IPushPublishHTTPOutputBuilder
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.pushpublish.model;

import com.wowza.wms.stream.IMediaStream;

public abstract interface IPushPublishSession
{
  public static final int PUSHPUBLISHSESSION_TYPE_UNKNOWN = 0;
  public static final int PUSHPUBLISHSESSION_TYPE_RTMP = 1;
  public static final int PUSHPUBLISHSESSION_TYPE_RTP = 2;
  
  public abstract int getType();
  
  public abstract IPushPublish getPushPublishImpl();
  
  public abstract void setPushPublishImpl(IPushPublish paramIPushPublish);
  
  public abstract IMediaStream getStream();
  
  public abstract void setStream(IMediaStream paramIMediaStream);
  
  public abstract String getProfile();
  
  public abstract void setProfile(String paramString);
  
  public abstract String getContextStr();
}

/* Location:
 * Qualified Name:     com.wowza.wms.pushpublish.model.IPushPublishSession
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.pushpublish.model;

import com.wowza.wms.stream.IMediaStream;

public abstract interface IPushPublishSessionNotify
{
  public abstract void onPushPublishSessionCreate(String paramString, IMediaStream paramIMediaStream, IPushPublishSession paramIPushPublishSession);
  
  public abstract void onPushPublishSessionDestroy(String paramString, IMediaStream paramIMediaStream, IPushPublishSession paramIPushPublishSession);
}

/* Location:
 * Qualified Name:     com.wowza.wms.pushpublish.model.IPushPublishSessionNotify
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.pushpublish.model;

import com.wowza.util.Base64;
import com.wowza.util.IOPerformanceCounter;
import com.wowza.util.JSON;
import com.wowza.util.XMLUtils;
import com.wowza.wms.application.IApplication;
import com.wowza.wms.application.IApplicationInstance;
import com.wowza.wms.application.WMSProperties;
import com.wowza.wms.logging.WMSLogger;
import com.wowza.wms.logging.WMSLoggerFactory;
import com.wowza.wms.server.ReleaseInfo;
import com.wowza.wms.stream.IMediaStream;
import com.wowza.wms.util.PushPublishUtils;
import java.net.InetAddress;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Locale;
import java.util.Set;
import org.apache.commons.modeler.Registry;
import org.w3c.dom.Element;

public abstract class PushPublishBase
  implements IPushPublish
{
  public static final Class<PushPublishBase> CLASS = PushPublishBase.class;
  public static final String CLASSNAME = "PushPublishBase";
  protected int pushPublishType = 0;
  protected boolean pushPublishStreamDebug = false;
  protected int reconnectWaitTime = 0;
  protected int mapFileIndex;
  private IOPerformanceCounter a = new IOPerformanceCounter();
  protected IOPerformanceCounter totalIOPerformanceLast;
  protected IOPerformanceCounter totalIOPerformance2Last;
  
  public PushPublishBase()
  {
    properties.put(Base64.endsWith(29 * 27, "l|<d{blv6nwh2mklhqwahluo&Yxd]{m|xa{Bpddqvt"), getPushPublishVersionStr());
  }
  
  protected WMSProperties properties = new WMSProperties();
  private boolean b = false;
  protected String userName = null;
  protected String password = null;
  protected IApplicationInstance appInstance = null;
  protected String srcStreamName = null;
  protected IMediaStream srcStream = null;
  protected String dstStreamName = null;
  protected String hostname = null;
  protected InetAddress inetAddr;
  protected int port = 1935;
  protected String mImplementation = null;
  protected String mType;
  protected boolean sendOriginalTimecodes = true;
  protected long originalTimecodeThreshold = 0L;
  
  public void init(IApplicationInstance paramIApplicationInstance, String paramString, IMediaStream paramIMediaStream, HashMap<String, String> paramHashMap1, HashMap<String, String> paramHashMap2, boolean paramBoolean)
  {
    setAppInstance(paramIApplicationInstance);
    
    HashMap localHashMap = new HashMap(paramHashMap1);
    setSendOriginalTimecodes(false);
    setOriginalTimecodeThreshold(0L);
    load(localHashMap);
    if (!paramBoolean)
    {
      PushPublishUtils.removeMapString(localHashMap, Base64.endsWith(51 + 85, "jhynOao|c"));
      PushPublishUtils.removeMapString(localHashMap, JSON.copyValueOf("wzflb`h", 43 * 21));
      if (!pushPublishStreamDebug) {
        break label429;
      }
      break label491;
    }
    label157:
    label166:
    label403:
    label416:
    label429:
    label491:
    label504:
    for (;;)
    {
      Object localObject;
      String str = (String)((Iterator)localObject).next();
      
      WMSLoggerFactory.getLogger(CLASS).info(JSON.copyValueOf("Ag`|Ecutpis^|mz#Hljp?Sicge|b-^}w{q5]ra#", 23 * 23) + str);
      break label416;
      for (;;)
      {
        if (!((Iterator)localObject).hasNext()) {
          break label403;
        }
        break label166;
        ((Exception)localObject).printStackTrace();
        
        return;pushPublishStreamDebug = true; break;str = (String)((Iterator)localObject).next();WMSLoggerFactory.getLogger(CLASS).info(Base64.endsWith(52 - 9, "[y~f_es~zg}Tvk|9Rrtj%\025/)-+2(g\005(:k\007(7u") + str); continue;localObject = localHashMap.keySet().iterator();
      }
      for (;;)
      {
        try
        {
          localObject = JSON.copyValueOf("H/68\"\02714\")$#%+\b (9?7i\"\005#$0\t/904-7%31~\02405/\030<('%>&cp'\023#$h", 23 * 25) + paramIApplicationInstance.getApplication().getName() + Base64.endsWith(9 - 4, ")&qIyzBb~zn~rw.") + paramIApplicationInstance.getName() + Base64.endsWith(44 - 15, "1hLtsgbi8") + paramString + Base64.endsWith('?' / '�', "*iido6EB^jbw}aytxt}");
          Registry.getRegistry(null, null).registerComponent(a, (String)localObject, a.getClass().getName());
        }
        catch (Exception localException)
        {
          WMSLoggerFactory.getLogger(CLASS).info(JSON.copyValueOf("\017urjSqgjn{aHjh-Jhrwc`|yy8PUKyoxprlcmg`&nf`~", 122 + 5) + localException.getMessage());
        }
        if (!pushPublishStreamDebug) {
          break label157;
        }
        break;setSrcStreamName(paramString);
        srcStream = paramIMediaStream;
      }
      Iterator localIterator;
      for (;; localIterator = localHashMap.keySet().iterator())
      {
        if (localException.hasNext()) {
          break label504;
        }
        localHashMap = new HashMap(paramHashMap2);
        load(localHashMap);
        PushPublishUtils.removeMapString(localHashMap, Base64.endsWith(47 * 33, "mqbwPxted"));
        PushPublishUtils.removeMapString(localHashMap, Base64.endsWith('?' / '?', "twiaaeo"));
        if (!pushPublishStreamDebug) {
          break label403;
        }
        break;
      }
    }
  }
  
  public String getImplementation()
  {
    return mImplementation;
  }
  
  public void setImplementation(String paramString)
  {
    if (paramString != null)
    {
      mImplementation = paramString; return;
    }
  }
  
  public WMSProperties getProperties()
  {
    return properties;
  }
  
  protected String getConfigDataOrDefault(Element paramElement, String paramString1, String paramString2)
  {
    String str = XMLUtils.getNodeValueByTagName(paramElement, paramString1);
    if (str != null) {
      return str;
    }
    return paramString2;
  }
  
  /* Error */
  protected int getConfigDataOrDefault(Element arg1, String arg2, int arg3)
  {
    // Byte code:
    //   0: aload_1
    //   1: aload_2
    //   2: invokestatic 261	com/wowza/util/XMLUtils:getNodeValueByTagName	(Lorg/w3c/dom/Element;Ljava/lang/String;)Ljava/lang/String;
    //   5: astore 4
    //   7: goto +26 -> 33
    //   10: iload_3
    //   11: ireturn
    //   12: aload 5
    //   14: invokevirtual 265	java/lang/NumberFormatException:printStackTrace	()V
    //   17: goto -7 -> 10
    //   20: astore 5
    //   22: aload_0
    //   23: getfield 52	com/wowza/wms/pushpublish/model/PushPublishBase:pushPublishStreamDebug	Z
    //   26: ifeq -16 -> 10
    //   29: goto -17 -> 12
    //   32: ireturn
    //   33: aload 4
    //   35: invokestatic 271	java/lang/Integer:parseInt	(Ljava/lang/String;)I
    //   38: istore 5
    //   40: iload 5
    //   42: goto -10 -> 32
    // Line number table:
    //   Java source line #229	-> byte code offset #0
    //   Java source line #242	-> byte code offset #10
    //   Java source line #239	-> byte code offset #12
    //   Java source line #235	-> byte code offset #20
    //   Java source line #237	-> byte code offset #22
    //   Java source line #233	-> byte code offset #32
    //   Java source line #232	-> byte code offset #33
    //   Java source line #233	-> byte code offset #40
    // Exception table:
    //   from	to	target	type
    //   33	45	20	java/lang/NumberFormatException
  }
  
  protected boolean getConfigDataOrDefault(Element paramElement, String paramString, boolean paramBoolean)
  {
    String str = XMLUtils.getNodeValueByTagName(paramElement, paramString);
    if (str == null) {
      return paramBoolean;
    }
    boolean bool = Boolean.parseBoolean(str);
    return bool;
  }
  
  public boolean isAdaptiveStreaming()
  {
    return b;
  }
  
  public void setAdaptiveStreaming(boolean paramBoolean)
  {
    b = paramBoolean;
  }
  
  private final void a(String paramString)
  {
    if (paramString == null) {}else {
      for (;;)
      {
        setSendOriginalTimecodes(true);
        setOriginalTimecodeThreshold(1048576L); break;b = Boolean.parseBoolean(paramString);
        if (!b) {
          break;
        }
      }
    }
  }
  
  public boolean isSendOriginalTimecodes()
  {
    return sendOriginalTimecodes;
  }
  
  public void setSendOriginalTimecodes(boolean paramBoolean)
  {
    sendOriginalTimecodes = paramBoolean;
  }
  
  private void b(String paramString)
  {
    if (paramString != null)
    {
      sendOriginalTimecodes = Boolean.parseBoolean(paramString); return;
    }
  }
  
  public long getOriginalTimecodeThreshold()
  {
    return originalTimecodeThreshold;
  }
  
  public void setOriginalTimecodeThreshold(long paramLong)
  {
    originalTimecodeThreshold = paramLong;
  }
  
  public void setOriginalTimecodeThreshold(String paramString)
  {
    if (paramString != null)
    {
      originalTimecodeThreshold = getNumberFromString(paramString); return;
    }
  }
  
  public String getUserName()
  {
    return userName;
  }
  
  public void setUserName(String paramString)
  {
    if (paramString != null)
    {
      userName = paramString; return;
    }
  }
  
  public String getPassword()
  {
    return password;
  }
  
  public void setPassword(String paramString)
  {
    if (paramString != null)
    {
      password = paramString; return;
    }
  }
  
  public IApplicationInstance getAppInstance()
  {
    return appInstance;
  }
  
  public void setAppInstance(IApplicationInstance paramIApplicationInstance)
  {
    appInstance = paramIApplicationInstance;
  }
  
  public String getSrcStreamName()
  {
    return srcStreamName;
  }
  
  public void setSrcStreamName(String paramString)
  {
    if (paramString != null)
    {
      srcStreamName = paramString; return;
    }
  }
  
  public String getDstStreamName()
  {
    return dstStreamName;
  }
  
  public void setDstStreamName(String paramString)
  {
    if (paramString != null)
    {
      dstStreamName = paramString; return;
    }
  }
  
  public void setStreamName(String paramString)
  {
    if (paramString != null)
    {
      srcStreamName = paramString; return;
    }
  }
  
  public String getHostname()
  {
    return hostname;
  }
  
  public void setHost(String paramString)
  {
    if (paramString != null)
    {
      hostname = paramString; return;
    }
  }
  
  public void setHostname(String paramString)
  {
    if (paramString != null)
    {
      hostname = paramString; return;
    }
  }
  
  public void setDebugLog(boolean paramBoolean)
  {
    pushPublishStreamDebug = paramBoolean;
  }
  
  private void c(String paramString)
  {
    if (paramString == null) {}
    for (;; pushPublishStreamDebug = Boolean.parseBoolean(paramString.toLowerCase(Locale.ENGLISH))) {
      return;
    }
  }
  
  public int getPort()
  {
    return port;
  }
  
  public void setPort(int paramInt)
  {
    port = paramInt;
  }
  
  public void setPort(String paramString)
  {
    if (paramString != null)
    {
      port = getNumberFromString(paramString); return;
    }
  }
  
  public static String getPushPublishVersionStr()
  {
    String str = "";
    if (str.length() > 0)
    {
      break label340;
      str = Base64.endsWith(-45 - 38, "-&") + str + ")";
      break label381;
      label52:
      str = str + System.getProperty(JSON.copyValueOf("yucw9nt4u}p{", 107 + 72)) + JSON.copyValueOf("%*", 43 * 27) + System.getProperty(JSON.copyValueOf("am{o!f|<eq{rxj", 63 * 53)) + JSON.copyValueOf("/$", '?' / 84) + System.getProperty(JSON.copyValueOf("kcue+pbzzcdb", 3 * 43)) + Base64.endsWith(21 * 15, "7<") + System.getProperty(JSON.copyValueOf("!-;/a&<|%1'%>77", 39 * 61)) + Base64.endsWith(63 + -56, "+(") + System.getProperty(Base64.endsWith('?' / '�', "pqk(fzjb%hlzn>|}wqy"));
      if (System.getProperty(Base64.endsWith(25 + 76, "05\":g&*\"*;.74")) != null) {
        break label543;
      }
    }
    for (;;)
    {
      str = str + System.getProperty(Base64.endsWith(51 * 11, "davf;zvv~oz{x")).toLowerCase() + "-" + System.getProperty(JSON.copyValueOf(" %2*w94)3*-9", -53 - -10)).toLowerCase();
      break label330;
      label298:
      str = str + JSON.copyValueOf("jr", 37 * 61);
      break label52;
      label330:
      if (str.length() > 0)
      {
        break;
        label340:
        str = str + JSON.copyValueOf("2*", 13 * 13);
        break label438;
      }
      for (;;)
      {
        if (str.length() <= 0) {
          break label563;
        }
        break label565;
        label381:
        return Base64.endsWith('?' / '�', "QhskXxkn}x|tQ{q~v|5") + ReleaseInfo.getVersion() + JSON.copyValueOf("8tbqu~", 9 - -12) + ReleaseInfo.getBuildNumber() + str;
        label438:
        str = str + System.getProperty(JSON.copyValueOf(";&x994?", 55 + 29)) + JSON.copyValueOf("nc", 63 - -35) + System.getProperty(Base64.endsWith(-16 - -49, "nq-r`ttafd")) + Base64.endsWith(63 + 119, ":7") + System.getProperty(Base64.endsWith(54 + 7, "rm1!3!+"));
        if (str.length() <= 0) {
          break;
        }
        break label298;
        label543:
        if (System.getProperty(JSON.copyValueOf("vw`t)kfexw", '?' / '�')) == null) {
          break label330;
        }
      }
      label563:
      continue;
      label565:
      str = str + JSON.copyValueOf("d`", 37 * 51);
    }
  }
  
  public void load(HashMap<String, String> paramHashMap)
  {
    c(PushPublishUtils.removeMapString(paramHashMap, JSON.copyValueOf("Gags`Dfm", '?' / '�')));
    setHost(PushPublishUtils.removeMapString(paramHashMap, JSON.copyValueOf("\031=  ", 15 * 31)));
    a(PushPublishUtils.removeMapString(paramHashMap, JSON.copyValueOf("Hnj|ygyuBfaqt{~v~", -55 - 32)));
    setImplementation(PushPublishUtils.removeMapString(paramHashMap, Base64.endsWith('?' / 76, "Ojxeoficzndx}}")));
    setOriginalTimecodeThreshold(PushPublishUtils.removeMapString(paramHashMap, Base64.endsWith(-46 - -2, "\033'?017;7\b43:#.&&\020-4\";!%'(")));
    setPassword(PushPublishUtils.removeMapString(paramHashMap, JSON.copyValueOf("\0371\"!$;'2", 49 * 31)));
    setPort(PushPublishUtils.removeMapString(paramHashMap, JSON.copyValueOf("Skwr", 37 * 39)));
    b(PushPublishUtils.removeMapString(paramHashMap, JSON.copyValueOf("\036+!4\036 :3<864\r369>1;%2", -42 - 9)));
    setDstStreamName(PushPublishUtils.removeMapString(paramHashMap, JSON.copyValueOf("\02007#&%\007+&)", 102 + 125)));
    d(PushPublishUtils.removeMapString(paramHashMap, JSON.copyValueOf("\n&pd", 23 - 25)));
    setUserName(PushPublishUtils.removeMapString(paramHashMap, Base64.endsWith('?' / '?', "PubzGkfi")));
    String str = PushPublishUtils.removeMapString(paramHashMap, JSON.copyValueOf("neu@ndlCehhv", '?' / '�'));
    setMapFileIndex(str);
  }
  
  private final void d(String paramString)
  {
    if (paramString != null)
    {
      mType = paramString; return;
    }
  }
  
  /* Error */
  protected static int getNumberFromString(String paramString)
  {
    // Byte code:
    //   0: aload_0
    //   1: ifnull +26 -> 27
    //   4: goto +25 -> 29
    //   7: astore_2
    //   8: iconst_0
    //   9: istore_1
    //   10: goto +4 -> 14
    //   13: nop
    //   14: iload_1
    //   15: ireturn
    //   16: aload_0
    //   17: invokestatic 451	java/lang/Integer:decode	(Ljava/lang/String;)Ljava/lang/Integer;
    //   20: invokevirtual 454	java/lang/Integer:intValue	()I
    //   23: istore_1
    //   24: goto -11 -> 13
    //   27: iconst_0
    //   28: ireturn
    //   29: aload_0
    //   30: invokevirtual 324	java/lang/String:length	()I
    //   33: iconst_1
    //   34: if_icmpge -18 -> 16
    //   37: goto -10 -> 27
    // Line number table:
    //   Java source line #630	-> byte code offset #0
    //   Java source line #638	-> byte code offset #7
    //   Java source line #640	-> byte code offset #8
    //   Java source line #641	-> byte code offset #13
    //   Java source line #642	-> byte code offset #14
    //   Java source line #636	-> byte code offset #16
    //   Java source line #631	-> byte code offset #27
    //   Java source line #630	-> byte code offset #29
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	40	0	paramString	String
    //   9	15	1	i	int
    //   7	1	2	localNumberFormatException	NumberFormatException
    // Exception table:
    //   from	to	target	type
    //   16	27	7	java/lang/NumberFormatException
  }
  
  public int getMapFileIndex()
  {
    return mapFileIndex;
  }
  
  public void setMapFileIndex(String paramString)
  {
    if (paramString != null)
    {
      mapFileIndex = Integer.parseInt(paramString); return;
    }
  }
  
  public int getReconnectWaitTime()
  {
    return reconnectWaitTime;
  }
  
  public void setReconnectWaitTime(int paramInt)
  {
    reconnectWaitTime = paramInt;
  }
  
  public double getBandwidth()
  {
    return a.getFileOutBytesRate();
  }
  
  public int getPushPublishType()
  {
    return pushPublishType;
  }
  
  public IPushPublishSession createPushPublishSession()
  {
    PushPublishSessionBase localPushPublishSessionBase = new PushPublishSessionBase();
    localPushPublishSessionBase.setPushPublishImpl(this);
    return localPushPublishSessionBase;
  }
  
  public IMediaStream getSrcStream()
  {
    return srcStream;
  }
  
  public void setSrcStream(IMediaStream paramIMediaStream)
  {
    srcStream = paramIMediaStream;
  }
  
  public String getContextStr()
  {
    return "";
  }
  
  public void incrementMessagesOut(long paramLong)
  {
    a.incrementMessagesOut(paramLong);
  }
  
  public long getMessagesOutCount()
  {
    return a.getMessagesOutCount();
  }
  
  public void add(IOPerformanceCounter paramIOPerformanceCounter)
  {
    IOPerformanceCounter localIOPerformanceCounter = a.clone();
    paramIOPerformanceCounter.addDifference(localIOPerformanceCounter, totalIOPerformanceLast);
    totalIOPerformanceLast = localIOPerformanceCounter;
  }
  
  public void addIOPerformance2(IOPerformanceCounter paramIOPerformanceCounter)
  {
    IOPerformanceCounter localIOPerformanceCounter = a.clone();
    paramIOPerformanceCounter.addDifference(localIOPerformanceCounter, totalIOPerformance2Last);
    totalIOPerformance2Last = localIOPerformanceCounter;
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.pushpublish.model.PushPublishBase
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.pushpublish.model;

import com.wowza.wms.vhost.IVHost;
import java.util.HashMap;
import java.util.Map;

public class PushPublishContext
{
  public static final Class<PushPublishContext> CLASS = PushPublishContext.class;
  public static final String CLASSNAME = "PushPublishContext";
  private IVHost a = null;
  private Map<String, HashMap<String, String>> b = new HashMap();
  private Object c = new Object();
  private int d = 0;
  private long e = -1L;
  private Map<String, IPushPublishCrossSession> f = new HashMap();
  private Object g = new Object();
  
  public PushPublishContext(IVHost paramIVHost)
  {
    a = paramIVHost;
  }
  
  public HashMap<String, String> getProfileData(String paramString)
  {
    HashMap localHashMap = null;
    Object localObject1;
    for (goto 42;; monitorenter)
    {
      try
      {
        localHashMap = (HashMap)b.get(paramString);
      }
      finally
      {
        break;
      }
      for (;;)
      {
        return localHashMap;
      }
    }
    throw ((Throwable)localObject2);
  }
  
  /* Error */
  public void putProfileData(String paramString, HashMap<String, String> paramHashMap)
  {
    // Byte code:
    //   0: aload_0
    //   1: getfield 45	com/wowza/wms/pushpublish/model/PushPublishContext:c	Ljava/lang/Object;
    //   4: dup
    //   5: astore_3
    //   6: goto +37 -> 43
    //   9: astore 4
    //   11: aload_3
    //   12: monitorexit
    //   13: goto +27 -> 40
    //   16: goto +23 -> 39
    //   19: aload_0
    //   20: getfield 43	com/wowza/wms/pushpublish/model/PushPublishContext:b	Ljava/util/Map;
    //   23: aload_1
    //   24: aload_2
    //   25: invokeinterface 71 3 0
    //   30: checkcast 40	java/util/HashMap
    //   33: astore_2
    //   34: aload_3
    //   35: monitorexit
    //   36: goto -20 -> 16
    //   39: return
    //   40: aload 4
    //   42: athrow
    //   43: monitorenter
    //   44: goto -25 -> 19
    // Line number table:
    //   Java source line #40	-> byte code offset #0
    //   Java source line #43	-> byte code offset #9
    //   Java source line #42	-> byte code offset #19
    //   Java source line #43	-> byte code offset #34
    //   Java source line #44	-> byte code offset #39
    //   Java source line #43	-> byte code offset #40
    //   Java source line #40	-> byte code offset #43
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	47	0	this	PushPublishContext
    //   0	47	1	paramString	String
    //   0	47	2	paramHashMap	HashMap<String, String>
    //   5	30	3	localObject1	Object
    //   9	32	4	localObject2	Object
    // Exception table:
    //   from	to	target	type
    //   9	16	9	finally
    //   19	39	9	finally
  }
  
  /* Error */
  public int getNextMapIndex()
  {
    // Byte code:
    //   0: aload_0
    //   1: getfield 45	com/wowza/wms/pushpublish/model/PushPublishContext:c	Ljava/lang/Object;
    //   4: dup
    //   5: astore_1
    //   6: goto +25 -> 31
    //   9: astore_2
    //   10: aload_1
    //   11: monitorexit
    //   12: goto +23 -> 35
    //   15: aload_0
    //   16: dup
    //   17: getfield 47	com/wowza/wms/pushpublish/model/PushPublishContext:d	I
    //   20: iconst_1
    //   21: iadd
    //   22: dup_x1
    //   23: putfield 47	com/wowza/wms/pushpublish/model/PushPublishContext:d	I
    //   26: aload_1
    //   27: monitorexit
    //   28: goto +9 -> 37
    //   31: monitorenter
    //   32: goto -17 -> 15
    //   35: aload_2
    //   36: athrow
    //   37: ireturn
    // Line number table:
    //   Java source line #48	-> byte code offset #0
    //   Java source line #51	-> byte code offset #9
    //   Java source line #50	-> byte code offset #15
    //   Java source line #48	-> byte code offset #31
    //   Java source line #51	-> byte code offset #35
    //   Java source line #50	-> byte code offset #37
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	38	0	this	PushPublishContext
    //   5	22	1	localObject1	Object
    //   9	27	2	localObject2	Object
    // Exception table:
    //   from	to	target	type
    //   9	15	9	finally
    //   15	31	9	finally
  }
  
  public void putCrossSession(String paramString, IPushPublishCrossSession paramIPushPublishCrossSession)
  {
    Object localObject1;
    try
    {
      for (;; monitorenter)
      {
        f.put(paramString, paramIPushPublishCrossSession);
        break;
        Object localObject2;
        throw ((Throwable)localObject2);
      }
      return;
    }
    finally {}
  }
  
  /* Error */
  public IPushPublishCrossSession getCrossSession(String arg1)
  {
    // Byte code:
    //   0: aload_0
    //   1: getfield 55	com/wowza/wms/pushpublish/model/PushPublishContext:g	Ljava/lang/Object;
    //   4: dup
    //   5: astore_2
    //   6: goto +9 -> 15
    //   9: astore_3
    //   10: aload_2
    //   11: monitorexit
    //   12: goto +7 -> 19
    //   15: monitorenter
    //   16: goto +6 -> 22
    //   19: aload_3
    //   20: athrow
    //   21: areturn
    //   22: aload_0
    //   23: getfield 53	com/wowza/wms/pushpublish/model/PushPublishContext:f	Ljava/util/Map;
    //   26: aload_1
    //   27: invokeinterface 61 2 0
    //   32: checkcast 77	com/wowza/wms/pushpublish/model/IPushPublishCrossSession
    //   35: aload_2
    //   36: monitorexit
    //   37: goto -16 -> 21
    // Line number table:
    //   Java source line #64	-> byte code offset #0
    //   Java source line #67	-> byte code offset #9
    //   Java source line #64	-> byte code offset #15
    //   Java source line #67	-> byte code offset #19
    //   Java source line #66	-> byte code offset #21
    // Exception table:
    //   from	to	target	type
    //   9	15	9	finally
    //   22	40	9	finally
  }
  
  /* Error */
  public IPushPublishCrossSession removeCrossSession(String paramString)
  {
    // Byte code:
    //   0: aload_0
    //   1: getfield 55	com/wowza/wms/pushpublish/model/PushPublishContext:g	Ljava/lang/Object;
    //   4: dup
    //   5: astore_2
    //   6: goto +30 -> 36
    //   9: aload_0
    //   10: getfield 53	com/wowza/wms/pushpublish/model/PushPublishContext:f	Ljava/util/Map;
    //   13: aload_1
    //   14: invokeinterface 83 2 0
    //   19: checkcast 77	com/wowza/wms/pushpublish/model/IPushPublishCrossSession
    //   22: aload_2
    //   23: monitorexit
    //   24: goto +11 -> 35
    //   27: aload_3
    //   28: athrow
    //   29: astore_3
    //   30: aload_2
    //   31: monitorexit
    //   32: goto -5 -> 27
    //   35: areturn
    //   36: monitorenter
    //   37: goto -28 -> 9
    // Line number table:
    //   Java source line #72	-> byte code offset #0
    //   Java source line #74	-> byte code offset #9
    //   Java source line #75	-> byte code offset #27
    //   Java source line #74	-> byte code offset #35
    //   Java source line #72	-> byte code offset #36
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	40	0	this	PushPublishContext
    //   0	40	1	paramString	String
    //   5	26	2	localObject1	Object
    //   27	1	3	localObject2	Object
    //   29	1	3	localObject3	Object
    // Exception table:
    //   from	to	target	type
    //   9	27	29	finally
    //   29	35	29	finally
  }
  
  /* Error */
  public void doWatchdog()
  {
    // Byte code:
    //   0: invokestatic 92	java/lang/System:currentTimeMillis	()J
    //   3: lstore_1
    //   4: aload_0
    //   5: getfield 51	com/wowza/wms/pushpublish/model/PushPublishContext:e	J
    //   8: lconst_0
    //   9: lcmp
    //   10: iflt +6 -> 16
    //   13: goto +113 -> 126
    //   16: aload_0
    //   17: lload_1
    //   18: putfield 51	com/wowza/wms/pushpublish/model/PushPublishContext:e	J
    //   21: aload_0
    //   22: getfield 55	com/wowza/wms/pushpublish/model/PushPublishContext:g	Ljava/lang/Object;
    //   25: dup
    //   26: astore_3
    //   27: goto +115 -> 142
    //   30: aload_0
    //   31: getfield 53	com/wowza/wms/pushpublish/model/PushPublishContext:f	Ljava/util/Map;
    //   34: invokeinterface 96 1 0
    //   39: invokeinterface 102 1 0
    //   44: astore 4
    //   46: goto +54 -> 100
    //   49: goto +51 -> 100
    //   52: aload 4
    //   54: invokeinterface 106 1 0
    //   59: goto -10 -> 49
    //   62: aload_3
    //   63: monitorexit
    //   64: goto +56 -> 120
    //   67: aload 4
    //   69: invokeinterface 110 1 0
    //   74: checkcast 7	java/util/Map$Entry
    //   77: astore 5
    //   79: aload 5
    //   81: invokeinterface 113 1 0
    //   86: checkcast 77	com/wowza/wms/pushpublish/model/IPushPublishCrossSession
    //   89: invokeinterface 117 1 0
    //   94: ifne -45 -> 49
    //   97: goto -45 -> 52
    //   100: aload 4
    //   102: invokeinterface 120 1 0
    //   107: ifeq -45 -> 62
    //   110: goto -43 -> 67
    //   113: astore 6
    //   115: aload_3
    //   116: monitorexit
    //   117: goto +6 -> 123
    //   120: goto +51 -> 171
    //   123: aload 6
    //   125: athrow
    //   126: lload_1
    //   127: aload_0
    //   128: getfield 51	com/wowza/wms/pushpublish/model/PushPublishContext:e	J
    //   131: lsub
    //   132: ldc2_w 121
    //   135: lcmp
    //   136: ifle +35 -> 171
    //   139: goto -123 -> 16
    //   142: monitorenter
    //   143: goto -113 -> 30
    //   146: return
    //   147: astore_1
    //   148: getstatic 124	com/wowza/wms/pushpublish/model/PushPublishContext:CLASS	Ljava/lang/Class;
    //   151: invokestatic 130	com/wowza/wms/logging/WMSLoggerFactory:getLogger	(Ljava/lang/Class;)Lcom/wowza/wms/logging/WMSLogger;
    //   154: bipush -41
    //   156: bipush 22
    //   158: isub
    //   159: ldc -124
    //   161: invokestatic 138	com/wowza/util/Base64:endsWith	(ILjava/lang/String;)Ljava/lang/String;
    //   164: aload_1
    //   165: invokevirtual 144	com/wowza/wms/logging/WMSLogger:info	(Ljava/lang/String;Ljava/lang/Throwable;)V
    //   168: goto -22 -> 146
    //   171: goto -25 -> 146
    // Line number table:
    //   Java source line #82	-> byte code offset #0
    //   Java source line #83	-> byte code offset #4
    //   Java source line #85	-> byte code offset #16
    //   Java source line #87	-> byte code offset #21
    //   Java source line #89	-> byte code offset #30
    //   Java source line #96	-> byte code offset #49
    //   Java source line #95	-> byte code offset #52
    //   Java source line #97	-> byte code offset #62
    //   Java source line #92	-> byte code offset #67
    //   Java source line #94	-> byte code offset #79
    //   Java source line #90	-> byte code offset #100
    //   Java source line #97	-> byte code offset #113
    //   Java source line #83	-> byte code offset #126
    //   Java source line #87	-> byte code offset #142
    //   Java source line #104	-> byte code offset #146
    //   Java source line #100	-> byte code offset #147
    //   Java source line #102	-> byte code offset #148
    //   Java source line #103	-> byte code offset #171
    // Exception table:
    //   from	to	target	type
    //   30	113	113	finally
    //   113	120	113	finally
    //   0	146	147	java/lang/Exception
  }
  
  public Object getCrossSessionLock()
  {
    return g;
  }
}

/* Location:
 * Qualified Name:     com.wowza.wms.pushpublish.model.PushPublishContext
 * Java Class Version: 6 (50.0)
 * JD-Core Version:    0.7.1
 */
package com.wowza.wms.pushpublish.model;

import com.wowza.util.Base64;
import com.wowza.util.JSON;
import com.wowza.util.StringUtils;
import com.wowza.wms.application.IApplicationInstance;
import com.wowza.wms.application.WMSProperties;
import com.wowza.wms.logging.WMSLogger;
import com.wowza.wms.logging.WMSLoggerFactory;
import com.wowza.wms.stream.IMediaStream;
import java.util.HashMap;

public abstract class PushPublishHTTPAkamaiBase
  extends PushPublishHTTPBase
{
  public static final Class<PushPublishHTTPAkamaiBase> CLASS = PushPublishHTTPAkamaiBase.class;
  public static final String CLASSNAME = "PushPublishHTTPAkamaiBase";
  public static final String AKAMAI_DEFAULT_HOSTID = "example-i";
  protected boolean sendToBackupServer = false;
  protected boolean redundant = false;
  protected String httpIngressDomainSuffix = Base64.endsWith('?' / 75, "bodkfald~t~`yf=zpb");
  protected String httpIngressDomainOverride = null;
  protected String httpPlaybackDomainSuffix = Base64.endsWith('?' / '?', "glidkbdi aue");
  protected String httpPlaybackDomainOverride = null;
  protected String akamaiStreamId = null;
  protected String akamaiHostId = JSON.copyValueOf("hvn}a~v9|", 59 + 114);
  protected String akamaiIngressURLPrefix = Base64.endsWith(-31 - 19, "&;$!h|{");
  protected String akamaiPlaybackURLPrefix = JSON.copyValueOf("(563~ji", 30 + 66);
  protected String akamaiEventName = null;
  protected String akamaiConfigName = null;
  protected String akamaiProtocolName = null;
  
  public void init(IApplicationInstance paramIApplicationInstance, String paramString, IMediaStream paramIMediaStream, HashMap<String, String> paramHashMap1, HashMap<String, String> paramHashMap2, boolean paramBoolean)
  {
    super.init(paramIApplicationInstance, paramString, paramIMediaStream, paramHashMap1, paramHashMap2, paramBoolean);
    
    WMSProperties localWMSProperties = paramIApplicationInstance.getProperties();
    
    String str = getAkamaiStreamId();
    if (!StringUtils.isEmpty(str))
    {
      break label167;
      label38:
      return;
      for (;;)
      {
        WMSLoggerFactory.getLogger(CLASS).warn(JSON.copyValueOf("Vr{aZ~nag|xYFGDT}vuxsY}n{1iokw_", '?' / 75) + getContextStr() + JSON.copyValueOf("\013mx\013?*)4,:$a/\"4e#)<;3kn>:=50?\035583ux0){14-,ioe#kw&nfkgei ", -30 - 12)); continue;
        label95:
        if (!StringUtils.isEmpty(getDstStreamName())) {
          break;
        }
      }
    }
    for (;;)
    {
      WMSLoggerFactory.getLogger(CLASS).warn(JSON.copyValueOf("TpuoX|hge~fGDEBRt{vq[{hy3wqiuY", '?' / '�') + getContextStr() + Base64.endsWith('?' / '�', "[=([ozyd|jt1rd5sylkc;>|u~m`k-wqtbidCo.-g|0|{`g|xp8vh;ush~,(&m"));
      break label95;
      break label38;
      label167:
      if (!StringUtils.equals(str, Base64.endsWith(53 * 45, "$<8::!9"))) {
        break;
      }
    }
  }
  
  /* Error */
  protected String getResolvedAkamaiStreamId()
  {
    // Byte code:
    //   0: new 111	java/lang/StringBuilder
    //   3: dup
    //   4: invokespecial 112	java/lang/StringBuilder:<init>	()V
    //   7: aload_0
    //   8: getfield 57	com/wowza/wms/pushpublish/model/PushPublishHTTPAkamaiBase:akamaiStreamId	Ljava/lang/String;
    //   11: invokevirtual 118	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   14: aload_0
    //   15: getfield 35	com/wowza/wms/pushpublish/model/PushPublishHTTPAkamaiBase:sendTo
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57

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