X-Git-Url: http://git.cascardo.eti.br/?a=blobdiff_plain;f=ofproto%2Fcollectors.c;h=5b2921236c74de63779350a6264687fa339aeeff;hb=77ab5fd2a95ba2fef5bbe25aaa429776b9e29ea3;hp=b41e8e64c255704f4f9b5de115fa96e2d3344b05;hpb=f125905cdd3dc0339ad968c0a70128807884b400;p=cascardo%2Fovs.git

diff --git a/ofproto/collectors.c b/ofproto/collectors.c
index b41e8e64c..5b2921236 100644
--- a/ofproto/collectors.c
+++ b/ofproto/collectors.c
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2008, 2009, 2010, 2011 Nicira Networks.
+ * Copyright (c) 2008, 2009, 2010, 2011, 2013, 2014 Nicira, Inc.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -26,7 +26,7 @@
 #include "socket-util.h"
 #include "sset.h"
 #include "util.h"
-#include "vlog.h"
+#include "openvswitch/vlog.h"
 
 VLOG_DEFINE_THIS_MODULE(collectors);
 
@@ -63,15 +63,14 @@ collectors_create(const struct sset *targets, uint16_t default_port,
         int error;
         int fd;
 
-        error = inet_open_active(SOCK_DGRAM, name, default_port, NULL, &fd,
-                                 DSCP_INVALID);
+        error = inet_open_active(SOCK_DGRAM, name, default_port, NULL, &fd, 0);
         if (fd >= 0) {
             c->fds[c->n_fds++] = fd;
         } else {
             static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 5);
 
             VLOG_WARN_RL(&rl, "couldn't open connection to collector %s (%s)",
-                         name, strerror(error));
+                         name, ovs_strerror(error));
             if (!retval) {
                 retval = error;
             }
@@ -96,7 +95,7 @@ collectors_destroy(struct collectors *c)
         size_t i;
 
         for (i = 0; i < c->n_fds; i++) {
-            close(c->fds[i]);
+            closesocket(c->fds[i]);
         }
         free(c->fds);
         free(c);
@@ -113,8 +112,10 @@ collectors_send(const struct collectors *c, const void *payload, size_t n)
         for (i = 0; i < c->n_fds; i++) {
             static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 5);
             if (send(c->fds[i], payload, n, 0) == -1) {
-                VLOG_WARN_RL(&rl, "sending to collector failed: %s",
-                             strerror(errno));
+                char *s = describe_fd(c->fds[i]);
+                VLOG_WARN_RL(&rl, "%s: sending to collector failed (%s)",
+                             s, ovs_strerror(errno));
+                free(s);
             }
         }
     }