code: def _process_indication(indication, host):
      '''This function gets called when an indication is received.'''
  
      global RECEIVED_INDICATION_DICT
      COUNTER_LOCK.acquire()
      if host in RECEIVED_INDICATION_DICT:
          RECEIVED_INDICATION_DICT[host] += 1
      else:
          RECEIVED_INDICATION_DICT[host] = 1
      COUNTER_LOCK.release()
  
      listener.logger.info("Consumed CIM indication #%s: host=%s\n%s",
                           RECEIVED_INDICATION_DICT, host, indication.tomof()f _process_indication(indication, host):
      '''This function gets called when an indication is received.'''
  
      global RECEIVED_INDICATION_DICT
      COUNTER_LOCK.acquire()
      if host in RECEIVED_INDICATION_DICT:
          RECEIVED_INDICATION_DICT[host] += 1
      else:
          RECEIVED_INDICATION_DICT[host] = 1
      COUNTER_LOCK.release()
  
      listener.logger.info("Consumed CIM indication #%s: host=%s\n%s",
                           RECEIVED_INDICATION_DICT, host, indication.tomof())
docs: This function gets called when an indication is received.