From a6311fe5358082612234463949ac628fb3815d56 Mon Sep 17 00:00:00 2001
From: Thulinma <jaron@vietors.com>
Date: Mon, 8 Nov 2010 16:09:42 +0100
Subject: [PATCH] DDVSocket edits

---
 util/ddv_socket.cpp | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/util/ddv_socket.cpp b/util/ddv_socket.cpp
index 0c14a371..1d3efd69 100644
--- a/util/ddv_socket.cpp
+++ b/util/ddv_socket.cpp
@@ -9,6 +9,7 @@
 #include <fcntl.h>
 
 bool socketError = false;
+bool socketBlocking = false;
 
 int DDV_OpenUnix(const char adres[], bool nonblock = false){
   int s = socket(AF_UNIX, SOCK_STREAM, 0);
@@ -67,11 +68,12 @@ int DDV_Accept(int sock, bool nonblock = false){
 
 bool DDV_write(void * buffer, int todo, int sock){
   int sofar = 0;
+  socketBlocking = false;
   while (sofar != todo){
     int r = send(sock, (char*)buffer + sofar, todo-sofar, 0);
     if (r <= 0){
       switch (errno){
-        case EWOULDBLOCK: printf("Would block\n"); break;
+        case EWOULDBLOCK: printf("Would block\n"); socketBlocking = true; break;
         default:
           socketError = true;
           printf("Could not write! %s\n", strerror(errno));
@@ -86,11 +88,12 @@ bool DDV_write(void * buffer, int todo, int sock){
 
 bool DDV_read(void * buffer, int todo, int sock){
   int sofar = 0;
+  socketBlocking = false;
   while (sofar != todo){
     int r = recv(sock, (char*)buffer + sofar, todo-sofar, 0);
     if (r <= 0){
       switch (errno){
-        case EWOULDBLOCK: printf("Read: Would block\n"); break;
+        case EWOULDBLOCK: printf("Read: Would block\n"); socketBlocking = true; break;
         default:
           socketError = true;
           printf("Could not read! %s\n", strerror(errno));