Add simple async signal example

This commit is contained in:
2021-01-07 18:33:26 +01:00
parent 0adeb4f492
commit 43efb5b4e2
8 changed files with 179 additions and 0 deletions

View File

@@ -0,0 +1,19 @@
#ifndef _INCLUDE__SIGNALS_SESSION__CLIENT_H_
#define _INCLUDE__SIGNALS_SESSION__CLIENT_H_
#include <signals_session/signals_session.h>
#include <base/rpc_client.h>
namespace Signals { struct Session_client; }
struct Signals::Session_client : Genode::Rpc_client<Session>
{
Session_client(Genode::Capability<Session> cap) : Genode::Rpc_client<Session>(cap) {
}
Genode::Signal_context_capability get_sig_con() override {
return call<Rpc_get_sig_con>();
}
};
#endif /* _INCLUDE__SIGNALS_SESSION__CLIENT_H_ */

View File

@@ -0,0 +1,14 @@
#ifndef _INCLUDE__SIGNALS_SESSION__CONNECTION_H_
#define _INCLUDE__SIGNALS_SESSION__CONNECTION_H_
#include <signals_session/client.h>
#include <base/connection.h>
namespace Signals { struct Connection; }
struct Signals::Connection : Genode::Connection<Session>, Session_client {
Connection(Genode::Env &env) : Genode::Connection<Signals::Session>(env, session(env.parent(), "ram_quota=6K, cap_quota=4")),
Session_client(cap()) { }
};
#endif /* _INCLUDE__SIGNALS_SESSION__CONNECTION_H_ */

View File

@@ -0,0 +1,21 @@
#ifndef _INCLUDE__SIGNALS_SESSION__SIGNALS_SESSION_H
#define _INCLUDE__SIGNALS_SESSION__SIGNALS_SESSION_H
#include <session/session.h>
#include <base/rpc.h>
namespace Signals { struct Session; }
struct Signals::Session : Genode::Session {
static const char *service_name() { return "Signals"; }
enum { CAP_QUOTA = 2 };
virtual Genode::Signal_context_capability get_sig_con() = 0;
GENODE_RPC(Rpc_get_sig_con, Genode::Signal_context_capability, get_sig_con);
GENODE_RPC_INTERFACE(Rpc_get_sig_con);
};
#endif /* _INCLUDE__SIGNALS_SESSION__SIGNALS_SESSION_H */

46
run/signals.run Normal file
View File

@@ -0,0 +1,46 @@
#
# Build
#
build { core init timer signals }
create_boot_directory
#
# Generate config
#
install_config {
<config>
<parent-provides>
<service name="LOG"/>
<service name="PD"/>
<service name="CPU"/>
<service name="ROM"/>
</parent-provides>
<default-route>
<any-service> <parent/> <any-child/> </any-service>
</default-route>
<default caps="100"/>
<start name="timer">
<resource name="RAM" quantum="1M"/>
<provides> <service name="Timer"/> </provides>
</start>
<start name="signals_server">
<resource name="RAM" quantum="1M"/>
<provides> <service name="Signals"/> </provides>
</start>
<start name="signals_client">
<resource name="RAM" quantum="1M"/>
</start>
</config>}
#
# Boot image
#
build_boot_image { core ld.lib.so init timer signals_client signals_server }
append qemu_args " -nographic "
run_genode_until forever

View File

@@ -0,0 +1,19 @@
#include <base/component.h>
#include <base/log.h>
#include <signals_session/connection.h>
#include <timer_session/connection.h>
void Component::construct(Genode::Env &env)
{
Signals::Connection _signals(env);
Genode::Signal_transmitter _signal_transmitter(_signals.get_sig_con());
Timer::Connection _timer(env);
while(true) {
_timer.msleep(1000);
Genode::log("Sending signal…");
_signal_transmitter.submit();
};
}

View File

@@ -0,0 +1,3 @@
TARGET = signals_client
SRC_CC = main.cc
LIBS = base

View File

@@ -0,0 +1,54 @@
#include <base/component.h>
#include <base/log.h>
#include <base/heap.h>
#include <root/component.h>
#include <signals_session/signals_session.h>
namespace Signals {
struct Session_component;
class Root_component;
struct Main;
}
struct Signals::Session_component : Genode::Rpc_object<Session> {
Genode::Signal_context_capability _sig_con;
Genode::Signal_context_capability get_sig_con() override {
return _sig_con;
}
Session_component(Genode::Signal_context_capability &sig_con) : _sig_con(sig_con) { }
};
class Signals::Root_component : public Genode::Root_component<Session_component> {
private:
Genode::Signal_context_capability _sig_con;
protected:
Session_component *_create_session(const char *) override {
return new (md_alloc()) Session_component(_sig_con);
}
public:
Root_component(Genode::Entrypoint &ep, Genode::Allocator &alloc, Genode::Signal_context_capability sig_con) : Genode::Root_component<Session_component>(ep, alloc), _sig_con(sig_con) { }
};
struct Signals::Main {
Genode::Env &_env;
Genode::Signal_handler<Main> _sig_handler = { _env.ep(), *this, &Main::_handle_signal };
Genode::Sliced_heap sliced_heap { _env.ram(), _env.rm() };
Signals::Root_component root { _env.ep(), sliced_heap, _sig_handler };
Main(Genode::Env &env) : _env(env) {
env.parent().announce(env.ep().manage(root));
}
void _handle_signal() {
Genode::log("Signal received!");
}
};
void Component::construct(Genode::Env &env) {
static Signals::Main main(env);
}

View File

@@ -0,0 +1,3 @@
TARGET = signals_server
SRC_CC = main.cc
LIBS = base