9ad1d2da68aa4acf817562502340bf319276b283,parlai/mturk/core/dev/socket_manager.py,SocketManager,close_channel,#SocketManager#Any#,627

Before Change

                        if connection_id == packet_conn_id:
                            del self.packet_map[packet_id]
                // Clean up other resources
                del self.queues[connection_id]

    def close_all_channels(self):
        Closes all channels by clearing the list of channels
        shared_utils.print_and_log(logging.DEBUG, "Closing all channels")

After Change

            "Closing channel {}".format(connection_id)
        )
        if connection_id in self.open_channels:
            self.open_channels.remove(connection_id)
            with self.packet_map_lock:
                packet_ids = list(self.packet_map.keys())
                for packet_id in packet_ids:
                    packet = self.packet_map[packet_id]

Instances