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