Home
last modified time | relevance | path

Searched refs:IOStatus (Results 1 – 11 of 11) sorted by relevance

/libcore/ojluni/src/main/java/sun/nio/ch/
DFileChannelImpl.java198 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in read()
199 return IOStatus.normalize(n); in read()
203 assert IOStatus.check(n); in read()
226 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in read()
227 return IOStatus.normalize(n); in read()
231 assert IOStatus.check(n); in read()
250 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in write()
251 return IOStatus.normalize(n); in write()
255 assert IOStatus.check(n); in write()
278 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in write()
[all …]
DSocketChannelImpl.java422 if ((n == IOStatus.INTERRUPTED) && isOpen()) { in read()
427 return IOStatus.normalize(n); in read()
448 end(n > 0 || (n == IOStatus.UNAVAILABLE)); in read()
454 return IOStatus.EOF; in read()
457 assert IOStatus.check(n); in read()
482 if ((n == IOStatus.INTERRUPTED) && isOpen()) in read()
484 return IOStatus.normalize(n); in read()
488 end(n > 0 || (n == IOStatus.UNAVAILABLE)); in read()
491 return IOStatus.EOF; in read()
493 assert IOStatus.check(n); in read()
[all …]
DSinkChannelImpl.java168 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in write()
169 return IOStatus.normalize(n); in write()
172 end((n > 0) || (n == IOStatus.UNAVAILABLE)); in write()
173 assert IOStatus.check(n); in write()
191 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in write()
192 return IOStatus.normalize(n); in write()
195 end((n > 0) || (n == IOStatus.UNAVAILABLE)); in write()
196 assert IOStatus.check(n); in write()
DSourceChannelImpl.java173 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in read()
174 return IOStatus.normalize(n); in read()
177 end((n > 0) || (n == IOStatus.UNAVAILABLE)); in read()
178 assert IOStatus.check(n); in read()
204 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in read()
205 return IOStatus.normalize(n); in read()
208 end((n > 0) || (n == IOStatus.UNAVAILABLE)); in read()
209 assert IOStatus.check(n); in read()
DDatagramChannelImpl.java384 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in receive()
385 if (n == IOStatus.UNAVAILABLE) in receive()
392 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in receive()
393 if (n == IOStatus.UNAVAILABLE) in receive()
416 end((n > 0) || (n == IOStatus.UNAVAILABLE)); in receive()
417 assert IOStatus.check(n); in receive()
507 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in send()
514 return IOStatus.normalize(n); in send()
517 end((n > 0) || (n == IOStatus.UNAVAILABLE)); in send()
518 assert IOStatus.check(n); in send()
[all …]
DIOStatus.java32 public final class IOStatus { class
34 private IOStatus() { } in IOStatus() method in IOStatus
DSimpleAsynchronousFileChannelImpl.java114 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in size()
137 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in truncate()
143 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in truncate()
163 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in force()
321 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in implRead()
375 } while ((n == IOStatus.INTERRUPTED) && isOpen()); in implWrite()
DUnixAsynchronousSocketChannelImpl.java351 if (n == IOStatus.UNAVAILABLE) { in implConnect()
413 if (n == IOStatus.UNAVAILABLE) { in finishRead()
521 int n = IOStatus.UNAVAILABLE; in implRead()
536 if (n == IOStatus.UNAVAILABLE) { in implRead()
608 if (n == IOStatus.UNAVAILABLE) { in finishWrite()
704 int n = IOStatus.UNAVAILABLE; in implWrite()
719 if (n == IOStatus.UNAVAILABLE) { in implWrite()
DUnixAsynchronousServerSocketChannelImpl.java170 if (n == IOStatus.UNAVAILABLE) { in onEvent()
304 if (n == IOStatus.UNAVAILABLE) { in implAccept()
DServerSocketChannelImpl.java251 if ((n == IOStatus.INTERRUPTED) && isOpen()) in accept()
258 assert IOStatus.check(n); in accept()
/libcore/
Dopenjdk_java_files.bp1557 "ojluni/src/main/java/sun/nio/ch/IOStatus.java",