X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=examples%2Fmeshlinkapp.c;h=9796cba30b1f51c5b2cd43fe40e4ca42221ff59b;hb=668664d0ea90dc81670cccd7b7d56b36b8360eaa;hp=aa9b30c5570d0351c16d40af5df7c9a77d8a4338;hpb=781eec3832e2e4eca97e3deff55e451c57418fb1;p=meshlink diff --git a/examples/meshlinkapp.c b/examples/meshlinkapp.c index aa9b30c5..9796cba3 100644 --- a/examples/meshlinkapp.c +++ b/examples/meshlinkapp.c @@ -1,44 +1,48 @@ -#include +#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); +} -void handle_recv_data(void *data); -void handle_recv_data(void *data) { -printf("Data received is %s\n",data); +int main(int argc, char **argv) { + char *confbase = argc > 1 ? argv[1] : "/tmp/meshlink/"; + char *name = argc > 2 ? argv[2] : "foo"; -} + char *remotename = argc > 3 ? argv[3] : "bar"; -int main(int argc , char **argv){ + meshlink_handle_t *myhandle; -char *confbase = argc > 1 ? argv[1] : "/tmp/meshlink/"; -char *name = argc > 2 ? argv[2] : "foo"; -debug_level = 5; + myhandle = meshlink_open(confbase, name, "meshlinkapp", DEV_CLASS_STATIONARY); -node_t* remotenode = new_node(); -char *remotename = argc > 3 ? argv[3] : "bar"; + //Register callback function for incoming data + meshlink_set_receive_cb(myhandle, (meshlink_receive_cb_t)handle_recv_data); -//TODO: change this, calling a function that returns node_t -remotenode->name = malloc(16); -remotenode->name = remotename; + meshlink_start(myhandle); -tinc_setup(confbase, name); -tinc_start(confbase); + while(1) { + sleep(10); -//Register callback function for incoming data -recvdata_register_cb(handle_recv_data); + meshlink_node_t *remotenode = meshlink_get_node(myhandle, remotename); -sleep(2); //there is a race condition here, tinc_start detaches to a thread the needs time to setup stuff -while(1) { + if(!remotenode) { + fprintf(stderr, "Node %s not known yet.\n", remotename); + continue; + } -//sample data to send out -char mydata[200]; -memset(mydata,0,200); -strcpy(mydata,"Hello World!"); + //sample data to send out + char mydata[200]; + memset(mydata, 0, 200); + strcpy(mydata, "Hello World!"); -//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; + //send out data + meshlink_send(myhandle, remotenode, mydata, sizeof(mydata)); + } + + meshlink_stop(myhandle); + meshlink_close(myhandle); + + return 0; }