more cleanup up of build files + indentation
diff --git a/aos/common/network/ReceiveSocket.cpp b/aos/common/network/ReceiveSocket.cpp
index 671f966..c754f32 100644
--- a/aos/common/network/ReceiveSocket.cpp
+++ b/aos/common/network/ReceiveSocket.cpp
@@ -19,12 +19,12 @@
return ret;
}
- if (bind(socket_, &addr_.addr,
+ if (bind(socket_, &addr_.addr,
sizeof(addr_)) == -1) {
LOG(ERROR, "failed to bind to address '%s' because of %d: %s\n", localhost,
errno, strerror(errno));
return last_ret_ = -1;
- }
+ }
return last_ret_ = 0;
}
diff --git a/aos/common/network/ReceiveSocket.h b/aos/common/network/ReceiveSocket.h
index bd834c9..468cb22 100644
--- a/aos/common/network/ReceiveSocket.h
+++ b/aos/common/network/ReceiveSocket.h
@@ -7,11 +7,8 @@
class ReceiveSocket : public Socket {
public:
- inline ReceiveSocket(NetworkPort port) { Connect(port); }
+ inline ReceiveSocket(NetworkPort port) { Connect(port); }
int Connect(NetworkPort port);
-
- inline int Recv(void *buf, int length) { return Socket::Recv(buf, length); }
- inline int Recv(void *buf, int length, long usec) { return Socket::Recv(buf, length, usec); }
};
} // namespace aos
diff --git a/aos/common/network/SendSocket.cpp b/aos/common/network/SendSocket.cpp
index 89665dc..78aca79 100644
--- a/aos/common/network/SendSocket.cpp
+++ b/aos/common/network/SendSocket.cpp
@@ -18,24 +18,24 @@
return ret;
}
- if (connect(socket_, &addr_.addr,
+ if (connect(socket_, &addr_.addr,
sizeof(addr_)) < 0) {
LOG(ERROR, "couldn't connect to ip '%s' because of %d: %s\n", robot_ip,
errno, strerror(errno));
last_ret_ = 1;
}
- hold_msg_len_ = 0;
+ hold_msg_len_ = 0;
return last_ret_ = 0;
}
int SendSocket::SendHoldMsg() {
- if (hold_msg_len_ > 0) {
- int val = Send(hold_msg_, hold_msg_len_);
- hold_msg_len_ = 0;
- return val;
- }
- return -1;
+ if (hold_msg_len_ > 0) {
+ int val = Send(hold_msg_, hold_msg_len_);
+ hold_msg_len_ = 0;
+ return val;
+ }
+ return -1;
}
} // namespace aos
diff --git a/aos/common/network/SendSocket.h b/aos/common/network/SendSocket.h
index 6d3feb1..27021e0 100644
--- a/aos/common/network/SendSocket.h
+++ b/aos/common/network/SendSocket.h
@@ -7,19 +7,18 @@
class SendSocket : public Socket {
public:
- //inline int Send(const void *buf, int length) { return Socket::Send(buf, length); }
// Connect must be called before use.
SendSocket() {}
// Calls Connect automatically.
- SendSocket(NetworkPort port, const char *robot_ip) {
+ SendSocket(NetworkPort port, const char *robot_ip) {
Connect(port, robot_ip);
}
- int Connect(NetworkPort port, const char *robot_ip, int type = SOCK_DGRAM);
+ int Connect(NetworkPort port, const char *robot_ip, int type = SOCK_DGRAM);
static const size_t MAX_MSG = 4096;
- char hold_msg_[MAX_MSG];
- size_t hold_msg_len_;
- int SendHoldMsg();
+ char hold_msg_[MAX_MSG];
+ size_t hold_msg_len_;
+ int SendHoldMsg();
};
} // namespace aos
diff --git a/aos/common/network/Socket.cpp b/aos/common/network/Socket.cpp
index b01bcb8..1ffc775 100644
--- a/aos/common/network/Socket.cpp
+++ b/aos/common/network/Socket.cpp
@@ -3,37 +3,38 @@
#include <string.h>
#include <errno.h>
-#include "aos/aos_core.h"
+#include "aos/common/logging/logging.h"
#include "aos/common/network/SocketLibraries.h"
namespace aos {
int Socket::Connect(NetworkPort port, const char *address, int type) {
last_ret_ = 0;
- if ((socket_ = socket(AF_INET, type, 0)) < 0) {
- LOG(ERROR, "failed to create socket because of %d: %s\n", errno, strerror(errno));
+ if ((socket_ = socket(AF_INET, type, 0)) < 0) {
+ LOG(ERROR, "failed to create socket because of %d: %s\n",
+ errno, strerror(errno));
return last_ret_ = 1;
- }
+ }
- memset(&addr_, 0, sizeof(addr_));
- addr_.in.sin_family = AF_INET;
+ memset(&addr_, 0, sizeof(addr_));
+ addr_.in.sin_family = AF_INET;
addr_.in.sin_port = htons(static_cast<uint16_t>(port));
#ifndef __VXWORKS__
const int failure_return = 0;
#else
const int failure_return = -1;
#endif
- if (inet_aton(lame_unconst(address), &addr_.in.sin_addr) == failure_return) {
- LOG(ERROR, "Invalid IP address '%s' because of %d: %s\n", address,
+ if (inet_aton(lame_unconst(address), &addr_.in.sin_addr) == failure_return) {
+ LOG(ERROR, "Invalid IP address '%s' because of %d: %s\n", address,
errno, strerror(errno));
return last_ret_ = -1;
- }
+ }
return last_ret_ = 0;
}
Socket::Socket() : socket_(-1), last_ret_(2) {}
Socket::~Socket() {
- close(socket_);
+ close(socket_);
}
void Socket::Reset() {
@@ -45,7 +46,7 @@
}
int Socket::Recv(void *buf, int length) {
- const int ret = recv(socket_, static_cast<char *>(buf), length, 0);
+ const int ret = recv(socket_, static_cast<char *>(buf), length, 0);
last_ret_ = (ret == -1) ? -1 : 0;
return ret;
}
@@ -67,11 +68,10 @@
}
}
int Socket::Send(const void *buf, int length) {
- const int ret = write(socket_,
+ const int ret = write(socket_,
lame_unconst(static_cast<const char *>(buf)), length);
- //const int ret = length;
last_ret_ = (ret == -1) ? -1 : 0;
return ret;
}
-} // namespace aos
+} // namespace aos
diff --git a/aos/common/network/Socket.h b/aos/common/network/Socket.h
index ceee754..b6d2c70 100644
--- a/aos/common/network/Socket.h
+++ b/aos/common/network/Socket.h
@@ -1,5 +1,5 @@
-#ifndef AOS_NETWORK_SOCKET_H_
-#define AOS_NETWORK_SOCKET_H_
+#ifndef AOS_COMMON_NETWORK_SOCKET_H_
+#define AOS_COMMON_NETWORK_SOCKET_H_
#include <sys/socket.h>
#include <sys/types.h>
@@ -8,7 +8,9 @@
#include <stdlib.h>
#include <unistd.h>
#include <stdio.h>
+
#include "aos/common/Configuration.h"
+#include "aos/common/time.h"
namespace aos {
@@ -27,16 +29,15 @@
// Resets socket_ and last_ret_.
void Reset();
- union {
+ union {
sockaddr_in in;
sockaddr addr;
} addr_; // filled in by Connect
- int socket_;
+ int socket_;
int last_ret_;
};
-} // namespace aos
+} // namespace aos
-#endif
-
+#endif // AOS_COMMON_NETWORK_SOCKET_H_
diff --git a/aos/common/network/network.gyp b/aos/common/network/network.gyp
index ca3e653..a41509d 100644
--- a/aos/common/network/network.gyp
+++ b/aos/common/network/network.gyp
@@ -47,9 +47,11 @@
],
'dependencies': [
'<(AOS)/build/aos.gyp:logging',
+ '<(AOS)/common/common.gyp:time',
],
'export_dependent_settings': [
'<(AOS)/build/aos.gyp:logging',
+ '<(AOS)/common/common.gyp:time',
],
},
],