Fix try_assimilate

Also get rid of CLOSE_WAIT in some situations.

confluent_server/confluent/collective/manager.py

@@ -96,6 +96,7 @@ def connect_to_leader(cert=None, name=None, leader=None):
 def follow_leader(remote):
     cfm.follow_channel(remote)
     # The leader has folded, time to startup again...
+    remote.close()
     eventlet.spawn_n(start_collective)
 
 
@@ -272,6 +273,8 @@ def try_assimilate(drone):
     tlvdata.send(remote, {'collective': {'operation': 'assimilate',
                                          'name': get_myname(),
                                          'txcount': cfm._txcount}})
+    tlvdata.recv(remote)  # the banner
+    tlvdata.recv(remote)  # authpassed... 0..
     answer = tlvdata.recv(remote)
     if 'error' in answer:
         connect_to_leader(None, None, leader=remote.getpeername()[0])

confluent_server/confluent/config/configmanager.py

@@ -475,6 +475,7 @@ def relay_slaved_requests(name, listener):
             if 'xid' in rpc:
                 _push_rpc(listener, cPickle.dumps({'xid': rpc['xid']}))
         msg = listener.recv(8)
+    listener.close()
     del cfgstreams[name]
     if not cfgstreams:
         cfgleader = True