def _send_pickle(self):
        if len(self.batch_buffer):
            payload = pickle.dumps(self.batch_buffer)
            header = struct.pack("!L", len(payload))
            message = header + payload
            self.socket.sendall(message)
            # Reinitialze buffer and counter
            self.batch_count = 0
            self.batch_buffer = []
dataset/ETHPy150Open cyberdelia/metrology/metrology/reporter/graphite.py/GraphiteReporter._send_pickle/original