summaryrefslogtreecommitdiff
path: root/netcon/NetconEthernetTap.cpp
diff options
context:
space:
mode:
authorJoseph Henry <josephjah@gmail.com>2016-01-15 10:27:27 -0800
committerJoseph Henry <josephjah@gmail.com>2016-01-15 10:27:27 -0800
commit323d40a5607acaa2a2fa6dba98e37b826e3ed7aa (patch)
tree5f327157348ff6c7564a2e5edca04af954c0a7cf /netcon/NetconEthernetTap.cpp
parent321bca4bf7621792d8bdb572ed8d8312769fb34f (diff)
downloadinfinitytier-323d40a5607acaa2a2fa6dba98e37b826e3ed7aa.tar.gz
infinitytier-323d40a5607acaa2a2fa6dba98e37b826e3ed7aa.zip
Small formatting changes
Diffstat (limited to 'netcon/NetconEthernetTap.cpp')
-rw-r--r--netcon/NetconEthernetTap.cpp26
1 files changed, 13 insertions, 13 deletions
diff --git a/netcon/NetconEthernetTap.cpp b/netcon/NetconEthernetTap.cpp
index 03d83091..903198dc 100644
--- a/netcon/NetconEthernetTap.cpp
+++ b/netcon/NetconEthernetTap.cpp
@@ -54,10 +54,10 @@
#include "common.inc.c"
#include "RPC.h"
-#define APPLICATION_POLL_FREQ 50
-#define ZT_LWIP_TCP_TIMER_INTERVAL 5
-#define STATUS_TMR_INTERVAL 1000 // How often we check connection statuses (in ms)
-#define DEFAULT_BUF_SZ 1024 * 1024 * 2
+#define APPLICATION_POLL_FREQ 50
+#define ZT_LWIP_TCP_TIMER_INTERVAL 5
+#define STATUS_TMR_INTERVAL 1000 // How often we check connection statuses (in ms)
+#define DEFAULT_BUF_SZ 1024 * 1024 * 2
namespace ZeroTier {
@@ -445,7 +445,7 @@ void NetconEthernetTap::closeConnection(PhySocket *sock)
}
dwr(MSG_DEBUG," closeConnection(): PCB->state = %d\n", conn->pcb->state);
if(lwipstack->_tcp_close(conn->pcb) != ERR_OK) {
- dwr(MSG_ERROR," closeConnection(): Error while calling tcp_close()\n");
+ dwr(MSG_ERROR," closeConnection(): error while calling tcp_close()\n");
}
if(!sock)
return;
@@ -487,8 +487,8 @@ void NetconEthernetTap::phyOnUnixWritable(PhySocket *sock,void **uptr)
}
} else {
perror("\n");
- dwr(MSG_ERROR, "errno = %d\n", errno);
- dwr(MSG_ERROR," phyOnUnixWritable(): No data written to stream <%x>\n", conn->sock);
+ dwr(MSG_ERROR," phyOnUnixWritable(): errno = %d\n", errno);
+ dwr(MSG_ERROR," phyOnUnixWritable(): no data written to stream <%x>\n", conn->sock);
}
}
@@ -544,11 +544,11 @@ void NetconEthernetTap::phyOnUnixData(PhySocket *sock,void **uptr,void *data,uns
// Grab token, next we'll use it to look up an RPC job
if(canary_pos > -1) {
memcpy(&CANARY_num, buf+canary_pos, CANARY_SZ);
- if(CANARY_num != 0) { // TODO: Added to address CANARY_num==0 bug, last seeen 20160108
+ if(CANARY_num != 0) {
// Find job
sockdata = jobmap[CANARY_num];
- if(!sockdata.first) { // Stream before RPC
- dwr(MSG_DEBUG," <%x> unable to locate job entry for %llu\n", sock, CANARY_num);
+ if(!sockdata.first) {
+ dwr(MSG_DEBUG," <%x> unable to locate job entry for %llu\n", sock, CANARY_num);
return;
} else
foundJob = true;
@@ -607,7 +607,7 @@ void NetconEthernetTap::phyOnUnixData(PhySocket *sock,void **uptr,void *data,uns
unloadRPC(buf, pid, tid, rpcCount, timestamp, CANARY, cmd, payload);
dwr(MSG_DEBUG," <%x> RPC: (pid=%d, tid=%d, rpcCount=%d, timestamp=%s, cmd=%d)\n",
sock, pid, tid, rpcCount, timestamp, cmd);
-
+
switch(cmd) {
case RPC_BIND:
dwr(MSG_DEBUG," <%x> RPC_BIND\n", sock);
@@ -712,12 +712,12 @@ err_t NetconEthernetTap::nc_accept(void *arg, struct tcp_pcb *newPCB, err_t err)
tap->lwipstack->_tcp_poll(newPCB, nc_poll, 1);
if(conn->pcb->state == LISTEN) {
dwr(MSG_DEBUG," nc_accept(): can't call tcp_accept() on LISTEN socket (pcb = %x)\n", conn->pcb);
- return ERR_OK; // TODO: Verify this is correct
+ return ERR_OK;
}
tcp_accepted(conn->pcb); // Let lwIP know that it can queue additional incoming connections
return ERR_OK;
} else
- dwr(MSG_ERROR," nc_accept(%d): can't locate Connection object for PCB.\n", fd);
+ dwr(MSG_ERROR," nc_accept(): can't locate Connection object for PCB.\n");
return -1;
}