def create_connection(self, controller_info, switch, max_backoff_seconds=1024):
    # TODO(cs): move this into a ConnectionFactory class
    while controller_info.address == "__address__":
      log.debug("Waiting for controller address for %s..." % controller_info.label)
      time.sleep(5)
    if self.multiplex_sockets:
      socket_ctor = STSMockSocket
    else:
      socket_ctor = socket.socket
    sock = connect_socket_with_backoff(controller_info.address,
                                       controller_info.port,
                                       max_backoff_seconds=max_backoff_seconds,
                                       socket_ctor=socket_ctor)
    # Set non-blocking
    sock.setblocking(0)
    io_worker = DeferredIOWorker(self.io_master.create_worker_for_socket(sock))
    connection = DeferredOFConnection(io_worker, controller_info.cid, switch.dpid, self.openflow_buffer)
    return connection
Returns the transform currently on the top of the stack.
dataset/ETHPy150Open ucb-sts/sts/sts/simulation_state.py/Simulation.create_connection--crossover with--dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/pipeline.py/Pipeline._current_transform