def do(self):
        success = False
        dealer = None

        try:
            self.start_transfer()
            dealer = self.context.socket(zmq.DEALER)
            dealer.connect(get_brocker_uri(self.session))

            if self.chunk_size * 2 < self.metadata.size:
                self.get_file_oneshot(dealer)
            else:
                if self.dealer.plug.has_handler('upload_chunk'):
                    self.get_file_multipart(dealer)
                else:
                    self.get_file_oneshot(dealer)
        except AbortOperation:
            pass
        else:
            success = True
        finally:
            if dealer:
                dealer.close()

        self.end_transfer(success)
dataset/ETHPy150Open onitu/onitu/onitu/plug/workers.py/TransferWorker.do/swapped operands of `<`