File tree Expand file tree Collapse file tree 2 files changed +8
-1
lines changed
branches/snap-stage3/src/libstd/rt/uv Expand file tree Collapse file tree 2 files changed +8
-1
lines changed Original file line number Diff line number Diff line change 1
1
---
2
2
refs/heads/master: 2d28d645422c1617be58c8ca7ad9a457264ca850
3
3
refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
4
- refs/heads/snap-stage3: 6fb92f8cab03824a52da6ad23060fe791928dcc9
4
+ refs/heads/snap-stage3: 413d51e32debf0c3f7dda2434b64d73585df21ef
5
5
refs/heads/try: 7b78b52e602bb3ea8174f9b2006bff3315f03ef9
6
6
refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105
7
7
refs/heads/ndm: f3868061cd7988080c30d6d5bf352a5a5fe2460b
Original file line number Diff line number Diff line change @@ -392,6 +392,13 @@ impl UdpWatcher {
392
392
393
393
extern fn recv_cb ( handle : * uvll:: uv_udp_t , nread : ssize_t , buf : Buf ,
394
394
addr : * uvll:: sockaddr , flags : c_uint ) {
395
+ // When there's no data to read the recv callback can be a no-op.
396
+ // This can happen if read returns EAGAIN/EWOULDBLOCK. By ignoring
397
+ // this we just drop back to kqueue and wait for the next callback.
398
+ if nread == 0 {
399
+ return ;
400
+ }
401
+
395
402
rtdebug ! ( "buf addr: %x" , buf. base as uint) ;
396
403
rtdebug ! ( "buf len: %d" , buf. len as int) ;
397
404
let mut udp_watcher: UdpWatcher = NativeHandle :: from_native_handle ( handle) ;
You can’t perform that action at this time.
0 commit comments