pc$b.java
4.58 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
import com.google.common.base.Equivalence;
import com.google.common.base.Preconditions;
import com.google.common.collect.ForwardingConcurrentMap;
import com.google.common.collect.MapMaker;
import com.google.common.collect.MapMaker.d;
import com.google.common.collect.MapMaker.e;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.Serializable;
import java.util.Iterator;
import java.util.Map.Entry;
import java.util.Set;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.TimeUnit;
abstract class pc$b<K, V>
extends ForwardingConcurrentMap<K, V>
implements Serializable
{
private static final long serialVersionUID = 3L;
final pc.p b;
final pc.p c;
final Equivalence<Object> d;
final Equivalence<Object> e;
final long f;
final long g;
final int h;
final int i;
final MapMaker.e<? super K, ? super V> j;
transient ConcurrentMap<K, V> k;
pc$b(pc.p paramp1, pc.p paramp2, Equivalence<Object> paramEquivalence1, Equivalence<Object> paramEquivalence2, long paramLong1, long paramLong2, int paramInt1, int paramInt2, MapMaker.e<? super K, ? super V> parame, ConcurrentMap<K, V> paramConcurrentMap)
{
this.b = paramp1;
this.c = paramp2;
this.d = paramEquivalence1;
this.e = paramEquivalence2;
this.f = paramLong1;
this.g = paramLong2;
this.h = paramInt1;
this.i = paramInt2;
this.j = parame;
this.k = paramConcurrentMap;
}
final MapMaker a(ObjectInputStream paramObjectInputStream)
throws IOException
{
boolean bool2 = false;
int m = paramObjectInputStream.readInt();
paramObjectInputStream = new MapMaker().initialCapacity(m).a(this.b).b(this.c).a(this.d).concurrencyLevel(this.i);
Object localObject = this.j;
if (paramObjectInputStream.a == null)
{
bool1 = true;
Preconditions.checkState(bool1);
paramObjectInputStream.a = ((MapMaker.e)Preconditions.checkNotNull(localObject));
paramObjectInputStream.b = true;
long l;
if (this.f > 0L)
{
l = this.f;
localObject = TimeUnit.NANOSECONDS;
paramObjectInputStream.a(l, (TimeUnit)localObject);
paramObjectInputStream.h = ((TimeUnit)localObject).toNanos(l);
if ((l == 0L) && (paramObjectInputStream.j == null)) {
paramObjectInputStream.j = MapMaker.d.d;
}
paramObjectInputStream.b = true;
}
if (this.g > 0L)
{
l = this.g;
localObject = TimeUnit.NANOSECONDS;
paramObjectInputStream.a(l, (TimeUnit)localObject);
paramObjectInputStream.i = ((TimeUnit)localObject).toNanos(l);
if ((l == 0L) && (paramObjectInputStream.j == null)) {
paramObjectInputStream.j = MapMaker.d.d;
}
paramObjectInputStream.b = true;
}
if (this.h != -1)
{
m = this.h;
if (paramObjectInputStream.e != -1) {
break label303;
}
}
}
label303:
for (boolean bool1 = true;; bool1 = false)
{
Preconditions.checkState(bool1, "maximum size was already set to %s", new Object[] { Integer.valueOf(paramObjectInputStream.e) });
bool1 = bool2;
if (m >= 0) {
bool1 = true;
}
Preconditions.checkArgument(bool1, "maximum size must not be negative");
paramObjectInputStream.e = m;
paramObjectInputStream.b = true;
if (paramObjectInputStream.e == 0) {
paramObjectInputStream.j = MapMaker.d.e;
}
return paramObjectInputStream;
bool1 = false;
break;
}
}
final void a(ObjectOutputStream paramObjectOutputStream)
throws IOException
{
paramObjectOutputStream.writeInt(this.k.size());
Iterator localIterator = this.k.entrySet().iterator();
while (localIterator.hasNext())
{
Map.Entry localEntry = (Map.Entry)localIterator.next();
paramObjectOutputStream.writeObject(localEntry.getKey());
paramObjectOutputStream.writeObject(localEntry.getValue());
}
paramObjectOutputStream.writeObject(null);
}
final void b(ObjectInputStream paramObjectInputStream)
throws IOException, ClassNotFoundException
{
for (;;)
{
Object localObject1 = paramObjectInputStream.readObject();
if (localObject1 == null) {
break;
}
Object localObject2 = paramObjectInputStream.readObject();
this.k.put(localObject1, localObject2);
}
}
protected ConcurrentMap<K, V> delegate()
{
return this.k;
}
}
/* Location: /home/merong/decompile/hackery-dex2jar.jar!/pc$b.class
* Java compiler version: 6 (50.0)
* JD-Core Version: 0.7.1
*/