C++

Winsock et création de thread

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : Winsock et création de thread

Imhotep

Le monde est mon huître !!!

Salut

Pour un programme que je dois faire, j'utilise winsock. Pour ce faire j'utilise 2 thread, le premier thread principal pour envoyé des infos sur le réso et un deuxième thread pour recevoir des infos en permanance sur le réso.

En faite le premier se connecte sur le port 5001 d'un serveur. Et le deuxième attend une connexion sur le port 5000.

Mon problème est le suivant, quand je n'utilise que le premier thread (pour envoyer des infos), je n'ai pas de problème, tout marche bien. Mais quand j'utilise le deuxième tread, je ne suis plus capable d'envoyer des infos (premier thread) dès que je commance à écouter sur le port 5000 (deuxieme thread). Pourtant la connexion au serveur (par le premier thread) se passe bien. Je pense que mon deuxième thread fonctionne bien, c'est juste quand je fais un listen pour écouter le port 5000 que ca bloque.

Est-ce que quelqu'un saurait m'aider ???

Un grand merci.

Publicité

LetoII

Le dormeur doit se réveiller

Avec ton code peut être.

---------------
Le Tyran

Imhotep

Le monde est mon huître !!!

LetoII a écrit :

Avec ton code peut être.

Ok

Une partie du main

Code :

port = 5001;
initSock ();
test = createSocket();
connexionError = connect(test, "x.x.x.x", 5001);
//if (connexionError == 0)
threadStart(5000);
//else
// threadStart(5001);

Voici mon fichier pour le réso.

H

Code :

void initSock (void);
SOCKET createSocket(void);
void assignPort(SOCKET s, int port);
void listen(SOCKET s);
int connect(SOCKET s, char *adress, int port);
SOCKET acceptConnexion(SOCKET s);
void write(SOCKET s, char *string);
int read(SOCKET s, char *buffer);
void close(SOCKET s);

CPP

Code :

#include <winsock2.h>
#include <string.h>
#include <stdio.h>
#define BUFFER_SIZE 256
void initSock (void){
// Must be done at the beginning of every WinSock program
WSADATA w; // used to store information about WinSock version
int error = WSAStartup (0x0202, &w); // Fill in w
if (error)
{ // there was an error
return;
}
if (w.wVersion != 0x0202)
{ // wrong WinSock version!
WSACleanup (); // unload ws2_32.dll
return;
}
}
SOCKET createSocket(void) {
return socket (AF_INET, SOCK_STREAM, 0); // Create socket
}
void assignPort(SOCKET s, int port) {
// Note that you should only bind server sockets, not client sockets
// SOCKET s is a valid socket
// WSAStartup has been called
sockaddr_in addr; // the address structure for a TCP socket
addr.sin_family = AF_INET; // Address family Internet
addr.sin_port = htons (port); // Assign port to this socket
addr.sin_addr.s_addr = htonl (INADDR_ANY); // No destination
if (bind(s, (LPSOCKADDR)&addr, sizeof(addr)) == SOCKET_ERROR)
{ // error
WSACleanup (); // unload WinSock
return; // quit
}
}
void listen(SOCKET s) {
// WSAStartup () has been called
// SOCKET s is valid
// s has been bound to a port using sockaddr_in sock
if (listen(s,5)==SOCKET_ERROR)
{ // error! unable to listen
printf("error! unable to listen" );
WSACleanup ();
return;
}
}
int connect(SOCKET s, char *adress, int port){
// WSAStartup () has been called
// SOCKET s is valid
// s has been bound to a port using sockaddr_in sock
sockaddr_in target;
target.sin_family = AF_INET; // address family Internet
target.sin_port = htons (port); // set server?s port number
target.sin_addr.s_addr = inet_addr (adress); // set server?s IP
if (connect(s, (LPSOCKADDR)&target, sizeof(target)) == SOCKET_ERROR)
{ // an error connecting has occurred!
printf("an error connecting has occurred!" );
WSACleanup ();
return -1;
}
return 0;
}
SOCKET acceptConnexion(SOCKET s){
// WSAStartup () has been called
// SOCKET s is valid
// s has been bound to a port using sockaddr_in sock
// s is listening
//#define MAX_CLIENTS 1; // just used for clearness
int number_of_clients = 0;
SOCKET client[1/*MAX_CLIENTS*/]; // socket handles to clients
sockaddr client_sock[1/*MAX_CLIENTS*/]; // info on client sockets
while (number_of_clients < 1/*MAX_CLIENTS*/) // let MAX_CLIENTS connect
{
client[number_of_clients] = // accept a connection
accept (s, NULL/*client_sock[number_of_clients]*/, NULL/*&addr_size*/);
if (client[number_of_clients] == INVALID_SOCKET)
{ // error accepting connection
printf("error accepting connection" );
WSACleanup ();
return client[0];
} else { // client connected successfully
// start a thread that will communicate with client
//startThread (client[number_of_clients]);
number_of_clients++;
return client[0];
}
}
}
void write(SOCKET s, char *string) {
// SOCKET s is initialized
char buffer[BUFFER_SIZE];
sprintf (buffer, string);
//buffer[23] = '\0';
send (s, buffer, BUFFER_SIZE, 0);
printf("%s %d\n", buffer, strlen(buffer));
}
int read(SOCKET s, char *buffer){
int toto;
toto = recv (s, buffer, BUFFER_SIZE, 0);
//printf("%s, buffer: %d, string: %d, recv: %d\n", buffer, sizeof(buffer), strlen(buffer), toto);
return toto;
}
void close(SOCKET s) {
shutdown (s, SD_SEND); // s cannot send anymore
// you should check to see if any last data has arrived here
closesocket (s); // close
}

Message édité par Imhotep le 04-06-2003 à 10:18:04

Imhotep

Le monde est mon huître !!!

Pour le thread

Code :

#include "stdio.h"
#include "process.h"
#include "network2.h"
#define BUFFER_SIZE 256
int port;
float xNet, yNet, zNet;
int tmpFrameNew = -1, part = 0;
// déclaration de la section critique
// code de la première tâche : PremierThread
DWORD WINAPI readThread ( LPVOID IpvThreadParam )
{
SOCKET test;
SOCKET testClient;
char buffer[BUFFER_SIZE];
//int port = 5001;
int rint;
int tempInt, tmpX, tmpY, tmpZ;
/*
if (argc == 2) port = (int)argv[1];
printf("arg: %d.\nport: %d.\n", argc, port);
*/
initSock ();
//
test = createSocket();
assignPort(test, port);
listen(test);
testClient = acceptConnexion(test);
while(true){
rint = read(testClient, buffer);
if (rint > 0) {
tempInt = sscanf(buffer,"%d %d %f %f %f", tmpFrameNew, part, tmpX, tmpY, tmpZ);
if (tempInt == 5 ) {
xNet = tmpX;
yNet = tmpY;
zNet = tmpZ;
}
}
}
//printf("%s %d", buffer, strlen(buffer));
close(testClient);
close(test);
return (0);
}
// point d'entrée du programme
void threadStart (int por)
{
// Initialisation de la section critique
port = por;
HANDLE hThreads [ 1 ] ;
DWORD dwThreadId ;
DWORD dwThreadParam = 1 ;
// création des Threads
hThreads [ 0 ] = CreateThread ( NULL, NULL, readThread, &dwThreadParam, 0, &dwThreadId ) ;
// attente de fin d'exécution des Threads
//WaitForMultipleObjects ( 1, hThreads, TRUE, INFINITE) ;
// destruction des Threads et de la section critique
//CloseHandle ( hThreads [ 0 ] ) ;
// destruction de la section critique
}
float retourXYZ(int nb) {
if (nb == 1)
return xNet;
else if (nb == 2)
return yNet;
else
return zNet;
}
int retourFrame() {
return tmpFrameNew;
}
int retourPart() {
return part;
}

Message édité par Imhotep le 04-06-2003 à 09:24:33

LetoII

Le dormeur doit se réveiller

tu devrais utiliser les balises de codes c pas top lisible là.

Message édité par LetoII le 04-06-2003 à 10:20:10

---------------
Le Tyran

Imhotep

Le monde est mon huître !!!

LetoII a écrit :

tu devrais utiliser les balises de codes c pas top lisible là.

Merci

LetoII

Le dormeur doit se réveiller

Le main ça pourait être sympa aussi

Message édité par LetoII le 04-06-2003 à 09:39:10

---------------
Le Tyran

Imhotep

Le monde est mon huître !!!

Vala (voir plus haut)

FORUM HardWare.fr

Programmation

C++

Winsock et création de thread

Sujets relatifs
Exercice PHP - Création de tableau	creation dune toolbar pr ie
winsock ??	création d'un site
[PHP] Création de Sous-dossier impossible	[QT] thread
compilation de xxx.java et création de xxx$1.java et xxx$2.java	création de liens hypertextes
[URGENT] [MSDE-SQLServer] Création d'une DB en ligne de commande	Creation de KM sous Patrol
Plus de sujets relatifs à : Winsock et création de thread

Page générée en 0.088 secondes