Sponsored Content
Full Discussion: Concurrent TCP client/server
Top Forums Programming Concurrent TCP client/server Post 302394940 by Johnny22 on Saturday 13th of February 2010 01:51:43 PM
Old 02-13-2010
Concurrent TCP client/server

I made a program and now I need to make it concurrent.
Can someone pls help me do this ?

The code is this:

Code:
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <netinet/in.h>
#include <errno.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <ctype.h>


/* portul folosit */
#define PORT 4256

struct operation
{
    int number1;
    int number2;
    int number3;
    int number4;
    int number5;
};

/* codul de eroare returnat de anumite apeluri */
extern int errno;

/* programul */
int main (int argc, char * argv[])
{
  struct sockaddr_in server;    /* structurile folosite de server si client */
  struct sockaddr_in from;
  struct operation request;    /* cererea primita de server */
  int sd;            /* descriptorul de socket */
  int port;
  
  /* setare port in cazul specificarii explicite */
  if (argc > 1)
  {
    port = atoi(argv[1]);
  }
  else
    port = PORT;

  /* cream un socket */
  if ((sd = socket (AF_INET, SOCK_STREAM, 0)) == -1)
    {
      perror ("Eroare la socket().\n");
      return errno;
    }

  /* pregatim structurile de date */
  bzero (&server, sizeof (server));
  bzero (&from, sizeof (from));
  
  /* umplem structura folosita de server */
  server.sin_family = AF_INET;    
      /* stabilirea familiei de socket-uri */
  server.sin_addr.s_addr = htonl (INADDR_ANY);
      /* acceptam orice adresa */
  server.sin_port = htons (port);
      /* utilizam un port utilizator */

  /* atasam socketul */
  if (bind (sd, (struct sockaddr *) &server, sizeof (struct sockaddr)) == -1)
    {
      perror ("Eroare la bind().\n");
      return errno;
    }

  /* punem serverul sa asculte daca vin clienti sa se conecteze */
  if (listen (sd, 3) == -1)
    {
      perror ("Eroare la listen().\n");
      return errno;
    }

  /* servim in mod iterativ clientii... */
  while (1)
    {
      int client;
      int length = sizeof (from);

      printf ("Asteptam la portul %d...\n", port);
      fflush (stdout);

      /* acceptam un client (ne vom bloca pina la realizarea conexiunii) */
      client = accept (sd, (struct sockaddr *) &from, &length);

      /* eroare la acceptarea conexiunii de la un client */
      if (client < 0)
    {
      perror ("Eroare la accept().\n");
      continue;
    }

      /* am realizat conexiunea, asteptam mesajul... */
      bzero (&request, sizeof(struct operation));
      printf ("Asteptam cererea...\n");
      fflush (stdout);
      
      /* citirea mesajului */
      int nrbytes = recv (client, &request, sizeof(struct operation), 0);
      if (nrbytes <= 0)
    {
      perror ("Eroare la read() de la client.\n");
      close (client);    /* inchidem conexiunea cu clientul */
      continue;        /* continuam sa ascultam... */
    }

      if (nrbytes < sizeof(struct operation))
      {
        perror ("Date primite incomplet");
    close (client);
    continue;
      }

      request.number1 = ntohl(request.number1);
      request.number2 = ntohl(request.number2);
      request.number3 = ntohl(request.number3);
      request.number4 = ntohl(request.number4);
      request.number5 = ntohl(request.number5);

      printf ("Cerere primita... \n In curs de rezolvare: %d %d %d %d %d \n", 
               request.number1, request.number2, request.number3, request.number4, request.number5);
      
      /* rezolvarea cererii */

int magic;
int a=0;
int b=0;
int c=0;
int d=0;
int e=0;
int min=0;
int result;


magic = rand() % 1001; /* generarea numarului magic de la 1 la 1000*/


/* diferenta dintre numarul magic si numerele primite */

if (magic >= request.number1)
a = magic - request.number1;
else
a = request.number1 - magic;

if (magic >= request.number2)
b = magic - request.number2;
else
b = request.number2 - magic;

if (magic >= request.number3)
c = magic - request.number3;
else
c = request.number3 - magic;

if (magic >= request.number4)
d = magic - request.number4;
else
d = request.number4 - magic;

if (magic >= request.number5)
e = magic - request.number5;
else
e = request.number5 - magic;

printf("\nnumar magic: %d\n", magic);
printf("numerele sunt: %d %d %d %d %d\n", a, b, c, d, e);
/* verificare care numar este mai aproape de numarul magic */

if (a > b)
min = b;
else min = a;

if (min > c)
min = c;

if (min > d)
min = d;

if (min > e)
{
min = e;
//result = min;
}
    printf("diferenta minima este: %d", min);
    /*selectam numarul care este mai apropiat de numarul magic*/
    if (min == a)
        result = request.number1;
    if (min == b)
        result = request.number2;
    if (min == c)
        result = request.number3;
    if (min == d)
        result = request.number4;
    else
        result = request.number5;
        
      result = htonl(result);

      /* returnam rapunsul clientului */
      if (send (client, &result, sizeof(int),0) <= 0)
    {
      perror ("Eroare la write() catre client.\n");
      continue;        /* continuam sa ascultam */
    }
      else
    printf (" trasmitere cu succes.\n");
      /* am terminat cu acest client, inchidem conexiunea */
      close (client);
    }                /* while */
}                /* main */

The program is a client/server. The server generates a random number and the clients(maximum 3) have to guess that number. The sever will only take the first 5 numbers from every client and see wich one is closest. The one that guesses the number or is the clossest will get a message that will say that he guessed the number!

Can someone pls help me make my server to be concurrent and to send messages to the one that is the closest ?

Now my program only gets the 5 numbers from the client, checks wich number is closest to the random number(the magic number) and returns that number to the client!

I tried to change it and use the fork() function but i got stuck because i got lots of errors and didn't knew how to resolve them!
 

10 More Discussions You Might Find Interesting

1. IP Networking

concurrent udp server

Just like concurrent tcp server, anyone know how to design the concurrent udp server with the thread? it's best to give some basic examples,thanks (0 Replies)
Discussion started by: Frank2004
0 Replies

2. Programming

tcp server listening, client connecting problems

hello everyone. I tried searching for something related to this, but I figured it was time to ask my own question. I am experiencing these problems using Ubuntu 7.04 I am starting up a TCP listener/server and once connected, will act as a communication/control link with a program on another... (3 Replies)
Discussion started by: pjwhite
3 Replies

3. UNIX for Advanced & Expert Users

HOW to create UDP Concurrent Server

HI I want to create a UDP concurrent server can any one give the code for UDP concurrent server (8 Replies)
Discussion started by: chanikya
8 Replies

4. Programming

Client/Server Socket Application - Preventing Client from quitting on server crash

Problem - Linux Client/Server Socket Application: Preventing Client from quitting on server crash Hi, I am writing a Linux socket Server and Client using TCP protocol on Ubuntu 9.04 x64. I am having problem trying to implement a scenario where the client should keep running even when the... (2 Replies)
Discussion started by: varun.nagpaal
2 Replies

5. Programming

Changing source port number of a TCP client packet

Hi all, I need to change the source port number of an outgoing TCP packet. First I have to bind the socket to a particular port(suppose 9001) but when I send the TCP packet I want to change the source port number lets say to 9002 still letting the socket to be bound to the same old port (9001).... (0 Replies)
Discussion started by: anuragrai134
0 Replies

6. Windows & DOS: Issues & Discussions

Office server => laptop =>client server ...a lengthy and laborious ftp procedure

Hi All, I need your expertise in finding a way to solve my problem.Please excuse if this is not the right forum to ask this question and guide me to the correct forum,if possible. I am a DBA and on a daily basis i have to ftp huge dump files from my company server to my laptop and then... (3 Replies)
Discussion started by: kunwar
3 Replies

7. Programming

[C++] [Unix] TCP non-blocking. Detect server disconnection procedure over, from client.

Hello! I searched forum for similar topic, with no luck, if you know one, delete this topic, and send me private message with link please. Little background: I have a lot of clients and one serwer. Client can make multiple connections on different ports and ips, but only one can be acctive... (2 Replies)
Discussion started by: ikeban
2 Replies

8. UNIX for Advanced & Expert Users

Problem with simple concurrent server example

hi all my problem is i have programmed a server to accept multiple clients through concurrent server approach https://lh3.googleusercontent.com/-hg-TSMdDj1k/UG5R7iICXaI/AAAAAAAAC5M/23_NnU5kH94/s800/concserver.png but when i try to execute the binding and connection accept works fine but the... (1 Reply)
Discussion started by: shyam.sunder91
1 Replies

9. Solaris

Too much TCP retransmitted and TCP duplicate on server Oracle Solaris 10

I have problem with oracle solaris 10 running on oracle sparc T4-2 server. Os information: 5.10 Generic_150400-03 sun4v sparc sun4v Output from tcpstat.d script TCP bytes: out outRetrans in inDup inUnorder 6833763 7300 98884 0... (2 Replies)
Discussion started by: insatiable1610
2 Replies

10. AIX

Difference between concurrent and enhanced concurrent VG

Hi, What are the differences between concurrent and enhanced concurrent VGs.? Any advantages of enhanced concurrent VG over normal concurrent vg Regards, Siva (2 Replies)
Discussion started by: ksgnathan
2 Replies
All times are GMT -4. The time now is 10:02 PM.
Unix & Linux Forums Content Copyright 1993-2022. All Rights Reserved.
Privacy Policy