/* vim: set expandtab ts=4 sw=4: */
/*
* You may redistribute this program and/or modify it under the terms of
* the GNU General Public License as published by the Free Software Foundation,
* either version 3 of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see .
*/
#ifndef Iface_H
#define Iface_H
#include
#include "wire/Message.h"
#include "util/Defined.h"
struct Iface;
/**
* @param thisInterface the interface which contains the sendMessage function pointer.
* @param message the message
*/
typedef struct Iface* (* Iface_Callback)(struct Message* message, struct Iface* thisInterface);
#define Iface_DEFUN __attribute__ ((warn_unused_result)) struct Iface*
struct Iface
{
/** Send a message through this interface. */
Iface_Callback send;
#ifdef PARANOIA
/** This is for checking currentMsg Iface_next() has not been called incorrectly. */
struct Message* currentMsg;
#endif
/** Interface to which this one is connected (if connected) */
struct Iface* connectedIf;
};
/**
* Send a message to an Iface.
* Whatever interface has been *plumbed* to this interface using Iface_plumb() will receive
* the message. If you are in an Iface_Callback function, you must not use this function to
* forward the message which you have received as your input, to do so will cause a runtime
* assertion error, in order to forward the message which you received, you must use Iface_next()
* and it must be a tail-call.
*/
static inline void Iface_send(struct Iface* iface, struct Message* msg)
{
do {
struct Iface* conn = iface->connectedIf;
#ifdef PARANOIA
Assert_true(conn);
Assert_true(conn->send);
Assert_true(msg);
struct Message* currentMsg = conn->currentMsg;
msg->currentIface = conn;
conn->currentMsg = msg;
#endif
iface = conn->send(msg, conn);
#ifdef PARANOIA
msg->currentIface = NULL;
conn->currentMsg = currentMsg;
#endif
if (!Defined(Iface_OPTIMIZE)) {
Assert_true(!iface);
}
} while (iface);
}
/**
* Forward a message from inside of an Iface_Callback function.
* This function must be a tail-call, you must return the value returned to you.
* If you do anything between the call to this function and your return of it's return value,
* the order in which that thing happens is undefined.
*
* Consider the following (bad) code:
* struct Iface* retVal = Iface_next(iface, msg);
* x++;
* return retVal;
*
* If Iface_OPTIMIZE is enabled, it becomes equivilant to:
* x++;
* struct Iface* retVal = Iface_next(iface, msg);
* return retVal;
*
* So simplify your life and follow the basic rule of always returning directly the value
* from this function, IE: return Iface_next(iface, msg);
*/
static inline Iface_DEFUN Iface_next(struct Iface* iface, struct Message* msg)
{
#ifdef PARANOIA
struct Iface* conn = iface->connectedIf;
struct Message* currentMsg = conn->currentMsg;
Assert_true(msg->currentIface);
Assert_true(msg->currentIface->currentMsg == msg);
msg->currentIface->currentMsg = NULL;
#endif
if (Defined(Iface_OPTIMIZE)) {
#ifdef PARANOIA
msg->currentIface = conn;
conn->currentMsg = msg;
#endif
return iface;
}
#ifdef PARANOIA
// done inside of Iface_send()
msg->currentIface = NULL;
conn->currentMsg = NULL;
#endif
Iface_send(iface, msg);
#ifdef PARANOIA
conn->currentMsg = currentMsg;
#endif
return NULL;
}
/**
* Call a function which might use Iface_next()
* This macro will call a function, passing it a message and other arguments, if the function
* you are calling might use Iface_next(), you must call it with this macro instead of calling
* it directly.
* If you are calling from a Iface_Callback function, you must not use this function to call
* the next function with the message passed to you. In that case just call the function directly.
*/
#ifdef PARANOIA
#define Iface_CALL(func, msg, ...) \
do { \
Assert_true(!msg->currentIface); \
struct Iface Iface_y = { .currentMsg = msg }; \
msg->currentIface = &Iface_y; \
struct Iface* Iface_x = func(msg, __VA_ARGS__); \
msg->currentIface = NULL; \
if (Iface_x) { Iface_send(Iface_x, msg); } \
} while (0)
// CHECKFILES_IGNORE missing ;
#else
#define Iface_CALL(func, msg, ...) \
do { \
struct Iface* Iface_x = func(msg, __VA_ARGS__); \
if (Iface_x) { Iface_send(Iface_x, msg); } \
} while (0)
// CHECKFILES_IGNORE missing ;
#endif
static inline void Iface_plumb(struct Iface* a, struct Iface* b)
{
Assert_true(!a->connectedIf);
Assert_true(!b->connectedIf);
a->connectedIf = b;
b->connectedIf = a;
}
static inline void Iface_unplumb(struct Iface* a, struct Iface* b)
{
Assert_true(a->connectedIf == b);
Assert_true(b->connectedIf == a);
a->connectedIf = NULL;
b->connectedIf = NULL;
}
#endif