@synchronized
  def _RemoveSink(self, endpoint):
    node = self._FindNodeByEndpoint(endpoint)
    if not node or node.index < 0:
      return False

    i = node.index
    Heap.Swap(self._heap, i, self._size)
    Heap.FixDown(self._heap, i, self._size - 1)
    self._heap.pop()
    self._size -= 1
    self.__varz.size(self._size)
    if self._size < 0:
      self._log.warning("Decrementing size below 0")
      self._size = 0
    node.index = -1
    if node.load == self.Idle or node.load >= 0:
      node.channel.Close()
    return True
Remove a sink from the heap.
dataset/ETHPy150Open steveniemitz/scales/scales/loadbalancer/heap.py/HeapBalancerSink._RemoveSink