#include "AM.h"
-generic module AMQueueImplP(int numClients) {
+generic module AMQueueImplP(int numClients) @safe() {
provides interface Send[uint8_t client];
uses{
interface AMSend[am_id_t id];
implementation {
typedef struct {
- message_t* msg;
+ message_t* ONE_NOK msg;
} queue_entry_t;
uint8_t current = numClients; // mark as empty
}
}
- void sendDone(uint8_t last, message_t *msg, error_t err) {
+ void sendDone(uint8_t last, message_t * ONE msg, error_t err) {
queue[last].msg = NULL;
tryToSend();
signal Send.sendDone[last](msg, err);
default event void Send.sendDone[uint8_t id](message_t* msg, error_t err) {
// Do nothing
}
+ default command error_t AMSend.send[uint8_t id](am_addr_t am_id, message_t* msg, uint8_t len) {
+ return FAIL;
+ }
}