百草园 v7.5版本的 MD5 值为:17f49811374a404d232d5b2cc35bf30f

以下内容为反编译后的 aN.java 源代码,内容仅作参考


package com.baidu.cyberplayer.utils;

import java.io.IOException;
import java.net.InetAddress;

public class aN extends aJ implements Runnable {
    private Z a = null;

    private Thread f446a = null;

    private boolean f447a;

    public aN(String str) {
        String str2;
        this.f447a = false;
        if (Q.m255a(str)) {
            str2 = aL.a();
            this.f447a = true;
        } else {
            str2 = "239.255.255.250";
        }
        a(str2, 1900, str);
        a((Z) null);
    }

    public Z a() {
        return this.a;
    }

    public void m315a() {
        StringBuffer stringBuffer = new StringBuffer("Cyber.SSDPNotifySocket/");
        String a = a();
        if (a != null && a.length() > 0) {
            stringBuffer.append(a());
            stringBuffer.append(':');
            stringBuffer.append(b());
            stringBuffer.append(" -> ");
            stringBuffer.append(b());
            stringBuffer.append(':');
            stringBuffer.append(a());
        }
        this.f446a = new Thread(this, stringBuffer.toString());
        this.f446a.start();
    }

    public void a(Z z) {
        this.a = z;
    }

    public boolean a(aM aMVar) {
        aMVar.b(this.f447a ? aL.a() : "239.255.255.250", 1900);
        return a((G) aMVar);
    }

    public void b() {
        this.f446a = null;
    }

    @Override
    public void run() {
        Thread currentThread = Thread.currentThread();
        Z a = a();
        while (this.f446a == currentThread) {
            Thread.yield();
            try {
                aP a2 = a();
                if (a2 != null) {
                    InetAddress a3 = a();
                    InetAddress m320a = a2.m320a();
                    if (!a3.equals(m320a)) {
                        ca.b("Invalidate Multicast Recieved from IP " + a3 + " on " + m320a);
                    } else if (a != null) {
                        a.a(a2);
                    }
                }
            } catch (IOException e) {
                ca.a(e);
                return;
            }
        }
    }
}