How to listens to two different ports at the same time

Dev Articles Community Forums Sponsor:

December 29th, 2005, 05:59 AM

jaro

Contributing User

Join Date: Nov 2005

Posts: 35

Time spent in forums: 1 Day 6 h 16 m 44 sec
Reputation Power: 4

How to listens to two different ports at the same time

hi there,
i've got this code that listens for incomming message through port and display the message it recieves..
here's the code:

Code:

#include "stdio.h" 
#include "winsock.h" 
#define PORT 1200 
#define BACKLOG 4 
struct sockaddr_in server; 
struct sockaddr_in client;
int sockfd,sockfd2,n_bytes; 
char msg[5000]; 
void handle_error(void);
int main(){ 
WSADATA wsda; 
WSAStartup(0x0101,&wsda); 
	if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1){ 
	handle_error();
	printf("Socket error..."); 
	return 0; 
	} 
server.sin_addr.s_addr=INADDR_ANY;
server.sin_port=htons(PORT);
server.sin_family=AF_INET; 
	if(bind(sockfd,(struct sockaddr*)&server,sizeof(struct sockaddr))==-1){ 
	handle_error();
	printf("Cannot bind..."); 
	return 0; 
	} 
	if(listen(sockfd,BACKLOG)){
	handle_error();
	printf("Error Listening..."); 
	return 0; 
	} 
	while (1){ 
	int size=sizeof(struct sockaddr_in); 
		if((sockfd2=accept(sockfd,(struct sockaddr*)&client,&size))==-1){ 
		handle_error();
		printf("Accept Error..."); 
		return 0; 
		} 
		if((n_bytes=recv(sockfd2,msg ,5000,0))==-1){ 
		handle_error();
		printf("Error Recv..."); 
		return 0; 
		} 
	msg[n_bytes]='\0'; 
	printf("Client's Message:%s",msg); 
	} 
WSACleanup(); 
closesocket(sockfd);
closesocket(sockfd2); 
return 0; 
} 


void handle_error(void)
{
  switch ( WSAGetLastError() )
  {
    case WSANOTINITIALISED :
      printf("Unable to initialise socket.\n");
    break;
    case WSAEAFNOSUPPORT :
      printf("The specified address family is not supported.\n");
    break;
    case WSAEADDRNOTAVAIL :
      printf("Specified address is not available from the local machine.\n");
    break;
    case WSAECONNREFUSED :
      printf("The attempt to connect was forcefully rejected.\n"); 
      break; 
    case WSAEDESTADDRREQ : 
      printf("address destination address is required.\n");
    break;
    case WSAEFAULT :
      printf("The namelen argument is incorrect.\n");
    break;
    case WSAEINVAL :
      printf("The socket is not already bound to an address.\n");
    break;
    case WSAEISCONN :
      printf("The socket is already connected.\n");
    break;
    case WSAEADDRINUSE :
      printf("The specified address is already in use.\n");
    break;
    case WSAEMFILE : 
      printf("No more file descriptors are available.\n");
    break;
    case WSAENOBUFS :
      printf("No buffer space available. The socket cannot be created.\n");
    break;
    case WSAEPROTONOSUPPORT :
      printf("The specified protocol is not supported.\n");
      break; 
    case WSAEPROTOTYPE :
      printf("The specified protocol is the wrong type for this socket.\n");
    break;
    case WSAENETUNREACH : 
      printf("The network can't be reached from this host at this time.\n");
    break; 
    case WSAENOTSOCK :
       printf("The descriptor is not a socket.\n");
    break;
    case WSAETIMEDOUT :
      printf("Attempt timed out without establishing a connection.\n");
    break;
    case WSAESOCKTNOSUPPORT :
       printf("Socket type is not supported in this address family.\n");
    break;
    case WSAENETDOWN :
      printf("Network subsystem failure.\n");
    break;
    case WSAHOST_NOT_FOUND :
      printf("Authoritative Answer Host not found.\n");
    break;
    case WSATRY_AGAIN :
      printf("Non-Authoritative Host not found or SERVERFAIL.\n");
     break;
    case WSANO_RECOVERY :
       printf("Non recoverable errors, FORMERR, REFUSED, NOTIMP.\n");
    break;
    case WSANO_DATA :
      printf("Valid name, no data record of requested type.\n");
    break;
      case WSAEINPROGRESS :
      printf("address blocking Windows Sockets operation is in progress.\n");
    break;
    case WSAEINTR :
      printf("The (blocking) call was canceled via WSACancelBlockingCall().\n");
    break;
    default :
      printf("Unknown error.\n");
     break;
  }

}

i've run/tested this and it works fine...
...now i want for the program to listens to two different ports and display the message it recieves through them (ports)...

so i've try to edit the code above to this ( not quite sure if it the right thing to do though ):

Code:

#include "stdio.h" 
#include "winsock.h" 
#define PORT 1200 
#define BACKLOG 4 
struct sockaddr_in server; 
struct sockaddr_in client;
int sockfd,sockfd2,n_bytes; 
char msg[5000]; 

struct sockaddr_in servertwo; 
struct sockaddr_in clienttwo;
int sock_one,secondn_bytes,sock_two; 
char workmsg[5000];
#define workPORT 7777 
#define workBACKLOG 4 
void handle_error(void);
int main(){ 
WSADATA wsda; 
WSAStartup(0x0101,&wsda); 
	if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1){ 
	handle_error();
	printf("Socket error..."); 
	return 0; 
	} 
server.sin_addr.s_addr=INADDR_ANY;
server.sin_port=htons(PORT); 
server.sin_family=AF_INET; 
	if((sock_one=socket(AF_INET,SOCK_STREAM,0))==-1){ 
	handle_error();
	printf("Socket error..."); 
	return 0; 
	} 

servertwo.sin_addr.s_addr=INADDR_ANY; 
servertwo.sin_port=htons(workPORT); 
servertwo.sin_family=AF_INET; 
	if(bind(sockfd,(struct sockaddr*)&server,sizeof(struct sockaddr))==-1){ 
	handle_error();
	printf("Cannot bind..."); 
	return 0; 
	} 
	if(listen(sockfd,BACKLOG)){ /*Listening */
	handle_error();
	printf("Error Listening..."); 
	return 0; 
	} 
	if(bind(sock_one,(struct sockaddr*)&servertwo,sizeof(struct sockaddr))==-1){ 
	handle_error();
	printf("Cannot bind..."); 
	return 0; 
	} 
	if(listen(sock_one,workBACKLOG)){
	handle_error();
	printf("Error Listening..."); 
	return 0; 
	} 
	while (1){ 
	int size=sizeof(struct sockaddr_in); 
	int size2=sizeof(struct sockaddr_in); 
		if((sockfd2=accept(sockfd,(struct sockaddr*)&client,&size))==-1){ 
		handle_error();
		printf("Accept Error..."); 
		return 0; 
		} 
		if((n_bytes=recv(sockfd2,msg ,5000,0))==-1){ 
		handle_error();
		printf("Error Recv..."); 
		return 0; 
		} 
		if((sock_two=accept(sock_one,(struct sockaddr*)&clienttwo,&size2))==-1){ 
		handle_error();
		printf("Accept Error..."); 
		return 0; 
		} 
		if((secondn_bytes=recv(sock_two,workmsg ,5000,0))==-1){ 
		handle_error();
		printf("Error Recv..."); 
		return 0; 
		} 
	msg[n_bytes]='\0'; 
	workmsg[secondn_bytes]='\0'; 
	printf("Client 1's Message:%s",msg); 
	printf("Client 2's Message:%s",workmsg); 
	} 
WSACleanup(); 
closesocket(sockfd);
closesocket(sockfd2); 
closesocket(sock_one); 
closesocket(sock_two); 
return 0; 
} 

void handle_error(void)
{
  switch ( WSAGetLastError() )
  {
    case WSANOTINITIALISED :
      printf("Unable to initialise socket.\n");
    break;
    case WSAEAFNOSUPPORT :
      printf("The specified address family is not supported.\n");
    break;
    case WSAEADDRNOTAVAIL :
      printf("Specified address is not available from the local machine.\n");
    break;
    case WSAECONNREFUSED :
      printf("The attempt to connect was forcefully rejected.\n"); 
      break; 
    case WSAEDESTADDRREQ : 
      printf("address destination address is required.\n");
    break;
    case WSAEFAULT :
      printf("The namelen argument is incorrect.\n");
    break;
    case WSAEINVAL :
      printf("The socket is not already bound to an address.\n");
    break;
    case WSAEISCONN :
      printf("The socket is already connected.\n");
    break;
    case WSAEADDRINUSE :
      printf("The specified address is already in use.\n");
    break;
    case WSAEMFILE : 
      printf("No more file descriptors are available.\n");
    break;
    case WSAENOBUFS :
      printf("No buffer space available. The socket cannot be created.\n");
    break;
    case WSAEPROTONOSUPPORT :
      printf("The specified protocol is not supported.\n");
      break; 
    case WSAEPROTOTYPE :
      printf("The specified protocol is the wrong type for this socket.\n");
    break;
    case WSAENETUNREACH : 
      printf("The network can't be reached from this host at this time.\n");
    break; 
    case WSAENOTSOCK :
       printf("The descriptor is not a socket.\n");
    break;
    case WSAETIMEDOUT :
      printf("Attempt timed out without establishing a connection.\n");
    break;
    case WSAESOCKTNOSUPPORT :
       printf("Socket type is not supported in this address family.\n");
    break;
    case WSAENETDOWN :
      printf("Network subsystem failure.\n");
    break;
    case WSAHOST_NOT_FOUND :
      printf("Authoritative Answer Host not found.\n");
    break;
    case WSATRY_AGAIN :
      printf("Non-Authoritative Host not found or SERVERFAIL.\n");
     break;
    case WSANO_RECOVERY :
       printf("Non recoverable errors, FORMERR, REFUSED, NOTIMP.\n");
    break;
    case WSANO_DATA :
      printf("Valid name, no data record of requested type.\n");
    break;
      case WSAEINPROGRESS :
      printf("address blocking Windows Sockets operation is in progress.\n");
    break;
    case WSAEINTR :
      printf("The (blocking) call was canceled via WSACancelBlockingCall().\n");
    break;
    default :
      printf("Unknown error.\n");
     break;
  }

}

now the problem when i run the program and try to send a message it does nothing. it does not display the message sent or display some error ( if any ).

can anyone help me shed light to this, or better yet give me a link in "How to listens to two different ports at the same time using C" i've tried to google it but the results a not that promising.

sorry for the long post.
any comment will be much appreciated

btw: i'm using mvc 6 and win2k

thanks in advance,
jaro

January 2nd, 2006, 08:57 AM

jaro

Contributing User

Join Date: Nov 2005

Posts: 35

Time spent in forums: 1 Day 6 h 16 m 44 sec
Reputation Power: 4

finally found the solution...
although the program sometimes hungs when i try to exit it...
anyways thats fine with me...
btw here is the code

Code:

#include <stdio.h>
#include <winsock.h> 
#include <process.h>

#define PORT 1200 
#define BACKLOG 4 
#define workPORT 7777 
#define workBACKLOG 4 
#define STRSIZE 16536
#define STRSIZETWO 16536

struct sockaddr_in server; 
struct sockaddr_in client;
int sockfd,sockfd2,n_bytes; 
char msg[5000]; 
struct sockaddr_in servertwo; 
struct sockaddr_in clienttwo;
int sock_one,secondn_bytes,sock_two; 
char workmsg[5000];

int recieveMessage(void);
int recieveMessageTwo(void);
void handle_error(void);

void errexit(const char *format, ...)
{
	va_list	args;
	va_start(args, format);
	vfprintf(stderr, format, args);
	va_end(args);
	WSACleanup();
	exit(1);
}


int main(){ 

WSADATA wsda; 
WSAStartup(0x0101,&wsda); 

	if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1){ 
	handle_error();
	printf("Socket error..."); 
	return 0; 
	} 

server.sin_addr.s_addr=INADDR_ANY; 
server.sin_port=htons(PORT); 
server.sin_family=AF_INET; 


	if((sock_one=socket(AF_INET,SOCK_STREAM,0))==-1){ 
	handle_error();
	printf("Socket error..."); 
	return 0; 
	} 

servertwo.sin_addr.s_addr=INADDR_ANY; 
servertwo.sin_port=htons(workPORT); 
servertwo.sin_family=AF_INET; 


	if(bind(sockfd,(struct sockaddr*)&server,sizeof(struct sockaddr))==-1){ 
	handle_error();
	printf("Cannot bind..."); 
	return 0; 
	} 


	if(bind(sock_one,(struct sockaddr*)&servertwo,sizeof(struct sockaddr))==-1){ 
	handle_error();
	printf("Cannot bind..."); 
	return 0; 
	} 

	if(listen(sockfd,BACKLOG)){ 
	handle_error();
	printf("Error Listening..."); 
	return 0; 
	} 

	if(listen(sock_one,workBACKLOG)){ 
	handle_error();
	printf("Error Listening..."); 
	return 0; 
	} 



	while (1){ 

		if (_beginthread((void (*)(void *)) recieveMessage, STRSIZE, ( void *) sockfd) < 0) 
			{ 
				handle_error();
				errexit("_beginthread: %s\n", strerror(errno));
			}

		if (_beginthread((void (*)(void *)) recieveMessageTwo, STRSIZETWO, ( void *) sock_one) < 0) 
			{ 
				handle_error();
				errexit("_beginthread: %s\n", strerror(errno));
			}

	} 


WSACleanup(); 
closesocket(sockfd); 
closesocket(sockfd2); 
closesocket(sock_one);
closesocket(sock_two); 

return 0; 
} 


int recieveMessage(){
	int size=sizeof(struct sockaddr_in); 

		if((sockfd2=accept(sockfd,(struct sockaddr*)&client,&size))==-1){ 
		printf("Accept Error..."); 
		} 

		if((n_bytes=recv(sockfd2,msg ,50,0))==-1){ 
		printf("Error Recv..."); 
		} 

		msg[n_bytes]='\0'; 

		printf("Client's Message:%s",msg); 

return 0; 
}


int recieveMessageTwo(){
	int size2=sizeof(struct sockaddr_in); 

		if((sock_two=accept(sock_one,(struct sockaddr*)&clienttwo,&size2))==-1){ 

		printf("Accept Error..."); 

		} 

		if((secondn_bytes=recv(sock_two,workmsg ,5000,0))==-1){ 

		printf("Error Recv..."); 

		} 

		workmsg[secondn_bytes]='\0'; 

		printf("Client 2's Message:%s",workmsg); 

return 0; 
}

void handle_error(void)
{
  switch ( WSAGetLastError() )
  {
    case WSANOTINITIALISED :
      printf("Unable to initialise socket.\n");
    break;
    case WSAEAFNOSUPPORT :
      printf("The specified address family is not supported.\n");
    break;
    case WSAEADDRNOTAVAIL :
      printf("Specified address is not available from the local machine.\n");
    break;
    case WSAECONNREFUSED :
      printf("The attempt to connect was forcefully rejected.\n"); 
      break; 
    case WSAEDESTADDRREQ : 
      printf("address destination address is required.\n");
    break;
    case WSAEFAULT :
      printf("The namelen argument is incorrect.\n");
    break;
    case WSAEINVAL :
      printf("The socket is not already bound to an address.\n");
    break;
    case WSAEISCONN :
      printf("The socket is already connected.\n");
    break;
    case WSAEADDRINUSE :
      printf("The specified address is already in use.\n");
    break;
    case WSAEMFILE : 
      printf("No more file descriptors are available.\n");
    break;
    case WSAENOBUFS :
      printf("No buffer space available. The socket cannot be created.\n");
    break;
    case WSAEPROTONOSUPPORT :
      printf("The specified protocol is not supported.\n");
      break; 
    case WSAEPROTOTYPE :
      printf("The specified protocol is the wrong type for this socket.\n");
    break;
    case WSAENETUNREACH : 
      printf("The network can't be reached from this host at this time.\n");
    break; 
    case WSAENOTSOCK :
       printf("The descriptor is not a socket.\n");
    break;
    case WSAETIMEDOUT :
      printf("Attempt timed out without establishing a connection.\n");
    break;
    case WSAESOCKTNOSUPPORT :
       printf("Socket type is not supported in this address family.\n");
    break;
    case WSAENETDOWN :
      printf("Network subsystem failure.\n");
    break;
    case WSAHOST_NOT_FOUND :
      printf("Authoritative Answer Host not found.\n");
    break;
    case WSATRY_AGAIN :
      printf("Non-Authoritative Host not found or SERVERFAIL.\n");
     break;
    case WSANO_RECOVERY :
       printf("Non recoverable errors, FORMERR, REFUSED, NOTIMP.\n");
    break;
    case WSANO_DATA :
      printf("Valid name, no data record of requested type.\n");
    break;
      case WSAEINPROGRESS :
      printf("address blocking Windows Sockets operation is in progress.\n");
    break;
    case WSAEINTR :
      printf("The (blocking) call was canceled via WSACancelBlockingCall().\n");
    break;
    default :
      printf("Unknown error.\n");
     break;
  }
}

i'm using vc6 and my os is win2k also include the WSOCK32.lib and make it multithreaded in the "USe run time Library"

any comment here will be much appreciated ( especially if you some wrong convention that i've used )

- jaro

January 11th, 2006, 03:10 AM

mox8iro

Registered User

Join Date: Jan 2006

Posts: 12

Time spent in forums: 10 h 5 m 38 sec
Reputation Power: 0

dumb question

its being a while since i dealed with sockets..
but i have to ask
shouldnt the listening being done in each thread?
i mean in this way you v done it; the prgram cant listen for two connections at the same time doesnt it?

let me know if i am wrong

January 11th, 2006, 09:35 PM

Geo.Garnett

Registered Loser

Join Date: Jul 2005

Location: Retardation Nation...

Posts: 347

Time spent in forums: 4 Days 3 h 13 m 45 sec
Reputation Power: 4

I think I would have to agree and I wouldn't see the reason why you would need to listen to two separate ports, Because If I'm not mistaken it is possible to have two or more clients connected through a single port, hence the extra open port would be unnecessary. But just my opinion.

__________________
---Official Member Of The Itsacon Fan Club---

Give a man a fish and he will eat for a day. Teach a man to fish and he will sit in a boat all day drinking beer.

January 17th, 2006, 09:48 AM

Neuro

Registered User

Join Date: Jan 2006

Posts: 7

Time spent in forums: 1 h 10 m 47 sec
Reputation Power: 0

I have just written a program (for Linux) that you might find useful.

you could easily create a seperate thread to handle each port and further threads to handle each client.

My program only does one port and you won't be able to execute it as you will also require a custom module. Important stuff is around line #46, although it'll prob confuse you a bit as you're writing for Windows.

C Code:

Original - C Code

#include <netinet/in.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <strings.h>
#include "stack.h"

int sd, balance;
struct sockaddr_in servaddr, cliaddr;
int exit_status;
tstack* statement;
tstack* slider;
pthread_mutex_t ac_lock;
const int zero = 0;

void* userconnect(int connfd);

int main(int argc, char** argv)
{
	int connfd;
	pthread_t tid;
	
	pthread_mutex_init(&ac_lock, NULL);
	balance = 100;

if(argc < 2) {printf("more arguments needed\n"); return 1;}
	printf("\033[2J"); printf("Press [CTRL-C] to exit this program.\n");
	statement = NULL;

/* Init Connection Tools*/

printf("Opening balance: $100\n\n");
	sd = socket(AF_INET,SOCK_STREAM,0);
	
	int clilen = sizeof(struct sockaddr_in);
	bzero(&cliaddr,sizeof(cliaddr));
	bzero(&servaddr,sizeof(servaddr));
	servaddr.sin_family = AF_INET;
	servaddr.sin_addr.s_addr=htonl(INADDR_ANY);
	servaddr.sin_port = htons(atoi(argv[1]));
	bind(sd,(struct sockaddr*)&servaddr,sizeof(servaddr));
	listen(sd, 10);

while(1) {
	connfd = accept(sd,(struct sockaddr*)&cliaddr,&clilen);
	printf("id#%d | Connected accepted from  \"%s\" on Port:%d\n",connfd,inet_ntoa(cliaddr.sin_addr),ntohs(cliaddr.  sin_port));
	pthread_create(&tid,NULL,userconnect,connfd);
	}

// END //
	close(sd);
	return exit_status;
}

void* userconnect(int connfd) {

int data,mode,wait;
int exit_flag;
exit_flag = 0;
while(!exit_flag) {
	data = 0;
	mode = 0;

//printf("Waiting for data...\n");
	wait = 1;
	while(wait) {
		if(recv(connfd,&data,sizeof(int),0)) { wait = 0; }
	}

//printf("Waiting for mode...\n");
	wait = 1;
	while(wait) {
		if(recv(connfd,&mode,sizeof(int),0)) { wait = 0; }
	}

pthread_mutex_lock(&ac_lock);
	switch(mode) {
		case 1 : printf("id#%d | Balance Checked\n",connfd);
			 send(connfd,&balance,sizeof(int),0);
			 break;
		case 2 : printf("id#%d | Funds Withdrawl, $%d\n",connfd,data);
			 s_push(data,mode,&statement);
			 balance = balance - data;
			 break;
		case 3 : printf("id#%d | Deposit Made, $%d\n",connfd,data);
			 s_push(data,mode,&statement);
			 balance = balance + data;
			 break;
		case 4 : printf("id#%d | Statement Requested\n",connfd);
			 send(connfd,&balance,sizeof(int),0);
			 slider = statement;
			 if(slider != NULL) { wait = 1; } else { wait = 0; } while(wait) {
				send(connfd,&slider->data,sizeof(int),0);
				send(connfd,&slider->mode,sizeof(int),0);
				slider = slider->next; if(slider==NULL){wait = 0;}
			 }
			 send(connfd,&zero,sizeof(int),0);
			 send(connfd,&zero,sizeof(int),0);
			 break;
		case 5 : exit_flag = 1; break;
	}
	pthread_mutex_unlock(&ac_lock);

}
	printf("id#%d | Connection closed\n",connfd); close(connfd);
}

#include <netinet/in.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <strings.h>
#include "stack.h"
 
int sd, balance;
struct sockaddr_in servaddr, cliaddr;
int exit_status;
tstack* statement;
tstack* slider;
pthread_mutex_t ac_lock;
const int zero = 0;
 
void* userconnect(int connfd);
 
int main(int argc, char** argv)
{
    int connfd;
    pthread_t tid;
    
    pthread_mutex_init(&ac_lock, NULL);
    balance = 100;
 
    if(argc < 2) {printf("more arguments needed\n"); return 1;}
    printf("\033[2J"); printf("Press [CTRL-C] to exit this program.\n");
    statement = NULL;
 
    /* Init Connection Tools*/
 
    printf("Opening balance: $100\n\n");
    sd = socket(AF_INET,SOCK_STREAM,0);
    
    int clilen = sizeof(struct sockaddr_in);
    bzero(&cliaddr,sizeof(cliaddr));
    bzero(&servaddr,sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_addr.s_addr=htonl(INADDR_ANY);
    servaddr.sin_port = htons(atoi(argv[1]));
    bind(sd,(struct sockaddr*)&servaddr,sizeof(servaddr));
    listen(sd, 10);
 
    while(1) {
    connfd = accept(sd,(struct sockaddr*)&cliaddr,&clilen);
    printf("id#%d | Connected accepted from  \"%s\" on Port:%d\n",connfd,inet_ntoa(cliaddr.sin_addr),ntohs(cliaddr.  sin_port));
    pthread_create(&tid,NULL,userconnect,connfd);
    }
 
    // END //
    close(sd);
    return exit_status;
}
 
void* userconnect(int connfd) {
 
int data,mode,wait;
int exit_flag;
exit_flag = 0;
while(!exit_flag) {
    data = 0;
    mode = 0;
 
    //printf("Waiting for data...\n");
    wait = 1;
    while(wait) {
        if(recv(connfd,&data,sizeof(int),0)) { wait = 0; }
    }
 
    //printf("Waiting for mode...\n");
    wait = 1;
    while(wait) {
        if(recv(connfd,&mode,sizeof(int),0)) { wait = 0; }
    }
 
    pthread_mutex_lock(&ac_lock);
    switch(mode) {
        case 1 : printf("id#%d | Balance Checked\n",connfd);
             send(connfd,&balance,sizeof(int),0);
             break;
        case 2 : printf("id#%d | Funds Withdrawl, $%d\n",connfd,data);
             s_push(data,mode,&statement);
             balance = balance - data;
             break;
        case 3 : printf("id#%d | Deposit Made, $%d\n",connfd,data);
             s_push(data,mode,&statement);
             balance = balance + data;
             break;
        case 4 : printf("id#%d | Statement Requested\n",connfd);
             send(connfd,&balance,sizeof(int),0);
             slider = statement;
             if(slider != NULL) { wait = 1; } else { wait = 0; } while(wait) {
                send(connfd,&slider->data,sizeof(int),0);
                send(connfd,&slider->mode,sizeof(int),0);
                slider = slider->next; if(slider==NULL){wait = 0;}
             }
             send(connfd,&zero,sizeof(int),0);
             send(connfd,&zero,sizeof(int),0);
             break;
        case 5 : exit_flag = 1; break;
    }
    pthread_mutex_unlock(&ac_lock);
 
}
    printf("id#%d | Connection closed\n",connfd); close(connfd);
}

Thread Tools	Search this Thread
Email this Page	Search this Thread: Advanced Search
Display Modes	Rate This Thread
Linear Mode Switch to Hybrid Mode Switch to Threaded Mode	Rate This Thread: