Segmentation fault when parsing CAT62

[skysanchegn]

Hi all,

I have an unexpected Segmentation fault issue when parsing asterix final file (mainly cat62 - ARTAS output).
I took the python example(https://github.com/CroatiaControlLtd/asterix/blob/master/asterix/examples/read_final_file.py), and it's working fine.
But after 100k packets parsed i have this message : "Segmentation fault (core dumped) "
I think we maybe have some issues with the file but not detected by our custom asterix file parser
I trying to put try except block, but this issue seen to be set from C/C++ subprogram

Have you simple way for trying to catch issue and continue the parsing loop ?

Thx a lot ;)

[dsalantic]

Hi @skysanchegn ,

If you can share some example of the file from which the error can be reproduced I can try to find the problem.
Also, make sure that you are using the latest version of decoder.

Damir

[Shal-Ziar]

I can confirm this happens, I've ran my code using
python -m trace --trace <file.py> and it reports

processor.py(21):             try:
processor.py(22):                 data = self.recv(10240)
processor.py(23):                 if not data:
processor.py(25):                 packets = asterix.parse(data)
 --- modulename: __init__, funcname: parse
__init__.py(138):     if 'verbose' in kwargs and not kwargs['verbose']:
__init__.py(141):         verbose = 1
__init__.py(143):     if sys.version_info <= (2, 7):
__init__.py(145):     return _asterix.parse(bytes(data), verbose)
fish: Job 1, 'python -m trace --trace run.py' terminated by signal SIGSEGV (Address boundary error)

I'm running Python 3.11.11 with asterix-decoder 0.7.9
I'm receiving a data-stream from an external source.

This is my toy code:

class TCPclient(socket.socket):
    def __init__(self, host: str, port: int, callback: Callable[[List[CAT62_Type]], None], buffer_size: int = 1024):
        super().__init__(socket.AF_INET, socket.SOCK_STREAM)
        self.connect((host, port))
        self.callback = callback
        self.buffer_size = buffer_size

    
    def run(self):
        while not STOP_EVENT.is_set():
            try:
                data = self.recv(10240)
                if not data:
                    continue
                packets = asterix.parse(data)
                print(data)
                if packets:
                    self.callback(convert_to_pydantic_cat62(packets))
            except Exception as e:
                print(f"Error: {e}")

        print("Exiting")

The data that can't be parsed:
data=b" \xd4P\xb4\xe5\x00\x00#\x00'\xff\xff\x00!\x000\x06\x06\x84\x00\x00 \x0f\x01y\xa0\x11\x94\x11\x94\x03 \x03 '\x10\x11\x9b\x1f\x13\x8f\x02\x04\xd3_\xe8\x00\x00\x95\x8e\xc7\x00\x0c\x0e\xcb\xff\xff\x00\x00A\x011\xa0\x00\x00\x0e\x03\x16P\xd6\x9d\x00\x02%c\xb2\x03\x03\xb3\x02t\xf4\x80\x91\x00\xff\x0f\x00\x00!\x01\x00\x00\xa5n\x01\x01\x00\xd4\x87\xb6\xe5\x00\x00\x17\x00\x1a\x00\x00\x00\x16\x00 \x04\x04\x84\x00\x00 \x0f\x01y\xa0\x03\x84\x03\x84\x01,\x01,'\x10\x10\x9b\x1f\x13\x8f\x02\x04\xd3_\xe8\x00\x00\x99\xd0\x00\x0f\xc7\x96\x00\x1e\x00\x04a\x01q\xa0\x00\x00\r\x9do\xe0:P\x00\x00:\xbd\x00C&t\x16\x03\xf1\x9c\x02\xa6t\x80\x91\x00\xff\x07\x00\x00!\x01\x00\x00\xad\t_-;\\\xd4\xb5\\\xe5\x00\x00\x13\x00\x15\x00\x00\x00\x12\x00\x1b\x03\x03\x84\x00\x00 \x0f\x01y\xa0:f:f\x08\xfc\x08\xfc'\x10\x11\x9b\x0f\x13\x8f\x02\x04\xd3_\xe8\x00\x00\x93\xa2\x91\x00\x0f\xd5\xaf\x00\x00\x00\x00\xa9\x03\x80\xc1\x00\xff\x15\x00\x00!\x01\x00\x00\xa4f\xd1\r\xc9\x0c\x07\x14q\xd4\n\x02\xe5\x00\x00\x11\x00\x15\x00\x00\x00\x12\x00\x17\x01\x01\xc4\x04\x07\x01\x067\x86($\xffy\xe0\x00\x00\x00\x00\x00\x17\x06\x08 \x00\r\xd2,\x00\x85\x00\x00\x00\x00\x00\xfa\x00\xfa\x00\xc8\x00\xc8'\x10\x02\x8f "