StackOverflow2013

Note that there are some explanatory texts on larger screens.

plurals

POAddress Already in Use.
primarykey
Id
8936342
data
AcceptedAnswerId
0
AnswerCount
2
ClosedDate
CommentCount
2
CommunityOwnedDate
CreationDate
2012-01-20T03:15:13.777
FavoriteCount
0
LastActivityDate
2012-01-20T04:35:10.950
LastEditDate
LastEditorUserId
0
OwnerUserId
1152599
ParentId
0
PostTypeId
1
Score
1
ViewCount
2749
LastEditorDisplayName
text
Body
Recently I have been working on some client-side code for sending and receiving messages from a server using threading. The below code behaves strangely when run. Upon inputting a message to send to the server, the code completes the task, albeit with a "socket already in use" error, the server gets it. But every subsequent message I attempt to send to the server is not received immediately, yet it is seemingly all received at once when the client program terminates. (Additionally, I am certain the error is client-side, the strange behavior isn't exhibited if one comments the output function.) How can I fix this error? Client <pre><code>#include <stdio.h> #include <cstdlib> #include <sys/types.h> #include <sys/socket.h> #include <sys/time.h> #include <unistd.h> #include <netdb.h> #include <arpa/inet.h> #include <string> #include <iostream> #include <errno.h> #include <pthread.h> void* input(void* ptr) { int on = 1; bool *input_done = ((struct thread_args*)ptr)->process_done; struct addrinfo *res = ((struct thread_args*)ptr)->result; char msg[256]; int sock = socket(res->ai_family,res->ai_socktype,res->ai_protocol); setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,(char *)&on,sizeof(on)); bind(sock,res->ai_addr,res->ai_addrlen); connect(sock,res->ai_addr,res->ai_addrlen); cin.getline(msg,256); if (msg[0] == '/') {exit(1);} send(sock,msg,sizeof msg,0); cout << "You:" << msg << endl; *input_done = 1; close(sock); pthread_exit(NULL); } void* output(void* ptr) { int on = 1; bool *output_done = ((struct thread_args*)ptr)->process_done; struct addrinfo *res = ((struct thread_args*)ptr)->result; char msg[256]; int sock = socket(res->ai_family,res->ai_socktype,res->ai_protocol); bind(sock,res->ai_addr,res->ai_addrlen); connect(sock,res->ai_addr,res->ai_addrlen); recv(sock,msg,sizeof msg,0); cout << "Recieved:" << msg; *output_done = 1; close(sock); pthread_exit(NULL); } void io_client() { //thread function variables pthread_t t1,t2; bool input_done = 1, output_done = 1; //socket setup variables struct addrinfo hints, *res; memset(&hints,0,sizeof hints); hints.ai_family = AF_INET; hints.ai_socktype = SOCK_STREAM; getaddrinfo("localhost","8080",&hints,&res); //setting up structures to pass data to threaded functions struct thread_args i_args, o_args; i_args.result = res; i_args.process_done = &input_done; o_args.result = res; o_args.process_done = &output_done; while(1) { if (output_done) { pthread_create(&t2,NULL,output,&o_args); output_done = 0; } if (input_done) { pthread_create(&t1,NULL,input,&i_args); input_done = 0; } } } int main() { io_client(); } </code></pre> Server <pre><code>void server() { struct addrinfo hints, *res; int sock=-1, newsock=-1; int length, on=1; char **address_list; int entries = 0; //fd_set read_fd; //struct timeval timeout; char buffer[100]; memset(&hints,0,sizeof hints); res = NULL; memset(&res,0,sizeof res); hints.ai_family = AF_INET; hints.ai_socktype = SOCK_STREAM; getaddrinfo("localhost","8080",&hints,&res); sock = socket(res->ai_family,res->ai_socktype,res->ai_protocol); setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,(char *)&on,sizeof(on)); bind(sock,res->ai_addr,res->ai_addrlen); listen(sock,10); while(1) { struct sockaddr_storage addr; char ipstr[INET6_ADDRSTRLEN]; socklen_t len; len = sizeof addr; newsock = accept(sock,NULL,NULL); getpeername(newsock,(struct sockaddr*)&addr,&len); struct sockaddr_in *s = (struct sockaddr_in*)&addr; inet_ntop(AF_INET,&s->sin_addr,ipstr,sizeof ipstr); length = 100; setsockopt(newsock,SOL_SOCKET,SO_RCVLOWAT, (char*)&length,sizeof length); recv(newsock,buffer,sizeof buffer,0); cout << buffer << endl; } if (newsock != -1) { close(newsock); } if (sock != -1) { close(sock); } } int main() { server(); } </code></pre>
Tags
<c++><sockets><client><bind>
Title
Address Already in Use.
singulars
PostAcceptedAnswerId
1. This table or related slice is empty.
PostParentId
1. This table or related slice is empty.
PostTypePostTypeId
1. PTQuestion
UserLastEditorUserId
1. This table or related slice is empty.
UserOwnerUserId
1. USChris Grimm
plurals
PostLinksPostIdRelatedPostId
1. This table or related slice is empty.
PostLinksRelatedPostIdPostId
1. This table or related slice is empty.
PostsAcceptedAnswerId
1. This table or related slice is empty.
PostsParentIdCreationDate
1. PO
 singulars
 PostTypePostTypeId
 PTAnswer
2. PO
 singulars
 PostTypePostTypeId
 PTAnswer
VotesPostIdCreationDate
1. This table or related slice is empty.
CommentsPostId
1. COIt is not a answer to your question, but I will suggest you to use Boost.Asio. =)
 singulars
 PostPostId
 POAddress Already in Use.
 UserUserId
 USAndré Puel
2. COAnd that's pure C, except for single `cout` statement.
 singulars
 PostPostId
 POAddress Already in Use.
 UserUserId
 USvines

Querying!

Guidance

A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.