/** * \addtogroup rimeruc * @{ */ /* * Copyright (c) 2006, Swedish Institute of Computer Science. * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * 3. Neither the name of the Institute nor the names of its contributors * may be used to endorse or promote products derived from this software * without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE INSTITUTE AND CONTRIBUTORS ``AS IS'' AND * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE INSTITUTE OR CONTRIBUTORS BE LIABLE * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF * SUCH DAMAGE. * * This file is part of the Contiki operating system. * * $Id: ruc.c,v 1.19 2008/02/25 02:14:35 adamdunkels Exp $ */ /** * \file * Reliable unicast * \author * Adam Dunkels */ #include "net/rime/ruc.h" #include "net/rime/neighbor.h" #include "net/rime.h" #include #define RUC_PACKET_ID_BITS 2 #define REXMIT_TIME CLOCK_SECOND #define TYPE_DATA 0 #define TYPE_ACK 1 static const struct rimebuf_attrlist attributes[] = { RUC_ATTRIBUTES RIMEBUF_ATTR_LAST }; #define DEBUG 0 #if DEBUG #include #define PRINTF(...) printf(__VA_ARGS__) #else #define PRINTF(...) #endif /*---------------------------------------------------------------------------*/ static void sent_by_suc(struct suc_conn *suc) { struct ruc_conn *c = (struct ruc_conn *)suc; if(c->rxmit != 0) { RIMESTATS_ADD(rexmit); PRINTF("%d.%d: ruc: packet %u resent %u\n", rimeaddr_node_addr.u8[0], rimeaddr_node_addr.u8[1], rimebuf_attr(RIMEBUF_ATTR_PACKET_ID), c->rxmit); } c->rxmit++; if(c->rxmit >= c->max_rxmit) { RIMESTATS_ADD(timedout); suc_cancel(&c->c); if(c->u->timedout) { c->u->timedout(c, suc_receiver(&c->c), c->rxmit); } PRINTF("%d.%d: ruc: packet %d timed out\n", rimeaddr_node_addr.u8[0],rimeaddr_node_addr.u8[1], c->sndnxt); } else { int shift; shift = c->rxmit > 4? 4: c->rxmit; suc_set_timer(&c->c, (REXMIT_TIME) << shift); } } /*---------------------------------------------------------------------------*/ static void recv_from_suc(struct suc_conn *suc, rimeaddr_t *from) { struct ruc_conn *c = (struct ruc_conn *)suc; /* struct ruc_hdr *hdr = rimebuf_dataptr();*/ PRINTF("%d.%d: ruc: recv_from_suc from %d.%d type %d seqno %d\n", rimeaddr_node_addr.u8[0],rimeaddr_node_addr.u8[1], from->u8[0], from->u8[1], rimebuf_attr(RIMEBUF_ATTR_PACKET_TYPE), rimebuf_attr(RIMEBUF_ATTR_PACKET_ID)); if(rimebuf_attr(RIMEBUF_ATTR_PACKET_TYPE) == RIMEBUF_ATTR_PACKET_TYPE_ACK) { if(rimebuf_attr(RIMEBUF_ATTR_PACKET_ID) == c->sndnxt) { RIMESTATS_ADD(ackrx); PRINTF("%d.%d: ruc: ACKed %d\n", rimeaddr_node_addr.u8[0], rimeaddr_node_addr.u8[1], rimebuf_attr(RIMEBUF_ATTR_PACKET_ID)); c->sndnxt = (c->sndnxt + 1) % (1 << RUC_PACKET_ID_BITS); suc_cancel(&c->c); if(c->u->sent != NULL) { c->u->sent(c, suc_receiver(&c->c), c->rxmit); } } else { PRINTF("%d.%d: ruc: received bad ACK %d for %d\n", rimeaddr_node_addr.u8[0],rimeaddr_node_addr.u8[1], rimebuf_attr(RIMEBUF_ATTR_PACKET_ID), c->sndnxt); RIMESTATS_ADD(badackrx); } } else if(rimebuf_attr(RIMEBUF_ATTR_PACKET_TYPE) == RIMEBUF_ATTR_PACKET_TYPE_DATA) { /* int send_ack = 1;*/ uint16_t packet_seqno; struct queuebuf *q; RIMESTATS_ADD(reliablerx); PRINTF("%d.%d: ruc: got packet %d\n", rimeaddr_node_addr.u8[0],rimeaddr_node_addr.u8[1], rimebuf_attr(RIMEBUF_ATTR_PACKET_ID)); packet_seqno = rimebuf_attr(RIMEBUF_ATTR_PACKET_ID); /* rimebuf_hdrreduce(sizeof(struct ruc_hdr));*/ q = queuebuf_new_from_rimebuf(); PRINTF("%d.%d: ruc: Sending ACK to %d.%d for %d\n", rimeaddr_node_addr.u8[0],rimeaddr_node_addr.u8[1], from->u8[0], from->u8[1], packet_seqno); rimebuf_clear(); /* rimebuf_hdralloc(sizeof(struct ruc_hdr)); hdr = rimebuf_hdrptr(); hdr->type = TYPE_ACK; hdr->seqno = packet_seqno;*/ rimebuf_set_attr(RIMEBUF_ATTR_PACKET_TYPE, RIMEBUF_ATTR_PACKET_TYPE_ACK); rimebuf_set_attr(RIMEBUF_ATTR_PACKET_ID, packet_seqno); suc_send(&c->c, from); RIMESTATS_ADD(acktx); queuebuf_to_rimebuf(q); queuebuf_free(q); if(c->u->recv != NULL) { c->u->recv(c, from, packet_seqno); } } } /*---------------------------------------------------------------------------*/ static const struct suc_callbacks ruc = {recv_from_suc, sent_by_suc}; /*---------------------------------------------------------------------------*/ void ruc_open(struct ruc_conn *c, uint16_t channel, const struct ruc_callbacks *u) { suc_open(&c->c, channel, &ruc); channel_set_attributes(channel, attributes); c->u = u; c->rxmit = 0; c->sndnxt = 0; } /*---------------------------------------------------------------------------*/ void ruc_close(struct ruc_conn *c) { suc_close(&c->c); } /*---------------------------------------------------------------------------*/ int ruc_send(struct ruc_conn *c, rimeaddr_t *receiver, uint8_t max_retransmissions) { rimebuf_set_attr(RIMEBUF_ATTR_RELIABLE, 1); rimebuf_set_attr(RIMEBUF_ATTR_PACKET_TYPE, RIMEBUF_ATTR_PACKET_TYPE_DATA); rimebuf_set_attr(RIMEBUF_ATTR_PACKET_ID, c->sndnxt); c->max_rxmit = max_retransmissions; c->rxmit = 0; RIMESTATS_ADD(reliabletx); PRINTF("%d.%d: ruc: sending packet %d\n", rimeaddr_node_addr.u8[0],rimeaddr_node_addr.u8[1], c->sndnxt); return suc_send_stubborn(&c->c, receiver, REXMIT_TIME); } /*---------------------------------------------------------------------------*/ /** @} */