def handle(self, sock, addr):
        try:
            initial = self.__read_pp_initial(sock)
            if initial.startswith(b'PROXY '):
                src_addr, _ = ProxyProtocolV1.process_pp_v1(sock, initial)
            elif initial == b'\r\n\r\n\x00\r\nQ':
                src_addr, _ = ProxyProtocolV2.process_pp_v2(sock, initial)
            else:
                raise AssertionError('Invalid proxy protocol signature')
        except LocalConnection:
            log.proxyproto_local(sock)
            return
        except AssertionError as exc:
            log.proxyproto_invalid(sock, exc)
            src_addr = invalid_pp_source_address
        else:
            log.proxyproto_success(sock, src_addr)
        return super(ProxyProtocol, self).handle(sock, src_addr)


# vim:et:fdm=marker:sts=4:sw=4:ts=4
Breaks a Queue such that it never blocks, always has size 1,
dataset/ETHPy150Open slimta/python-slimta/slimta/util/proxyproto.py/ProxyProtocol.handle--crossover with--dataset/ETHPy150Open beetbox/beets/beets/util/pipeline.py/_invalidate_queue