TOPIC:

FUNCTION Logging(dwParam AS DWORD) AS INT PASCAL
	LOCAL oDta AS dtaSocket
	LOCAL t1 AS TParams
	LOCAL cLine AS STRING
	LOCAL nError := 0 AS DWORD

	t1 := dwParam
	oDta := OBJECT(_CAST,t1.MainDlg)

	WHILE TRUE
		oDta:oSocket:listen(1)     // --> Zeile 11
		cLine := oDta:oSocket:GetLine()
		// Wenn Codes 10050 bzw. 10056 wieder zurückgehen auf 0 ist CRDServer gestorben
		IF nError > 0 .AND. oDta:oSocket:Error == 0
			oDta:DoAnswer(TRUE, "CRDServer Fehler")
			oDta:EndWindow()
			ExitVOThread(0)
			EXIT
		ENDIF
		nError := oDta:oSocket:Error
		IF !Empty(cLine)
			oDta:Speichern(cLine)
		ENDIF

		IF oDta:lStop
			oDta:DoAnswer(TRUE, "Thread beendet")
			oDta:oSocket:Disconnect()
			oDta:oSocket := NULL_OBJECT
			ExitVOThread(0)
			EXIT
		ENDIF
		ApplicationExec(EXECWHILEEVENT)
	END
	
	RETURN 0

CLASS dtaSocket INHERIT dtaSerial     // dtaSerial ist ein generiertes Form mit MLEs zur Protokollierung der Vorgänge
PROTECT _oSocket as CSocket
PROTECT _cIP AS STRING
PROTECT _nPort AS WORD
PROTECT _lStop AS LOGIC
PROTECT _t1 AS TParams
PROTECT _cCard AS STRING		// CRDServer Kommando Lead-In: *@*#Card?#

METHOD Setup(nIndex) CLASS dtaSocket
	LOCAL nID AS DWORD
	LOCAL pTask AS PTR

	// Socket erstellen
	_oSocket := CSocket{SOCK_STREAM}
	_oSocket:Timeout:=100
	IF !_oSocket:connect(_cIP, _nPort)
		SELF:DoAnswer(TRUE, "Keine Verbindung zum CRDServer")
	ELSE
		SELF:DoAnswer(TRUE, "Verbindung zum CRDServer")
	
		// Thread starten für Listening
		_lStop := FALSE
		_t1:=MemAlloc(_SIZEOF(TParams))
		RegisterKid(_t1,1,FALSE)
		_t1.MainDlg:=PTR(_CAST,SELF)
		pTask:=CreateVOThread(NULL,0,@Logging(),_t1,0,@nID)
		IF pTask <> NULL_PTR
			SELF:DoAnswer(TRUE, "Thread Listener gestartet")
		ELSE
			SELF:DoAnswer(TRUE, "Thread Listener nicht gestartet")
		ENDIF
		CloseHandle(pTask)

		// INFO-Nachricht senden
		SELF:GenerateEvent(_cCard+"INFO#")
	ENDIF

	RETURN SELF
	
METHOD GenerateEvent(cMsg) CLASS dtaSocket
	IF _oSocket:Sendline(cMsg) > 0
		SELF:DoAnswer(FALSE, cMsg+"...OK")
	ELSE
		SELF:DoAnswer(FALSE, cMsg+"...Error")
	ENDIF
	RETURN SELF

STRUCTURE TParams
	MEMBER MainDlg AS PTR

METHOD DoAnswer(lShow, cStr) CLASS dtaSerial
	SELF:oDCmleCommLog:TextValue += cStr + CHR(13) + CHR(10)
	SELF:MleKuerzen()
	RETURN SELF

CLASS dtaSocket INHERIT dtaSerial
	EXPORT  _oSocket AS CSocket

METHOD Setup(nIndex) CLASS dtaSocket
	LOCAL t1 AS TParams
...
	_t1 := MemAlloc(_SIZEOF(TParams))
	RegisterKid(_t1, 1, FALSE)
	_t1.MainDlg := PTR(_CAST, SELF)
	pTask:=CreateVOThread(NULL, 0, @Logging(), _t1, 0, @nID)   // Übergabe an Func Logging _t1 = dtaSocket

ACCESS oSocket CLASS dtaSocket
	RETURN _oSocket

FUNCTION Logging(dwParam AS DWORD) AS INT PASCAL
	LOCAL oDta AS dtaSocket
	LOCAL t1 AS TParams
...
	t1 := dwParam
	oDta := OBJECT(_CAST,t1.MainDlg)
	WHILE TRUE
		oDta:oSocket:listen(1)     // oDta:oSocket über ACCESS bringt Absturz
		oDta:_oSocket:listen(1)     // oDta:_oSocket über EXPORT Var funktioniert

CLASS dtaSocket INHERIT dtaSerial
	EXPORT  _oSocket AS CSocket
	PROTECT _t1 AS TParams
	PROTECT _cIP AS STRING
	PROTECT _nPort AS WORD

METHOD Setup(nIndex) CLASS dtaSocket
	LOCAL nID AS DWORD
	LOCAL pTask AS PTR

	// Socket erstellen
	_oSocket := CSocket{SOCK_STREAM}
	_oSocket:Timeout:=100
	IF _oSocket:connect(_cIP, _nPort)
	
		// Thread starten für Listening
		_lStop := FALSE
		_t1 := MemAlloc(_SIZEOF(TParams))
		RegisterKid(_t1, 1, FALSE)
		_t1.MainDlg := PTR(_CAST, SELF)
		pTask:=CreateVOThread(NULL, 0, @Logging(), _t1, 0, @nID)
		CloseHandle(pTask)

		// Nachricht senden
		_oSocket:SendLine("INFO#1")     // Kommt beim EchoSrv an, Antwort in Func Logging retour
		_oSocket:SendLine("INFO#2")     // Kommt nicht an
	ENDIF
	RETURN SELF