int dsock = -1;
if(sockets.count(ds->remote) == 0) {
- dsock=sockets[ds->remote]=setupTCPDownstream(ds);
+ dsock=setupTCPDownstream(ds);
+ sockets[ds->remote]=dsock;
}
else
dsock=sockets[ds->remote];
close(dsock);
dsock=-1;
sockets.erase(ds->remote);
- sockets[ds->remote]=dsock=setupTCPDownstream(ds);
+ dsock=setupTCPDownstream(ds);
+ sockets[ds->remote]=dsock;
downstream_failures++;
goto retry;
}
close(dsock);
dsock=-1;
sockets.erase(ds->remote);
- sockets[ds->remote]=dsock=setupTCPDownstream(ds);
+ dsock=setupTCPDownstream(ds);
+ sockets[ds->remote]=dsock;
downstream_failures++;
goto retry;
}
close(dsock);
dsock=-1;
sockets.erase(ds->remote);
- sockets[ds->remote]=dsock=setupTCPDownstream(ds);
+ dsock=setupTCPDownstream(ds);
+ sockets[ds->remote]=dsock;
downstream_failures++;
if(xfrStarted) {
goto drop;