app.c

来自「tinyos最新版」· C语言 代码 · 共 3,462 行 · 第 1/5 页

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:/PROGRA~1/UCB/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:/PROGRA~1/UCB/cygwin/opt/tinyos-1.x/tos/platform/pc/powermod.h"
double *cycles;
 int power_init;
 int prof_on;
 int cpu_prof_on;
# 39 "C:/PROGRA~1/UCB/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 





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_unnamed4287 {
  ADC_LATENCY = 200
};
#line 345
enum __nesc_unnamed4288 {
  NOT_WAITING = 0, 
  WAITING_FOR_ONE_TO_PASS = 1, 
  WAITING_FOR_ONE_TO_CAPTURE = 2
};
#line 470
void   event_spi_byte_create(event_t *fevent, int mote, long long ftime, int interval, int count);
# 46 "C:/PROGRA~1/UCB/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:/PROGRA~1/UCB/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 
#line 125
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_unnamed4289 {
  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:/PROGRA~1/UCB/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:/PROGRA~1/UCB/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_unnamed4290 {
  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:/PROGRA~1/UCB/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];
};
# 152 "/usr/include/sys/fcntl.h" 3
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;
};
# 168 "/usr/include/sys/fcntl.h"
extern int open(const char *, int , ...);
# 52 "C:/PROGRA~1/UCB/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:/PROGRA~1/UCB/cygwin/opt/tinyos-1.x/tos/system/sched.c"
typedef struct __nesc_unnamed4291 {
  void (*tp)(void);
} TOSH_sched_entry_T;

enum __nesc_unnamed4292 {






  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 92
bool TOS_post(void (*tp)(void));
#line 106
bool  TOS_post(void (*tp)(void));
static 
#line 140
bool TOSH_run_next_task(void);
static inline 
# 149 "C:/PROGRA~1/UCB/cygwin/opt/tinyos-1.x/tos/system/tos.h"
void *nmemcpy(void *to, const void *from, size_t n);
# 28 "C:/PROGRA~1/UCB/cygwin/opt/tinyos-1.x/tos/system/Ident.h"
enum __nesc_unnamed4293 {

  IDENT_MAX_PROGRAM_NAME_LENGTH = 17
};

typedef struct __nesc_unnamed4294 {

  uint32_t unix_time;
  uint32_t user_hash;
  char program_name[IDENT_MAX_PROGRAM_NAME_LENGTH];
} Ident_t;
# 33 "C:/PROGRA~1/UCB/cygwin/opt/tinyos-1.x/tos/platform/pc/PCRadio.h"
typedef struct __nesc_unnamed4295 {
  TOS_MsgPtr msg;
  int success;
} uart_send_done_data_t;

enum __nesc_unnamed4296 {
  UART_SEND_DELAY = 1600
};
static 
# 47 "C:/PROGRA~1/UCB/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:/PROGRA~1/UCB/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);
static inline 
#line 371
char lossy_hears(int moteID);
static inline 
#line 392
int read_lossy_entry(FILE *file, int *mote_one, int *mote_two, double *loss);
static inline 
#line 471
void lossy_init(void);
static inline 
#line 512
link_t *lossy_neighbors(int moteID);
static inline 






rfm_model *create_lossy_model(char *file);
static inline 
#line 550
void set_link_prob_value(uint16_t moteID1, uint16_t moteID2, double prob);
# 57 "C:/PROGRA~1/UCB/cygwin/opt/tinyos-1.x/tos/platform/pc/packet_sim.c"
int byteTransmitTime = 8 * 104 * 2;


int backoffLow = 10 * (8 * 104);
int backoffHigh = 20 * (8 * 104);
int txChangeLatency = 30 * (8 * 104);
int preambleLength = 20;
int headerLength = 7;


struct IncomingMsg;

typedef struct IncomingMsg {
  TOS_Msg msg;
  struct IncomingMsg *next;
} IncomingMsg;

TOS_MsgPtr packet_transmitting[TOSNODES];
IncomingMsg *incoming[TOSNODES];
link_t *cc1000_connectivity[TOSNODES];
static 

void event_backoff_create(event_t *event, int node, long long eventTime);
void   event_backoff_handle(event_t *event, struct TOS_state *state);

void   event_start_transmit_handle(event_t *event, struct TOS_state *state);
static inline void event_start_transmit_create(event_t *event, int node, long long eventTime);

void   event_receive_packet_create(event_t *event, int node, long long eventTime, IncomingMsg *msg);
void   event_receive_packet_handle(event_t *event, struct TOS_state *state);

void   event_send_packet_done_create(event_t *event, int node, long long eventTime);
void   event_send_packet_done_handle(event_t *event, struct TOS_state *state);
static inline 
void packet_sim_init(void);
static 
#line 130
void event_backoff_create(event_t *event, int node, long long eventTime);










void   event_backoff_handle(event_t *event, struct TOS_state *state);
static inline 
#line 155
void event_start_transmit_create(event_t *event, int node, long long eventTime);
static 








void corruptPacket(IncomingMsg *msg, int src, int dest);








void   event_start_transmit_handle(event_t *event, struct TOS_state *state);
#line 228
void   event_receive_packet_create(event_t *event, int node, long long eventTime, IncomingMsg *msg);










void   event_receive_packet_handle(event_t *event, struct TOS_state *state);
#line 266
void   event_send_packet_done_create(event_t *event, int node, long long eventTime);










void   event_send_packet_done_handle(event_t *event, struct TOS_state *state);
# 45 "C:/PROGRA~1/UCB/cygwin/opt/tinyos-1.x/tos/sensorboards/micasb/sensorboard.h"
enum __nesc_unnamed4297 {
  TOSH_ACTUAL_PHOTO_PORT = 1, 
  TOSH_ACTUAL_TEMP_PORT = 1, 
  TOSH_ACTUAL_MIC_PORT = 2, 
  TOSH_ACTUAL_ACCEL_X_PORT = 3, 
  TOSH_ACTUAL_ACCEL_Y_PORT = 4, 
  TOSH_ACTUAL_MAG_X_PORT = 6, 
  TOSH_ACTUAL_MAG_Y_PORT = 5
};

enum __nesc_unnamed4298 {
  TOS_ADC_PHOTO_PORT = 1, 
  TOS_ADC_TEMP_PORT = 2, 
  TOS_ADC_MIC_PORT = 3, 
  TOS_ADC_ACCEL_X_PORT = 4, 
  TOS_ADC_ACCEL_Y_PORT = 5, 
  TOS_ADC_MAG_X_PORT = 6, 

  TOS_ADC_MAG_Y_PORT = 8
};

enum __nesc_unnamed4299 {
  TOS_MAG_POT_ADDR = 0, 
  TOS_MIC_POT_ADDR = 1
};
# 39 "C:/PROGRA~1/UCB/cygwin/opt/tinyos-1.x/tos/interfaces/Timer.h"
enum __nesc_unnamed4300 {
  TIMER_REPEAT = 0, 
  TIMER_ONE_SHOT = 1, 
  NUM_TIMERS = 1
};
# 34 "C:/PROGRA~1/UCB/cygwin/opt/tinyos-1.x/tos/interfaces/Clock.h"
enum __nesc_unnamed4301 {
  TOS_I1024PS = 0, TOS_S1024PS = 3, 
  TOS_I512PS = 1, TOS_S512PS = 3, 
  TOS_I256PS = 3, TOS_S256PS = 3, 
  TOS_I128PS = 7, TOS_S128PS = 3, 
  TOS_I64PS = 15, TOS_S64PS = 3, 
  TOS_I32PS = 31, TOS_S32PS = 3, 
  TOS_I16PS = 63, TOS_S16PS = 3, 
  TOS_I8PS = 127, TOS_S8PS = 3, 
  TOS_I4PS = 255, TOS_S4PS = 3, 
  TOS_I2PS = 15, TOS_S2PS = 7, 
  TOS_I1PS = 31, TOS_S1PS = 7, 
  TOS_I0PS = 0, TOS_S0PS = 0
};
enum __nesc_unnamed4302 {
  DEFAULT_SCALE = 3, DEFAULT_INTERVAL = 255
};
static  TOS_MsgPtr Nido$UARTReceiveMsg$default$receive(TOS_MsgPtr arg_0xa630db8);
static  result_t Nido$RadioSendMsg$default$sendDone(TOS_MsgPtr arg_0xa650a88, result_t arg_0xa650bd8);
static  TOS_MsgPtr Nido$RadioReceiveMsg$default$receive(TOS_MsgPtr arg_0xa630db8);
static   void PowerStateM$PowerState$CPUCycleCheckpoint(void);
static   result_t PowerStateM$PowerState$init(int arg_0xa64bb48, int arg_0xa64bc90);
static   void PowerStateM$PowerState$redOff(void);
static   void PowerStateM$PowerState$redOn(void);
static   result_t PowerStateM$PowerState$stop(void);
static   double PowerStateM$PowerState$get_mote_cycles(int arg_0xa64b738);