Lines 128-136
Link Here
|
128 |
return super.toString()+":"+this.sc.toString(); |
128 |
return super.toString()+":"+this.sc.toString(); |
129 |
} |
129 |
} |
130 |
|
130 |
|
|
|
131 |
private volatile Exception trace = null; |
131 |
@Override |
132 |
@Override |
132 |
public Future<Integer> read(ByteBuffer dst) { |
133 |
public Future<Integer> read(ByteBuffer dst) { |
133 |
return sc.read(dst); |
134 |
try { |
|
|
135 |
throw new Exception(Thread.currentThread().getName()); |
136 |
} catch (Exception e) { |
137 |
trace = e; |
138 |
} |
139 |
try { |
140 |
return sc.read(dst); |
141 |
} catch (java.nio.channels.ReadPendingException e) { |
142 |
System.out.println("Read pending " + Thread.currentThread().getName()); |
143 |
trace.printStackTrace(); |
144 |
throw e; |
145 |
} |
134 |
} |
146 |
} |
135 |
|
147 |
|
136 |
@Override |
148 |
@Override |