l.txt

手机QQ原代码,有喜欢的朋友可以大量的下载,我不要钱的哦

import java.io.IOException;
import java.io.OutputStream;
import java.util.Enumeration;
import java.util.Vector;
import javax.microedition.io.Connector;
import javax.microedition.io.SocketConnection;

public class l extends Thread
{

    public int e;
    public static int a_int_static_fld = 0;
    public static int d = 1;
    public static int c = 2;
    public static int b = 3;
    public SocketConnection a_javax_microedition_io_SocketConnection_fld;
    public Vector a_java_util_Vector_fld;
    public String a_java_lang_String_fld;
    public ad a_ad_fld;
    public z a_z_fld;
    public OutputStream a_java_io_OutputStream_fld;
    private volatile boolean a_boolean_fld;

    public l()
    {
        e = 0;
        a_javax_microedition_io_SocketConnection_fld = null;
        a_java_lang_String_fld = null;
        a_ad_fld = null;
        a_z_fld = null;
        a_java_io_OutputStream_fld = null;
        a_boolean_fld = false;
        a_java_util_Vector_fld = new Vector();
        e = a_int_static_fld;
    }

    public void a(ad ad1)
    {
        synchronized(KQQMIDlet.a)
        {
            a_ad_fld = ad1;
        }
    }

    public boolean a(String s)
    {
        synchronized(this)
        {
            a_java_util_Vector_fld.addElement(s);
        }
        b();
        return true;
    }

    public boolean b(String s)
    {
        a_java_lang_String_fld = s;
        e = d;
        b();
        return true;
    }

    public void c()
    {
        e = b;
        a_ad_fld.b(this);
        b();
    }

    public void run()
    {
_L3:
        while(e == b) 
        {
            i.a("COMM_STATE_SHUTDOWNING");
            try
            {
                i.a("Socket closed");
                if(a_javax_microedition_io_SocketConnection_fld != null)
                {
                    if(a_java_io_OutputStream_fld != null)
                    {
                        a_java_io_OutputStream_fld.close();
                    }
                    a_java_io_OutputStream_fld = null;
                    if(a_z_fld != null)
                    {
                        a_z_fld.a();
                        a_z_fld = null;
                    }
                    a_javax_microedition_io_SocketConnection_fld.close();
                    a_javax_microedition_io_SocketConnection_fld = null;
                }
            }
            catch(IOException ioexception) { }
            e = a_int_static_fld;
            if(a_boolean_fld)
            {
                break MISSING_BLOCK_LABEL_631;
            }
        }
        if(e != d) goto _L2; else goto _L1
_L1:
        try
        {
            i.a("COMM_STATE_CONNECTING");
            i.a(a_java_lang_String_fld);
            a_javax_microedition_io_SocketConnection_fld = (SocketConnection)Connector.open(a_java_lang_String_fld);
            a_javax_microedition_io_SocketConnection_fld.setSocketOption((byte)0, 0);
            break MISSING_BLOCK_LABEL_232;
        }
        catch(SecurityException securityexception)
        {
            e = a_int_static_fld;
            i.a("SecurityException:");
            a_ad_fld.a(this);
        }
        catch(IllegalArgumentException illegalargumentexception)
        {
            i.a("IllegalArgumentException");
            e = a_int_static_fld;
            a_ad_fld.a(this);
        }
        catch(IOException ioexception1)
        {
            i.a("CONNECTING_IOException");
            e = a_int_static_fld;
            a_ad_fld.a(this, false);
        }
          goto _L3
label0:
        {
            i.a("CONNECTING:star read thread");
            a_z_fld = new z(this);
            if(!a_z_fld.a())
            {
                e = a_int_static_fld;
                a_ad_fld.a(this, false);
            } else
            {
                try
                {
                    i.a("CONNECTING:open output Stream");
                    a_java_io_OutputStream_fld = a_javax_microedition_io_SocketConnection_fld.openOutputStream();
                    break label0;
                }
                catch(Exception exception)
                {
                    try
                    {
                        a_javax_microedition_io_SocketConnection_fld.close();
                        if(a_z_fld != null)
                        {
                            a_z_fld.a = true;
                            a_z_fld = null;
                        }
                        if(a_java_io_OutputStream_fld != null)
                        {
                            a_java_io_OutputStream_fld.close();
                            a_java_io_OutputStream_fld = null;
                        }
                    }
                    catch(Exception exception1) { }
                    e = a_int_static_fld;
                    a_ad_fld.a(this, false);
                }
            }
        }
        if(false)
        {
            e = c;
            a_ad_fld.a(this, true);
            synchronized(a_z_fld)
            {
                a_z_fld.notify();
            }
            i.a("CONNECTING_mmmmmmmmmm");
        }
          goto _L3
_L2:
        if(e != c) goto _L3; else goto _L4
_L4:
        l l1 = this;
        JVM INSTR monitorenter ;
_L6:
        if(a_java_util_Vector_fld.size() != 0)
        {
            break; /* Loop/switch isn't completed */
        }
        i.a("wait");
        wait();
        i.a("after wait");
        if(e != c)
        {
            break; /* Loop/switch isn't completed */
        }
        continue; /* Loop/switch isn't completed */
        InterruptedException interruptedexception;
        interruptedexception;
        if(true) goto _L6; else goto _L5
_L5:
        try
        {
            String s;
            for(Enumeration enumeration = a_java_util_Vector_fld.elements(); enumeration.hasMoreElements(); a_java_util_Vector_fld.removeElement(s))
            {
                s = (String)enumeration.nextElement();
                byte abyte0[] = i.a(s);
                i.a("send:" + s);
                a_java_io_OutputStream_fld.write(abyte0);
                a_java_io_OutputStream_fld.write("\r\n".getBytes());
                a_java_io_OutputStream_fld.flush();
                i.a("after send");
            }

        }
        catch(IOException ioexception2)
        {
            i.a("Communicator IOException: " + ioexception2.getMessage());
            c();
        }
          goto _L3
        Exception exception3;
        exception3;
        throw exception3;
    }

    public void b()
    {
        synchronized(this)
        {
            notify();
            i.a("wake up");
        }
    }

    public void a()
    {
        a_boolean_fld = true;
        c();
    }

}