Compare commits
2 commits
fdba92fddb
...
331a84627a
Author | SHA1 | Date | |
---|---|---|---|
xenofem | 331a84627a | ||
xenofem | 2d64f0529c |
|
@ -288,19 +288,12 @@ where
|
|||
if offset >= *this.available_file_size {
|
||||
trace!("waiting for inotify events");
|
||||
file.get_or_insert(inner_file);
|
||||
match this.events.poll_next(cx) {
|
||||
Poll::Pending => {
|
||||
return Poll::Pending;
|
||||
}
|
||||
Poll::Ready(Some(_)) => {
|
||||
return self.poll_next(cx);
|
||||
}
|
||||
_ => {
|
||||
return Poll::Ready(Some(Err(ErrorInternalServerError(
|
||||
"inotify stream empty",
|
||||
))));
|
||||
}
|
||||
if ready!(this.events.poll_next(cx)).is_none() {
|
||||
return Poll::Ready(Some(Err(ErrorInternalServerError(
|
||||
"inotify stream empty",
|
||||
))));
|
||||
}
|
||||
return self.poll_next(cx);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in a new issue