*/
-#include "config.h"
-
#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>
#include "gsm-api.h"
#include "devices/device.h"
+#include "files/cfgreader.h"
#include <string.h>
#include "mversion.h"
#endif
-static char PortDevice[GSM_MAX_DEVICE_NAME_LENGTH]={0x00};
+char PortDevice[GSM_MAX_DEVICE_NAME_LENGTH]={0x00};
-static bool duringwrite;
+bool duringwrite;
#ifndef WIN32
+char *lockfile;
+
//pthread_t Thread;
#if defined(__svr4__) || defined(__FreeBSD__)
pthread_t selThread;
#endif
-static int device_portfd = -1;
+int device_portfd = -1;
+
+#define max_buf_len 128
+#define lock_path "/var/lock/LCK.."
+
+/* Lock the device. Return allocated string with a lock name */
+char *lock_device(const char* port)
+{
+ char *lock_file = NULL;
+ char buffer[max_buf_len];
+ const char *aux = rindex(port, '/');
+ int fd, len = strlen(aux) + strlen(lock_path);
+
+ /* Remove leading '/' */
+ if (aux) aux++;
+ else aux = port;
+
+ memset(buffer, 0, sizeof(buffer));
+ lock_file = calloc(len + 1, 1);
+ if (!lock_file) {
+ fprintf(stderr, _("Out of memory error while locking device\n"));
+ return NULL;
+ }
+ /* I think we don't need to use strncpy, as we should have enough
+ * buffer due to strlen results
+ */
+ strcpy(lock_file, lock_path);
+ strcat(lock_file, aux);
+
+ /* Check for the stale lockfile.
+ * The code taken from minicom by Miquel van Smoorenburg */
+ if ((fd = open(lock_file, O_RDONLY)) >= 0) {
+ char buf[max_buf_len];
+ int pid, n = 0;
+
+ n = read(fd, buf, sizeof(buf) - 1);
+ close(fd);
+ if (n > 0) {
+ pid = -1;
+ if (n == 4)
+ /* Kermit-style lockfile. */
+ pid = *(int *)buf;
+ else {
+ /* Ascii lockfile. */
+ buf[n] = 0;
+ sscanf(buf, "%d", &pid);
+ }
+ if (pid > 0 && kill((pid_t)pid, 0) < 0 && errno == ESRCH) {
+ fprintf(stderr, _("Lockfile %s is stale. Overriding it..\n"), lock_file);
+ sleep(1);
+ if (unlink(lock_file) == -1) {
+ fprintf(stderr, _("Overriding failed, please check the permissions\n"));
+ fprintf(stderr, _("Cannot lock device\n"));
+ goto failed;
+ }
+ } else {
+ fprintf(stderr, _("Device already locked.\n"));
+ goto failed;
+ }
+ }
+ /* this must not happen. because we could open the file */
+ /* no wrong permissions are set. only reason could be */
+ /* flock/lockf or a empty lockfile due to a broken binary */
+ /* which is more likely (like gnokii 0.4.0pre11 ;-) */
+ if (n == 0) {
+ fprintf(stderr, _("Unable to read lockfile %s.\n"), lock_file);
+ fprintf(stderr, _("Please check for reason and remove the lockfile by hand.\n"));
+ fprintf(stderr, _("Cannot lock device\n"));
+ goto failed;
+ }
+ }
+
+ /* Try to create a new file, with 0644 mode */
+ fd = open(lock_file, O_CREAT | O_EXCL | O_WRONLY, 0644);
+ if (fd == -1) {
+ if (errno == EEXIST)
+ fprintf(stderr, _("Device seems to be locked by unknown process\n"));
+ else if (errno == EACCES)
+ fprintf(stderr, _("Please check permission on lock directory\n"));
+ else if (errno == ENOENT)
+ fprintf(stderr, _("Cannot create lockfile %s. Please check for existence of path"), lock_file);
+ goto failed;
+ }
+ sprintf(buffer, "%10ld gnokii\n", (long)getpid());
+ write(fd, buffer, strlen(buffer));
+ close(fd);
+ return lock_file;
+failed:
+ free(lock_file);
+ return NULL;
+}
+
+/* Removes lock and frees memory */
+bool unlock_device(char *lock_file)
+{
+ int err;
+
+ if (!lock_file) {
+// fprintf(stderr, _("Cannot unlock device\n"));
+ return false;
+ }
+ err = unlink(lock_file);
+ free(lock_file);
+ return (err + 1);
+}
/*
* Structure to store the filedescriptor we use.
*
*/
-#ifdef DEBUG
-static int device_getfd(void)
+int device_getfd(void)
{
return device_portfd;
}
-#endif /* DEBUG */
-
-static int device_open(__const char *__file, int __with_odd_parity) {
+int device_open(__const char *__file, int __with_odd_parity) {
+ struct CFG_Header *cfg_info;
+ char *aux;
+
+ cfg_info=CFG_FindGnokiirc();
+ if (cfg_info!=NULL) {
+ aux = CFG_Get(cfg_info, "global", "use_locking");
+ if (aux) {
+ if (!strcmp(aux, "yes")) {
+ lockfile = lock_device(__file);
+ if (!lockfile) return false;
+ }
+ }
+ }
+
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;
/* Now wait for thread to terminate. */
//pthread_join(Thread, NULL);
+ unlock_device(lockfile);
+
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;
}
-#ifndef UCLINUX
-
void device_reset(void) {
}
-#endif /* UCLINUX */
-
-#ifdef DEBUG
-static void device_dumpserial(void);
-#endif /* DEBUG */
-
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
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
}
}
-static size_t device_read(__ptr_t __buf, size_t __nbytes)
+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;
}
}
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;
}
#ifdef DEBUG
-static void device_dumpserial(void)
+void device_dumpserial(void)
{
int PortFD;
unsigned int Flags=0;
}
#endif /* DEBUG */
-static void SigHandler(int status)
+void SigHandler(int status)
{
unsigned char buffer[2048];
struct sigaction sig_io;
#endif
-#ifndef UCLINUX
#ifdef DEBUG
if ((strstr(GSM_Info->IrdaModels,"decode")!=NULL) && (CurrentConnectionType == GCT_Irda))
{
return true;
}
#endif
-#endif /* UCLINUX */
if (PortDevice[0]!=0x00) return true;
strcpy(text,"Connection ");
switch (con) {
case GCT_FBUS :strcpy(text+strlen(text),"FBUS");break;
-#ifndef UCLINUX
+ 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;
-#endif /* UCLINUX */
}
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;
}