PE Project 1 - goofcode/UR GitHub Wiki

#define NETSTACK_CONF_RDC nullrdc_driver
#define NETSTACK_CONF_MAC nullmac_driver
#define NETSTACK_CONF_FRAMER framer_nullmac

// settings for packet
#define MAX_PKT_NUM 1000
#define PKT_SIZE 10

// settings for sender
#define TX_DELAY_SEC 0

// settings for receiver
#define EXPECTED_TX_DURATION_SEC 10

#include "contiki.h"
#include "net/rime/rime.h"

#include <stdio.h> /* For printf() */

#define MAX_PKT_NUM 1000
#define PKT_SIZE 117
#define CHANNEL_NUM 129

#define TX_DELAY 0
#define WAIT_RX_DELAY 5

/*---------------------------------------------------------------------------*/
PROCESS(project_1_sender, "sender process");
AUTOSTART_PROCESSES(&project_1_sender);
/*---------------------------------------------------------------------------*/

static void
broadcast_recv(struct broadcast_conn *c, const linkaddr_t *from)
{
  /* do nothing */
}
static const struct broadcast_callbacks recv_callbacks = {broadcast_recv};
static struct broadcast_conn broadcast;

PROCESS_THREAD(project_1_sender, ev, data)
{
  static uint8_t payload[PKT_SIZE] = {0,};
  static int count = 0;
  static struct etimer et;
  static clock_time_t begin_time, end_time;

  PROCESS_EXITHANDLER(broadcast_close(&broadcast));
  PROCESS_BEGIN();

  printf("Wait for receiver to start\n");
  etimer_set(&et, WAIT_RX_DELAY * CLOCK_SECOND);
  PROCESS_WAIT_EVENT_UNTIL(etimer_expired(&et));

  broadcast_open(&broadcast, CHANNEL_NUM, &recv_callbacks);

  printf("Start sending...\n");
  begin_time = clock_time();

  while (count < MAX_PKT_NUM){

    packetbuf_copyfrom(payload, PKT_SIZE);
    broadcast_send(&broadcast);

    count++;

#if TX_DELAY == 0
    PROCESS_PAUSE();
#else
    etimer_set(&et, TX_DELAY_SEC);
    PROCESS_WAIT_EVENT_UNTIL(etimer_expired(&et));
#endif
  }

  end_time = clock_time();

  printf("%d packets (length: %d bytes) sent in %lu clocks (CLOCK_SECOND: %lu)\n", 
    count, PKT_SIZE, end_time-begin_time, CLOCK_SECOND);

  PROCESS_END();
}

#include "contiki.h"
#include "net/rime/rime.h"

#include <stdio.h> /* For printf() */

#define CHANNEL_NUM 129

#define EXPECTED_TX_DURATION 30

/*---------------------------------------------------------------------------*/
PROCESS(project_1_receiver, "receiver process");
AUTOSTART_PROCESSES(&project_1_receiver);
/*---------------------------------------------------------------------------*/

static int count = 0;
static clock_time_t begin_time, end_time;

static void
broadcast_recv(struct broadcast_conn *c, const linkaddr_t *from)
{
  // if this is first packet
  if(count == 0) 
    begin_time = clock_time(); 
  
  end_time = clock_time();

  count++;
}
static const struct broadcast_callbacks recv_callbacks = {broadcast_recv};
static struct broadcast_conn broadcast;

PROCESS_THREAD(project_1_receiver, ev, data)
{
  static struct etimer et;

  PROCESS_EXITHANDLER(broadcast_close(&broadcast);)
  PROCESS_BEGIN();

  broadcast_open(&broadcast, CHANNEL_NUM, &recv_callbacks);

  etimer_set(&et, EXPECTED_TX_DURATION * CLOCK_SECOND);
  PROCESS_WAIT_EVENT_UNTIL(etimer_expired(&et));

  printf("%d packets received in %lu (CLOCK_SECOND: %lu) \n", 
    count, end_time-begin_time, CLOCK_SECOND);

  PROCESS_END();
}