equal
deleted
inserted
replaced
185 long to = timeout; |
185 long to = timeout; |
186 for (;;) { |
186 for (;;) { |
187 if (!dc.isOpen()) |
187 if (!dc.isOpen()) |
188 throw new ClosedChannelException(); |
188 throw new ClosedChannelException(); |
189 long st = System.currentTimeMillis(); |
189 long st = System.currentTimeMillis(); |
190 int result = dc.poll(PollArrayWrapper.POLLIN, to); |
190 int result = dc.poll(Net.POLLIN, to); |
191 if (result > 0 && |
191 if (result > 0 && |
192 ((result & PollArrayWrapper.POLLIN) != 0)) { |
192 ((result & Net.POLLIN) != 0)) { |
193 if ((sender = dc.receive(bb)) != null) |
193 if ((sender = dc.receive(bb)) != null) |
194 return sender; |
194 return sender; |
195 } |
195 } |
196 to -= System.currentTimeMillis() - st; |
196 to -= System.currentTimeMillis() - st; |
197 if (to <= 0) |
197 if (to <= 0) |