--- /dev/null
+/*
+
+ G N O K I I
+
+ A Linux/Unix toolset and driver for Nokia mobile phones.
+
+ Released under the terms of the GNU GPL, see file COPYING for more details.
+
+*/
+
+#ifndef WIN32
+ #include "devices/unixserial.h"
+ #include "devices/unixirda.h"
+ #include "devices/tekram.h"
+ #include <sys/ioctl.h>
+ #include <pthread.h>
+ #include <termios.h>
+ #include <signal.h>
+ #include <errno.h>
+#else
+ #include <windows.h>
+ #include "devices/winserial.h"
+#endif
+
+#include "gsm-api.h"
+#include "devices/device.h"
+
+#include <string.h>
+
+#ifdef VC6
+ /* for VC6 make scripts save VERSION constant in mversion.h file */
+ #include "mversion.h"
+#endif
+
+char PortDevice[GSM_MAX_DEVICE_NAME_LENGTH]={0x00};
+
+bool duringwrite;
+
+#ifndef WIN32
+
+//pthread_t Thread;
+#if defined(__svr4__) || defined(__FreeBSD__)
+ pthread_t selThread;
+#endif
+
+int device_portfd = -1;
+
+/*
+ * Structure to store the filedescriptor we use.
+ *
+ */
+int device_getfd(void)
+{
+ return device_portfd;
+}
+
+int device_open(__const char *__file, int __with_odd_parity) {
+
+ switch (CurrentConnectionType) {
+ case GCT_Tekram:
+ device_portfd = tekram_open(__file);
+ break;
+ case GCT_Irda:
+ device_portfd = irda_open();
+ break;
+ default:
+ device_portfd = serial_opendevice(__file, __with_odd_parity, true, false);
+ break;
+ }
+
+ return (device_portfd >= 0);
+}
+
+void device_close(void)
+{
+ AppendLogText("CLOSE\n",false);
+
+ /* Now wait for thread to terminate. */
+ //pthread_join(Thread, NULL);
+
+ switch (CurrentConnectionType) {
+ case GCT_Tekram: tekram_close(device_portfd); break;
+ case GCT_Irda : irda_close(device_portfd); break;
+ default : serial_close(device_portfd); break;
+ }
+
+ PortDevice[0]=0x00;
+}
+
+void device_reset(void) {
+}
+
+void device_setdtrrts(int __dtr, int __rts)
+{
+ switch (CurrentConnectionType) {
+ case GCT_Tekram:
+ case GCT_Irda:
+ break;
+ default:
+ serial_setdtrrts(device_portfd, __dtr, __rts);
+#ifdef DEBUG
+ device_dumpserial();
+#endif
+ break;
+ }
+}
+
+void device_changespeed(int __speed)
+{
+ switch (CurrentConnectionType) {
+ case GCT_Irda:
+ break;
+ case GCT_Tekram:
+ tekram_changespeed(device_portfd, __speed);
+ break;
+ default:
+ serial_changespeed(device_portfd, __speed);
+#ifdef DEBUG
+ fprintf(stdout,_("Serial device: changing speed to %i\n"),__speed);
+#endif
+ break;
+ }
+}
+
+size_t device_read(__ptr_t __buf, size_t __nbytes)
+{
+ switch (CurrentConnectionType) {
+ case GCT_Tekram: return (tekram_read(device_portfd, __buf, __nbytes)); break;
+ case GCT_Irda : return ( irda_read(device_portfd, __buf, __nbytes)); break;
+ default : return (serial_read(device_portfd, __buf, __nbytes)); break;
+ }
+}
+
+size_t device_write(__const __ptr_t __buf, size_t __n) {
+ u8 buffer[300];
+ size_t mysize;
+
+ while (duringwrite) {}
+
+ memcpy(buffer,__buf,__n);
+ AppendLog(buffer,__n,true);
+
+ duringwrite=true;
+ switch (CurrentConnectionType) {
+ case GCT_Irda : mysize = irda_write(device_portfd, __buf, __n); break;
+ case GCT_Tekram: mysize = tekram_write(device_portfd, __buf, __n); break;
+ default : mysize = serial_write(device_portfd, __buf, __n); break;
+ }
+ duringwrite=false;
+ return mysize;
+}
+
+#ifdef DEBUG
+void device_dumpserial(void)
+{
+ int PortFD;
+ unsigned int Flags=0;
+
+ PortFD = device_getfd();
+
+ ioctl(PortFD, TIOCMGET, &Flags);
+
+ fprintf(stdout, _("Serial device:"));
+ fprintf(stdout, _(" DTR is %s"), Flags&TIOCM_DTR?_("up"):_("down"));
+ fprintf(stdout, _(", RTS is %s"), Flags&TIOCM_RTS?_("up"):_("down"));
+ fprintf(stdout, _(", CAR is %s"), Flags&TIOCM_CAR?_("up"):_("down"));
+ fprintf(stdout, _(", CTS is %s\n"), Flags&TIOCM_CTS?_("up"):_("down"));
+}
+#endif /* DEBUG */
+
+void SigHandler(int status)
+{
+
+ unsigned char buffer[2048];
+
+ int count, res;
+
+ res = device_read(buffer, 255);
+
+ for (count = 0; count < res ; count ++) {
+ Protocol->StateMachine(buffer[count]);
+ }
+}
+
+
+#if defined(__svr4__) || defined(__FreeBSD__)
+/* thread for handling incoming data */
+void SelectLoop() {
+ int err;
+ fd_set readfds;
+ struct timeval timeout;
+
+ FD_ZERO(&readfds);
+ FD_SET(device_portfd,&readfds);
+ /* set timeout to 15 seconds */
+ timeout.tv_sec=15;
+ timeout.tv_usec=0;
+ while (!CurrentRequestTerminate) {
+ err=select(device_portfd+1,&readfds,NULL,NULL,&timeout);
+ if ( err > 0 ) {
+ /* call singal handler to process incoming data */
+ SigHandler(0);
+ /* refresh timeout, just for linux :-( */\r
+ /* required for irda */
+ timeout.tv_sec=15;\r
+ } else {
+ if (err == -1)
+ perror("Error in SelectLoop");
+ }
+ }
+}
+#endif
+
+bool StartConnection (char *port_device, bool with_odd_parity, GSM_ConnectionType con)
+{
+ int result;
+
+ char text[100];
+
+#if defined(__svr4__) || defined(__FreeBSD__)
+ int rtn;
+#else
+ struct sigaction sig_io;
+#endif
+
+#ifdef DEBUG
+ if ((strstr(GSM_Info->IrdaModels,"decode")!=NULL) && (CurrentConnectionType == GCT_Irda))
+ {
+ printf("DEBUG and Irda decode Model -> not realy open ;-)\n");
+ return true;
+ }
+#endif
+
+ if (PortDevice[0]!=0x00) return true;
+
+ duringwrite=false;
+
+ strncpy(PortDevice, port_device, GSM_MAX_DEVICE_NAME_LENGTH);
+
+#ifdef DEBUG
+ fprintf(stdout,_("Opening \"%s\" device...\n"),PortDevice);
+#endif
+
+ strcpy(text,"\n\n\nMygnokii ");
+ sprintf(text+strlen(text), "%s",VERSION);
+ strcpy(text+strlen(text),"\n");
+ AppendLogText(text,false);
+
+ strcpy(text,"Port ");
+ strcpy(text+strlen(text),PortDevice);
+ strcpy(text+strlen(text),"\n");
+ AppendLogText(text,false);
+
+ strcpy(text,"Connection ");
+ switch (con) {
+ case GCT_FBUS :strcpy(text+strlen(text),"FBUS");break;
+ case GCT_Infrared:strcpy(text+strlen(text),"infrared");break;
+ case GCT_Irda :strcpy(text+strlen(text),"irda sockets");break;
+ case GCT_MBUS :strcpy(text+strlen(text),"MBUS");break;
+ case GCT_DLR3 :strcpy(text+strlen(text),"DLR3");break;
+ case GCT_Tekram :strcpy(text+strlen(text),"Tekram");break;
+ case GCT_AT :strcpy(text+strlen(text),"AT");break;
+ default :strcpy(text+strlen(text),"unknown");break;
+ }
+ strcpy(text+strlen(text),"\n");
+ AppendLogText(text,false);
+
+ /* Ralf Thelen: In this moment there is NO method of communication,
+ which require keepalive packets and GSM->KeepAlive is
+ always NULL_KeepAlive, I comment this thread, */
+
+ /* Create and start main thread. */
+// rtn = pthread_create(&Thread, NULL,(void*)GSM->KeepAlive, (void *)NULL);
+//
+// if (rtn != 0) {
+// fprintf(stdout,_("Error\n"));
+// return false;
+// }
+
+#if defined(__svr4__) || defined(__FreeBSD__)
+#else
+ /* Set up and install handler before enabling async IO on port. */
+ sig_io.sa_handler = SigHandler;
+ sig_io.sa_flags = 0;
+ sigaction (SIGIO, &sig_io, NULL);
+#endif
+
+ /* Open device. */
+ result = device_open(PortDevice, with_odd_parity);
+
+ if (!result) {
+ fprintf(stdout,_("Error\n"));
+ return false;
+ }
+
+#if defined(__svr4__) || defined(__FreeBSD__)
+ /* create a thread to handle incoming data from mobile phone */
+ rtn=pthread_create(&selThread,NULL,(void*)SelectLoop,(void*)NULL);
+ if (rtn != 0) {
+ fprintf(stdout,_("Error\n"));
+ return false;
+ }
+#endif
+
+ return true;
+}
+
+/* ---------------- RTH: #ifdef WIN32 ------------------ */
+
+#else
+
+ extern HANDLE hPhone;
+
+void device_close(void)
+{
+ AppendLogText("CLOSE\n",false);
+
+ CloseConnection();
+
+ PortDevice[0]=0x00;
+}
+
+#ifdef DEBUG
+void device_dumpserial(void)
+{
+ DCB dcb;
+
+ dcb.DCBlength = sizeof(DCB);
+ GetCommState(hPhone, &dcb);
+
+ fprintf(stdout, _("Serial device:"));
+ fprintf(stdout, _(" DTR is "));
+ switch (dcb.fDtrControl) {
+ case DTR_CONTROL_ENABLE : fprintf(stdout, _("up")); break;
+ case DTR_CONTROL_DISABLE : fprintf(stdout, _("down")); break;
+ case DTR_CONTROL_HANDSHAKE: fprintf(stdout, _("handshake"));break;
+ }
+ fprintf(stdout, _(", RTS is "));
+ switch (dcb.fRtsControl) {
+ case RTS_CONTROL_ENABLE : fprintf(stdout, _("up\n")); break;
+ case RTS_CONTROL_DISABLE : fprintf(stdout, _("down\n")); break;
+ case RTS_CONTROL_HANDSHAKE: fprintf(stdout, _("handshake\n"));break;
+ case RTS_CONTROL_TOGGLE : fprintf(stdout, _("toggle\n")); break;
+ }
+}
+#endif /* DEBUG */
+
+void device_setdtrrts(int __dtr, int __rts)
+{
+ DCB dcb;
+
+ dcb.DCBlength = sizeof(DCB);
+ GetCommState(hPhone, &dcb);
+
+ if (__dtr==1) dcb.fDtrControl = DTR_CONTROL_ENABLE;
+ else dcb.fDtrControl = DTR_CONTROL_DISABLE;
+
+ if (__rts==1) dcb.fRtsControl = RTS_CONTROL_ENABLE;
+ else dcb.fRtsControl = RTS_CONTROL_DISABLE;
+
+ SetCommState(hPhone, &dcb);
+
+#ifdef DEBUG
+ device_dumpserial();
+#endif
+}
+
+void device_changespeed(int __speed)
+{
+
+ DCB dcb;
+
+ dcb.DCBlength = sizeof(DCB);
+ GetCommState(hPhone, &dcb);
+
+ switch (__speed) {
+ case 115200: dcb.BaudRate=CBR_115200; break;
+ case 19200 : dcb.BaudRate=CBR_19200; break;
+ case 9600 : dcb.BaudRate=CBR_9600; break;
+ }
+
+ SetCommState(hPhone, &dcb);
+
+#ifdef DEBUG
+ fprintf(stdout,_("Serial device: changing speed to %i\n"),__speed);
+#endif
+}
+
+bool StartConnection (char *port_device, bool with_odd_parity, GSM_ConnectionType con)
+{
+ DCB dcb;
+ char text[100];
+
+ int rtn;
+
+ if (PortDevice[0]!=0x00) return true;
+
+ duringwrite=false;
+ strncpy(PortDevice, port_device, GSM_MAX_DEVICE_NAME_LENGTH);
+
+#ifdef DEBUG
+ fprintf(stdout,_("Opening \"%s\" device...\n"),PortDevice);
+#endif
+
+ strcpy(text,"\n\n\nMygnokii ");
+ sprintf(text+strlen(text), "%s",VERSION);
+ strcpy(text+strlen(text),"\n");
+ AppendLogText(text,false);
+
+ strcpy(text,"Port ");
+ strcpy(text+strlen(text),PortDevice);
+ strcpy(text+strlen(text),"\n");
+ AppendLogText(text,false);
+
+ strcpy(text,"Connection ");
+ switch (con) {
+ case GCT_FBUS :strcpy(text+strlen(text),"FBUS");break;
+ case GCT_Infrared:strcpy(text+strlen(text),"infrared");break;
+ case GCT_Irda :strcpy(text+strlen(text),"irda sockets");break;
+ case GCT_MBUS :strcpy(text+strlen(text),"MBUS");break;
+ case GCT_DLR3 :strcpy(text+strlen(text),"DLR3");break;
+ case GCT_Tekram :strcpy(text+strlen(text),"Tekram");break;
+ case GCT_AT :strcpy(text+strlen(text),"AT");break;
+ default :strcpy(text+strlen(text),"unknown");break;
+ }
+ strcpy(text+strlen(text),"\n");
+ AppendLogText(text,false);
+
+ CurrentDisableKeepAlive = true;
+
+ /* Create and start main thread. */
+ rtn = ! OpenConnection(PortDevice, Protocol->StateMachine, GSM->KeepAlive);
+
+ if (rtn != 0) {
+
+ fprintf(stdout,_("Error\n"));
+ return false;
+ } else {
+ CurrentDisableKeepAlive = false;
+ }
+
+ if (with_odd_parity) {
+ dcb.DCBlength = sizeof(DCB);
+ GetCommState(hPhone, &dcb);
+
+ dcb.Parity=ODDPARITY;
+
+ SetCommState(hPhone, &dcb);
+ }
+
+ return true;
+}
+
+size_t device_write(const __ptr_t __buf, size_t __n) {
+ int i;
+ while (duringwrite) {}
+ duringwrite=true;
+ AppendLog(__buf,__n,true);
+ i=WriteCommBlock(__buf,__n);
+ duringwrite=false;
+ if (i) return __n; else return 0;
+}
+
+#endif /*WIN32*/
git://git.jankratochvil.net / gnokii.git / blobdiff