diff --git a/repos/os/include/file_system_session/client.h b/repos/os/include/file_system_session/client.h index c5388f132a..01164eee91 100644 --- a/repos/os/include/file_system_session/client.h +++ b/repos/os/include/file_system_session/client.h @@ -51,13 +51,9 @@ class File_system::Session_client : public Genode::Rpc_client Tx::Source *tx() override { return _tx.source(); } - void sigh_ready_to_submit(Genode::Signal_context_capability sigh) + void sigh(Genode::Signal_context_capability sigh) { _tx.sigh_ready_to_submit(sigh); - } - - void sigh_ack_avail(Genode::Signal_context_capability sigh) - { _tx.sigh_ack_avail(sigh); } diff --git a/repos/os/src/lib/vfs/fs_file_system.h b/repos/os/src/lib/vfs/fs_file_system.h index 2bd862362b..5dfdb687e9 100644 --- a/repos/os/src/lib/vfs/fs_file_system.h +++ b/repos/os/src/lib/vfs/fs_file_system.h @@ -535,12 +535,6 @@ class Vfs::Fs_file_system : public File_system return count; } - void _ready_to_submit() - { - _congested_handles.dequeue_all([] (Fs_vfs_handle &handle) { - handle.io_progress_response(); }); - } - void _handle_ack() { ::File_system::Session::Tx::Source &source = *_fs.tx(); @@ -616,19 +610,17 @@ class Vfs::Fs_file_system : public File_system } } - void _handle_ack_signal() + void _handle_signal() { _handle_ack(); - /* packet buffer space available */ - _ready_to_submit(); + _congested_handles.dequeue_all([] (Fs_vfs_handle &handle) { + handle.io_progress_response(); }); + } - Genode::Io_signal_handler _ack_handler { - _env.env().ep(), *this, &Fs_file_system::_handle_ack_signal }; - - Genode::Io_signal_handler _ready_handler { - _env.env().ep(), *this, &Fs_file_system::_ready_to_submit }; + Genode::Io_signal_handler _signal_handler { + _env.env().ep(), *this, &Fs_file_system::_handle_signal }; static size_t buffer_size(Genode::Xml_node const &config) { @@ -648,8 +640,7 @@ class Vfs::Fs_file_system : public File_system config.attribute_value("writeable", true), buffer_size(config)) { - _fs.sigh_ack_avail(_ack_handler); - _fs.sigh_ready_to_submit(_ready_handler); + _fs.sigh(_signal_handler); } /********************************* diff --git a/repos/os/src/server/cached_fs_rom/main.cc b/repos/os/src/server/cached_fs_rom/main.cc index d754430d67..cae731c3cd 100755 --- a/repos/os/src/server/cached_fs_rom/main.cc +++ b/repos/os/src/server/cached_fs_rom/main.cc @@ -453,7 +453,7 @@ struct Cached_fs_rom::Main final : Genode::Session_request_handler Main(Genode::Env &env) : env(env) { - fs.sigh_ack_avail(packet_handler); + fs.sigh(packet_handler); /* process any requests that have already queued */ session_requests.schedule(); diff --git a/repos/os/src/server/fs_rom/main.cc b/repos/os/src/server/fs_rom/main.cc index d17fc386a8..c89d92e5c0 100755 --- a/repos/os/src/server/fs_rom/main.cc +++ b/repos/os/src/server/fs_rom/main.cc @@ -542,7 +542,7 @@ class Fs_rom::Rom_root : public Root_component _env(env) { /* Process CONTENT_CHANGED acknowledgement packets at the entrypoint */ - _fs.sigh_ack_avail(_packet_handler); + _fs.sigh(_packet_handler); env.parent().announce(env.ep().manage(*this)); } diff --git a/repos/os/src/test/fs_packet/component.cc b/repos/os/src/test/fs_packet/component.cc index 255e318b9a..54a56d4164 100644 --- a/repos/os/src/test/fs_packet/component.cc +++ b/repos/os/src/test/fs_packet/component.cc @@ -63,7 +63,7 @@ struct Fs_packet::Main Main(Genode::Env &env) : env(env) { - fs.sigh_ack_avail(ack_handler); + fs.sigh(ack_handler); /********************** ** Stuff the buffer **