'Function to process the cached arp entries.'

def _process_arp_cache_for_internal_port(self, subnet_id):

    arp_remove = set()
    for arp_entry in self._pending_arp_set:
        if (subnet_id == arp_entry.subnet_id):
            try:
                state = self._update_arp_entry(arp_entry.ip, arp_entry.mac, arp_entry.subnet_id, arp_entry.operation)
            except Exception:
                state = False
            if state:
                arp_remove.add(arp_entry)
    self._pending_arp_set -= arp_remove
