正在查看： Aptoide v9.22.5.3 应用的 l.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。
页面标题
页面副标题
Aptoide v9.22.5.3 - l.java 源代码
package i.a.g;
import i.a.a;
import i.a.d;
import i.a.g.h;
import i.a.g.j;
import i.a.g.m;
import i.a.g.n;
import java.io.IOException;
import java.io.Serializable;
import java.net.DatagramPacket;
import java.net.Inet4Address;
import java.net.Inet6Address;
import java.net.InetAddress;
import java.net.MulticastSocket;
import java.net.SocketException;
import java.util.AbstractMap;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Random;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.ReentrantLock;
public class l extends i.a.a implements i.a.g.i, i.a.g.j {
private static k.b.b f6186g = k.b.c.i(l.class.getName());
private static final Random f6187h = new Random();
private final String A;
private volatile InetAddress f6188i;
private volatile MulticastSocket j;
private final List<i.a.g.d> k;
final ConcurrentMap<String, List<m.a>> l;
private final Set<m.b> m;
private final i.a.g.a n;
private final ConcurrentMap<String, i.a.d> o;
private final ConcurrentMap<String, j> p;
private volatile a.InterfaceC0149a q;
protected Thread r;
private k s;
private Thread t;
private int u;
private long v;
private i.a.g.c y;
private final ConcurrentMap<String, i> z;
private final ExecutorService w = Executors.newSingleThreadExecutor(new i.a.g.u.a("JmDNS"));
private final ReentrantLock x = new ReentrantLock();
private final Object B = new Object();
class a implements Runnable {
final m.a f6189f;
final i.a.c f6190g;
a(m.a aVar, i.a.c cVar) {
this.f6189f = aVar;
this.f6190g = cVar;
}
@Override
public void run() {
this.f6189f.f(this.f6190g);
}
}
class b implements Runnable {
final m.b f6192f;
final i.a.c f6193g;
b(m.b bVar, i.a.c cVar) {
this.f6192f = bVar;
this.f6193g = cVar;
}
@Override
public void run() {
this.f6192f.c(this.f6193g);
}
}
class c implements Runnable {
final m.b f6195f;
final i.a.c f6196g;
c(m.b bVar, i.a.c cVar) {
this.f6195f = bVar;
this.f6196g = cVar;
}
@Override
public void run() {
this.f6195f.d(this.f6196g);
}
}
class d implements Runnable {
final m.a f6198f;
final i.a.c f6199g;
d(m.a aVar, i.a.c cVar) {
this.f6198f = aVar;
this.f6199g = cVar;
}
@Override
public void run() {
this.f6198f.d(this.f6199g);
}
}
class e implements Runnable {
final m.a f6201f;
final i.a.c f6202g;
e(m.a aVar, i.a.c cVar) {
this.f6201f = aVar;
this.f6202g = cVar;
}
@Override
public void run() {
this.f6201f.e(this.f6202g);
}
}
class f extends Thread {
f(String str) {
super(str);
}
@Override
public void run() {
l.this.D();
}
}
static class g {
static final int[] a;
static {
int[] iArr = new int[h.values().length];
a = iArr;
try {
iArr[h.Add.ordinal()] = 1;
} catch (NoSuchFieldError unused) {
}
try {
a[h.Remove.ordinal()] = 2;
} catch (NoSuchFieldError unused2) {
}
}
}
public enum h {
Remove,
Update,
Add,
RegisterServiceType,
Noop
}
private static class i implements i.a.e {
private final String c;
private final ConcurrentMap<String, i.a.d> a = new ConcurrentHashMap();
private final ConcurrentMap<String, i.a.c> b = new ConcurrentHashMap();
private volatile boolean d = true;
public i(String str) {
this.c = str;
}
@Override
public void serviceAdded(i.a.c cVar) {
synchronized (this) {
i.a.d e2 = cVar.e();
if (e2 == null || !e2.u()) {
q u1 = ((l) cVar.d()).u1(cVar.g(), cVar.f(), e2 != null ? e2.q() : "", true);
if (u1 != null) {
this.a.put(cVar.f(), u1);
} else {
this.b.put(cVar.f(), cVar);
}
} else {
this.a.put(cVar.f(), e2);
}
}
}
@Override
public void serviceRemoved(i.a.c cVar) {
synchronized (this) {
this.a.remove(cVar.f());
this.b.remove(cVar.f());
}
}
@Override
public void serviceResolved(i.a.c cVar) {
synchronized (this) {
this.a.put(cVar.f(), cVar.e());
this.b.remove(cVar.f());
}
}
public String toString() {
StringBuffer stringBuffer = new StringBuffer();
stringBuffer.append("\n\tType: ");
stringBuffer.append(this.c);
if (this.a.isEmpty()) {
stringBuffer.append("\n\tNo services collected.");
} else {
stringBuffer.append("\n\tServices");
for (String str : this.a.keySet()) {
stringBuffer.append("\n\t\tService: ");
stringBuffer.append(str);
stringBuffer.append(": ");
stringBuffer.append(this.a.get(str));
}
}
if (this.b.isEmpty()) {
stringBuffer.append("\n\tNo event queued.");
} else {
stringBuffer.append("\n\tEvents");
for (String str2 : this.b.keySet()) {
stringBuffer.append("\n\t\tEvent: ");
stringBuffer.append(str2);
stringBuffer.append(": ");
stringBuffer.append(this.b.get(str2));
}
}
return stringBuffer.toString();
}
}
public static class j extends AbstractMap<String, String> implements Cloneable {
private final Set<Map.Entry<String, String>> f6209f = new HashSet();
private final String f6210g;
private static class a implements Map.Entry<String, String>, Serializable, Cloneable {
private final String f6211f;
private final String f6212g;
public a(String str) {
str = str == null ? "" : str;
this.f6212g = str;
this.f6211f = str.toLowerCase();
}
public a clone() {
return this;
}
@Override
public String getKey() {
return this.f6211f;
}
@Override
public String getValue() {
return this.f6212g;
}
@Override
public boolean equals(Object obj) {
if (!(obj instanceof Map.Entry)) {
return false;
}
Map.Entry entry = (Map.Entry) obj;
return getKey().equals(entry.getKey()) && getValue().equals(entry.getValue());
}
@Override
public String setValue(String str) {
throw new UnsupportedOperationException();
}
@Override
public int hashCode() {
String str = this.f6211f;
int hashCode = str == null ? 0 : str.hashCode();
String str2 = this.f6212g;
return hashCode ^ (str2 != null ? str2.hashCode() : 0);
}
public String toString() {
return this.f6211f + "=" + this.f6212g;
}
}
public j(String str) {
this.f6210g = str;
}
public boolean b(String str) {
if (str == null || e(str)) {
return false;
}
this.f6209f.add(new a(str));
return true;
}
@Override
public j clone() {
j jVar = new j(f());
Iterator<Map.Entry<String, String>> it = entrySet().iterator();
while (it.hasNext()) {
jVar.b(it.next().getValue());
}
return jVar;
}
public boolean e(String str) {
return str != null && containsKey(str.toLowerCase());
}
@Override
public Set<Map.Entry<String, String>> entrySet() {
return this.f6209f;
}
public String f() {
return this.f6210g;
}
@Override
public String toString() {
StringBuilder sb = new StringBuilder(200);
if (isEmpty()) {
sb.append("empty");
} else {
Iterator<String> it = values().iterator();
while (it.hasNext()) {
sb.append(it.next());
sb.append(", ");
}
sb.setLength(sb.length() - 2);
}
return sb.toString();
}
}
public l(InetAddress inetAddress, String str) throws IOException {
if (f6186g.b()) {
f6186g.c("JmDNS instance created");
}
this.n = new i.a.g.a(100);
this.k = Collections.synchronizedList(new ArrayList());
this.l = new ConcurrentHashMap();
this.m = Collections.synchronizedSet(new HashSet());
this.z = new ConcurrentHashMap();
this.o = new ConcurrentHashMap(20);
this.p = new ConcurrentHashMap(20);
k A = k.A(inetAddress, this, str);
this.s = A;
this.A = str == null ? A.q() : str;
f1(n0());
A1(y0().values());
j();
}
private void A1(Collection<? extends i.a.d> collection) {
if (this.t == null) {
r rVar = new r(this);
this.t = rVar;
rVar.start();
}
k();
Iterator<? extends i.a.d> it = collection.iterator();
while (it.hasNext()) {
try {
l1(new q(it.next()));
} catch (Exception e2) {
f6186g.f("start() Registration exception ", e2);
}
}
}
static String B1(String str, String str2) {
String lowerCase = str.toLowerCase();
String lowerCase2 = str2.toLowerCase();
return (!lowerCase2.endsWith(lowerCase) || lowerCase2.equals(lowerCase)) ? str2 : str2.substring(0, (str2.length() - str.length()) - 1);
}
private List<i.a.g.h> H(List<i.a.g.h> list) {
ArrayList arrayList = new ArrayList(list.size());
ArrayList arrayList2 = new ArrayList();
for (i.a.g.h hVar : list) {
if (hVar.f().equals(i.a.g.s.e.TYPE_A) || hVar.f().equals(i.a.g.s.e.TYPE_AAAA)) {
arrayList2.add(hVar);
} else {
arrayList.add(hVar);
}
}
arrayList.addAll(arrayList2);
return arrayList;
}
private void J(String str, i.a.e eVar, boolean z) {
m.a aVar = new m.a(eVar, z);
String lowerCase = str.toLowerCase();
List<m.a> list = this.l.get(lowerCase);
if (list == null) {
if (this.l.putIfAbsent(lowerCase, new LinkedList()) == null && this.z.putIfAbsent(lowerCase, new i(str)) == null) {
J(lowerCase, this.z.get(lowerCase), true);
}
list = this.l.get(lowerCase);
}
if (list != null) {
synchronized (list) {
if (!list.contains(aVar)) {
list.add(aVar);
}
}
}
ArrayList arrayList = new ArrayList();
Iterator<i.a.g.b> it = Z().c().iterator();
while (it.hasNext()) {
i.a.g.h hVar = (i.a.g.h) it.next();
if (hVar.f() == i.a.g.s.e.TYPE_SRV && hVar.b().endsWith(lowerCase)) {
arrayList.add(new p(this, hVar.h(), B1(hVar.h(), hVar.c()), hVar.C()));
}
}
Iterator it2 = arrayList.iterator();
while (it2.hasNext()) {
aVar.d((i.a.c) it2.next());
}
c(str);
}
private void T() {
if (f6186g.b()) {
f6186g.c("closeMulticastSocket()");
}
if (this.j != null) {
try {
try {
this.j.leaveGroup(this.f6188i);
} catch (Exception e2) {
f6186g.f("closeMulticastSocket() Close socket exception ", e2);
}
} catch (SocketException unused) {
}
this.j.close();
while (true) {
Thread thread = this.t;
if (thread == null || !thread.isAlive()) {
break;
}
synchronized (this) {
try {
Thread thread2 = this.t;
if (thread2 != null && thread2.isAlive()) {
if (f6186g.b()) {
f6186g.c("closeMulticastSocket(): waiting for jmDNS monitor");
}
wait(1000L);
}
} catch (InterruptedException unused2) {
}
}
}
this.t = null;
this.j = null;
}
}
private void Y() {
if (f6186g.b()) {
f6186g.c("disposeServiceCollectors()");
}
for (String str : this.z.keySet()) {
i iVar = this.z.get(str);
if (iVar != null) {
s1(str, iVar);
this.z.remove(str, iVar);
}
}
}
private boolean c1(q qVar) {
boolean z;
i.a.d dVar;
String L = qVar.L();
long currentTimeMillis = System.currentTimeMillis();
do {
z = false;
for (i.a.g.b bVar : Z().f(qVar.L())) {
if (i.a.g.s.e.TYPE_SRV.equals(bVar.f()) && !bVar.j(currentTimeMillis)) {
h.f fVar = (h.f) bVar;
if (fVar.T() != qVar.l() || !fVar.V().equals(this.s.q())) {
if (f6186g.b()) {
f6186g.c("makeServiceNameUnique() JmDNS.makeServiceNameUnique srv collision:" + bVar + " s.server=" + fVar.V() + " " + this.s.q() + " equals:" + fVar.V().equals(this.s.q()));
}
qVar.d0(n.c.a().a(this.s.o(), qVar.k(), n.d.SERVICE));
z = true;
dVar = this.o.get(qVar.L());
if (dVar != null && dVar != qVar) {
qVar.d0(n.c.a().a(this.s.o(), qVar.k(), n.d.SERVICE));
z = true;
}
}
}
}
dVar = this.o.get(qVar.L());
if (dVar != null) {
qVar.d0(n.c.a().a(this.s.o(), qVar.k(), n.d.SERVICE));
z = true;
}
} while (z);
return !L.equals(qVar.L());
}
private void f1(k kVar) throws IOException {
if (this.f6188i == null) {
if (kVar.o() instanceof Inet6Address) {
this.f6188i = InetAddress.getByName("FF02::FB");
} else {
this.f6188i = InetAddress.getByName("224.0.0.251");
}
}
if (this.j != null) {
T();
}
this.j = new MulticastSocket(i.a.g.s.a.a);
if (kVar != null && kVar.p() != null) {
try {
this.j.setNetworkInterface(kVar.p());
} catch (SocketException e2) {
if (f6186g.b()) {
f6186g.c("openMulticastSocket() Set network interface exception: " + e2.getMessage());
}
}
}
this.j.setTimeToLive(255);
this.j.joinGroup(this.f6188i);
}
public static Random q0() {
return f6187h;
}
@Override
public void B() {
if (f6186g.b()) {
f6186g.c("unregisterAllServices()");
}
Iterator<String> it = this.o.keySet().iterator();
while (it.hasNext()) {
q qVar = (q) this.o.get(it.next());
if (qVar != null) {
if (f6186g.b()) {
f6186g.c("Cancelling service info: " + qVar);
}
qVar.F();
}
}
f();
for (String str : this.o.keySet()) {
q qVar2 = (q) this.o.get(str);
if (qVar2 != null) {
if (f6186g.b()) {
f6186g.c("Wait for service info cancel: " + qVar2);
}
qVar2.k0(5000L);
this.o.remove(str, qVar2);
}
}
}
public void C1(long j2, i.a.g.h hVar, h hVar2) {
ArrayList arrayList;
List<m.a> emptyList;
synchronized (this.k) {
arrayList = new ArrayList(this.k);
}
Iterator it = arrayList.iterator();
while (it.hasNext()) {
((i.a.g.d) it.next()).b(Z(), j2, hVar);
}
if (i.a.g.s.e.TYPE_PTR.equals(hVar.f())) {
i.a.c B = hVar.B(this);
if (B.e() == null || !B.e().u()) {
q t0 = t0(B.g(), B.f(), "", false);
if (t0.u()) {
B = new p(this, B.g(), B.f(), t0);
}
}
List<m.a> list = this.l.get(B.g().toLowerCase());
if (list != null) {
synchronized (list) {
emptyList = new ArrayList(list);
}
} else {
emptyList = Collections.emptyList();
}
if (f6186g.d()) {
f6186g.i(p0() + ".updating record for event: " + B + " list " + emptyList + " operation: " + hVar2);
}
if (emptyList.isEmpty()) {
return;
}
int i2 = g.a[hVar2.ordinal()];
if (i2 == 1) {
for (m.a aVar : emptyList) {
if (aVar.b()) {
aVar.d(B);
} else {
this.w.submit(new d(aVar, B));
}
}
return;
}
if (i2 != 2) {
return;
}
for (m.a aVar2 : emptyList) {
if (aVar2.b()) {
aVar2.e(B);
} else {
this.w.submit(new e(aVar2, B));
}
}
}
}
void D() {
if (f6186g.b()) {
f6186g.c(p0() + "recover() Cleanning up");
}
f6186g.h("RECOVERING");
a();
ArrayList arrayList = new ArrayList(y0().values());
B();
Y();
E1(5000L);
p();
T();
Z().clear();
if (f6186g.b()) {
f6186g.c(p0() + "recover() All is clean");
}
if (!V0()) {
f6186g.h(p0() + "recover() Could not recover we are Down!");
if (a0() != null) {
a0().a(e0(), arrayList);
return;
}
return;
}
Iterator<i.a.d> it = arrayList.iterator();
while (it.hasNext()) {
((q) it.next()).X();
}
k1();
try {
f1(n0());
A1(arrayList);
} catch (Exception e2) {
f6186g.f(p0() + "recover() Start services exception ", e2);
}
f6186g.h(p0() + "recover() We are back!");
}
public boolean D1(long j2) {
return this.s.F(j2);
}
public MulticastSocket E0() {
return this.j;
}
public boolean E1(long j2) {
return this.s.G(j2);
}
public int F0() {
return this.u;
}
void G0(i.a.g.c cVar, InetAddress inetAddress, int i2) throws IOException {
if (f6186g.b()) {
f6186g.c(p0() + ".handle query: " + cVar);
}
boolean z = false;
long currentTimeMillis = System.currentTimeMillis() + 120;
Iterator<i.a.g.h> it = cVar.b().iterator();
while (it.hasNext()) {
z |= it.next().F(this, currentTimeMillis);
}
N0();
try {
i.a.g.c cVar2 = this.y;
if (cVar2 != null) {
cVar2.y(cVar);
} else {
i.a.g.c clone = cVar.clone();
if (cVar.r()) {
this.y = clone;
}
m(clone, inetAddress, i2);
}
Q0();
long currentTimeMillis2 = System.currentTimeMillis();
Iterator<? extends i.a.g.h> it2 = cVar.c().iterator();
while (it2.hasNext()) {
J0(it2.next(), currentTimeMillis2);
}
if (z) {
k();
}
} catch (Throwable th) {
Q0();
throw th;
}
}
public void I(i.a.g.d dVar, i.a.g.g gVar) {
long currentTimeMillis = System.currentTimeMillis();
this.k.add(dVar);
if (gVar != null) {
for (i.a.g.b bVar : Z().f(gVar.c().toLowerCase())) {
if (gVar.A(bVar) && !bVar.j(currentTimeMillis)) {
dVar.b(Z(), currentTimeMillis, bVar);
}
}
}
}
void J0(i.a.g.h hVar, long j2) {
h hVar2 = h.Noop;
boolean j3 = hVar.j(j2);
if (f6186g.b()) {
f6186g.c(p0() + " handle response: " + hVar);
}
if (!hVar.o() && !hVar.i()) {
boolean p = hVar.p();
i.a.g.h hVar3 = (i.a.g.h) Z().e(hVar);
if (f6186g.b()) {
f6186g.c(p0() + " handle response cached record: " + hVar3);
}
if (p) {
for (i.a.g.b bVar : Z().f(hVar.b())) {
if (hVar.f().equals(bVar.f()) && hVar.e().equals(bVar.e()) && bVar != hVar3) {
((i.a.g.h) bVar).P(j2);
}
}
}
if (hVar3 != null) {
if (j3) {
if (hVar.E() == 0) {
hVar2 = h.Noop;
hVar3.P(j2);
} else {
hVar2 = h.Remove;
Z().i(hVar3);
}
} else if (hVar.N(hVar3) && (hVar.u(hVar3) || hVar.g().length() <= 0)) {
hVar3.L(hVar);
hVar = hVar3;
} else if (hVar.I()) {
hVar2 = h.Update;
Z().j(hVar, hVar3);
} else {
hVar2 = h.Add;
Z().b(hVar);
}
} else if (!j3) {
hVar2 = h.Add;
Z().b(hVar);
}
}
if (hVar.f() == i.a.g.s.e.TYPE_PTR) {
if (hVar.o()) {
if (j3) {
return;
}
n1(((h.e) hVar).T());
return;
} else if ((n1(hVar.c()) | false) && hVar2 == h.Noop) {
hVar2 = h.RegisterServiceType;
}
}
if (hVar2 != h.Noop) {
C1(j2, hVar, hVar2);
}
}
public void K(i.a.g.t.a aVar, i.a.g.s.g gVar) {
this.s.b(aVar, gVar);
}
void K0(i.a.g.c cVar) throws IOException {
long currentTimeMillis = System.currentTimeMillis();
boolean z = false;
boolean z2 = false;
for (i.a.g.h hVar : H(cVar.b())) {
J0(hVar, currentTimeMillis);
if (i.a.g.s.e.TYPE_A.equals(hVar.f()) || i.a.g.s.e.TYPE_AAAA.equals(hVar.f())) {
z |= hVar.G(this);
} else {
z2 |= hVar.G(this);
}
}
if (z || z2) {
k();
}
}
void M0(i.a.c cVar) {
ArrayList arrayList;
List<m.a> list = this.l.get(cVar.g().toLowerCase());
if (list == null || list.isEmpty() || cVar.e() == null || !cVar.e().u()) {
return;
}
synchronized (list) {
arrayList = new ArrayList(list);
}
Iterator it = arrayList.iterator();
while (it.hasNext()) {
this.w.submit(new a((m.a) it.next(), cVar));
}
}
public boolean N() {
return this.s.c();
}
public void N0() {
this.x.lock();
}
public void Q() {
long currentTimeMillis = System.currentTimeMillis();
HashSet hashSet = new HashSet();
for (i.a.g.b bVar : Z().c()) {
try {
i.a.g.h hVar = (i.a.g.h) bVar;
if (hVar.j(currentTimeMillis)) {
C1(currentTimeMillis, hVar, h.Remove);
Z().i(hVar);
} else if (hVar.K(currentTimeMillis)) {
hVar.H();
String lowerCase = hVar.C().s().toLowerCase();
if (hashSet.add(lowerCase)) {
t1(lowerCase);
}
}
} catch (Exception e2) {
f6186g.f(p0() + ".Error while reaping records: " + bVar, e2);
f6186g.h(toString());
}
}
}
public void Q0() {
this.x.unlock();
}
public boolean R0() {
return this.s.s();
}
public boolean T0(i.a.g.t.a aVar, i.a.g.s.g gVar) {
return this.s.t(aVar, gVar);
}
public boolean V0() {
return this.s.u();
}
public boolean W() {
return this.s.e();
}
public boolean X0() {
return this.s.v();
}
public i.a.g.a Z() {
return this.n;
}
public boolean Z0() {
return this.s.x();
}
@Override
public void a() {
j.b.b().c(e0()).a();
}
public a.InterfaceC0149a a0() {
return this.q;
}
public boolean a1() {
return this.s.y();
}
@Override
public void b() {
j.b.b().c(e0()).b();
}
@Override
public void c(String str) {
j.b.b().c(e0()).c(str);
}
@Override
public void close() {
if (Z0()) {
return;
}
if (f6186g.b()) {
f6186g.c("Cancelling JmDNS: " + this);
}
if (W()) {
f6186g.c("Canceling the timer");
e();
B();
Y();
if (f6186g.b()) {
f6186g.c("Wait for JmDNS cancel: " + this);
}
E1(5000L);
f6186g.c("Canceling the state timer");
b();
this.w.shutdown();
T();
if (this.r != null) {
Runtime.getRuntime().removeShutdownHook(this.r);
}
j.b.b().a(e0());
if (f6186g.b()) {
f6186g.c("JmDNS closed.");
}
}
d(null);
}
@Override
public boolean d(i.a.g.t.a aVar) {
return this.s.d(aVar);
}
@Override
public void e() {
j.b.b().c(e0()).e();
}
public l e0() {
return this;
}
@Override
public void f() {
j.b.b().c(e0()).f();
}
public InetAddress f0() {
return this.f6188i;
}
public void h1() {
f6186g.c(p0() + "recover()");
if (Z0() || isClosed() || X0() || V0()) {
return;
}
synchronized (this.B) {
if (N()) {
f6186g.c(p0() + "recover() thread " + Thread.currentThread().getName());
StringBuilder sb = new StringBuilder();
sb.append(p0());
sb.append(".recover()");
new f(sb.toString()).start();
}
}
}
public InetAddress i0() throws IOException {
return this.s.o();
}
public boolean isClosed() {
return this.s.w();
}
@Override
public void j() {
j.b.b().c(e0()).j();
}
@Override
public void k() {
j.b.b().c(e0()).k();
}
public boolean k1() {
return this.s.B();
}
@Override
public void l() {
j.b.b().c(e0()).l();
}
public void l1(i.a.d dVar) throws IOException {
if (Z0() || isClosed()) {
throw new IllegalStateException("This DNS is closed.");
}
q qVar = (q) dVar;
if (qVar.K() != null) {
if (qVar.K() != this) {
throw new IllegalStateException("A service information can only be registered with a single instamce of JmDNS.");
}
if (this.o.get(qVar.L()) != null) {
throw new IllegalStateException("A service information can only be registered once.");
}
}
qVar.c0(this);
n1(qVar.O());
qVar.X();
qVar.g0(this.s.q());
qVar.B(this.s.m());
qVar.C(this.s.n());
D1(6000L);
c1(qVar);
while (this.o.putIfAbsent(qVar.L(), qVar) != null) {
c1(qVar);
}
k();
qVar.j0(6000L);
if (f6186g.b()) {
f6186g.c("registerService() JmDNS registered service as " + qVar);
}
}
@Override
public void m(i.a.g.c cVar, InetAddress inetAddress, int i2) {
j.b.b().c(e0()).m(cVar, inetAddress, i2);
}
public long m0() {
return this.v;
}
public k n0() {
return this.s;
}
public boolean n1(String str) {
boolean z;
j jVar;
Map<d.a, String> J = q.J(str);
String str2 = J.get(d.a.Domain);
String str3 = J.get(d.a.Protocol);
String str4 = J.get(d.a.Application);
String str5 = J.get(d.a.Subtype);
StringBuilder sb = new StringBuilder();
sb.append(str4.length() > 0 ? "_" + str4 + "." : "");
sb.append(str3.length() > 0 ? "_" + str3 + "." : "");
sb.append(str2);
sb.append(".");
String sb2 = sb.toString();
String lowerCase = sb2.toLowerCase();
if (f6186g.b()) {
k.b.b bVar = f6186g;
StringBuilder sb3 = new StringBuilder();
sb3.append(p0());
sb3.append(".registering service type: ");
sb3.append(str);
sb3.append(" as: ");
sb3.append(sb2);
sb3.append(str5.length() > 0 ? " subtype: " + str5 : "");
bVar.c(sb3.toString());
}
boolean z2 = true;
if (this.p.containsKey(lowerCase) || str4.toLowerCase().equals("dns-sd") || str2.toLowerCase().endsWith("in-addr.arpa") || str2.toLowerCase().endsWith("ip6.arpa")) {
z = false;
} else {
z = this.p.putIfAbsent(lowerCase, new j(sb2)) == null;
if (z) {
Set<m.b> set = this.m;
m.b[] bVarArr = (m.b[]) set.toArray(new m.b[set.size()]);
p pVar = new p(this, sb2, "", null);
for (m.b bVar2 : bVarArr) {
this.w.submit(new b(bVar2, pVar));
}
}
}
if (str5.length() <= 0 || (jVar = this.p.get(lowerCase)) == null || jVar.e(str5)) {
return z;
}
synchronized (jVar) {
if (jVar.e(str5)) {
z2 = z;
} else {
jVar.b(str5);
Set<m.b> set2 = this.m;
m.b[] bVarArr2 = (m.b[]) set2.toArray(new m.b[set2.size()]);
p pVar2 = new p(this, "_" + str5 + "._sub." + sb2, "", null);
for (m.b bVar3 : bVarArr2) {
this.w.submit(new c(bVar3, pVar2));
}
}
}
return z2;
}
@Override
public void p() {
j.b.b().c(e0()).p();
}
public String p0() {
return this.A;
}
public void q1(i.a.g.t.a aVar) {
this.s.C(aVar);
}
public void r1(i.a.g.d dVar) {
this.k.remove(dVar);
}
public void s1(String str, i.a.e eVar) {
String lowerCase = str.toLowerCase();
List<m.a> list = this.l.get(lowerCase);
if (list != null) {
synchronized (list) {
list.remove(new m.a(eVar, false));
if (list.isEmpty()) {
this.l.remove(lowerCase, list);
}
}
}
}
q t0(String str, String str2, String str3, boolean z) {
q qVar;
q qVar2;
String str4;
i.a.d D;
i.a.d D2;
i.a.d D3;
i.a.d D4;
q qVar3 = new q(str, str2, str3, 0, 0, 0, z, null);
i.a.g.a Z = Z();
i.a.g.s.d dVar = i.a.g.s.d.CLASS_ANY;
i.a.g.b e2 = Z.e(new h.e(str, dVar, false, 0, qVar3.o()));
if (!(e2 instanceof i.a.g.h) || (qVar = (q) ((i.a.g.h) e2).D(z)) == null) {
return qVar3;
}
Map<d.a, String> N = qVar.N();
byte[] bArr = null;
i.a.g.b d2 = Z().d(qVar3.o(), i.a.g.s.e.TYPE_SRV, dVar);
if (!(d2 instanceof i.a.g.h) || (D4 = ((i.a.g.h) d2).D(z)) == null) {
qVar2 = qVar;
str4 = "";
} else {
qVar2 = new q(N, D4.l(), D4.t(), D4.m(), z, (byte[]) null);
bArr = D4.r();
str4 = D4.p();
}
Iterator<? extends i.a.g.b> it = Z().h(str4, i.a.g.s.e.TYPE_A, dVar).iterator();
while (true) {
if (!it.hasNext()) {
break;
}
i.a.g.b next = it.next();
if ((next instanceof i.a.g.h) && (D3 = ((i.a.g.h) next).D(z)) != null) {
for (Inet4Address inet4Address : D3.h()) {
qVar2.B(inet4Address);
}
qVar2.A(D3.r());
}
}
for (i.a.g.b bVar : Z().h(str4, i.a.g.s.e.TYPE_AAAA, i.a.g.s.d.CLASS_ANY)) {
if ((bVar instanceof i.a.g.h) && (D2 = ((i.a.g.h) bVar).D(z)) != null) {
for (Inet6Address inet6Address : D2.i()) {
qVar2.C(inet6Address);
}
qVar2.A(D2.r());
}
}
i.a.g.b d3 = Z().d(qVar2.o(), i.a.g.s.e.TYPE_TXT, i.a.g.s.d.CLASS_ANY);
if ((d3 instanceof i.a.g.h) && (D = ((i.a.g.h) d3).D(z)) != null) {
qVar2.A(D.r());
}
if (qVar2.r().length == 0) {
qVar2.A(bArr);
}
return qVar2.u() ? qVar2 : qVar3;
}
public void t1(String str) {
if (this.z.containsKey(str.toLowerCase())) {
c(str);
}
}
public String toString() {
StringBuilder sb = new StringBuilder(2048);
sb.append("\n");
sb.append("\t---- Local Host -----");
sb.append("\n\t");
sb.append(this.s);
sb.append("\n\t---- Services -----");
for (String str : this.o.keySet()) {
sb.append("\n\t\tService: ");
sb.append(str);
sb.append(": ");
sb.append(this.o.get(str));
}
sb.append("\n");
sb.append("\t---- Types ----");
Iterator<String> it = this.p.keySet().iterator();
while (it.hasNext()) {
j jVar = this.p.get(it.next());
sb.append("\n\t\tType: ");
sb.append(jVar.f());
sb.append(": ");
if (jVar.isEmpty()) {
jVar = "no subtypes";
}
sb.append(jVar);
}
sb.append("\n");
sb.append(this.n.toString());
sb.append("\n");
sb.append("\t---- Service Collectors ----");
for (String str2 : this.z.keySet()) {
sb.append("\n\t\tService Collector: ");
sb.append(str2);
sb.append(": ");
sb.append(this.z.get(str2));
}
sb.append("\n");
sb.append("\t---- Service Listeners ----");
for (String str3 : this.l.keySet()) {
sb.append("\n\t\tService Listener: ");
sb.append(str3);
sb.append(": ");
sb.append(this.l.get(str3));
}
return sb.toString();
}
q u1(String str, String str2, String str3, boolean z) {
Q();
String lowerCase = str.toLowerCase();
n1(str);
if (this.z.putIfAbsent(lowerCase, new i(str)) == null) {
J(lowerCase, this.z.get(lowerCase), true);
}
q t0 = t0(str, str2, str3, z);
y(t0);
return t0;
}
public void v1(i.a.g.c cVar) {
N0();
try {
if (this.y == cVar) {
this.y = null;
}
} finally {
Q0();
}
}
public boolean w1() {
return this.s.D();
}
@Override
public void x() {
j.b.b().c(e0()).x();
}
public Map<String, j> x0() {
return this.p;
}
public void x1(i.a.g.f fVar) throws IOException {
InetAddress inetAddress;
int i2;
if (fVar.n()) {
return;
}
if (fVar.D() != null) {
inetAddress = fVar.D().getAddress();
i2 = fVar.D().getPort();
} else {
inetAddress = this.f6188i;
i2 = i.a.g.s.a.a;
}
byte[] C = fVar.C();
DatagramPacket datagramPacket = new DatagramPacket(C, C.length, inetAddress, i2);
if (f6186g.d()) {
try {
i.a.g.c cVar = new i.a.g.c(datagramPacket);
if (f6186g.d()) {
f6186g.i("send(" + p0() + ") JmDNS out:" + cVar.C(true));
}
} catch (IOException e2) {
f6186g.a(l.class.toString(), "send(" + p0() + ") - JmDNS can not parse what it sends!!!", e2);
}
}
MulticastSocket multicastSocket = this.j;
if (multicastSocket == null || multicastSocket.isClosed()) {
return;
}
multicastSocket.send(datagramPacket);
}
@Override
public void y(q qVar) {
j.b.b().c(e0()).y(qVar);
}
public Map<String, i.a.d> y0() {
return this.o;
}
public void y1(long j2) {
this.v = j2;
}
@Override
public void z(String str, i.a.e eVar) {
J(str, eVar, false);
}
public void z1(int i2) {
this.u = i2;
}
}