SOME/IP-TP for Large Payloads

# SOME/IP-TP reassembler
class SomeIpTpReassembler:
    def __init__(self, timeout_ms=500):
        self.sessions = {}   # (client_id, session_id) → segment list
        self.timeout_ms = timeout_ms

    def receive_segment(self, client_id, session_id, offset_units, more_seg, payload):
        key = (client_id, session_id)
        if key not in self.sessions:
            self.sessions[key] = {"segments": {}, "complete": False}

        byte_offset = offset_units * 16
        self.sessions[key]["segments"][byte_offset] = payload

        if not more_seg:
            self.sessions[key]["last_offset"] = byte_offset + len(payload)
            return self._try_reassemble(key)
        return None

    def _try_reassemble(self, key):
        session = self.sessions[key]
        if "last_offset" not in session:
            return None  # haven't seen last segment yet

        # Sort by offset and check for gaps
        sorted_segs = sorted(session["segments"].items())
        reassembled = bytearray()
        expected_offset = 0
        for offset, data in sorted_segs:
            if offset != expected_offset:
                print(f"Gap at offset {expected_offset} (got {offset}) — incomplete")
                return None  # gap → wait for missing segment or timeout
            reassembled.extend(data)
            expected_offset += len(data)

        del self.sessions[key]
        return bytes(reassembled)

  SomeIpTp_CameraStream
  
    
      0  
      1400  
    
    
      500