ExternalVendorCode/serval-dna
1
0
Fork 0
mirror of https://github.com/servalproject/serval-dna.git synced 2024-12-23 15:02:27 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fixed socket type from TCP to UDP.

Browse Source
This commit is contained in:
gardners 2012-03-17 22:31:48 +10:30
parent f384e6ea79
commit 46599269d7
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
overlay_mdp.c
View File

@ -45,13 +45,11 @@ int overlay_mdp_setup_sockets()
snprintf(&name.sun_path[1],100,"org.servalproject.mesh.overlay.mdp"); snprintf(&name.sun_path[1],100,"org.servalproject.mesh.overlay.mdp");
len = 1+strlen(&name.sun_path[1]) + sizeof(name.sun_family); len = 1+strlen(&name.sun_path[1]) + sizeof(name.sun_family);
mdp_abstract_socket = socket(AF_UNIX, SOCK_STREAM, 0); mdp_abstract_socket = socket(AF_UNIX, SOCK_DGRAM, 0);
if (mdp_abstract_socket>-1) { if (mdp_abstract_socket>-1) {
int dud=0; int dud=0;
int r=bind(mdp_abstract_socket, (struct sockaddr *)&name, len); int r=bind(mdp_abstract_socket, (struct sockaddr *)&name, len);
if (r) { dud=1; r=0; WHY("bind() of abstract name space socket failed (not an error on non-linux systems"); } if (r) { dud=1; r=0; WHY("bind() of abstract name space socket failed (not an error on non-linux systems"); }
r=listen(mdp_abstract_socket,100); // allow a lot of queued up MDP frames
if (r) { dud++; WHY("listen() failed"); }
if (dud) { if (dud) {
close(mdp_abstract_socket); close(mdp_abstract_socket);
mdp_abstract_socket=-1; mdp_abstract_socket=-1;
@ -64,13 +62,11 @@ int overlay_mdp_setup_sockets()
char *instancepath=serval_instancepath(); char *instancepath=serval_instancepath();
snprintf(&name.sun_path[0],100,"%s/mdp.socket",instancepath); snprintf(&name.sun_path[0],100,"%s/mdp.socket",instancepath);
len = 0+strlen(&name.sun_path[0]) + sizeof(name.sun_family); len = 0+strlen(&name.sun_path[0]) + sizeof(name.sun_family);
mdp_named_socket = socket(AF_UNIX, SOCK_STREAM, 0); mdp_named_socket = socket(AF_UNIX, SOCK_DGRAM, 0);
if (mdp_named_socket>-1) { if (mdp_named_socket>-1) {
int dud=0; int dud=0;
int r=bind(mdp_named_socket, (struct sockaddr *)&name, len); int r=bind(mdp_named_socket, (struct sockaddr *)&name, len);
if (r) { dud=1; r=0; WHY("bind() of named unix domain socket failed"); } if (r) { dud=1; r=0; WHY("bind() of named unix domain socket failed"); }
r=listen(mdp_named_socket,100); // allow a lot of queued up MDP frames
if (r) { dud++; WHY("listen() failed"); }
if (dud) { if (dud) {
close(mdp_named_socket); close(mdp_named_socket);
mdp_named_socket=-1; mdp_named_socket=-1;