@@ -44,24 +44,9 @@ TransportArbitrator::~TransportArbitrator(void)
4444 freeClientList (m_clientFreeList);
4545}
4646
47- void TransportArbitrator::setCrc16 (Crc16 *crcImpl )
47+ uint8_t TransportArbitrator::reserveHeaderSize ( void )
4848{
49- erpc_assert (crcImpl != NULL );
50- erpc_assert (m_sharedTransport != NULL );
51- m_sharedTransport->setCrc16 (crcImpl);
52- }
53-
54- Crc16 *TransportArbitrator::getCrc16 (void )
55- {
56- erpc_assert (m_sharedTransport != NULL );
57- return m_sharedTransport->getCrc16 ();
58- }
59-
60- bool TransportArbitrator::hasMessage (void )
61- {
62- erpc_assert ((m_sharedTransport != NULL ) && (" shared transport is not set" != NULL ));
63-
64- return m_sharedTransport->hasMessage ();
49+ return m_sharedTransport->reserveHeaderSize ();
6550}
6651
6752erpc_status_t TransportArbitrator::receive (MessageBuffer *message)
@@ -151,6 +136,46 @@ erpc_status_t TransportArbitrator::send(MessageBuffer *message)
151136 return m_sharedTransport->send (message);
152137}
153138
139+ bool TransportArbitrator::hasMessage (void )
140+ {
141+ erpc_assert ((m_sharedTransport != NULL ) && (" shared transport is not set" != NULL ));
142+
143+ return m_sharedTransport->hasMessage ();
144+ }
145+
146+ void TransportArbitrator::setCrc16 (Crc16 *crcImpl)
147+ {
148+ erpc_assert (crcImpl != NULL );
149+ erpc_assert (m_sharedTransport != NULL );
150+ m_sharedTransport->setCrc16 (crcImpl);
151+ }
152+
153+ Crc16 *TransportArbitrator::getCrc16 (void )
154+ {
155+ erpc_assert (m_sharedTransport != NULL );
156+ return m_sharedTransport->getCrc16 ();
157+ }
158+
159+ void TransportArbitrator::setSharedTransport (Transport *shared)
160+ {
161+ m_sharedTransport = shared;
162+ }
163+
164+ Transport *TransportArbitrator::getSharedTransport (void )
165+ {
166+ return m_sharedTransport;
167+ }
168+
169+ void TransportArbitrator::setCodec (Codec *codec)
170+ {
171+ m_codec = codec;
172+ }
173+
174+ Codec *TransportArbitrator::getCodec (void )
175+ {
176+ return m_codec;
177+ }
178+
154179TransportArbitrator::client_token_t TransportArbitrator::prepareClientReceive (RequestContext &request)
155180{
156181 PendingClientInfo *info = addPendingClient ();
0 commit comments