WebSVN - Projects - Diff - Rev 70 and 81 - /DUBwise/src/MKCommunicator.java

 import javax.microedition.io.*;
 import java.io.*;
 public class MKCommunicator
-   implements Runnable
+    implements Runnable
+{
     /***************** Section: public Attributes **********************************************/
     public String mk_url=""; // buffer the url which is given in the constuctor for reconnectin purposes
     public MKLCD LCD;
     public MKVersion version;
+    public MKDebugData debug_data;
-    public MKDebugData debug_data;
+    public MKStickData stick_data;
     public MKParamsParser params;
     public MKWatchDog watchdog;
     public MKProxy proxy=null;
+    String name;
-    String name;
+    DUBwise root;
-    DUBwise root;
+    DUBwiseDebug debug;
+    /******************  Section: public Methods ************************************************/
-    /******************  Section: public Methods ************************************************/
+    public MKCommunicator(DUBwise root_,DUBwiseDebug debug_)
     public MKCommunicator(DUBwise root_)
         debug=debug_;
+        root=root_;
-        root=root_;
+        version=new MKVersion();
-        version=new MKVersion();
+        debug_data=new MKDebugData();
-        debug_data=new MKDebugData();
+        stick_data=new MKStickData();
         params=new MKParamsParser();
         LCD= new MKLCD(this);
     /******************  Section: private Methods ************************************************/
     private void connect()
+    {
         System.out.println("trying to connect to" + mk_url);
         try{
-                connection = (StreamConnection) Connector.open(mk_url);
+            connection = (StreamConnection) Connector.open(mk_url);
-                // old call
+            // old call
-                // connection = (StreamConnection) Connector.open(mk_url, Connector.READ_WRITE);
+            // connection = (StreamConnection) Connector.open(mk_url, Connector.READ_WRITE);
-                reader=connection.openInputStream();
+            reader=connection.openInputStream();
-                writer=connection.openOutputStream();
+            writer=connection.openOutputStream();
+            //
+            String magic="\rmk-mode\r";
+            writer.write(magic.getBytes());
+            writer.flush();
+            //
-                connection_start_time=System.currentTimeMillis();
+            connection_start_time=System.currentTimeMillis();
-                connected=true; // if we get here everything seems to be OK
+            connected=true; // if we get here everything seems to be OK
-                get_version();
+            get_version();
-                lcd_data_count=0;
+            lcd_data_count=0;
-                debug_data_count=0;
+            debug_data_count=0;
-                version_data_count=0;
+            version_data_count=0;
+        }
         catch (Exception ex)
+            {
                 // TODO difference fatal errors from those which will lead to reconnection
+    }
                 send_buff[3+param_pos*4+3] = (char)('=' + ( c & 0x3f));
                 //send_buff[3+foo]='=';
             }
-/*      for(int foo=0;foo<(params.length/3 + (params.length%3==0?0:1) )*4;foo++)
+        /*      for(int foo=0;foo<(params.length/3 + (params.length%3==0?0:1) )*4;foo++)
+                {
                 int a = (foo<params.length) params[foo];
                 int a = params[foo];
                 //send_buff[3+foo]='=';
+                }
-*/
+        */
         try
+            {
+    }
-    public void process_data(int[] data,int len)
-    {
-        int[] decoded_data;
+    public void process_data(int[] data,int len)
+    {
         switch((char)data[2])
             case '0':
             case '1':
             case '2':
-            case '3':
-                LCD.handle_lcd_data(Decode64(data,3,20),data[2]-(int)'0');
+            case '3':
+                lcd_data_count++;
+                LCD.handle_lcd_data(Decode64(data,3,20),data[2]-(int)'0');
+                break;
+            case '4':
+                stick_data.set_by_mk_data(Decode64(data,3,20));
+                String tmp_s="";
+                for (int tmp_c=0;tmp_c<10;tmp_c++)
+                    tmp_s+="s"+tmp_c+"v"+stick_data.stick[tmp_c]+" ";
-                lcd_data_count++;
+                debug.log(tmp_s);
                 break;
             case 'L':
                 params_data_count++;
                 break;
             default:
+                other_data_count++;
+                debug.log("got other data:" + (char)data[2] + "=>" + (byte)data[2]);
+                String tmp_str="";
+                for (int tmp_i=0;tmp_i<len;tmp_i++)
+                    tmp_str+=(char)data[tmp_i];
-                other_data_count++;
+                debug.log(tmp_str);
                 break;
         int input;
         int pos=0;
         msg+="!!run started!!";
         while(true)
+            {
-            if (!connected)
+                if (!connected)
-                {
+                    {
-                   if (!force_disconnect) connect();
+                        if (!force_disconnect) connect();
-                }
+                    }
-            else
+                else
-                try{
+                    try{
-                    pos=0;
+                        pos=0;
-                    input=0;
+                        input=0;
-                    // recieve data-set
+                        // recieve data-set
-                    while ((input != 13)) // &&(input!=-1))
+                        while ((input != 13)) // &&(input!=-1))
-                       {
+                            {
-                           input = reader.read() ;
+                                input = reader.read() ;
-                           if (proxy!=null)
+                                if (proxy!=null)
-                               proxy.writer.write(input);
+                                    proxy.writer.write(input);
+                                //                              if (input==-1) throw new Exception("test");
+                                if (input!=-1)
-                           if (input==-1) throw new Exception("test");
+                                    {
-                           data_set[pos]=input;
+                                        data_set[pos]=input;
+                                        pos++;
-                           pos++;
+                                    }
-                       }
+                            }
-                           if (proxy!=null)
+                        if (proxy!=null)
-                               {
+                            {
                                 proxy.writer.write('\r');
+                                proxy.writer.write('\n');
-                                proxy.writer.write('\n');
+                                proxy.writer.flush();
-                                proxy.writer.flush();
+                            }
-                               }
+                        if (pos>5)
-                    process_data(data_set,pos);
+                            process_data(data_set,pos);
+                    }
-                   }
+                    catch (Exception ex)
-        catch (Exception ex)
+                        {
-            {
+                            debug.log("Problem reading from MK -> closing conn");
-                msg="Problem reading from MK";
+                            debug.log(ex.toString());
-                // close the connection
+                            // close the connection
-                close_connections(false);
+                            close_connections(false);

Subversion Repositories Projects

(root)/DUBwise/src/MKCommunicator.java - Rev 70 → 81