X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=examples%2Fmeshlinkapp.c;h=85cdf6feab2ccbadba61532fcc49680dfc06e5a5;hb=97b93e51807c818c6ccd2e759e9cc380e0137b52;hp=aa9b30c5570d0351c16d40af5df7c9a77d8a4338;hpb=781eec3832e2e4eca97e3deff55e451c57418fb1;p=meshlink diff --git a/examples/meshlinkapp.c b/examples/meshlinkapp.c index aa9b30c5..85cdf6fe 100644 --- a/examples/meshlinkapp.c +++ b/examples/meshlinkapp.c @@ -1,44 +1,47 @@ -#include - - -void handle_recv_data(void *data); -void handle_recv_data(void *data) { -printf("Data received is %s\n",data); +#include "../src/logger.h" +#include "../src/system.h" +#include "../src/meshlink.h" +void handle_recv_data(meshlink_handle_t *mesh, meshlink_node_t *source, void *data, size_t len) { + printf("Received %zu bytes from %s: %s\n", len, source->name, (char*)data); } int main(int argc , char **argv){ + char *confbase = argc > 1 ? argv[1] : "/tmp/meshlink/"; + char *name = argc > 2 ? argv[2] : "foo"; -char *confbase = argc > 1 ? argv[1] : "/tmp/meshlink/"; -char *name = argc > 2 ? argv[2] : "foo"; -debug_level = 5; + char *remotename = argc > 3 ? argv[3] : "bar"; -node_t* remotenode = new_node(); -char *remotename = argc > 3 ? argv[3] : "bar"; + meshlink_handle_t* myhandle; -//TODO: change this, calling a function that returns node_t -remotenode->name = malloc(16); -remotenode->name = remotename; + myhandle = meshlink_open(confbase, name, "meshlinkapp"); -tinc_setup(confbase, name); -tinc_start(confbase); + //Register callback function for incoming data + meshlink_set_receive_cb(myhandle, (meshlink_receive_cb_t)handle_recv_data); -//Register callback function for incoming data -recvdata_register_cb(handle_recv_data); + meshlink_start(myhandle); -sleep(2); //there is a race condition here, tinc_start detaches to a thread the needs time to setup stuff -while(1) { + while(1) { + sleep(10); -//sample data to send out -char mydata[200]; -memset(mydata,0,200); -strcpy(mydata,"Hello World!"); + meshlink_node_t *remotenode = meshlink_get_node(myhandle, remotename); + if(!remotenode) { + fprintf(stderr, "Node %s not known yet.\n", remotename); + continue; + } -//send out data -tinc_send_packet(remotenode,mydata,sizeof(mydata)); -sleep(10); //give time to this thread to finish before we exit -} -free(remotenode); -return 0; + //sample data to send out + char mydata[200]; + memset(mydata,0,200); + strcpy(mydata,"Hello World!"); + + //send out data + meshlink_send(myhandle,remotenode,mydata,sizeof(mydata)); + } + + meshlink_stop(myhandle); + meshlink_close(myhandle); + + return 0; }