bedrest_relay.c

MANTIS是由科罗拉多大学开发的传感器网络嵌入式操作系统。 这是mantis的0.9.5版本的源码。

//  This file is part of MANTIS OS, Operating System
//  See http://mantis.cs.colorado.edu/
//
//  Copyright (C) 2003,2004,2005 University of Colorado, Boulder
//
//  This program is free software; you can redistribute it and/or
//  modify it under the terms of the mos license (see file LICENSE)

/**************************************************************************/
/* File:    relay.c                                                       */
/* Author     Jeff Rose & Brian Shucker: rosejn & [e-mail] */
/*   Date: 03/09/04                                                       */
/* Edited     Charles Gruenwald III : [e-mail]               */
/*   Date: 03/30/04                                                       */
/*                                                                        */
/* Base station app for bionet sensor connected to a host computer over   */
/* a serial link.                                                         */
/**************************************************************************/


#include "msched.h"
#include "com.h"
//#include "config.h"
#include "command_daemon.h"
#include "uart.h"
#include "node_net_event.h"
#include "printf.h"
#include "net.h"
#include "led.h"
#include "dev.h"
#include "clock.h"

static comBuf out_packet;
static comBuf *recv_pkt_radio;
static comBuf *recv_pkt_serial;
static void quick_blink(uint8_t val);

void relay_serial(void)
{
   com_mode (IFACE_SERIAL, IF_LISTEN);
   while (1) {
      recv_pkt_serial = com_recv (IFACE_SERIAL);
      quick_blink(1);
      net_send(recv_pkt_serial, SIMPLE_PROTO_ID, 1, true);
      com_free_buf (recv_pkt_serial);
   }
}

void relay_radio(void)
{
   net_event_t *event;
   bedrest_t *inpacket;
   
   com_mode (IFACE_RADIO, IF_LISTEN);
   while(1) {
      recv_pkt_radio = net_recv(2);
      quick_blink(2);

      event = (net_event_t *)recv_pkt_radio->data;
      inpacket = (bedrest_t *)&(recv_pkt_radio->data[6]);
      
      if(event->to == 0) { //packet meant for base-station..
#ifdef GET_RSSI
	 recv_pkt_radio->data[recv_pkt_radio->size++] = recv_pkt_radio->signal;
#else
	 recv_pkt_radio->data[recv_pkt_radio->size++] = 255;
#endif
	 com_send(IFACE_SERIAL, recv_pkt_radio);
      }
      com_free_buf(recv_pkt_radio);
   }

}


void battery_update(void)
{
   net_event_t *event;
   event = (net_event_t *)out_packet.data;
   event->from = 0;
   event->to = 0;
   event->event = BATTERY;

   while(1) {
      out_packet.size = 8;
      dev_open(DEV_MICA2_BATTERY);
      dev_read(DEV_MICA2_BATTERY, &(out_packet.data[6]), 2);
      dev_close(DEV_MICA2_BATTERY);
      com_send(IFACE_SERIAL, &out_packet);
      mos_thread_sleep(10000);
   }
}

void start(void)
{
   //initialize the network layer and appropriate protocol
   net_init();
   simple_proto_init();

   //start listening threads
   mos_thread_new(relay_radio, 128, PRIORITY_NORMAL);
   mos_thread_new(relay_serial, 128, PRIORITY_NORMAL);

   mos_thread_new(battery_update, 128, PRIORITY_NORMAL);
}

static void quick_blink(uint8_t val)
{
   val &= 3;
   mos_led_on(val);
   mos_thread_sleep(100);
   mos_led_off(val);
}