Reversse r841

git-svn-id: file:///home/lennart/svn/public/avahi/trunk@843 941a03a8-eaeb-0310-b9a0-b1bbd8fe43fe

diff --git a/avahi-compat-libdns_sd/compat.c b/avahi-compat-libdns_sd/compat.c
index cc9ca1cf7d85e99855d69c2a5dd71fae6c68c6e2..0306c2f2c2eb102162ac9c65b3092ffa4c7ab499 100644 (file)
--- a/avahi-compat-libdns_sd/compat.c
+++ b/avahi-compat-libdns_sd/compat.c
@@ -47,7 +47,6 @@
 #include "dns_sd.h"
 
 enum {
-    COMMAND_COME_AGAIN = 0,
     COMMAND_POLL = 'p',
     COMMAND_QUIT = 'q',
     COMMAND_POLL_DONE = 'P',
@@ -173,10 +172,6 @@ static int read_command(int fd) {
     assert(fd >= 0);
     
     if ((r = read(fd, &command, 1)) != 1) {
-
-        if (errno == EAGAIN)
-            return COMMAND_COME_AGAIN;
-        
         fprintf(stderr, __FILE__": read() failed: %s\n", r < 0 ? strerror(errno) : "EOF");
         return -1;
     }
@@ -195,21 +190,6 @@ static int write_command(int fd, char reply) {
     return 0;
 }
 
-static int set_nonblock(int fd) {
-    int n;
-
-    assert(fd >= 0);
-
-    if ((n = fcntl(fd, F_GETFL)) < 0)
-        return -1;
-
-    if (n & O_NONBLOCK)
-        return 0;
-
-    return fcntl(fd, F_SETFL, n|O_NONBLOCK);
-}
-
-
 static int poll_func(struct pollfd *ufds, unsigned int nfds, int timeout, void *userdata) {
     DNSServiceRef sdref = userdata;
     int ret;
@@ -276,9 +256,6 @@ static void * thread_func(void *data) {
 
             case COMMAND_QUIT:
                 return NULL;
-
-            case COMMAND_COME_AGAIN:
-                break;
         }
         
     }
@@ -301,8 +278,6 @@ static DNSServiceRef sdref_new(void) {
     sdref->thread_fd = fd[0];
     sdref->main_fd = fd[1];
 
-    set_nonblock(sdref->main_fd);
-
     sdref->client = NULL;
     sdref->service_browser = NULL;
     sdref->service_resolver = NULL;
@@ -407,7 +382,6 @@ int DNSSD_API DNSServiceRefSockFD(DNSServiceRef sdref) {
 
 DNSServiceErrorType DNSSD_API DNSServiceProcessResult(DNSServiceRef sdref) {
     DNSServiceErrorType ret = kDNSServiceErr_Unknown;
-    int t;
 
     assert(sdref);
     assert(sdref->n_ref >= 1);
@@ -419,11 +393,8 @@ DNSServiceErrorType DNSSD_API DNSServiceProcessResult(DNSServiceRef sdref) {
     ASSERT_SUCCESS(pthread_mutex_lock(&sdref->mutex));
     
     /* Cleanup notification socket */
-    if ((t = read_command(sdref->main_fd)) != COMMAND_POLL_DONE) {
-        if (t == COMMAND_COME_AGAIN)
-            ret = kDNSServiceErr_Unknown;
+    if (read_command(sdref->main_fd) != COMMAND_POLL_DONE)
         goto finish;
-    }
     
     if (avahi_simple_poll_dispatch(sdref->simple_poll) < 0)
         goto finish;