genode/repos/os/include/event_session/client.h

95 lines
1.8 KiB
C
Raw Normal View History

2020-07-02 17:21:22 +00:00
/*
* \brief Client-side event session interface
* \author Norman Feske
* \date 2020-07-02
*/
/*
* Copyright (C) 2020 Genode Labs GmbH
*
* This file is part of the Genode OS framework, which is distributed
* under the terms of the GNU Affero General Public License version 3.
*/
#ifndef _INCLUDE__EVENT_SESSION__CLIENT_H_
#define _INCLUDE__EVENT_SESSION__CLIENT_H_
#include <util/noncopyable.h>
#include <event_session/event_session.h>
#include <base/attached_dataspace.h>
#include <base/rpc_client.h>
#include <input/event.h>
namespace Event { struct Session_client; }
class Event::Session_client : public Genode::Rpc_client<Session>
{
private:
Genode::Attached_dataspace _ds;
public:
Session_client(Genode::Region_map &local_rm,
Genode::Capability<Session> session)
:
Genode::Rpc_client<Session>(session),
_ds(local_rm, call<Rpc_dataspace>())
{ }
class Batch : Genode::Noncopyable
{
private:
friend class Session_client;
Session_client &_session;
struct {
Input::Event * const events;
Genode::size_t const max;
} _buffer;
unsigned _count = 0;
void _submit()
{
if (_count)
_session.call<Rpc_submit_batch>(_count);
_count = 0;
}
Batch(Session_client &session)
:
_session(session),
_buffer({ .events = session._ds.local_addr<Input::Event>(),
.max = session._ds.size() / sizeof(Input::Event) })
{ }
~Batch() { _submit(); }
public:
void submit(Input::Event const &event)
{
if (_count == _buffer.max)
_submit();
if (_count < _buffer.max)
_buffer.events[_count++] = event;
}
};
template <typename FN>
void with_batch(FN const &fn)
{
Batch batch { *this };
fn(batch);
}
};
#endif /* _INCLUDE__EVENT_SESSION__CLIENT_H_ */