1. Startseite
2. ScanDoc Development
3. J2534-Handbuch
4. Beschreibung der PassThru-Funktionen

PassThruReadMsgs v4.04 v5.0

Lesen empfangener Nachrichten

Letzte Änderung: 11. Januar 2026

Beschreibung

Die Funktion liest die empfangenen Nachrichten aus der Warteschlange des Kanals aus. Der Adapter kann maximal 100 Nachrichten pro Warteschlange für einen Kanal aufnehmen und verfügt über 64 KByte freien Speicher für alle Warteschlangen. Ist die Warteschlange oder der gesamte freie Speicher belegt, wird der Empfang von Nachrichten ausgesetzt.

long PassThruReadMsgs(unsigned long ChannelID, PASSTHRU_MSG* pMsg, unsigned long* pNumMsgs, unsigned long Timeout)

Parameter

• unsigned long ChannelID - Die Kanal-ID, die vom Befehl PassThruConnect zurückgegeben wurde.
• PASSTHRU_MSG* pMsg - Zeiger auf ein Array von Nachrichtenstrukturen. In dieses Array werden die empfangenen Nachrichten geschrieben.
• unsigned long* pNumMsgs - Zeiger auf eine Variable mit der Anzahl der angeforderten Nachrichten. Nach Ausführung der Funktion wird in diese Variable die Anzahl der tatsächlich gelesenen Nachrichten geschrieben.
• unsigned long Timeout - Wartezeit auf Nachrichten in Millisekunden. Ist Timeout = 0, liefert die Funktion sofort die verfügbaren Nachrichten ohne Wartezeit zurück (es wird kein Fehler ERR_TIMEOUT erzeugt).

Rückgabe-Fehlercodes

Beispiele

Beispiel in C/C++

#include "j2534_dll.hpp"

unsigned long ChannelID; // Von PassThruConnect erhaltene ID
PASSTHRU_MSG Msgs[10];   // Puffer für Nachrichten
unsigned long NumMsgs = 10; // Bis zu 10 Nachrichten anfordern
unsigned long Timeout = 1000; // Timeout 1000 ms

long ret = PassThruReadMsgs(ChannelID, &Msgs[0], &NumMsgs, Timeout);
if (ret == STATUS_NOERROR || ret == ERR_TIMEOUT)
{
    // Verarbeitung der empfangenen Nachrichten (NumMsgs Stück)
    for (unsigned long i = 0; i < NumMsgs; i++) {
        if (Msgs[i].RxStatus & START_OF_MESSAGE) {
            // Indikator für den Nachrichtenbeginn
            continue;
        }
        // Verarbeitung der Daten Msgs[i].Data, Msgs[i].DataSize
    }
}
else
{
    char error[256];
    PassThruGetLastError(error);
    printf("Error: %s\n", error);
}

Beispiel in Kotlin (Android)

// channelID wurde zuvor von ptConnect erhalten
val numMsgsToRead = 10
val timeout = 1000 // ms

val result = j2534.ptReadMsgs(channelID, numMsgsToRead, timeout)
if (result.status == STATUS_NOERROR || result.status == ERR_TIMEOUT) {
    // result.msgs.size Nachrichten erfolgreich gelesen
    for (msg in result.msgs) {
        if (msg.rxStatus and START_OF_MESSAGE != 0) {
            continue // Indikator für den Beginn überspringen
        }
        Log.i("J2534", "Empfangen: ${msg.data.toHexString()}")
    }
} else {
    Log.e("J2534", "Lesefehler: ${result.status}")
}

Beispiel in Python (ctypes)

from ctypes import *
import platform

# Laden der Bibliothek
if platform.system() == "Windows":
    j2534 = windll.LoadLibrary("j2534sd_v04_04_x64.dll")
elif platform.system() == "Darwin":
    j2534 = cdll.LoadLibrary("libj2534_v04_04.dylib")
else:
    j2534 = cdll.LoadLibrary("libj2534_v04_04.so")

# Struktur PASSTHRU_MSG
class PASSTHRU_MSG(Structure):
    _fields_ = [
        ("ProtocolID", c_ulong),
        ("RxStatus", c_ulong),
        ("TxFlags", c_ulong),
        ("Timestamp", c_ulong),
        ("DataSize", c_ulong),
        ("ExtraDataIndex", c_ulong),
        ("Data", c_ubyte * 4128)
    ]

# channel_id wurde zuvor von PassThruConnect erhalten
msgs = (PASSTHRU_MSG * 10)()
num_msgs = c_ulong(10)
timeout = c_ulong(1000)

ret = j2534.PassThruReadMsgs(channel_id, byref(msgs[0]), byref(num_msgs), timeout)

if ret == 0 or ret == 0x09:  # STATUS_NOERROR or ERR_TIMEOUT
    print(f"{num_msgs.value} Nachrichten empfangen")
    for i in range(num_msgs.value):
        if msgs[i].RxStatus & 0x02:  # START_OF_MESSAGE
            continue
        data = bytes(msgs[i].Data[:msgs[i].DataSize])
        print(f"Daten: {data.hex()}")
else:
    error = create_string_buffer(256)
    j2534.PassThruGetLastError(error)
    print(f"Fehler: {error.value.decode()}")

Beispiel in C# (P/Invoke)

using System;
using System.Runtime.InteropServices;

[StructLayout(LayoutKind.Sequential)]
public struct PASSTHRU_MSG
{
    public uint ProtocolID;
    public uint RxStatus;
    public uint TxFlags;
    public uint Timestamp;
    public uint DataSize;
    public uint ExtraDataIndex;
    [MarshalAs(UnmanagedType.ByValArray, SizeConst = 4128)]
    public byte[] Data;
}

class J2534
{
    [DllImport("j2534sd_v04_04_x64.dll", CallingConvention = CallingConvention.StdCall)]
    public static extern int PassThruReadMsgs(
        uint ChannelID,
        [In, Out] PASSTHRU_MSG[] pMsg,
        ref uint pNumMsgs,
        uint Timeout);

    [DllImport("j2534sd_v04_04_x64.dll", CallingConvention = CallingConvention.StdCall)]
    public static extern int PassThruGetLastError(
        [MarshalAs(UnmanagedType.LPStr)] System.Text.StringBuilder pErrorDescription);
}

// Verwendung:
// channelId wurde zuvor von PassThruConnect erhalten
PASSTHRU_MSG[] msgs = new PASSTHRU_MSG[10];
for (int i = 0; i < msgs.Length; i++)
    msgs[i].Data = new byte[4128];

uint numMsgs = 10;
uint timeout = 1000;

int ret = J2534.PassThruReadMsgs(channelId, msgs, ref numMsgs, timeout);

if (ret == 0 || ret == 0x09) // STATUS_NOERROR or ERR_TIMEOUT
{
    Console.WriteLine($"{numMsgs} Nachrichten empfangen");
    for (uint i = 0; i < numMsgs; i++)
    {
        if ((msgs[i].RxStatus & 0x02) != 0) // START_OF_MESSAGE
            continue;
        byte[] data = new byte[msgs[i].DataSize];
        Array.Copy(msgs[i].Data, data, msgs[i].DataSize);
        Console.WriteLine($"Daten: {BitConverter.ToString(data)}");
    }
}
else
{
    var error = new System.Text.StringBuilder(256);
    J2534.PassThruGetLastError(error);
    Console.WriteLine($"Fehler: {error}");
}

1. nach oben