parent
b55646e1b0
commit
f0ec8b27c1
|
@ -104,7 +104,7 @@ class Kernel::Ipc_node
|
||||||
/* update state */
|
/* update state */
|
||||||
if (_state != PREPARE_AND_AWAIT_REPLY) { _state = INACTIVE; }
|
if (_state != PREPARE_AND_AWAIT_REPLY) { _state = INACTIVE; }
|
||||||
else { _state = PREPARE_REPLY; }
|
else { _state = PREPARE_REPLY; }
|
||||||
_await_ipc_succeeded(_inbuf.size);
|
_await_ipc_succeeded();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -115,7 +115,7 @@ class Kernel::Ipc_node
|
||||||
/* directly receive request if we've awaited it */
|
/* directly receive request if we've awaited it */
|
||||||
if (_state == AWAIT_REQUEST) {
|
if (_state == AWAIT_REQUEST) {
|
||||||
_receive_request(r);
|
_receive_request(r);
|
||||||
_await_ipc_succeeded(_inbuf.size);
|
_await_ipc_succeeded();
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
/* cannot receive yet, so queue request */
|
/* cannot receive yet, so queue request */
|
||||||
|
@ -183,10 +183,8 @@ class Kernel::Ipc_node
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* IPC node returned from waiting due to message receipt
|
* IPC node returned from waiting due to message receipt
|
||||||
*
|
|
||||||
* \param s size of incoming message
|
|
||||||
*/
|
*/
|
||||||
virtual void _await_ipc_succeeded(size_t const s) = 0;
|
virtual void _await_ipc_succeeded() = 0;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* IPC node returned from waiting due to cancellation
|
* IPC node returned from waiting due to cancellation
|
||||||
|
|
|
@ -71,7 +71,7 @@ void Thread::_receive_signal(void * const base, size_t const size)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
void Thread::_await_ipc_succeeded(size_t const s)
|
void Thread::_await_ipc_succeeded()
|
||||||
{
|
{
|
||||||
switch (_state) {
|
switch (_state) {
|
||||||
case AWAITS_IPC:
|
case AWAITS_IPC:
|
||||||
|
|
|
@ -280,7 +280,7 @@ class Kernel::Thread
|
||||||
** Ipc_node **
|
** Ipc_node **
|
||||||
**************/
|
**************/
|
||||||
|
|
||||||
void _await_ipc_succeeded(size_t const s);
|
void _await_ipc_succeeded();
|
||||||
void _await_ipc_failed();
|
void _await_ipc_failed();
|
||||||
|
|
||||||
public:
|
public:
|
||||||
|
|
Loading…
Reference in New Issue