this.output=new DataOutputStream(sock.getOutputStream());
}
void close() {
if(active.compareAndSet(true, false)) {
if(log.isDebugEnabled())
<BUG>log.debug("Closing connection handler " + this.toString());
Util.close(input);</BUG>
Util.close(output);
Util.close(sock);
for(Address addr: logical_addrs) {

this.output=new DataOutputStream(sock.getOutputStream());
}
void close() {
if(active.compareAndSet(true, false)) {
if(log.isDebugEnabled())
log.debug(this + " is being closed");
Util.close(input);
Util.close(output);
Util.close(sock);
for(Address addr: logical_addrs) {
