def METHOD_NAME(pkt):
    global parser
    global rm
    global event_queue
    global SCHC_machine
    scheduler.run(session=schc_protocol, period=10)
    # look for a tunneled SCHC pkt
    if pkt.getlayer(Ether) != None: #HE tunnel do not have Ethernet
        e_type = pkt.getlayer(Ether).type
        if e_type == 0x0800:
            ip_proto = pkt.getlayer(IP).proto
            if ip_proto == 17:
                udp_dport = pkt.getlayer(UDP).dport
                if udp_dport == socket_port: # tunnel SCHC msg to be decompressed
                    print ("tunneled SCHC msg")
                    schc_pkt, addr = tunnel.recvfrom(2000)
                    r = schc_protocol.schc_recv(device_id, schc_pkt)
                    print (r)
    elif IP in pkt and pkt.getlayer(IP).version == 6 : # regular IPv6trafic to be compression
        schc_protocol.schc_send(bytes(pkt))