1.1 --- a/libfsserver/lib/pipes/pipe_pager.cc Mon Jul 12 22:52:52 2021 +0200
1.2 +++ b/libfsserver/lib/pipes/pipe_pager.cc Mon Jul 12 23:18:16 2021 +0200
1.3 @@ -59,7 +59,7 @@
1.4
1.5 /* Notify the other endpoint. */
1.6
1.7 - _paging->notify(_writing, NOTIFY_PEER_CLOSED);
1.8 + _paging->notify_others(_writing ? PipePaging::WRITER : PipePaging::READER, NOTIFY_PEER_CLOSED);
1.9 }
1.10
1.11 /* Support paging. */
1.12 @@ -157,7 +157,8 @@
1.13
1.14 // NOTE: Perhaps employ a distinct event type for metadata updates.
1.15
1.16 - _paging->notify(_writing, NOTIFY_CONTENT_AVAILABLE | NOTIFY_SPACE_AVAILABLE);
1.17 + _paging->notify_others(_writing ? PipePaging::WRITER : PipePaging::READER,
1.18 + NOTIFY_CONTENT_AVAILABLE | NOTIFY_SPACE_AVAILABLE);
1.19 return L4_EOK;
1.20 }
1.21
1.22 @@ -170,13 +171,13 @@
1.23 /* Readers can subscribe to new data (at end), and pipe closed events.
1.24 Writers can subscribe to new space and pipe closed events. */
1.25
1.26 - _paging->subscribe(_writing, notifier, flags);
1.27 + _paging->subscribe(_writing ? PipePaging::WRITER : PipePaging::READER, notifier, flags);
1.28 return L4_EOK;
1.29 }
1.30
1.31 long PipePager::unsubscribe(l4_cap_idx_t notifier)
1.32 {
1.33 - _paging->unsubscribe(_writing, notifier);
1.34 + _paging->unsubscribe(_writing ? PipePaging::WRITER : PipePaging::READER, notifier);
1.35 return L4_EOK;
1.36 }
1.37