hydrar/mistserver
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

DDVSocket edits

Browse source
This commit is contained in:
Thulinma 2010-11-08 15:51:06 +01:00
parent ac2998ae28
commit b34ee4927a
1 changed files with 20 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
util/ddv_socket.cpp
View file

@ -64,9 +64,15 @@ bool DDV_write(void * buffer, int todo, int sock){
while (sofar != todo){ while (sofar != todo){
int r = send(sock, (char*)buffer + sofar, todo-sofar, 0); int r = send(sock, (char*)buffer + sofar, todo-sofar, 0);
if (r <= 0){ if (r <= 0){
switch (errno){
case EWOULDBLOCK: printf("Would block\n"); break;
case EAGAIN: printf("Again\n"); break;
default:
socketError = true; socketError = true;
printf("Could not write! %s\n", strerror(errno)); printf("Could not write! %s\n", strerror(errno));
return false; return false;
break;
}
} }
sofar += r; sofar += r;
} }
@ -78,9 +84,15 @@ bool DDV_read(void * buffer, int todo, int sock){
while (sofar != todo){ while (sofar != todo){
int r = recv(sock, (char*)buffer + sofar, todo-sofar, 0); int r = recv(sock, (char*)buffer + sofar, todo-sofar, 0);
if (r <= 0){ if (r <= 0){
switch (errno){
case EWOULDBLOCK: printf("Read: Would block\n"); break;
case EAGAIN: printf("Read: Again\n"); break;
default:
socketError = true; socketError = true;
printf("Could not read! %s\n", strerror(errno)); printf("Could not read! %s\n", strerror(errno));
return false; return false;
break;
}
} }
sofar += r; sofar += r;
} }
@ -96,7 +108,7 @@ int DDV_iwrite(void * buffer, int todo, int sock){
int r = send(sock, buffer, todo, 0); int r = send(sock, buffer, todo, 0);
if (r < 0){ if (r < 0){
socketError = true; socketError = true;
printf("Could not write! %s\n", strerror(errno)); printf("Could not iwrite! %s\n", strerror(errno));
} }
return r; return r;
} }
@ -105,7 +117,7 @@ int DDV_iread(void * buffer, int todo, int sock){
int r = recv(sock, buffer, todo, 0); int r = recv(sock, buffer, todo, 0);
if (r < 0){ if (r < 0){
socketError = true; socketError = true;
printf("Could not write! %s\n", strerror(errno)); printf("Could not iread! %s\n", strerror(errno));
} }
return r; return r;
} }