Merge remote-tracking branch 'guus/1.1' into thkr-1.1-ponyhof
This commit is contained in:
commit
8ac16a5cf2
3 changed files with 23 additions and 10 deletions
19
src/netutl.c
19
src/netutl.c
|
@ -258,3 +258,22 @@ void sockaddrunmap(sockaddr_t *sa) {
|
|||
sa->in.sin_family = AF_INET;
|
||||
}
|
||||
}
|
||||
|
||||
void sockaddr_setport(sockaddr_t *sa, const char *port) {
|
||||
uint16_t portnum = htons(atoi(port));
|
||||
if(!portnum)
|
||||
return;
|
||||
switch(sa->sa.sa_family) {
|
||||
case AF_INET:
|
||||
sa->in.sin_port = portnum;
|
||||
break;
|
||||
case AF_INET6:
|
||||
sa->in6.sin6_port = portnum;
|
||||
break;
|
||||
case AF_UNKNOWN:
|
||||
free(sa->unknown.port);
|
||||
sa->unknown.port = xstrdup(port);
|
||||
default:
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
|
|
@ -35,5 +35,6 @@ extern int sockaddrcmp_noport(const sockaddr_t *, const sockaddr_t *);
|
|||
extern void sockaddrunmap(sockaddr_t *);
|
||||
extern void sockaddrfree(sockaddr_t *);
|
||||
extern void sockaddrcpy(sockaddr_t *, const sockaddr_t *);
|
||||
extern void sockaddr_setport(sockaddr_t *, const char *);
|
||||
|
||||
#endif /* __TINC_NETUTL_H__ */
|
||||
|
|
|
@ -800,7 +800,6 @@ bool ack_h(connection_t *c, const char *request) {
|
|||
return upgrade_h(c, request);
|
||||
|
||||
char hisport[MAX_STRING_SIZE];
|
||||
char *hisaddress;
|
||||
int weight, mtu;
|
||||
uint32_t options;
|
||||
node_t *n;
|
||||
|
@ -877,19 +876,13 @@ bool ack_h(connection_t *c, const char *request) {
|
|||
c->edge = new_edge();
|
||||
c->edge->from = myself;
|
||||
c->edge->to = n;
|
||||
sockaddr2str(&c->address, &hisaddress, NULL);
|
||||
c->edge->address = str2sockaddr(hisaddress, hisport);
|
||||
free(hisaddress);
|
||||
sockaddr_setport(&c->address, hisport);
|
||||
sockaddr_t local_sa;
|
||||
socklen_t local_salen = sizeof local_sa;
|
||||
if (getsockname(c->socket, &local_sa.sa, &local_salen) < 0)
|
||||
logger(DEBUG_ALWAYS, LOG_WARNING, "Could not get local socket address for connection with %s", c->name);
|
||||
else {
|
||||
char *local_address;
|
||||
sockaddr2str(&local_sa, &local_address, NULL);
|
||||
c->edge->local_address = str2sockaddr(local_address, myport);
|
||||
free(local_address);
|
||||
}
|
||||
else
|
||||
sockaddr_setport(&local_sa, myport);
|
||||
c->edge->weight = (weight + c->estimated_weight) / 2;
|
||||
c->edge->connection = c;
|
||||
c->edge->options = c->options;
|
||||
|
|
Loading…
Reference in a new issue