Changeset 548
- Timestamp:
- 04/26/08 20:16:16 (3 weeks ago)
- Files:
-
- nano-RK/projects/SAMPL/app_pkt_handlers/ack_pkt.c (modified) (3 diffs)
- nano-RK/projects/SAMPL/app_pkt_handlers/ack_pkt.h (modified) (1 diff)
- nano-RK/projects/SAMPL/app_pkt_handlers/control_pkt.c (modified) (1 diff)
- nano-RK/projects/SAMPL/app_pkt_handlers/control_pkt.h (modified) (1 diff)
- nano-RK/projects/SAMPL/app_pkt_handlers/eeprom_data.c (modified) (3 diffs)
- nano-RK/projects/SAMPL/app_pkt_handlers/eeprom_data.h (modified) (1 diff)
- nano-RK/projects/SAMPL/app_pkt_handlers/ff_basic_sensor_pkt.c (modified) (4 diffs)
- nano-RK/projects/SAMPL/app_pkt_handlers/ff_basic_sensor_pkt.h (modified) (1 diff)
- nano-RK/projects/SAMPL/app_pkt_handlers/neighbor_pkt.c (modified) (2 diffs)
- nano-RK/projects/SAMPL/app_pkt_handlers/neighbor_pkt.h (modified) (1 diff)
- nano-RK/projects/SAMPL/app_pkt_handlers/ping_pkt.c (modified) (3 diffs)
- nano-RK/projects/SAMPL/app_pkt_handlers/ping_pkt.h (modified) (1 diff)
- nano-RK/projects/SAMPL/app_pkt_handlers/route_pkt.c (modified) (1 diff)
- nano-RK/projects/SAMPL/app_pkt_handlers/route_pkt.h (modified) (1 diff)
- nano-RK/projects/SAMPL/app_pkt_handlers/stats_pkt.c (modified) (2 diffs)
- nano-RK/projects/SAMPL/app_pkt_handlers/stats_pkt.h (modified) (1 diff)
- nano-RK/projects/SAMPL/app_pkt_handlers/trace.c (modified) (2 diffs)
- nano-RK/projects/SAMPL/app_pkt_handlers/trace.h (modified) (1 diff)
- nano-RK/projects/SAMPL/app_pkt_handlers/xmpp_pkt.c (modified) (1 diff)
- nano-RK/projects/SAMPL/app_pkt_handlers/xmpp_pkt.h (modified) (1 diff)
- nano-RK/projects/SAMPL/client/aggregate.c (modified) (2 diffs)
- nano-RK/projects/SAMPL/client/aggregate.h (modified) (1 diff)
- nano-RK/projects/SAMPL/client/generate.c (modified) (2 diffs)
- nano-RK/projects/SAMPL/client/generate.h (modified) (1 diff)
- nano-RK/projects/SAMPL/client/main.c (modified) (4 diffs)
- nano-RK/projects/SAMPL/client/p2p_handler.c (modified) (1 diff)
- nano-RK/projects/SAMPL/client/p2p_handler.h (modified) (1 diff)
- nano-RK/projects/SAMPL/gateway/main.c (modified) (2 diffs)
- nano-RK/projects/SAMPL/include/pkt_packer.c (modified) (9 diffs)
- nano-RK/projects/SAMPL/include/pkt_packer.h (modified) (1 diff)
- nano-RK/projects/SAMPL/include/sampl.h (modified) (6 diffs)
- nano-RK/projects/SAMPL/mobile-example/mobile-multithread/main.c (modified) (2 diffs)
- nano-RK/projects/SAMPL/mobile-example/mobile-push-st/main.c (modified) (1 diff)
- nano-RK/projects/SAMPL/mobile-example/mobile-single-thread/main.c (modified) (1 diff)
- nano-RK/projects/SAMPL/mobile-example/mobile-xmpp-st/main.c (modified) (1 diff)
- nano-RK/projects/SAMPL/phoenix-reprogrammer/main.c (modified) (1 diff)
- nano-RK/projects/SAMPL/slip-clients/pkt-scripter/main.c (modified) (5 diffs)
- nano-RK/projects/SAMPL/slip-clients/simple-client/main.c (modified) (6 diffs)
- nano-RK/projects/SAMPL/slip-clients/tests/control-pkt/main.c (modified) (7 diffs)
- nano-RK/projects/SAMPL/slip-clients/tests/ds-data/main.c (modified) (6 diffs)
- nano-RK/projects/SAMPL/slip-clients/tests/stats-pkt/main.c (modified) (8 diffs)
- nano-RK/projects/SAMPL/slip-clients/xmpp-client/main.c (modified) (5 diffs)
- nano-RK/projects/SAMPL/slip-clients/xmpp-client/xmpp_pkt_writer.c (modified) (3 diffs)
- nano-RK/projects/SAMPL/slip-clients/xmpp-client/xmpp_pkt_writer.h (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
nano-RK/projects/SAMPL/app_pkt_handlers/ack_pkt.c
r508 r548 13 13 14 14 15 int8_t ack_generate( FF_UPSTREAM_PKT_T *pkt)15 int8_t ack_generate(SAMPL_UPSTREAM_PKT_T *pkt) 16 16 { 17 17 ACK_PKT_T p; … … 23 23 } 24 24 25 int8_t ack_p2p_generate( FF_PEER_2_PEER_PKT_T *pkt)25 int8_t ack_p2p_generate(SAMPL_PEER_2_PEER_PKT_T *pkt) 26 26 { 27 27 ACK_PKT_T p; … … 32 32 33 33 34 int8_t ack_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out)34 int8_t ack_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out) 35 35 { 36 36 uint8_t len,i,j,k,dup; nano-RK/projects/SAMPL/app_pkt_handlers/ack_pkt.h
r508 r548 14 14 15 15 16 int8_t ack_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out);17 int8_t ack_generate( FF_UPSTREAM_PKT_T *pkt);16 int8_t ack_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out); 17 int8_t ack_generate(SAMPL_UPSTREAM_PKT_T *pkt); 18 18 uint8_t ack_pkt_add( ACK_PKT_T *p, uint8_t *buf, uint8_t index ); 19 19 void ack_pkt_get( ACK_PKT_T *p, uint8_t *buf, uint8_t index ); nano-RK/projects/SAMPL/app_pkt_handlers/control_pkt.c
r536 r548 7 7 8 8 9 int8_t control_generate( FF_UPSTREAM_PKT_T *pkt,FF_DOWNSTREAM_PKT_T *ds_pkt )9 int8_t control_generate(SAMPL_UPSTREAM_PKT_T *pkt,SAMPL_DOWNSTREAM_PKT_T *ds_pkt ) 10 10 { 11 11 ACK_PKT_T p; nano-RK/projects/SAMPL/app_pkt_handlers/control_pkt.h
r535 r548 21 21 22 22 23 int8_t control_generate( FF_UPSTREAM_PKT_T *pkt, FF_DOWNSTREAM_PKT_T *ds_pkt);23 int8_t control_generate(SAMPL_UPSTREAM_PKT_T *pkt, SAMPL_DOWNSTREAM_PKT_T *ds_pkt); 24 24 // This function returns a computed checksum to compare against the normal checksum 25 25 uint8_t control_pkt_get( CONTROL_PKT_T *p, uint8_t *buf, uint8_t index ); nano-RK/projects/SAMPL/app_pkt_handlers/eeprom_data.c
r473 r548 5 5 #include <eeprom_data.h> 6 6 7 int8_t eeprom_storage_p2p_generate( FF_PEER_2_PEER_PKT_T *pkt, FF_PEER_2_PEER_PKT_T *ds_pkt)7 int8_t eeprom_storage_p2p_generate(SAMPL_PEER_2_PEER_PKT_T *pkt, SAMPL_PEER_2_PEER_PKT_T *ds_pkt) 8 8 { 9 9 EEPROM_STORAGE_PKT_T p; … … 40 40 41 41 42 int8_t eeprom_storage_generate( FF_UPSTREAM_PKT_T *pkt, FF_DOWNSTREAM_PKT_T *ds_pkt)42 int8_t eeprom_storage_generate(SAMPL_UPSTREAM_PKT_T *pkt, SAMPL_DOWNSTREAM_PKT_T *ds_pkt) 43 43 { 44 44 EEPROM_STORAGE_PKT_T p; … … 80 80 81 81 82 int8_t eeprom_storage_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out)82 int8_t eeprom_storage_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out) 83 83 { 84 84 // DATA STORAGE currently does not support aggregation nano-RK/projects/SAMPL/app_pkt_handlers/eeprom_data.h
r473 r548 26 26 27 27 28 int8_t eeprom_storage_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out);29 int8_t eeprom_storage_generate( FF_UPSTREAM_PKT_T *pkt, FF_DOWNSTREAM_PKT_T *ds_pkt);28 int8_t eeprom_storage_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out); 29 int8_t eeprom_storage_generate(SAMPL_UPSTREAM_PKT_T *pkt, SAMPL_DOWNSTREAM_PKT_T *ds_pkt); 30 30 uint8_t eeprom_storage_pkt_add( EEPROM_STORAGE_PKT_T *p,char *buf); 31 31 void eeprom_storage_pkt_get( EEPROM_STORAGE_PKT_T *p, char *buf); nano-RK/projects/SAMPL/app_pkt_handlers/ff_basic_sensor_pkt.c
r543 r548 24 24 uint16_t buf; 25 25 26 int8_t sensor_short_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out)26 int8_t sensor_short_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out) 27 27 { 28 28 uint8_t len,i,j,k,dup; … … 51 51 52 52 #ifdef NRK_VERSION 53 int8_t sensor_short_generate( FF_UPSTREAM_PKT_T *pkt)53 int8_t sensor_short_generate(SAMPL_UPSTREAM_PKT_T *pkt) 54 54 { 55 55 int8_t fd,val,i; … … 152 152 153 153 154 int8_t sensor_long_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out)154 int8_t sensor_long_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out) 155 155 { 156 156 uint8_t len,i,j,k,dup; … … 179 179 180 180 #ifdef NRK_VERSION 181 int8_t sensor_long_generate( FF_UPSTREAM_PKT_T *pkt)181 int8_t sensor_long_generate(SAMPL_UPSTREAM_PKT_T *pkt) 182 182 { 183 183 int8_t fd,val,i; nano-RK/projects/SAMPL/app_pkt_handlers/ff_basic_sensor_pkt.h
r527 r548 35 35 36 36 37 int8_t sensor_short_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out);38 int8_t sensor_short_generate( FF_UPSTREAM_PKT_T *pkt);37 int8_t sensor_short_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out); 38 int8_t sensor_short_generate(SAMPL_UPSTREAM_PKT_T *pkt); 39 39 uint8_t sensor_short_pkt_add( FF_SENSOR_SHORT_PKT_T *p, uint8_t *buf, uint8_t index ); 40 40 void sensor_short_pkt_get( FF_SENSOR_SHORT_PKT_T *p, uint8_t *buf, uint8_t index ); 41 41 42 int8_t sensor_long_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out);43 int8_t sensor_long_generate( FF_UPSTREAM_PKT_T *pkt);42 int8_t sensor_long_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out); 43 int8_t sensor_long_generate(SAMPL_UPSTREAM_PKT_T *pkt); 44 44 uint8_t sensor_long_pkt_add( FF_SENSOR_LONG_PKT_T *p, uint8_t *buf, uint8_t index ); 45 45 void sensor_long_pkt_get( FF_SENSOR_LONG_PKT_T *p, uint8_t *buf, uint8_t index ); nano-RK/projects/SAMPL/app_pkt_handlers/neighbor_pkt.c
r544 r548 16 16 17 17 #ifdef NANORK 18 int8_t nlist_generate( FF_UPSTREAM_PKT_T *pkt, FF_DOWNSTREAM_PKT_T *ds_pkt)18 int8_t nlist_generate(SAMPL_UPSTREAM_PKT_T *pkt, SAMPL_DOWNSTREAM_PKT_T *ds_pkt) 19 19 { 20 20 NLIST_PKT_T p; … … 49 49 } 50 50 51 int8_t nlist_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out)51 int8_t nlist_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out) 52 52 { 53 53 uint8_t len,i,j,k,dup; nano-RK/projects/SAMPL/app_pkt_handlers/neighbor_pkt.h
r544 r548 19 19 20 20 21 int8_t nlist_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out);22 int8_t nlist_generate( FF_UPSTREAM_PKT_T *pkt, FF_DOWNSTREAM_PKT_T *ds_pkt);21 int8_t nlist_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out); 22 int8_t nlist_generate(SAMPL_UPSTREAM_PKT_T *pkt, SAMPL_DOWNSTREAM_PKT_T *ds_pkt); 23 23 uint8_t nlist_pkt_add( NLIST_PKT_T *p, uint8_t *buf, uint8_t index ); 24 24 void nlist_pkt_get( NLIST_PKT_T *p, uint8_t *buf, uint8_t index ); nano-RK/projects/SAMPL/app_pkt_handlers/ping_pkt.c
r502 r548 13 13 #define MAX_MSGS 50 14 14 15 int8_t ping_generate( FF_UPSTREAM_PKT_T *pkt)15 int8_t ping_generate(SAMPL_UPSTREAM_PKT_T *pkt) 16 16 { 17 17 PING_PKT_T p; … … 22 22 } 23 23 24 int8_t ping_p2p_generate( FF_PEER_2_PEER_PKT_T *pkt)24 int8_t ping_p2p_generate(SAMPL_PEER_2_PEER_PKT_T *pkt) 25 25 { 26 26 PING_PKT_T p; … … 31 31 32 32 33 int8_t ping_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out)33 int8_t ping_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out) 34 34 { 35 35 uint8_t len,i,j,k,dup; nano-RK/projects/SAMPL/app_pkt_handlers/ping_pkt.h
r498 r548 14 14 15 15 16 int8_t ping_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out);17 int8_t ping_generate( FF_UPSTREAM_PKT_T *pkt);16 int8_t ping_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out); 17 int8_t ping_generate(SAMPL_UPSTREAM_PKT_T *pkt); 18 18 uint8_t ping_pkt_add( PING_PKT_T *p, uint8_t *buf, uint8_t index ); 19 19 void ping_pkt_get( PING_PKT_T *p, uint8_t *buf, uint8_t index ); nano-RK/projects/SAMPL/app_pkt_handlers/route_pkt.c
r473 r548 8 8 9 9 10 int8_t route_generate( FF_UPSTREAM_PKT_T *pkt,FF_DOWNSTREAM_PKT_T *ds_pkt )10 int8_t route_generate(SAMPL_UPSTREAM_PKT_T *pkt,SAMPL_DOWNSTREAM_PKT_T *ds_pkt ) 11 11 { 12 12 ACK_PKT_T p; nano-RK/projects/SAMPL/app_pkt_handlers/route_pkt.h
r475 r548 18 18 19 19 20 int8_t route_generate( FF_UPSTREAM_PKT_T *pkt, FF_DOWNSTREAM_PKT_T *ds_pkt);20 int8_t route_generate(SAMPL_UPSTREAM_PKT_T *pkt, SAMPL_DOWNSTREAM_PKT_T *ds_pkt); 21 21 void route_pkt_get( ROUTE_PKT_T *p, uint8_t *buf, uint8_t index ); 22 22 nano-RK/projects/SAMPL/app_pkt_handlers/stats_pkt.c
r544 r548 15 15 16 16 #ifdef NANORK 17 int8_t stats_generate( FF_UPSTREAM_PKT_T *pkt, FF_DOWNSTREAM_PKT_T *ds_pkt)17 int8_t stats_generate(SAMPL_UPSTREAM_PKT_T *pkt, SAMPL_DOWNSTREAM_PKT_T *ds_pkt) 18 18 { 19 19 STATS_PKT_T p; … … 33 33 } 34 34 35 int8_t stats_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out)35 int8_t stats_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out) 36 36 { 37 37 uint8_t len,i,j,k,dup; nano-RK/projects/SAMPL/app_pkt_handlers/stats_pkt.h
r541 r548 24 24 25 25 26 int8_t stats_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out);27 int8_t stats_generate( FF_UPSTREAM_PKT_T *pkt, FF_DOWNSTREAM_PKT_T *ds_pkt);26 int8_t stats_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out); 27 int8_t stats_generate(SAMPL_UPSTREAM_PKT_T *pkt, SAMPL_DOWNSTREAM_PKT_T *ds_pkt); 28 28 uint8_t stats_pkt_add( STATS_PKT_T *p, uint8_t *buf, uint8_t index ); 29 29 void stats_pkt_get( STATS_PKT_T *p, uint8_t *buf, uint8_t index ); nano-RK/projects/SAMPL/app_pkt_handlers/trace.c
r465 r548 6 6 7 7 8 int8_t trace_generate( FF_UPSTREAM_PKT_T *pkt, FF_DOWNSTREAM_PKT_T *ds_pkt)8 int8_t trace_generate(SAMPL_UPSTREAM_PKT_T *pkt, SAMPL_DOWNSTREAM_PKT_T *ds_pkt) 9 9 { 10 10 TRACE_PKT_T p; … … 19 19 } 20 20 21 int8_t trace_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out)21 int8_t trace_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out) 22 22 { 23 23 uint8_t len,i,j,k,dup; nano-RK/projects/SAMPL/app_pkt_handlers/trace.h
r465 r548 18 18 19 19 20 int8_t trace_aggregate( FF_UPSTREAM_PKT_T *in, FF_UPSTREAM_PKT_T *out);21 int8_t trace_generate( FF_UPSTREAM_PKT_T *pkt, FF_DOWNSTREAM_PKT_T *ds_pkt);20 int8_t trace_aggregate(SAMPL_UPSTREAM_PKT_T *in, SAMPL_UPSTREAM_PKT_T *out); 21 int8_t trace_generate(SAMPL_UPSTREAM_PKT_T *pkt, SAMPL_DOWNSTREAM_PKT_T *ds_pkt); 22 22 uint8_t trace_pkt_add( TRACE_PKT_T *p, uint8_t *buf, uint8_t index ); 23 23 void trace_pkt_get( TRACE_PKT_T *p, uint8_t *buf, uint8_t index ); nano-RK/projects/SAMPL/app_pkt_handlers/xmpp_pkt.c
r516 r548 13 13 14 14 15 int8_t xmpp_generate( FF_UPSTREAM_PKT_T *pkt, FF_DOWNSTREAM_PKT_T *ds_pkt)15 int8_t xmpp_generate(SAMPL_UPSTREAM_PKT_T *pkt, SAMPL_DOWNSTREAM_PKT_T *ds_pkt) 16 16 { 17 17 // For downstream messages, generate an ACK reply to show nano-RK/projects/SAMPL/app_pkt_handlers/xmpp_pkt.h
r510 r548 20 20 21 21 22 int8_t xmpp_generate( FF_UPSTREAM_PKT_T *pkt,FF_DOWNSTREAM_PKT_T *ds_pkt);22 int8_t xmpp_generate( SAMPL_UPSTREAM_PKT_T *pkt,SAMPL_DOWNSTREAM_PKT_T *ds_pkt); 23 23 uint8_t xmpp_pkt_pack( XMPP_PKT_T *p, uint8_t *buf, uint8_t index ); 24 24 void xmpp_pkt_unpack( XMPP_PKT_T *p, uint8_t *buf, uint8_t index ); nano-RK/projects/SAMPL/client/aggregate.c
r547 r548 14 14 15 15 16 void aggregate_upstream_data ( FF_UPSTREAM_PKT_T * us_pkt_in,17 FF_UPSTREAM_PKT_T * us_pkt)16 void aggregate_upstream_data ( SAMPL_UPSTREAM_PKT_T * us_pkt_in, 17 SAMPL_UPSTREAM_PKT_T * us_pkt) 18 18 { 19 19 uint8_t i,j,k,dup,len; … … 45 45 ping_aggregate(us_pkt_in, us_pkt ); 46 46 break; 47 case SENSOR_LONG_PKT:47 case FF_SENSOR_LONG_PKT: 48 48 sensor_long_aggregate(us_pkt_in, us_pkt ); 49 49 break; 50 case SENSOR_SHORT_PKT:50 case FF_SENSOR_SHORT_PKT: 51 51 sensor_short_aggregate(us_pkt_in, us_pkt ); 52 52 break; nano-RK/projects/SAMPL/client/aggregate.h
r465 r548 5 5 #include <../include/sampl.h> 6 6 7 void aggregate_upstream_data( FF_UPSTREAM_PKT_T *us_pkt_in, FF_UPSTREAM_PKT_T *us_pkt );7 void aggregate_upstream_data( SAMPL_UPSTREAM_PKT_T *us_pkt_in, SAMPL_UPSTREAM_PKT_T *us_pkt ); 8 8 9 9 #endif nano-RK/projects/SAMPL/client/generate.c
r547 r548 18 18 reply address. 19 19 */ 20 void create_upstream_data_packet ( FF_DOWNSTREAM_PKT_T * ds_pkt,21 FF_UPSTREAM_PKT_T * us_pkt,20 void create_upstream_data_packet (SAMPL_DOWNSTREAM_PKT_T * ds_pkt, 21 SAMPL_UPSTREAM_PKT_T * us_pkt, 22 22 uint8_t upstream_reply_mac) 23 23 { … … 98 98 99 99 100 case SENSOR_LONG_PKT:100 case FF_SENSOR_LONG_PKT: 101 101 sensor_long_generate(us_pkt); 102 102 break; 103 103 104 case SENSOR_SHORT_PKT:104 case FF_SENSOR_SHORT_PKT: 105 105 sensor_short_generate(us_pkt); 106 106 break; nano-RK/projects/SAMPL/client/generate.h
r465 r548 5 5 #include <../include/sampl.h> 6 6 7 void create_upstream_data_packet( FF_DOWNSTREAM_PKT_T *ds_pkt, FF_UPSTREAM_PKT_T *us_pkt, uint8_t upstream_reply_mac );7 void create_upstream_data_packet(SAMPL_DOWNSTREAM_PKT_T *ds_pkt, SAMPL_UPSTREAM_PKT_T *us_pkt, uint8_t upstream_reply_mac ); 8 8 9 9 #endif nano-RK/projects/SAMPL/client/main.c
r544 r548 54 54 uint8_t check_subnet(uint8_t *in,uint8_t *my ); 55 55 56 nrk_task_type FF_RX_TASK;56 nrk_task_type SAMPL_RX_TASK; 57 57 NRK_STK ff_rx_task_stack[NRK_APP_STACKSIZE]; 58 58 void ff_rx_task (void); 59 59 60 60 61 nrk_task_type FF_TX_TASK;61 nrk_task_type SAMPL_TX_TASK; 62 62 NRK_STK ff_tx_task_stack[NRK_APP_STACKSIZE]; 63 63 void ff_tx_task (void); … … 65 65 void nrk_create_taskset (); 66 66 67 FF_DOWNSTREAM_PKT_T ds_pkt;68 FF_UPSTREAM_PKT_T us_pkt;69 FF_UPSTREAM_PKT_T us_pkt_in;70 FF_PEER_2_PEER_PKT_T p2p_pkt;71 FF_PEER_2_PEER_PKT_T p2p_pkt_in;67 SAMPL_DOWNSTREAM_PKT_T ds_pkt; 68 SAMPL_UPSTREAM_PKT_T us_pkt; 69 SAMPL_UPSTREAM_PKT_T us_pkt_in; 70 SAMPL_PEER_2_PEER_PKT_T p2p_pkt; 71 SAMPL_PEER_2_PEER_PKT_T p2p_pkt_in; 72 72 73 73 … … 135 135 136 136 137 void print_ds_pkt ( FF_DOWNSTREAM_PKT_T * ds_pkt)137 void print_ds_pkt (SAMPL_DOWNSTREAM_PKT_T * ds_pkt) 138 138 { 139 139 nrk_kprintf (PSTR ("Downstream Packet:\r\n")); … … 639 639 640 640 641 FF_RX_TASK.task = ff_rx_task;642 nrk_task_set_stk (& FF_RX_TASK, ff_rx_task_stack, NRK_APP_STACKSIZE);643 FF_RX_TASK.prio = 5;644 FF_RX_TASK.FirstActivation = TRUE;645 FF_RX_TASK.Type = BASIC_TASK;646 FF_RX_TASK.SchType = PREEMPTIVE;647 FF_RX_TASK.period.secs = 1;648 FF_RX_TASK.period.nano_secs = 0;649 FF_RX_TASK.cpu_reserve.secs = 1;650 FF_RX_TASK.cpu_reserve.nano_secs = 500 * NANOS_PER_MS;651 FF_RX_TASK.offset.secs = 0;652 FF_RX_TASK.offset.nano_secs = 0;653 nrk_activate_task (& FF_RX_TASK);654 655 FF_TX_TASK.task = ff_tx_task;656 nrk_task_set_stk (& FF_TX_TASK, ff_tx_task_stack, NRK_APP_STACKSIZE);657 FF_TX_TASK.prio = 10;658 FF_TX_TASK.FirstActivation = TRUE;659 FF_TX_TASK.Type = BASIC_TASK;660 FF_TX_TASK.SchType = PREEMPTIVE;661 FF_TX_TASK.period.secs = 1;662 FF_TX_TASK.period.nano_secs = 0;663 FF_TX_TASK.cpu_reserve.secs = 1;664 FF_TX_TASK.cpu_reserve.nano_secs = 500 * NANOS_PER_MS;665 FF_TX_TASK.offset.secs = 0;666 FF_TX_TASK.offset.nano_secs = 0;667 nrk_activate_task (& FF_TX_TASK);641 SAMPL_RX_TASK.task = ff_rx_task; 642 nrk_task_set_stk (&SAMPL_RX_TASK, ff_rx_task_stack, NRK_APP_STACKSIZE); 643 SAMPL_RX_TASK.prio = 5; 644 SAMPL_RX_TASK.FirstActivation = TRUE; 645 SAMPL_RX_TASK.Type = BASIC_TASK; 646 SAMPL_RX_TASK.SchType = PREEMPTIVE; 647 SAMPL_RX_TASK.period.secs = 1; 648 SAMPL_RX_TASK.period.nano_secs = 0; 649 SAMPL_RX_TASK.cpu_reserve.secs = 1; 650 SAMPL_RX_TASK.cpu_reserve.nano_secs = 500 * NANOS_PER_MS; 651 SAMPL_RX_TASK.offset.secs = 0; 652 SAMPL_RX_TASK.offset.nano_secs = 0; 653 nrk_activate_task (&SAMPL_RX_TASK); 654 655 SAMPL_TX_TASK.task = ff_tx_task; 656 nrk_task_set_stk (&SAMPL_TX_TASK, ff_tx_task_stack, NRK_APP_STACKSIZE); 657 SAMPL_TX_TASK.prio = 10; 658 SAMPL_TX_TASK.FirstActivation = TRUE; 659 SAMPL_TX_TASK.Type = BASIC_TASK; 660 SAMPL_TX_TASK.SchType = PREEMPTIVE; 661 SAMPL_TX_TASK.period.secs = 1; 662 SAMPL_TX_TASK.period.nano_secs = 0; 663 SAMPL_TX_TASK.cpu_reserve.secs = 1; 664 SAMPL_TX_TASK.cpu_reserve.nano_secs = 500 * NANOS_PER_MS; 665 SAMPL_TX_TASK.offset.secs = 0; 666 SAMPL_TX_TASK.offset.nano_secs = 0; 667 nrk_activate_task (&SAMPL_TX_TASK); 668 668 669 669 } nano-RK/projects/SAMPL/client/p2p_handler.c
r524 r548 20 20 // p2p_pkt_out 21 21 22 uint8_t handle_peer_2_peer_pkt( FF_PEER_2_PEER_PKT_T *p2p_pkt_in, FF_PEER_2_PEER_PKT_T *p2p_pkt_out)22 uint8_t handle_peer_2_peer_pkt(SAMPL_PEER_2_PEER_PKT_T *p2p_pkt_in, SAMPL_PEER_2_PEER_PKT_T *p2p_pkt_out) 23 23 { 24 24 uint8_t i, mode, len; nano-RK/projects/SAMPL/client/p2p_handler.h
r524 r548 5 5 #include <../include/sampl.h> 6 6 7 uint8_t handle_general_purpose_pkt( FF_PEER_2_PEER_PKT_T *p2p_pkt_in, FF_PEER_2_PEER_PKT_T *p2p_pkt_out);7 uint8_t handle_general_purpose_pkt(SAMPL_PEER_2_PEER_PKT_T *p2p_pkt_in, SAMPL_PEER_2_PEER_PKT_T *p2p_pkt_out); 8 8 9 9 #endif nano-RK/projects/SAMPL/gateway/main.c
r520 r548 66 66 67 67 68 FF_GATEWAY_PKT_T gw_pkt;69 FF_UPSTREAM_PKT_T us_pkt;70 FF_PEER_2_PEER_PKT_T p2p_pkt;68 SAMPL_GATEWAY_PKT_T gw_pkt; 69 SAMPL_UPSTREAM_PKT_T us_pkt; 70 SAMPL_PEER_2_PEER_PKT_T p2p_pkt; 71 71 72 72 int main () … … 264 264 nrk_sig_mask_t ret; 265 265 nrk_time_t check_period; 266 FF_DOWNSTREAM_PKT_T ds_pkt;266 SAMPL_DOWNSTREAM_PKT_T ds_pkt; 267 267 268 268 printf ("tx_task PID=%d\r\n", nrk_get_pid ()); nano-RK/projects/SAMPL/include/pkt_packer.c
r507 r548 4 4 5 5 6 uint8_t unpack_downstream_packet( FF_DOWNSTREAM_PKT_T *ds_pkt, uint8_t my_node_mac)6 uint8_t unpack_downstream_packet( SAMPL_DOWNSTREAM_PKT_T *ds_pkt, uint8_t my_node_mac) 7 7 { 8 8 uint8_t i; … … 52 52 } 53 53 54 uint8_t downstream_packet_add_mac_filter( FF_DOWNSTREAM_PKT_T *ds_pkt, uint8_t mac)54 uint8_t downstream_packet_add_mac_filter( SAMPL_DOWNSTREAM_PKT_T *ds_pkt, uint8_t mac) 55 55 { 56 56 // FIXME: Add correct max number of messages … … 66 66 } 67 67 68 uint8_t pack_downstream_packet( FF_DOWNSTREAM_PKT_T *ds_pkt)68 uint8_t pack_downstream_packet( SAMPL_DOWNSTREAM_PKT_T *ds_pkt) 69 69 { 70 70 ds_pkt->buf_len=DS_PAYLOAD_START+ds_pkt->payload_len; … … 99 99 100 100 101 uint8_t pack_upstream_packet( FF_UPSTREAM_PKT_T *us_pkt)101 uint8_t pack_upstream_packet( SAMPL_UPSTREAM_PKT_T *us_pkt) 102 102 { 103 103 us_pkt->buf_len=US_PAYLOAD_START+us_pkt->payload_len; … … 121 121 } 122 122 123 uint8_t pack_gateway_packet( FF_GATEWAY_PKT_T *gw_pkt)123 uint8_t pack_gateway_packet( SAMPL_GATEWAY_PKT_T *gw_pkt) 124 124 { 125 125 gw_pkt->buf_len=GW_PAYLOAD_START+gw_pkt->payload_len; … … 145 145 } 146 146 147 uint8_t unpack_gateway_packet( FF_GATEWAY_PKT_T *gw_pkt)147 uint8_t unpack_gateway_packet( SAMPL_GATEWAY_PKT_T *gw_pkt) 148 148 { 149 149 gw_pkt->protocol_id= gw_pkt->buf[PROTOCOL_ID]; … … 173 173 174 174 175 uint8_t unpack_upstream_packet( FF_UPSTREAM_PKT_T *us_pkt)175 uint8_t unpack_upstream_packet( SAMPL_UPSTREAM_PKT_T *us_pkt) 176 176 { 177 177 us_pkt->protocol_id= us_pkt->buf[PROTOCOL_ID]; … … 201 201 202 202 203 uint8_t pack_peer_2_peer_packet( FF_PEER_2_PEER_PKT_T *p2p_pkt)203 uint8_t pack_peer_2_peer_packet( SAMPL_PEER_2_PEER_PKT_T *p2p_pkt) 204 204 { 205 205 p2p_pkt->buf_len=P2P_PAYLOAD_START+p2p_pkt->payload_len; … … 224 224 225 225 226 uint8_t unpack_peer_2_peer_packet( FF_PEER_2_PEER_PKT_T *p2p_pkt)226 uint8_t unpack_peer_2_peer_packet( SAMPL_PEER_2_PEER_PKT_T *p2p_pkt) 227 227 { 228 228 p2p_pkt->protocol_id= p2p_pkt->buf[PROTOCOL_ID]; nano-RK/projects/SAMPL/include/pkt_packer.h
r504 r548 4 4 #include "sampl.h" 5 5 6 uint8_t pack_peer_2_peer_packet( FF_PEER_2_PEER_PKT_T *p2p_pkt);7 uint8_t unpack_peer_2_peer_packet( FF_PEER_2_PEER_PKT_T *p2p_pkt);6 uint8_t pack_peer_2_peer_packet( SAMPL_PEER_2_PEER_PKT_T *p2p_pkt); 7 uint8_t unpack_peer_2_peer_packet( SAMPL_PEER_2_PEER_PKT_T *p2p_pkt); 8 8 9 uint8_t unpack_downstream_packet( FF_DOWNSTREAM_PKT_T *ds_pkt,uint8_t my_node_mac);10 uint8_t pack_downstream_packet( FF_DOWNSTREAM_PKT_T *ds_pkt);9 uint8_t unpack_downstream_packet( SAMPL_DOWNSTREAM_PKT_T *ds_pkt,uint8_t my_node_mac); 10 uint8_t pack_downstream_packet( SAMPL_DOWNSTREAM_PKT_T *ds_pkt); 11 11 12 uint8_t pack_upstream_packet( FF_UPSTREAM_PKT_T *us_pkt);13 uint8_t unpack_upstream_packet( FF_UPSTREAM_PKT_T *us_pkt);12 uint8_t pack_upstream_packet( SAMPL_UPSTREAM_PKT_T *us_pkt); 13 uint8_t unpack_upstream_packet( SAMPL_UPSTREAM_PKT_T *us_pkt); 14 14 15 15 #endif nano-RK/projects/SAMPL/include/sampl.h
r547 r548 84 84 #define ERROR_PKT 0x04 85 85 #define ROUTE_PKT 0x05 86 #define SENSOR_LONG_PKT 0x0687 #define SENSOR_SHORT_PKT 0x0786 #define FF_SENSOR_LONG_PKT 0x06 87 #define FF_SENSOR_SHORT_PKT 0x07 88 88 #define TRACEROUTE_PKT 0x08 89 89 #define CONTROL_PKT 0x09 … … 150 150 151 151 152 typedef struct ff_downstream_pkt152 typedef struct sampl_downstream_pkt 153 153 { 154 154 // Common Header … … 184 184 int8_t rssi; 185 185 186 } FF_DOWNSTREAM_PKT_T;187 188 typedef struct ff_gateway_pkt186 } SAMPL_DOWNSTREAM_PKT_T; 187 188 typedef struct sampl_gateway_pkt 189 189 { 190 190 // Common Header … … 216 216 uint8_t payload_len; 217 217 218 } FF_GATEWAY_PKT_T;219 220 221 222 typedef struct ff_upstream_pkt218 }SAMPL_GATEWAY_PKT_T; 219 220 221 222 typedef struct sampl_upstream_pkt 223 223 { 224 224 // Common Header … … 248 248 // Special Flags 249 249 int8_t rssi; 250 } FF_UPSTREAM_PKT_T;251 252 typedef struct ff_peer_2_peer_pkt250 }SAMPL_UPSTREAM_PKT_T; 251 252 typedef struct sampl_peer_2_peer_pkt 253 253 { 254 254 // Common Header … … 279 279 // Special Flags 280 280 int8_t rssi; 281 } FF_PEER_2_PEER_PKT_T;281 }SAMPL_PEER_2_PEER_PKT_T; 282 282 283 283 nano-RK/projects/SAMPL/mobile-example/mobile-multithread/main.c
r346 r548 58 58 59 59 60 FF_MOBILE_PKT_T mobile_pkt;60 SAMPL_MOBILE_PKT_T mobile_pkt; 61 61 62 62 int main () … … 164 164 nrk_sig_mask_t ret; 165 165 nrk_time_t check_period; 166 FF_DOWNSTREAM_PKT_T ds_pkt;166 SAMPL_DOWNSTREAM_PKT_T ds_pkt; 167 167 168 168 printf ("tx_task PID=%d\r\n", nrk_get_pid ()); nano-RK/projects/SAMPL/mobile-example/mobile-push-st/main.c
r510 r548 55 55 56 56 57 FF_PEER_2_PEER_PKT_T p2p_pkt;57 SAMPL_PEER_2_PEER_PKT_T p2p_pkt; 58 58 59 59 int main () nano-RK/projects/SAMPL/mobile-example/mobile-single-thread/main.c
r529 r548 55 55 56 56 57 FF_PEER_2_PEER_PKT_T p2p_pkt;57 SAMPL_PEER_2_PEER_PKT_T p2p_pkt; 58 58 59 59 int main () nano-RK/projects/SAMPL/mobile-example/mobile-xmpp-st/main.c
r524 r548 58 58 59 59 60 FF_PEER_2_PEER_PKT_T p2p_pkt;60 SAMPL_PEER_2_PEER_PKT_T p2p_pkt; 61 61 62 62 int main () nano-RK/projects/SAMPL/phoenix-reprogrammer/main.c
r532 r548 111 111 112 112 113 FF_PEER_2_PEER_PKT_T p2p_pkt;113 SAMPL_PEER_2_PEER_PKT_T p2p_pkt; 114 114 115 115 int main () nano-RK/projects/SAMPL/slip-clients/pkt-scripter/main.c
r502 r548 27 27 void handle_incomming_pkt(uint8_t *rx_buf,uint8_t len); 28 28 void error(char *msg); 29 void print_ds_packet( FF_DOWNSTREAM_PKT_T *ds_pkt );29 void print_ds_packet(SAMPL_DOWNSTREAM_PKT_T *ds_pkt ); 30 30 31 31 int sockfd, portno, n; … … 35 35 char buffer[2048]; 36 36 37 FF_DOWNSTREAM_PKT_T ds_pkt;37 SAMPL_DOWNSTREAM_PKT_T ds_pkt; 38 38 39 39 int main (int argc, char *argv[]) … … 167 167 } 168 168 169 void print_ds_packet( FF_DOWNSTREAM_PKT_T *ds_pkt )169 void print_ds_packet(SAMPL_DOWNSTREAM_PKT_T *ds_pkt ) 170 170 { 171 171 int i; … … 195 195 } 196 196 197 void print_gw_packet( FF_GATEWAY_PKT_T *gw_pkt )197 void print_gw_packet(SAMPL_GATEWAY_PKT_T *gw_pkt ) 198 198 { 199 199 int i; … … 217 217 { 218 218 int i; 219 FF_GATEWAY_PKT_T gw_pkt;219 SAMPL_GATEWAY_PKT_T gw_pkt; 220 220 221 221 printf( "Raw Pkt [%d] = ",len ); nano-RK/projects/SAMPL/slip-clients/simple-client/main.c
r527 r548 26 26 void handle_incomming_pkt(uint8_t *rx_buf,uint8_t len); 27 27 void error(char *msg); 28 void print_ds_packet( FF_DOWNSTREAM_PKT_T *ds_pkt );29 void print_gw_packet( FF_GATEWAY_PKT_T *gw_pkt );28 void print_ds_packet(SAMPL_DOWNSTREAM_PKT_T *ds_pkt ); 29 void print_gw_packet(SAMPL_GATEWAY_PKT_T *gw_pkt ); 30 30 31 31 int sockfd, portno, n; … … 35 35 char buffer[2048]; 36 36 37 FF_DOWNSTREAM_PKT_T ds_pkt;37 SAMPL_DOWNSTREAM_PKT_T ds_pkt; 38 38 39 39 int main (int argc, char *argv[]) … … 173 173 { 174 174 int i; 175 FF_GATEWAY_PKT_T gw_pkt;175 SAMPL_GATEWAY_PKT_T gw_pkt; 176 176 FF_SENSOR_SHORT_PKT_T sensor_short; 177 177 ACK_PKT_T ack; … … 204 204 205 205 // Default FireFly sensor packet 206 case SENSOR_SHORT_PKT:206 case FF_SENSOR_SHORT_PKT: 207 207 for(i=0; i<gw_pkt.num_msgs; i++ ) 208 208 { … … 222 222 223 223 224 void print_ds_packet( FF_DOWNSTREAM_PKT_T *ds_pkt )224 void print_ds_packet(SAMPL_DOWNSTREAM_PKT_T *ds_pkt ) 225 225 { 226 226 int i; … … 254 254 } 255 255 256 void print_gw_packet( FF_GATEWAY_PKT_T *gw_pkt )256 void print_gw_packet(SAMPL_GATEWAY_PKT_T *gw_pkt ) 257 257 { 258 258 int i; nano-RK/projects/SAMPL/slip-clients/tests/control-pkt/main.c
r546 r548 26 26 void handle_incomming_pkt(uint8_t *rx_buf,uint8_t len); 27 27 void error(char *msg); 28 void print_ds_packet( FF_DOWNSTREAM_PKT_T *ds_pkt );29 void print_gw_packet( FF_GATEWAY_PKT_T *gw_pkt );28 void print_ds_packet(SAMPL_DOWNSTREAM_PKT_T *ds_pkt ); 29 void print_gw_packet(SAMPL_GATEWAY_PKT_T *gw_pkt ); 30 30
