deac/osd-contiki
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Rewrote the code to use the servreg-hack module, so that clients can look up the IP address of the collector node.

Browse source
This commit is contained in:
adamdunkels 2010-06-15 19:02:00 +00:00
parent 5dc55f0a1b
commit 237398a74b
2 changed files with 28 additions and 28 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

48
examples/ipv6/rpl-udp/udp-client.c
View file

@ -35,16 +35,16 @@
#include "net/uip-udp-packet.h" #include "net/uip-udp-packet.h"
#include "sys/ctimer.h" #include "sys/ctimer.h"
#include "servreg-hack.h"
#include <stdio.h> #include <stdio.h>
#include <string.h> #include <string.h>
#ifndef SERVER_ID
#define SERVER_ID 1
#endif
#define UDP_CLIENT_PORT 8765 #define UDP_CLIENT_PORT 8765
#define UDP_SERVER_PORT 5678 #define UDP_SERVER_PORT 5678
#define UDP_EXAMPLE_ID 190
#define DEBUG DEBUG_PRINT #define DEBUG DEBUG_PRINT
#include "net/uip-debug.h" #include "net/uip-debug.h"
@ -75,12 +75,17 @@ send_packet(void *ptr)
{ {
static int seq_id; static int seq_id;
char buf[MAX_PAYLOAD_LEN]; char buf[MAX_PAYLOAD_LEN];
uip_ipaddr_t *ipaddr;
seq_id++; ipaddr = servreg_hack_lookup(UDP_EXAMPLE_ID);
PRINTF("DATA send to %d 'Hello %d'\n", if(ipaddr != NULL) {
client_conn->ripaddr.u8[15], seq_id); seq_id++;
sprintf(buf, "Hello %d from the client", seq_id); PRINTF("DATA send to %d 'Hello %d'\n",
uip_udp_packet_send(client_conn, buf, strlen(buf)); client_conn->ripaddr.u8[15], seq_id);
sprintf(buf, "Hello %d from the client", seq_id);
uip_udp_packet_sendto(client_conn, buf, strlen(buf),
ipaddr, HTONS(UDP_SERVER_PORT));
}
} }
/*---------------------------------------------------------------------------*/ /*---------------------------------------------------------------------------*/
static void static void
@ -114,39 +119,26 @@ set_global_address(void)
uip_ds6_addr_add(&ipaddr, 0, ADDR_AUTOCONF); uip_ds6_addr_add(&ipaddr, 0, ADDR_AUTOCONF);
} }
/*---------------------------------------------------------------------------*/ /*---------------------------------------------------------------------------*/
static void
set_connection_address(uip_ipaddr_t *ipaddr)
{
#ifdef IEEE_802154_MAC_ADDRESS
/* Node 1 in the testbed scripts */
uint8_t ieee[] = IEEE_802154_MAC_ADDRESS;
ieee[7] = SERVER_ID;
uip_ip6addr(ipaddr, 0xaaaa, 0, 0, 0, 0, 0, 0, 0);
uip_ds6_set_addr_iid(ipaddr, (uip_lladdr_t *) ieee);
#else
uip_ip6addr(ipaddr,0xaaaa,0,0,0,0x0212,0x7400 + SERVER_ID,
SERVER_ID,SERVER_ID << 8 | SERVER_ID);
#endif
}
/*---------------------------------------------------------------------------*/
PROCESS_THREAD(udp_client_process, ev, data) PROCESS_THREAD(udp_client_process, ev, data)
{ {
static struct etimer periodic; static struct etimer periodic;
static struct ctimer backoff_timer; static struct ctimer backoff_timer;
uip_ipaddr_t ipaddr; uip_ipaddr_t *ipaddr;
PROCESS_BEGIN(); PROCESS_BEGIN();
servreg_hack_init();
PROCESS_PAUSE(); PROCESS_PAUSE();
set_global_address();
PRINTF("UDP client process started\n"); PRINTF("UDP client process started\n");
print_local_addresses(); print_local_addresses();
set_connection_address(&ipaddr);
/* new connection with remote host */ /* new connection with remote host */
client_conn = udp_new(&ipaddr, HTONS(UDP_SERVER_PORT), NULL); client_conn = udp_new(NULL, HTONS(UDP_SERVER_PORT), NULL);
udp_bind(client_conn, HTONS(UDP_CLIENT_PORT)); udp_bind(client_conn, HTONS(UDP_CLIENT_PORT));
PRINTF("Created a connection with the server "); PRINTF("Created a connection with the server ");

8
examples/ipv6/rpl-udp/udp-server.c
View file

@ -33,6 +33,8 @@
#include "net/uip.h" #include "net/uip.h"
#include "net/rpl/rpl.h" #include "net/rpl/rpl.h"
#include "servreg-hack.h"
#include "net/netstack.h" #include "net/netstack.h"
#include "dev/button-sensor.h" #include "dev/button-sensor.h"
#include <stdio.h> #include <stdio.h>
@ -48,6 +50,8 @@
#define UDP_CLIENT_PORT 8765 #define UDP_CLIENT_PORT 8765
#define UDP_SERVER_PORT 5678 #define UDP_SERVER_PORT 5678
#define UDP_EXAMPLE_ID 190
static struct uip_udp_conn *server_conn; static struct uip_udp_conn *server_conn;
uint16_t dag_id[] = {0x1111, 0x1100, 0, 0, 0, 0, 0, 0x0011}; uint16_t dag_id[] = {0x1111, 0x1100, 0, 0, 0, 0, 0, 0x0011};
@ -101,6 +105,10 @@ PROCESS_THREAD(udp_server_process, ev, data)
PROCESS_BEGIN(); PROCESS_BEGIN();
servreg_hack_init();
servreg_hack_register(UDP_EXAMPLE_ID);
PROCESS_PAUSE(); PROCESS_PAUSE();
SENSORS_ACTIVATE(button_sensor); SENSORS_ACTIVATE(button_sensor);