+++ /dev/null
-// Decompiled by Jad v1.5.8g. Copyright 2001 Pavel Kouznetsov.
-// Jad home page: http://www.kpdus.com/jad.html
-// Decompiler options: packimports(3) fieldsfirst nonlb space
-
-package mcsClient;
-
-import java.io.IOException;
-import java.net.*;
-import java.util.LinkedList;
-import java.util.logging.Level;
-import java.util.logging.Logger;
-import javax.swing.JFrame;
-import javax.swing.JOptionPane;
-
-// Referenced classes of package mcsClient:
-// BitMap, SecureDatagramSocket, McsTcpConnection, LiveVideoPanel,
-// McsToolBar
-
-public final class DatagramReader
- implements Runnable {
-
- public boolean videoLostSync;
- private DatagramSocket dgSocket;
- private McsTcpConnection mcsTcpConnection;
- private LiveVideoPanel liveVideoPanel;
- private LinkedList datagramList;
- private static final boolean USE_MULTICAST = false;
- public static final int DEFAULT_DIALIN_BITRATE;
- public static final int DEFAULT_NET_BITRATE;
- private long serverTime;
- private long serverBaseTime;
- private long clientTime;
- private long clientBaseTime;
- private boolean gotBaseTime;
- private long skew;
- private long upperSkew;
- private long lowerSkew;
- private long initialBitRate;
- private long skewTime;
- private boolean gotBeginningOfFrame;
- private boolean gotInitialBitRate;
- private boolean detectedPPP;
- private int frameNumber;
- private int maxSequenceNumber;
- private int lastFrameNumber;
- private long totalFrameSize;
- private BitMap bitmap;
- private boolean initialized;
- private static int nakMessage[] = new int[4];
- private McsToolBar sliderListener;
- private int nakCount;
- private static Logger logger = Logger.getAnonymousLogger();
-
- public DatagramReader(McsTcpConnection mcstcpconnection, LiveVideoPanel livevideopanel, LinkedList linkedlist, String s, int i, boolean flag) {
- videoLostSync = false;
- serverBaseTime = 0L;
- clientTime = 0L;
- clientBaseTime = 0L;
- gotBaseTime = false;
- skew = 0L;
- upperSkew = 150L;
- lowerSkew = -10L;
- initialBitRate = 0L;
- skewTime = 225L;
- gotBeginningOfFrame = false;
- gotInitialBitRate = false;
- detectedPPP = false;
- maxSequenceNumber = 0;
- lastFrameNumber = 0;
- totalFrameSize = 0L;
- bitmap = new BitMap();
- initialized = true;
- sliderListener = null;
- nakCount = 0;
- mcsTcpConnection = mcstcpconnection;
- liveVideoPanel = livevideopanel;
- datagramList = linkedlist;
- logger.setLevel(Level.WARNING);
- String s1 = System.getProperty("mcs.debug");
- if (s1 != null && s1.equalsIgnoreCase("true"))
- logger.setLevel(Level.ALL);
- nakMessage[0] = nakMessage.length * 4;
- nakMessage[1] = 5;
- if (mcstcpconnection.getDetectedPPP() || flag) {
- detectedPPP = true;
- upperSkew = 150L;
- lowerSkew = -30L;
- skewTime = 2000L;
- }
- if (mcstcpconnection.videoEncrypted())
- dgSocket = new SecureDatagramSocket(mcstcpconnection.cipher1, mcstcpconnection.cipher2, mcstcpconnection.getLocalPort());
- else
- dgSocket = new DatagramSocket(mcstcpconnection.getLocalPort());
- dgSocket.setReceiveBufferSize(0x1f400);
- dgSocket.setSoTimeout(500);
- if (flag)
- return;
- try {
- byte abyte0[] = new byte[10];
- DatagramPacket datagrampacket = new DatagramPacket(abyte0, abyte0.length, InetAddress.getByName(s), i);
- for (int j = 0; j < 6; j++) {
- dgSocket.send(datagrampacket);
- try {
- Thread.currentThread();
- Thread.sleep(60L);
- }
- catch (InterruptedException interruptedexception) { }
- }
-
- try {
- Thread.currentThread();
- Thread.sleep(200L);
- }
- catch (InterruptedException interruptedexception1) { }
- }
- catch (Exception exception) {
- logger.severe(exception.toString());
- initialized = false;
- JOptionPane.showMessageDialog(new JFrame(), "Failed to connect. Try again.", "Remote Console Datagram Reader Initialization Error", 0);
- }
- return;
- }
-
- private void cleanupThread() {
- if (dgSocket != null) {
- dgSocket.disconnect();
- dgSocket.close();
- }
- dgSocket = null;
- mcsTcpConnection = null;
- liveVideoPanel = null;
- datagramList = null;
- initialized = false;
- }
-
- private void process() {
- int l;
- Thread thread;
- l = 0;
- boolean flag = false;
- boolean flag1 = false;
- boolean flag2 = false;
- if (!initialized)
- return;
- thread = Thread.currentThread();
- goto _L1
-_L22:
- if (nakCount >= 25) {
- logger.info("25 NAK messages sent");
- nakCount = 0;
- }
- DatagramPacket datagrampacket;
- byte abyte1[] = new byte[1500];
- datagrampacket = new DatagramPacket(abyte1, abyte1.length);
- dgSocket.receive(datagrampacket);
- goto _L2
- SocketTimeoutException sockettimeoutexception;
- sockettimeoutexception;
- goto _L1
- IOException ioexception3;
- ioexception3;
- logger.warning("Datagram Reader - error reading datagram " + ioexception3);
- return;
-_L2:
- byte abyte0[];
- int j;
- abyte0 = datagrampacket.getData();
- j = datagrampacket.getOffset();
- if (datagrampacket.getLength() >= 24) goto _L3; else goto _L1
-_L3:
- if (abyte0[j + 7] != 6) goto _L5; else goto _L4
-_L4:
- videoLostSync = true;
- gotBaseTime = false;
- logger.info("DatagramReader: video lost sync");
- goto _L1
-_L5:
- videoLostSync = false;
- frameNumber = (abyte0[j + 8] & 0xff) << 8 | abyte0[j + 9] & 0xff;
- if (gotBeginningOfFrame) goto _L7; else goto _L6
-_L6:
- if ((abyte0[j + 7] & 0xbf) != 0) goto _L8; else goto _L1
-_L8:
- gotBeginningOfFrame = true;
- lastFrameNumber = frameNumber - 1;
- l = 128;
- bitmap.clear();
- bitmap.setBit(0);
-_L7:
- int i;
- i = (abyte0[j + 10] & 0xff) << 8 | abyte0[j + 11] & 0xff;
- int i1 = (abyte0[j + 2] & 0xff) << 8 | abyte0[j + 3] & 0xff;
- totalFrameSize += i1;
- serverTime = ((long)abyte0[j + 20] & 255L) << 24 | ((long)abyte0[j + 21] & 255L) << 16 | ((long)abyte0[j + 22] & 255L) << 8 | (long)abyte0[j + 23] & 255L;
- clientTime = System.currentTimeMillis();
- if (gotBaseTime) goto _L10; else goto _L9
-_L9:
- gotBaseTime = true;
- serverBaseTime = serverTime;
- clientBaseTime = clientTime;
- totalFrameSize = 0L;
- goto _L11
-_L10:
- long l1;
- skew = clientTime - clientBaseTime - (serverTime - serverBaseTime);
- l1 = (totalFrameSize * 8L * 1000L) / ((clientTime - clientBaseTime) + 50L);
- if (l1 > 0x13880L)
- liveVideoPanel.doPartialScreenUpdates = false;
- else
- liveVideoPanel.doPartialScreenUpdates = true;
- if (skew >= lowerSkew) goto _L13; else goto _L12
-_L12:
- gotBaseTime = false;
- goto _L11
-_L13:
- if (skew <= upperSkew || clientTime - clientBaseTime <= skewTime) goto _L11; else goto _L14
-_L14:
- int ai[];
- if (!gotInitialBitRate) {
- initialBitRate = l1;
- gotInitialBitRate = true;
- if (detectedPPP) {
- if (initialBitRate < (long)DEFAULT_DIALIN_BITRATE)
- initialBitRate = DEFAULT_DIALIN_BITRATE;
- } else
- if (initialBitRate < (long)DEFAULT_NET_BITRATE)
- initialBitRate = DEFAULT_NET_BITRATE;
- if (sliderListener != null)
- sliderListener.setSliderInitialBitRate(initialBitRate);
- } else {
- if (l1 < (initialBitRate * 60L) / 100L)
- l1 = (initialBitRate * 60L) / 100L;
- if (detectedPPP && l1 > initialBitRate)
- l1 = initialBitRate;
- }
- gotBaseTime = false;
- l1 *= 75L;
- l1 /= 100L;
- ai = new int[3];
- ai[0] = ai.length * 4;
- ai[1] = 10;
- ai[2] = (int)l1;
- thread;
- if (Thread.interrupted())
- return;
- try {
- mcsTcpConnection.sendMessage(ai, false);
- }
- catch (IOException ioexception4) {
- logger.severe("Socket exception - DatagramReader exiting");
- return;
- }
-_L11:
- if (frameNumber == lastFrameNumber)
- break MISSING_BLOCK_LABEL_1033;
- if (frameNumber == lastFrameNumber + 1) goto _L16; else goto _L15
-_L15:
- nakMessage[2] = 0;
- nakMessage[3] = frameNumber;
- try {
- mcsTcpConnection.sendMessage(nakMessage, false);
- }
- catch (IOException ioexception) {
- logger.severe("Socket exception - DatagramReader exiting");
- return;
- }
- nakCount++;
- goto _L17
-_L16:
- if ((l & 0x80) != 0) goto _L19; else goto _L18
-_L18:
- nakMessage[2] = 0;
- nakMessage[3] = 0;
- thread;
- if (Thread.interrupted())
- return;
- try {
- mcsTcpConnection.sendMessage(nakMessage, false);
- }
- catch (IOException ioexception1) {
- logger.severe("Socket exception - DatagramReader exiting");
- return;
- }
- nakCount++;
- goto _L17
-_L20:
- int k;
- nakMessage[2] = k;
- nakMessage[3] = frameNumber;
- thread;
- if (Thread.interrupted())
- return;
- try {
- mcsTcpConnection.sendMessage(nakMessage, false);
- }
- catch (IOException ioexception2) {
- logger.severe("Socket exception - DatagramReader exiting");
- return;
- }
- nakCount++;
- break; /* Loop/switch isn't completed */
-_L19:
- if ((k = bitmap.findZeroBit()) <= maxSequenceNumber) goto _L20; else goto _L17
-_L17:
- lastFrameNumber = frameNumber;
- bitmap.clear();
- l = 0;
- maxSequenceNumber = 0;
- bitmap.setBit(i);
- maxSequenceNumber = i <= maxSequenceNumber ? maxSequenceNumber : i;
- l |= abyte0[j + 7];
- abyte0[j + 7] &= 0x3f;
- int j1;
- if ((j1 = datagramList.size()) < 10 || liveVideoPanel.imagesAutomaticallyPaused)
- break MISSING_BLOCK_LABEL_1147;
- thread;
- if (Thread.interrupted())
- return;
- if (liveVideoPanel.pauseVideo() != 1) {
- logger.severe("Socket exception - DatagramReader exiting");
- return;
- }
- liveVideoPanel.imagesAutomaticallyPaused = true;
- long l2 = ((long)abyte0[j] & 255L) << 24 | ((long)abyte0[j + 1] & 255L) << 16 | ((long)abyte0[j + 2] & 255L) << 8 | (long)abyte0[j + 3] & 255L;
- long l3 = ((long)abyte0[j + 12] & 255L) << 24 | ((long)abyte0[j + 13] & 255L) << 16 | ((long)abyte0[j + 14] & 255L) << 8 | (long)abyte0[j + 15] & 255L;
- long l4 = ((long)abyte0[j + 16] & 255L) << 24 | ((long)abyte0[j + 17] & 255L) << 16 | ((long)abyte0[j + 18] & 255L) << 8 | (long)abyte0[j + 19] & 255L;
- if (i >= 0 && i <= 896 && l3 >= 0L && l3 <= 0xc0000L && l4 >= 0L && l3 <= 0xc0000L) {
- if (l2 != 31L)
- synchronized (datagramList) {
- datagramList.addFirst(datagrampacket);
- datagramList.notify();
- }
- } else {
- logger.warning("Bad packet discarded. seq num: " + i + " vid ram offset: " + l3 + " vid ram count: " + l4);
- }
- goto _L1
- ArrayIndexOutOfBoundsException arrayindexoutofboundsexception;
- arrayindexoutofboundsexception;
- logger.warning(arrayindexoutofboundsexception.toString());
-_L1:
- thread;
- if (Thread.interrupted())
- return;
- if (true) goto _L22; else goto _L21
-_L21:
- }
-
- public void run() {
- process();
- cleanupThread();
- }
-
- protected void finalize() throws Throwable {
- cleanupThread();
- }
-
- public boolean initialized() {
- return initialized;
- }
-
- public void addSliderListener(McsToolBar mcstoolbar) {
- sliderListener = mcstoolbar;
- }
-
- public void setInitialBitRate(long l) {
- initialBitRate = l;
- gotInitialBitRate = true;
- int ai[] = new int[3];
- ai[0] = ai.length * 4;
- ai[1] = 10;
- ai[2] = (int)l;
- try {
- mcsTcpConnection.sendMessage(ai, true);
- }
- catch (IOException ioexception) {
- logger.severe("Socket exception - setInitialBitRate");
- return;
- }
- }
-
- static {
- DEFAULT_DIALIN_BITRATE = McsToolBar.BITRATES[2];
- DEFAULT_NET_BITRATE = McsToolBar.BITRATES[7];
- }
-}
projects / rsa2client.git / blobdiff