app.c

针对wsn网络

static inline 
#line 98
short clear_io_bit(char port, char bit);
# 47 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/event_queue.c"
struct timespec;
static inline 


void queue_init(event_queue_t *queue, int fpause);
static 




void queue_insert_event(event_queue_t *queue, event_t *event);
static inline 




event_t *queue_pop_event(event_queue_t *queue);
static inline 
#line 86
int queue_is_empty(event_queue_t *queue);
static inline 






long long queue_peek_event_time(event_queue_t *queue);
static inline 
#line 109
void queue_handle_next_event(event_queue_t *queue);
static inline 
# 43 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/events.c"
void event_default_cleanup(event_t *event);
static 



void event_total_cleanup(event_t *event);
static inline 






void event_cleanup(event_t *fevent);
 
# 11 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/powermod.h"
double *cycles;
 int power_init;
 int prof_on;
 int cpu_prof_on;
# 39 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/hpl.c"
static int clockScales[8] = { -1, 122, 976, 3906, 7812, 15625, 31250, 125000 };
 
static event_t *clockEvents[TOSNODES];
 static uint8_t intervals[TOSNODES];
 static uint8_t scales[TOSNODES];
 static long long setTime[TOSNODES];
 static uint8_t interruptPending[TOSNODES];
static inline 
void  SIG_OUTPUT_COMPARE2_interrupt(void );
static inline 
void TOSH_adc_data_ready(uint16_t data);
static 



void TOSH_clock_set_interval(uint8_t interval);
static 
#line 86
void TOSH_clock_set_rate(char interval, char scale);
static inline 
#line 115
uint8_t TOSH_get_clock_interval(void);
static 







uint8_t TOSH_get_clock0_counter(void);
#line 154
struct timeval;
static inline 
void event_clocktick_handle(event_t *event, 
struct TOS_state *state);
static 
#line 191
void event_clocktick_create(event_t *event, int mote, long long eventTime, int interval);
static inline 
#line 211
void event_clocktick_invalidate(event_t *event);










enum __nesc_unnamed4283 {
  ADC_LATENCY = 200
};
 


static event_t *adcEvents[TOSNODES];
static char adcSamplingRates[TOSNODES];
static inline 
void TOSH_adc_init(void );
static 








void TOSH_adc_sample_port(uint8_t port);
static inline 
#line 272
void TOSH_adc_sample_stop(void );
static inline 



uint16_t get_adc_data(uint8_t port);
static inline 


void  SIG_ADC_signal(void);
static inline 
#line 294
void event_adc_handle(event_t *event, struct TOS_state *state);
static inline 
#line 312
void event_adc_update(event_t *event, int mote, uint8_t port, long long eventTime, int interval);
static inline 






void event_adc_create(event_t *event, int mote, uint8_t port, long long eventTime, int interval);
#line 342
uint8_t radioWaitingState[TOSNODES];
char TOSH_MHSR_start[12] = { 0xf0, 0xf0, 0xf0, 0xff, 0x00, 0xff, 0x0f, 0x00, 0xff, 0x0f, 0x0f, 0x0f };

enum __nesc_unnamed4284 {
  NOT_WAITING = 0, 
  WAITING_FOR_ONE_TO_PASS = 1, 
  WAITING_FOR_ONE_TO_CAPTURE = 2
};
static 
#line 389
uint8_t TOSH_rfm_rx_bit(void );
static inline 







void TOSH_rfm_tx_bit(uint8_t data);
#line 470
void   event_spi_byte_create(event_t *fevent, int mote, long long ftime, int interval, int count);

event_t *spiByteEvents[TOSNODES];

int RADIO_TICKS_PER_EVENT = 100;
# 46 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/dbg.c"
static TOS_dbg_mode_names dbg_nametab[34] = { 
{ "all", DBG_ALL }, { "boot", DBG_BOOT | DBG_ERROR }, { "clock", DBG_CLOCK | DBG_ERROR }, { "task", DBG_TASK | DBG_ERROR }, { "sched", DBG_SCHED | DBG_ERROR }, { "sensor", DBG_SENSOR | DBG_ERROR }, { "led", DBG_LED | DBG_ERROR }, { "crypto", DBG_CRYPTO | DBG_ERROR }, { "route", DBG_ROUTE | DBG_ERROR }, { "am", DBG_AM | DBG_ERROR }, { "crc", DBG_CRC | DBG_ERROR }, { "packet", DBG_PACKET | DBG_ERROR }, { "encode", DBG_ENCODE | DBG_ERROR }, { "radio", DBG_RADIO | DBG_ERROR }, { "logger", DBG_LOG | DBG_ERROR }, { "adc", DBG_ADC | DBG_ERROR }, { "i2c", DBG_I2C | DBG_ERROR }, { "uart", DBG_UART | DBG_ERROR }, { "prog", DBG_PROG | DBG_ERROR }, { "sounder", DBG_SOUNDER | DBG_ERROR }, { "time", DBG_TIME | DBG_ERROR }, { "power", DBG_POWER | DBG_ERROR }, { "sim", DBG_SIM | DBG_ERROR }, { "queue", DBG_QUEUE | DBG_ERROR }, { "simradio", DBG_SIMRADIO | DBG_ERROR }, { "hardware", DBG_HARD | DBG_ERROR }, { "simmem", DBG_MEM | DBG_ERROR }, { "usr1", DBG_USR1 | DBG_ERROR }, { "usr2", DBG_USR2 | DBG_ERROR }, { "usr3", DBG_USR3 | DBG_ERROR }, { "temp", DBG_TEMP | DBG_ERROR }, { "error", DBG_ERROR }, { "none", DBG_NONE }, { (void *)0, DBG_ERROR } };






void dbg_set(TOS_dbg_mode modes);



void dbg_add_mode(const char *name);
#line 84
void dbg_add_modes(const char *modes);








void dbg_init(void );
#line 107
void dbg_help(void );
static 
# 36 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/external_comm.c"
int64_t bswap_64(int64_t n);
#line 83
int commandServerSocket = -1;
int eventServerSocket = -1;
int commandClients[4];
uint8_t batchState[4];
 int eventClients[4];
 uint16_t eventMask;

pthread_t eventAcceptThread;
pthread_t commandReadThread;
pthread_mutex_t eventClientsLock;
pthread_cond_t eventClientsCond;


TOS_Msg external_comm_msgs_[TOSNODES];
TOS_MsgPtr external_comm_buffers_[TOSNODES];
 static int GUI_enabled;
static 
int createServerSocket(short port);
static inline void *eventAcceptThreadFunc(void *arg);
static inline void *commandReadThreadFunc(void *arg);









static int __nesc_nido_resolve(int __nesc_mote, 
char *varname, 
uintptr_t *addr, size_t *size);
static inline 









void initializeSockets(void);
static 
#line 152
int acceptConnection(int servfd);
static 
#line 168
int createServerSocket(short port);
static inline 
#line 225
void waitForGuiConnection(void);
static 
#line 245
int printOtherTime(char *buf, int len, long long int ftime);
static inline 
#line 262
int printTime(char *buf, int len);
static inline 


char *currentTime(void);
static 




void addClient(int *clientSockets, int clifd);
static inline 
#line 286
void sendInitEvent(int clifd);
static inline 
#line 305
void *eventAcceptThreadFunc(void *arg);
#line 339
typedef struct __nesc_unnamed4285 {
  GuiMsg *msg;
  char *payLoad;
} incoming_command_data_t;



void nido_start_mote(uint16_t moteID);
void nido_stop_mote(uint16_t moteID);
TOS_MsgPtr NIDO_received_radio(TOS_MsgPtr packet);
TOS_MsgPtr NIDO_received_uart(TOS_MsgPtr packet);
static inline void set_link_prob_value(uint16_t moteID1, uint16_t moteID2, double prob);
static inline 
void event_command_cleanup(event_t *event);
static inline 




void event_command_in_handle(event_t *event, 
struct TOS_state *state);
static inline void event_command_in_create(event_t *event, 
GuiMsg *msg, 
char *payLoad);
static inline 
#line 382
int processCommand(int clifd, int clidx, GuiMsg *msg, char *payLoad, 
unsigned char **replyMsg, int *replyLen);
static inline 
#line 512
void event_command_in_handle(event_t *event, 
struct TOS_state *state);
static inline 
#line 583
int readTossimCommand(int clifd, int clidx);
static inline 
#line 679
void *commandReadThreadFunc(void *arg);
static 
#line 754
int writeTossimEvent(void *data, int datalen, int clifd);
static 
#line 785
void buildTossimEvent(uint16_t moteID, uint16_t type, long long ftime, void *data, 
unsigned char **msgp, int *lenp);
static 
#line 845
void sendTossimEvent(uint16_t moteID, uint16_t type, long long ftime, void *data);
# 32 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/tos.c"
int signaled = 0;

long long rate_checkpoint_time;
double rate_value;

struct timeval startTime;
struct timeval thisTime;
static inline 
void handle_signal(int sig);
static inline 
#line 52
void init_signals(void );
static inline 
#line 72
double get_rate_value(void);
static inline 


void set_rate_value(double rate);
static inline 


void rate_checkpoint(void);
static inline 




void rate_based_wait(void);
static inline 
# 48 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/adc_model.c"
void random_adc_init(void);
static inline 
uint16_t random_adc_read(int moteID, uint8_t port, long long ftime);
static inline 


adc_model *create_random_adc_model(void);










enum __nesc_unnamed4286 {
  ADC_NUM_PORTS_PER_NODE = 256
};

uint16_t adcValues[TOSNODES][ADC_NUM_PORTS_PER_NODE];
pthread_mutex_t adcValuesLock;
static inline 
void generic_adc_init(void);
static inline 









uint16_t generic_adc_read(int moteID, uint8_t port, long long ftime);
static inline 
#line 99
adc_model *create_generic_adc_model(void);
static inline 





void set_adc_value(int moteID, uint8_t port, uint16_t value);
# 49 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/spatial_model.c"
point3D *points;
static inline 
void simple_spatial_init(void);
static inline 
#line 63
void simple_spatial_get_position(int moteID, long long ftime, point3D *point);
static inline 





spatial_model *create_simple_spatial_model(void);
# 62 "/usr/include/cygwin/stat.h" 3
struct stat {

  dev_t st_dev;
  ino_t st_ino;
  mode_t st_mode;
  nlink_t st_nlink;
  uid_t st_uid;
  gid_t st_gid;
  dev_t st_rdev;
  off_t st_size;
  timestruc_t st_atim;
  timestruc_t st_mtim;
  timestruc_t st_ctim;
  blksize_t st_blksize;
  blkcnt_t st_blocks;
  long st_spare4[2];
};
# 139 "/usr/include/sys/fcntl.h"
struct flock {
  short l_type;
  short l_whence;
  long l_start;
  long l_len;
  short l_pid;
  short l_xxx;
};



struct eflock {
  short l_type;
  short l_whence;
  long l_start;
  long l_len;
  short l_pid;
  short l_xxx;
  long l_rpid;
  long l_rsys;
};






extern int open(const char *, int , ...);
# 52 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/eeprom.c"
static char *local_filename;
static int numMotes = 0;
static int moteSize = 0;
static int initialized = 0;
static int local_fd = -1;
static 
int createEEPROM(char *file, int motes, int eempromBytes);
static inline 
#line 91
int anonymousEEPROM(int fnumMotes, int eepromSize);
static inline 
#line 104
int namedEEPROM(char *name, int fnumMotes, int eepromSize);
# 59 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/system/sched.c"
typedef struct __nesc_unnamed4287 {
  void (*tp)(void);
} TOSH_sched_entry_T;

enum __nesc_unnamed4288 {






  TOSH_MAX_TASKS = 8, 

  TOSH_TASK_BITMASK = TOSH_MAX_TASKS - 1
};

volatile TOSH_sched_entry_T TOSH_queue[TOSH_MAX_TASKS];
uint8_t TOSH_sched_full;
volatile uint8_t TOSH_sched_free;
#line 102
bool  TOS_post(void (*tp)(void));
static 
#line 134
bool TOSH_run_next_task(void);
static 
# 149 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/system/tos.h"
void *nmemcpy(void *to, const void *from, size_t n);
# 28 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/system/Ident.h"
enum __nesc_unnamed4289 {

  IDENT_MAX_PROGRAM_NAME_LENGTH = 10
};

typedef struct __nesc_unnamed4290 {

  uint32_t unix_time;
  uint32_t user_hash;
  char program_name[IDENT_MAX_PROGRAM_NAME_LENGTH];
} Ident_t;
# 33 "Surge.h"
int INITIAL_TIMER_RATE = 1000;
#line 51
typedef struct SurgeMsg {
  uint8_t type;
  uint16_t reading;
} 

__attribute((packed))  SurgeMsg;

enum __nesc_unnamed4291 {
  AM_SURGEMSG = 17
};
# 33 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/PCRadio.h"
typedef struct __nesc_unnamed4292 {
  TOS_MsgPtr msg;
  int success;
} uart_send_done_data_t;

enum __nesc_unnamed4293 {
  UART_SEND_DELAY = 1600
};



void NIDO_uart_send_done(TOS_MsgPtr fmsg, result_t fsuccess);
static inline 
void event_uart_write_create(event_t *uevent, int mote, long long utime, TOS_MsgPtr msg, result_t success);
static inline 
void event_uart_write_handle(event_t *uevent, 
struct TOS_state *state);
static inline 
#line 61
void event_uart_write_create(event_t *uevent, int mote, long long utime, TOS_MsgPtr msg, result_t success);
static inline 
#line 77
void TOSH_uart_send(TOS_MsgPtr msg);
static 
# 47 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/adjacency_list.c"
link_t *allocate_link(int mote);
static 
#line 78
int adjacency_list_init(void);
# 61 "C:/tinyos/cygwin/opt/tinyos-1.x/tos/platform/pc/rfm_model.c"
char transmitting[TOSNODES];
int radio_active[TOSNODES];
link_t *radio_connectivity[TOSNODES];
pthread_mutex_t radioConnectivityLock;





short radio_heard[TOSNODES];

bool radio_idle_state[TOSNODES];
double noise_prob = 0;

short IDLE_STATE_MASK = 0xffff;
char *lossyFileName = "lossy.nss";
static inline 
bool simple_connected(int moteID1, int moteID2);
static inline 


void simple_init(void);
static inline 








void simple_transmit(int moteID, char bit);
static inline 







void simple_stops_transmit(int moteID);
static inline 









char simple_hears(int moteID);
static inline 
#line 124
link_t *simple_neighbors(int moteID);
static inline 






rfm_model *create_simple_model(void);
static 
#line 194
void static_one_cell_init(void);
static inline 
#line 313
bool lossy_connected(int moteID1, int moteID2);
static inline 
#line 336
void lossy_transmit(int moteID, char bit);
static inline 
#line 357
void lossy_stop_transmit(int moteID);