sergiotarxz/nuttx-apps
sergiotarxz/nuttx-apps
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Unix domain: More fixes. With these changes, apps/examples/ustream works

Browse Source
This commit is contained in:
Gregory Nutt 2015-01-28 08:39:48 -06:00
parent b7fa5a3359
commit 1c2cb493e6
2 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
examples/ustream/ustream_client.c
View File

@ -103,7 +103,7 @@ int client_main(int argc, char *argv[])
strncpy(myaddr.sun_path, CONFIG_EXAMPLES_USTREAM_ADDR, addrlen); strncpy(myaddr.sun_path, CONFIG_EXAMPLES_USTREAM_ADDR, addrlen);
myaddr.sun_path[addrlen] = '\0'; myaddr.sun_path[addrlen] = '\0';
printf("client: Connecting...\n"); printf("client: Connecting to %s...\n", CONFIG_EXAMPLES_USTREAM_ADDR);
addrlen += sizeof(sa_family_t) + 1; addrlen += sizeof(sa_family_t) + 1;
ret = connect( sockfd, (struct sockaddr *)&myaddr, addrlen); ret = connect( sockfd, (struct sockaddr *)&myaddr, addrlen);
if (ret < 0) if (ret < 0)
@ -176,6 +176,7 @@ int client_main(int argc, char *argv[])
goto errout_with_socket; goto errout_with_socket;
} }
printf("client: Terminating\n");
close(sockfd); close(sockfd);
free(outbuf); free(outbuf);
free(inbuf); free(inbuf);

12
examples/ustream/ustream_server.c
View File

@ -113,6 +113,8 @@ int server_main(int argc, char *argv[])
/* Listen for connections on the bound socket */ /* Listen for connections on the bound socket */
printf("server: Accepting connections on %s ...\n", CONFIG_EXAMPLES_USTREAM_ADDR);
if (listen(listensd, 5) < 0) if (listen(listensd, 5) < 0)
{ {
printf("server: listen failure %d\n", errno); printf("server: listen failure %d\n", errno);
@ -121,7 +123,6 @@ int server_main(int argc, char *argv[])
/* Accept only one connection */ /* Accept only one connection */
printf("server: Accepting connections on %s\n", CONFIG_EXAMPLES_USTREAM_ADDR);
acceptsd = accept(listensd, (struct sockaddr*)&myaddr, &addrlen); acceptsd = accept(listensd, (struct sockaddr*)&myaddr, &addrlen);
if (acceptsd < 0) if (acceptsd < 0)
{ {
@ -187,14 +188,7 @@ int server_main(int argc, char *argv[])
} }
printf("server: Sent %d bytes\n", nbytessent); printf("server: Sent %d bytes\n", nbytessent);
printf("server: Terminating\n");
/* If this platform only does abortive disconnects, then wait a bit to get the
* client side a change to receive the data.
*/
printf("server: Wait before closing\n");
sleep(60);
close(listensd); close(listensd);
close(acceptsd); close(acceptsd);
free(buffer); free(buffer);