def METHOD_NAME(cpu, data, size):
    event = b["ipv4_events"].event(data)
    # print("%-8s %-7d %-2d %-20s > %-20s %s (%s)" % (
    #     strftime("%H:%M:%S"), event.pid, event.ip,
    #     "%s:%d" % (inet_ntop(AF_INET, pack('I', event.saddr)), event.sport),
    #     "%s:%s" % (inet_ntop(AF_INET, pack('I', event.daddr)), event.dport),
    #     tcp.tcpstate[event.state], tcp.flags2str(event.tcpflags)))
    # write to influxdb
    test_data = lmp_data(datetime.now().isoformat(),'glob', event.pid, event.ip,
        inet_ntop(AF_INET, pack('I', event.saddr)), event.sport,
        inet_ntop(AF_INET, pack('I', event.daddr)), event.dport,
        tcp.tcpstate[event.state], tcp.flags2str(event.tcpflags))
    #print(test_data)
    write2db(data_struct, test_data, influx_client, DatabaseType.INFLUXDB.value)
    # for addr in stack_traces.walk(event.stack_id):
    #     sym = b.ksym(addr, show_offset=True)
    #     print("\t%s" % sym)
    # print("")