genode/os/include/packet_stream_rx/client.h
2012-01-03 15:35:05 +01:00

67 lines
1.9 KiB
C++

/*
* \brief Client-side interface for packet-stream transmission
* \author Norman Feske
* \date 2010-03-01
*/
/*
* Copyright (C) 2010-2012 Genode Labs GmbH
*
* This file is part of the Genode OS framework, which is distributed
* under the terms of the GNU General Public License version 2.
*/
#ifndef _INCLUDE__PACKET_STREAM_RX__CLIENT_H_
#define _INCLUDE__PACKET_STREAM_RX__CLIENT_H_
#include <packet_stream_rx/packet_stream_rx.h>
#include <base/rpc_client.h>
namespace Packet_stream_rx {
template <typename CHANNEL>
class Client : public Genode::Rpc_client<CHANNEL>
{
private:
typename CHANNEL::Sink _sink;
/*
* Type shortcuts
*/
typedef Genode::Rpc_client<CHANNEL> Base;
typedef typename Base::Rpc_dataspace Rpc_dataspace;
typedef typename Base::Rpc_packet_avail Rpc_packet_avail;
typedef typename Base::Rpc_ready_to_ack Rpc_ready_to_ack;
typedef typename Base::Rpc_ready_to_submit Rpc_ready_to_submit;
typedef typename Base::Rpc_ack_avail Rpc_ack_avail;
public:
/**
* Constructor
*/
Client(Genode::Capability<CHANNEL> channel_cap) :
Genode::Rpc_client<CHANNEL>(channel_cap),
_sink(Base::template call<Rpc_dataspace>())
{
/* wire data-flow signals for the packet receiver */
_sink.register_sigh_ack_avail(Base::template call<Rpc_ack_avail>());
_sink.register_sigh_ready_to_submit(Base::template call<Rpc_ready_to_submit>());
sigh_ready_to_ack(_sink.sigh_ready_to_ack());
sigh_packet_avail(_sink.sigh_packet_avail());
}
void sigh_ready_to_ack(Genode::Signal_context_capability sigh) {
Base::template call<Rpc_ready_to_ack>(sigh); }
void sigh_packet_avail(Genode::Signal_context_capability sigh) {
Base::template call<Rpc_packet_avail>(sigh); }
typename CHANNEL::Sink *sink() { return &_sink; }
};
}
#endif /* _INCLUDE__PACKET_STREAM_RX__CLIENT_H_ */