Inoffizielles deutsches Xbase-Forum

Code: Alles auswählen

  * ---------------------------------------------------------------------------
  *  Thread  Telefonschnittstelle
  * ---------------------------------------------------------------------------
  IF FRITZ_ON
    IF empty(FRITZ_IP)
      msg("Die Fritzbox kann nicht aktiviert werden,\ "+;
          "da keine IP Adresse angeben wurde.","",;
          " dFAKT Friztbox-Schnittstelle","W",oDfdlg)
    ELSE
      oThread := ServerThread():new( alltrim(FRITZ_IP) , 1012 )
      oThread:start()
    ENDIF
  ENDIF

Code: Alles auswählen

/* ***************************************************************************
 *
 * Der ServerThread wartet auf ankommende Nachrichten
 */
CLASS ServerThread FROM Thread
   PROTECTED:
   VAR nPort     /* Zielport */
   VAR cAddress  /* Zieladresse */
   VAR nSocket
   VAR nError

   EXPORTED:
   METHOD init, atStart, execute, atEnd, stop
   METHOD logCall
ENDCLASS


METHOD ServerThread:init( cAddress, nPort )
   ::Thread:init()
   ::nSocket  := 0
   ::cAddress := cAddress
   ::nPort    := nPort
RETURN self

/*
 * Threadstart!
 *
 * Der Socket wird erzeugt, und mit setInterval(0) wird dafuer gesorgt,
 * dass execute permanent laeuft.
 */
METHOD ServerThread:atStart
   ::nSocket := SocketOpen(SOCK_STREAM, ::cAddress, ::nPort, @::nError)

   IF ::nSocket <> 0
      ::setInterval(0)
   ELSE
     /* hier irgendwas nuetzliches mit nError anfangen FIXME */
   ENDIF
RETURN self


/*
 * Thread laeuft hier
 *
 * Daten von der Box werden empfangen
 */
METHOD ServerThread:execute
   LOCAL cBuffer := space(1024) /* keine ahnung, wie gross das werden darf FIXME */
   LOCAL nRead

   IF ::nSocket <> 0
      /* der Socket ist Blocking, also wird gewartet */
      nRead := SocketRecv(::nSocket, @cBuffer, 1024, @::nError)

      IF nRead > 0
         ::logCall( left(cBuffer, nRead) )
      ENDIF
   ENDIF
RETURN self


/*
 * Thread is ending!
 */
METHOD ServerThread:atEnd
   ::nSocket := 0
RETURN self


/*
 * Stop listening thread from outside!
 *
 * :setInterval( NIL ) results in :execute() not being called again.
 * SocketClose() causes SocketAccept() -which is blocking- to return.
 * :synchronize(0) causes external function to wait until this thread
 * has ended.
 */
METHOD ServerThread:stop
   IF ::nSocket <> 0
      ::setInterval( NIL )

      SocketClose( ::nSocket )

      ::synchronize(0)
   ENDIF
RETURN self


/*
 * Anzeige der Anrufinformation
 *  Ausgehende Anrufe: datum;CALL;ConnectionID;Nebenstelle;GenutzteNummer;AngerufeneNummer;
 *  Eingehende Anrufe: datum;RING;ConnectionID;Anrufer-Nr;Angerufene-Nummer;
 *  Zustandegekommene Verbindung: datum;CONNECT;ConnectionID;Nebenstelle;Nummer;
 *  Ende der Verbindung: datum;DISCONNECT;ConnectionID;dauerInSekunden;
*/

METHOD ServerThread:logCall( cData )
   LOCAL oThread

   oThread := Thread():new()
   oThread:Start("Telefon","FRITZBOX",cData)

RETURN self

Code: Alles auswählen

#include "Common.ch"
#include "Appevent.ch"
#include "Asinetc.ch"

#define CRLF chr(13)+chr(10)


/* This is our main procedure
 */
PROCEDURE Main( cFritzIP, cPort )
  LOCAL nEvent, mp1, mp2, oXbp, oThread

  cls
  ? "Hallo Fritz"

  IF empty(cFritzIP)         // 192.168.152.1
    ? "Die Fritzbox kann nicht aktiviert werden,"+;
        "da keine IP Adresse angeben wurde."
    ?
    ? "Syntax:  xFritz.exe  IP-Adresse   [Port]"
  ELSE
    IF !file("telefon.dbf")
      dbcreate( "Telefon.dbf",;
                {{ "FRITZMSG", "C", 100, 0}} )
      ? "telefon.dbf angelegt"

    ENDIF

    oThread := ServerThread():new( alltrim(cFritzIP) ,;
               iif(cPort == NIL, 1012, cPort ) )
    oThread:start()

    ?  "Abbruch mit ESC"

     DO WHILE nEvent<> xbeP_Close
        nEvent := AppEvent( @mp1, @mp2, @oXbp )
        oXbp:handleEvent( nEvent, mp1, mp2 )

        IF nEvent == xbeK_ESC
           EXIT
        ENDIF
     ENDDO
  ENDIF

RETURN

///<summary>
///<para>  wandelt den durch 'cDiv' getrennten 'cText' in ein Array um </para>
///<para>  cDiv default ";"   </para>
///</summary>
///<returns>  aZeilen                                                      </returns>
FUNCTION Explode(cText,cDiv)
  **************************
  LOCAL aRet := {}
  LOCAL nPos := 0
  cDiv := IIF(cDiv==NIL,";",cDiv)
  nPos := at(cDiv,cText)
  DO WHILE nPos>0
    aadd(aRet,left(cText,nPos-1))
    cText := substr(cText,nPos+1)
    nPos := at(cDiv,cText)
  ENDDO
  IF !empty(cText)
    aadd(aRet,cText)
  ENDIF
RETURN (aRet)


/* ***************************************************************************
 *
 * Der ServerThread wartet auf ankommende Nachrichten
 */
CLASS ServerThread FROM Thread
   PROTECTED:
   VAR nPort     /* Zielport */
   VAR cAddress  /* Zieladresse */
   VAR nSocket
   VAR nError

   EXPORTED:
   METHOD init, atStart, execute, atEnd, stop
   METHOD logCall
ENDCLASS


METHOD ServerThread:init( cAddress, nPort )
   ::Thread:init()
   ::nSocket  := 0
   ::cAddress := cAddress
   ::nPort    := nPort
RETURN self

/*
 * Threadstart!
 *
 * Der Socket wird erzeugt, und mit setInterval(0) wird dafuer gesorgt,
 * dass execute permanent laeuft.
 */
METHOD ServerThread:atStart
   ::nSocket := SocketOpen(SOCK_STREAM, ::cAddress, ::nPort, @::nError)
   ? ts()+"Start"
   IF ::nSocket <> 0
      ::setInterval(0)
   ELSE
     /* hier irgendwas nuetzliches mit nError anfangen FIXME */
   ENDIF
RETURN self


/*
 * Thread laeuft hier
 *
 * Daten von der Box werden empfangen
 */
METHOD ServerThread:execute
   LOCAL cBuffer := space(1024) /* keine ahnung, wie gross das werden darf FIXME */
   LOCAL nRead

   IF ::nSocket <> 0
      /* der Socket ist Blocking, also wird gewartet */
      nRead := SocketRecv(::nSocket, @cBuffer, 1024, @::nError)

      IF nRead > 0
         ::logCall( left(cBuffer, nRead) )
      ENDIF
   ENDIF
RETURN self


/*
 * Thread is ending!
 */
METHOD ServerThread:atEnd
   ::nSocket := 0
   ? ts()+"End"
RETURN self


/*
 * Stop listening thread from outside!
 *
 * :setInterval( NIL ) results in :execute() not being called again.
 * SocketClose() causes SocketAccept() -which is blocking- to return.
 * :synchronize(0) causes external function to wait until this thread
 * has ended.
 */
METHOD ServerThread:stop
   IF ::nSocket <> 0
      ::setInterval( NIL )

      SocketClose( ::nSocket )

      ::synchronize(0)
   ENDIF
RETURN self


/*
 * Anzeige der Anrufinformation
 *  Ausgehende Anrufe: datum;CALL;ConnectionID;Nebenstelle;GenutzteNummer;AngerufeneNummer;
 *  Eingehende Anrufe: datum;RING;ConnectionID;Anrufer-Nr;Angerufene-Nummer;
 *  Zustandegekommene Verbindung: datum;CONNECT;ConnectionID;Nebenstelle;Nummer;
 *  Ende der Verbindung: datum;DISCONNECT;ConnectionID;dauerInSekunden;
*/

METHOD ServerThread:logCall( cData )
   #define FC_
   LOCAL oThread
   ? cData

   oThread := Thread():new()
   oThread:Start("Telefon","FRITZBOX",cData)

RETURN self


/// <summary>
/// <para>  cQuelle  - Eingangsschnittstelle z.b. FRITZBOX              </para>
/// <para>  cData    - Uebergabedaten                                   </para>
/// </summary>
/// <returns> NIL                                                </returns>
PROCEDURE Telefon(cQuelle, cData)
  use telefon.dbf alias tel new
  dbappend()
  tel->fritzmsg := cData
  dbskip(0)
  dbunlock()
  dbclosearea()
RETURN



STATIC FUNCTION ts()

RETURN( dtoc(date())+" "+time()+": " )

Code: Alles auswählen

#include "service.ch"
#include "fileio.ch"

#define STAT_RUNNING    1
#define STAT_NOTRUNNING 2
#define STAT_PAUSING    3

#define CRLF chr(13)+chr(10)


PROCEDURE Main()
  ServiceApplication():start()
RETURN

CLASS ServiceApplication FROM ServiceApp

  HIDDEN:
    CLASS VAR    _Status

  EXPORTED:

    CLASS ACCESS METHOD getStopped VAR Stopped

    CLASS METHOD main
    CLASS METHOD pause
    CLASS METHOD CONTINUE
    CLASS METHOD stop

ENDCLASS

CLASS METHOD ServiceApplication:getStopped()
RETURN(::_Status==STAT_NOTRUNNING)

CLASS METHOD ServiceApplication:main()
   LOCAL oWasSagtFritz := ServerThread():new( "192.168.178.1", 1012 )
   oWasSagtFritz:Start()

  DO WHILE ::_Status != STAT_NOTRUNNING

    IF ::_Status == STAT_PAUSING
      /* $TODO: pause your application */
      Sleep( 10 )
      Loop
    ENDIF
    /* Die Haupschleife macht NIX - gelauscht wird im ServerThread  */
    sleep(10)

  ENDDO

  ::oWasSagtFritz:Stop()

RETURN self

CLASS METHOD ServiceApplication:pause()
  ::_Status := STAT_PAUSING
RETURN

CLASS METHOD ServiceApplication:continue()
  ::_Status := STAT_RUNNING
RETURN

CLASS METHOD ServiceApplication:stop()
  ::_Status := STAT_NOTRUNNING
RETURN