This commit was manufactured by cvs2svn to create branch 'uc'.

[gnokii.git] / common / data / datapump.c

diff --git a/common/data/datapump.c b/common/data/datapump.c
new file mode 100644 (file)
index 0000000..4eede53
--- /dev/null
+++ b/common/data/datapump.c
@@ -0,0 +1,167 @@
+/*
+
+  $Id$
+
+  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.
+
+  This file provides routines to handle processing of data when connected in
+  fax or data mode. Converts data from/to GSM phone to virtual modem
+  interface.
+
+*/
+
+#define                __data_datapump_c
+
+
+#include <stdio.h>
+#include <errno.h>
+#include <fcntl.h>
+#include <signal.h>
+#include <termios.h>
+#include <grp.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <sys/poll.h>
+#include <unistd.h>
+
+
+#include "misc.h"
+#include "gsm-common.h"
+#include "gsm-api.h"
+#include "data/at-emulator.h"
+#include "data/virtmodem.h"
+#include "data/datapump.h"
+#include "data/rlp-common.h"
+
+/* Global variables */
+extern bool CommandMode;
+
+/* Local variables */
+int            PtyRDFD;        /* File descriptor for reading and writing to/from */
+int            PtyWRFD;        /* pty interface - only different in debug mode. */ 
+struct pollfd ufds;
+u8 pluscount;
+bool connected;
+
+bool DP_Initialise(int read_fd, int write_fd)
+{
+       PtyRDFD = read_fd;
+       PtyWRFD = write_fd;
+       ufds.fd=PtyRDFD;
+       ufds.events=POLLIN;
+       RLP_Initialise(GSM->SendRLPFrame, DP_CallBack);
+       RLP_SetUserRequest(Attach_Req,true);
+       pluscount=0;
+       connected=false;
+       return true;
+}
+
+
+int DP_CallBack(RLP_UserInds ind, u8 *buffer, int length)
+{
+       int temp;
+
+       switch(ind) {
+       case Data:
+               if (CommandMode==false) write(PtyWRFD, buffer, length);
+               break;
+       case Conn_Ind:
+               if (CommandMode==false) ATEM_ModemResult(MR_CARRIER);
+               RLP_SetUserRequest(Conn_Req,true);
+               break;
+       case StatusChange:
+               if (buffer[0]==0) {
+                       connected=true;
+                       if (CommandMode==false) ATEM_ModemResult(MR_CONNECT);
+               }
+               break;
+       case Disc_Ind:
+               if (CommandMode==false) ATEM_ModemResult(MR_NOCARRIER);
+               connected=false;
+               /* Set the call passup back to the at emulator */
+               GSM->DialData(NULL,-1,&ATEM_CallPassup);
+               CommandMode=true;
+               break;
+       case Reset_Ind:
+               RLP_SetUserRequest(Reset_Resp,true);
+               break;
+       case GetData:
+               if (poll(&ufds,1,0)) {
+
+                       /* Check if the program has closed */
+                       /* Return to command mode */
+                       /* Note that the call will still be in progress, */
+                       /* as with a normal modem (I think) */
+
+                       if (ufds.revents!=POLLIN) { 
+                               CommandMode=true;
+                               /* Set the call passup back to the at emulator */
+                               GSM->DialData(NULL,-1,&ATEM_CallPassup);
+                               return 0;
+                       }
+
+                       temp = read(PtyRDFD, buffer, length);
+
+                       if (temp<0) return 0; /* FIXME - what do we do now? */
+
+                       /* This will only check +++ and the beginning of a read */
+                       /* But there should be a pause before it anyway */
+      
+                       if (buffer[0]=='+') {
+                               pluscount++;
+                               if (temp>1) {
+                                       if (buffer[1]=='+') pluscount++;
+                                       else pluscount=0;
+                                       if (temp>2) {
+                                               if (buffer[2]=='+') pluscount++;
+                                               else pluscount=0;
+                                               if (temp>3) pluscount=0;
+                                       }
+                               }
+                       } else pluscount=0;
+      
+                       if (pluscount==3) {
+                               CommandMode=true;
+                               /* Set the call passup back to the at emulator */
+                               GSM->DialData(NULL,-1,&ATEM_CallPassup);
+                               ATEM_ModemResult(MR_OK);
+                               break;
+                       }
+      
+                       return temp;
+               }
+               return 0;
+               break;
+
+       default:
+
+       }
+       return 0;
+}
+
+void DP_CallPassup(char c)
+{
+       switch (c) {
+       case 'D':
+               if (CommandMode==false) ATEM_ModemResult(MR_CARRIER);
+               RLP_SetUserRequest(Conn_Req,true);
+               connected=true;
+               break;
+       case ' ':
+               CommandMode=true;
+               /* Set the call passup back to the at emulator */
+               GSM->DialData(NULL,-1,&ATEM_CallPassup);
+               ATEM_ModemResult(MR_NOCARRIER);
+               RLP_SetUserRequest(Disc_Req, true);
+               connected=false;
+               break;
+       default:
+               break;
+       }
+}