switchboard_bf.java

经过反编译和部分代码修改后的ultraimpro java源代码。可在netbean环境下成功编译。供学习和分析用。

    private void c(InputCommandProcess_be be1)
    {
        if(d == null)
        {
            d = be1.l();
            a_t_fld.a(d, b_java_lang_String_fld, this);
        }
    }

    private void d(InputCommandProcess_be be1)
    {
        String s;
        if((s = be1.e()) == null)
            return;
        String s1 = be1.b_mod_tos();
        a_java_util_Vector_fld.addElement(new String[] {
            s, s1
        });
        if(s.equals(b_java_lang_String_fld))
        {
            b_boolean_fld = true;
            if(c_java_util_Vector_fld.size() > 0)
                FlushMsnMsg();
        }
        ConnectionManage_ag.GetObject().a(d, a_java_util_Vector_fld);
    }

    private void e(InputCommandProcess_be be1)
    {
        String s;
        if((s = be1.e()) == null)
        {
            return;
        } else
        {
            String s1 = be1.b_mod_tos();
            a_java_util_Vector_fld.addElement(new String[] {
                s, s1
            });
            return;
        }
    }

    private void f(InputCommandProcess_be be1)
    {
        b_boolean_fld = true;
    }

    private void g(InputCommandProcess_be be1)
    {
        byte abyte0[];
        if((abyte0 = be1.a_byte_array1d_fld) == null || abyte0.length == 0)
            return;
        String s;
        int k = (s = new String(abyte0)).indexOf("Content-Type:");
        int l = "Content-Type:".length();
        int i1 = s.indexOf("\r\n", k + l);
        String s1;
        if((s1 = s.substring(k + l, i1)).indexOf("charset=UTF-8") > 0)
            s = Utf8Util_ao.Decode(abyte0, 0, abyte0.length);
        if((k = s.indexOf("\r\n\r\n")) <= 0 || k + 4 >= s.length())
            return;
        if(s1.indexOf("text/plain") >= 0)
        {
            String s2 = s.substring(k + 4);
            try
            {
                ConnectionManage_ag.GetObject().a(d, a_java_util_Vector_fld, be1.b_mod_tos(), s2);
                return;
            }
            catch(Exception _ex)
            {
                return;
            }
        }
        if(s1.indexOf("application/x-msnmsgrp2p") >= 0)
        {
            aa aa1 = new aa(abyte0, k + 4);
            a(aa1, be1);
        }
    }

    private void a(aa aa1, InputCommandProcess_be be1)
    {
        int k;
        if((k = aa1.a_int_fld) == 1 && aa1.a("EUF-GUID:") != null)
        {
            h h1;
            a(h1 = new h(d, a_java_lang_String_fld, be1.e()));
            h1.a(this, d, aa1);
            return;
        }
        String s;
        long l1;
        if(k == -1)
        {
            long l = aa1.e();
            for(int j1 = 0; j1 < b_java_util_Vector_static_fld.size(); j1++)
            {
                h h2 = (h)b_java_util_Vector_static_fld.elementAt(j1);
                if(l == h2.b_long_fld)
                {
                    h2.a(this, d, aa1);
                    return;
                }
            }

        } else
        if((s = aa1.a("Call-ID:")) != null && s.length() > 0)
        {
            s = s.toUpperCase();
            for(int i1 = 0; i1 < b_java_util_Vector_static_fld.size(); i1++)
            {
                h h3 = (h)b_java_util_Vector_static_fld.elementAt(i1);
                if(s.equals(h3.c_java_lang_String_fld))
                {
                    h3.a(this, d, aa1);
                    return;
                }
            }

        } else
        if((l1 = aa1.d()) != 0L)
        {
            for(int k1 = 0; k1 < b_java_util_Vector_static_fld.size(); k1++)
            {
                h h4;
                String s1;
                if((s1 = (h4 = (h)b_java_util_Vector_static_fld.elementAt(k1)).a_java_lang_String_fld) != null && s1.length() > 0)
                    try
                    {
                        if(l1 == Long.parseLong(s1))
                        {
                            h4.a(this, d, aa1);
                            return;
                        }
                    }
                    catch(Exception _ex) { }
            }

        } else
        {
            long l2 = aa1.a_long_fld;
            for(int i2 = 0; i2 < b_java_util_Vector_static_fld.size(); i2++)
            {
                h h5 = (h)b_java_util_Vector_static_fld.elementAt(i2);
                if(Math.abs(l2 - h5.a_long_fld) <= 3L)
                {
                    h5.a(this, d, aa1);
                    return;
                }
            }

        }
    }

    private void h(InputCommandProcess_be be1)
    {
        Integer integer = new Integer(be1.GetTraceId());
        if(a_java_util_Hashtable_fld.remove(integer) == null)
        {
            String s;
            if((s = d) == null)
                s = b_java_lang_String_fld;
            ConnectionManage_ag.GetObject().h(s);
        }
    }

    private void i(InputCommandProcess_be be1)
    {
        Integer integer = new Integer(be1.GetTraceId());
        Object obj = null;
        if((obj = b_java_util_Hashtable_fld.remove(integer)) != null)
            ((h)obj).c();
        a_java_util_Hashtable_fld.remove(integer);
    }

    private void j(InputCommandProcess_be be1)
    {
        int k;
        try
        {
            k = be1.d_mod_toi();
        }
        catch(Exception _ex)
        {
            return;
        }
        if(k == 217 || k == 216)
            h(be1);
    }

    private void FlushMsnMsg()
    {
        synchronized(c_java_util_Vector_fld)
        {
            for(int k = 0; k < c_java_util_Vector_fld.size(); k++)
            {
                bl bl1 = (bl)c_java_util_Vector_fld.elementAt(k);
                SendMsnMsg(false, bl1.a_int_fld, bl1.a_java_lang_Object_fld);
            }

            c_java_util_Vector_fld.removeAllElements();
        }
    }

    public final int a_mod_toi()
    {
        a_int_fld++;
        return a_int_fld;
    }

    public static final void a(h h1)
    {
        synchronized(b_java_util_Vector_static_fld)
        {
            b_java_util_Vector_static_fld.addElement(h1);
        }
    }

    public static final boolean a_mod_tob(h h1)
    {
        Vector vector = b_java_util_Vector_static_fld;
        //JVM INSTR monitorenter ;
        synchronized(b_java_util_Vector_static_fld)
        {
        return b_java_util_Vector_static_fld.removeElement(h1);
        }
        //Exception exception;
        //exception;
        //throw exception;
    }

    public static final void c()
    {
        Object obj = null;
        for(int k = 0; k < b_java_util_Vector_static_fld.size(); k++)
        {
            h h1;
            (h1 = (h)b_java_util_Vector_static_fld.elementAt(k)).a(false, false);
        }

        b_java_util_Vector_static_fld.removeAllElements();
    }

    public final int a(OutCommandComposit_ae ae1)
    {
        int k = a_mod_toi();
        ae1.a(k);
        if(!a_bp_fld.Output(ae1))
        {
            a_bp_fld.CloseSocket();
            return -1;
        } else
        {
            a_java_util_Hashtable_fld.put(new Integer(k), new Integer(k));
            return k;
        }
    }

    public final void a(int k, h h1)
    {
        b_java_util_Hashtable_fld.put(new Integer(k), h1);
    }

    public String a_java_lang_String_fld;
    public String b_java_lang_String_fld;
    public String c_java_lang_String_fld;
    public String d;
    public String e;
    public Integer a_java_lang_Integer_fld;
    public SocketManage_bp a_bp_fld;
    public Vector a_java_util_Vector_fld;
    public static Vector b_java_util_Vector_static_fld = new Vector(3);
    public Vector c_java_util_Vector_fld;
    public Hashtable a_java_util_Hashtable_fld;
    public Hashtable b_java_util_Hashtable_fld;
    public boolean a_boolean_fld;
    public boolean b_boolean_fld;
    public int a_int_fld;
    public Notification_t a_t_fld;

}