Simulation communication série virtuel Arduino

~$ socat -d -d pty,raw,echo=0 pty,raw,echo=0
2016/02/20 11:14:09 socat[16985] N PTY is /dev/pts/12
2016/02/20 11:14:09 socat[16985] N PTY is /dev/pts/25
2016/02/20 11:14:09 socat[16985] N starting data transfer loop with FDs [3,3] and [5,5]

~$ cat < /dev/pts/12

~$ sudo ln -s /dev/pts/25 /dev/ttyUSB25
~$ echo "test" > /dev/ttyUSB25

~$ cat < /dev/pts/12
test

//Envoie "h" pour allumer une LED et "l" pour l'éteindre.

import gnu.io.CommPort;
import gnu.io.CommPortIdentifier;
import gnu.io.NoSuchPortException;
import gnu.io.PortInUseException;
import gnu.io.SerialPort;
import gnu.io.UnsupportedCommOperationException;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.Enumeration;
import java.util.logging.Level;
import java.util.logging.Logger;




public class recieve extends javax.swing.JFrame {
    static InputStream in;
    static SerialPort serialPort;
    Enumeration<CommPortIdentifier> portsEnum;
    CommPortIdentifier portId;
    ArrayList<CommPortIdentifier> l;

    public recieve() {
        l = new ArrayList();
        initComponents();
    }

    /**
     * This method is called from within the constructor to initialize the form.
     * WARNING: Do NOT modify this code. The content of this method is always
     * regenerated by the Form Editor.
     */
    @SuppressWarnings("unchecked")
    // <editor-fold defaultstate="collapsed" desc="Generated Code">                          
    private void initComponents() {

        searchAvailablePortsBtn = new javax.swing.JButton();
        portsList = new javax.swing.JComboBox<>();
        jScrollPane1 = new javax.swing.JScrollPane();
        portsListDisplayArea = new javax.swing.JTextArea();
        disconnectBtn = new javax.swing.JButton();
        connectBtn = new javax.swing.JButton();
        ledOnBtn = new javax.swing.JButton();
        ledOfBtn = new javax.swing.JButton();

        setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE);

        searchAvailablePortsBtn.setText("Search availble ports");
        searchAvailablePortsBtn.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                searchAvailablePortsBtnActionPerformed(evt);
            }
        });

        portsList.setModel(new javax.swing.DefaultComboBoxModel<>(new String[] { "" }));

        portsListDisplayArea.setColumns(20);
        portsListDisplayArea.setRows(5);
        jScrollPane1.setViewportView(portsListDisplayArea);

        disconnectBtn.setText("Disconnect");
        disconnectBtn.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                disconnectBtnActionPerformed(evt);
            }
        });

        connectBtn.setText("Connect");
        connectBtn.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                connectBtnActionPerformed(evt);
            }
        });

        ledOnBtn.setText("LED ON");
        ledOnBtn.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                ledOnBtnActionPerformed(evt);
            }
        });

        ledOfBtn.setText("LED OFF");
        ledOfBtn.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                ledOfBtnActionPerformed(evt);
            }
        });

        javax.swing.GroupLayout layout = new javax.swing.GroupLayout(getContentPane());
        getContentPane().setLayout(layout);
        layout.setHorizontalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(javax.swing.GroupLayout.Alignment.TRAILING, layout.createSequentialGroup()
                .addGap(62, 62, 62)
                .addComponent(connectBtn)
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED, javax.swing.GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE)
                .addComponent(disconnectBtn)
                .addGap(86, 86, 86))
            .addGroup(javax.swing.GroupLayout.Alignment.TRAILING, layout.createSequentialGroup()
                .addContainerGap()
                .addComponent(jScrollPane1)
                .addContainerGap())
            .addGroup(layout.createSequentialGroup()
                .addContainerGap()
                .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
                    .addComponent(searchAvailablePortsBtn, javax.swing.GroupLayout.PREFERRED_SIZE, 367, javax.swing.GroupLayout.PREFERRED_SIZE)
                    .addComponent(portsList, javax.swing.GroupLayout.PREFERRED_SIZE, 367, javax.swing.GroupLayout.PREFERRED_SIZE))
                .addContainerGap(48, Short.MAX_VALUE))
            .addGroup(layout.createSequentialGroup()
                .addGap(71, 71, 71)
                .addComponent(ledOnBtn)
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED, javax.swing.GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE)
                .addComponent(ledOfBtn)
                .addGap(57, 57, 57))
        );
        layout.setVerticalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(layout.createSequentialGroup()
                .addGap(34, 34, 34)
                .addComponent(searchAvailablePortsBtn)
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED)
                .addComponent(portsList, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE)
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.UNRELATED)
                .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.BASELINE)
                    .addComponent(disconnectBtn)
                    .addComponent(connectBtn))
                .addGap(18, 18, 18)
                .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.BASELINE)
                    .addComponent(ledOnBtn)
                    .addComponent(ledOfBtn))
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED, 17, Short.MAX_VALUE)
                .addComponent(jScrollPane1, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE)
                .addContainerGap())
        );

        pack();
    }// </editor-fold>                        

    private void searchAvailablePortsBtnActionPerformed(java.awt.event.ActionEvent evt) {                                                        
        portsList.removeAllItems();
        portsEnum = CommPortIdentifier.getPortIdentifiers();
        while(portsEnum.hasMoreElements()) {
            portId = portsEnum.nextElement();
            portsList.addItem(portId.getName());
            l.add(portId);
            System.out.println(portId.getName());
        }      
    }                                                       

    private void disconnectBtnActionPerformed(java.awt.event.ActionEvent evt) {                                              
      serialPort.close();
      portsListDisplayArea.append(portsList.getSelectedItem().toString()+" disconnected.\n");
    }                                             

    private void connectBtnActionPerformed(java.awt.event.ActionEvent evt) {                                           
        try {
            CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier(portsList.getSelectedItem().toString());
            if ( portIdentifier.isCurrentlyOwned() )
                portsListDisplayArea.append("Error: Port is currently in use");
            else {
                CommPort commPort = portIdentifier.open(this.getClass().getName(),2000);

                if ( commPort instanceof SerialPort ) {
                    serialPort = (SerialPort) commPort;
                    serialPort.setSerialPortParams(9600,SerialPort.DATABITS_8,SerialPort.STOPBITS_1,SerialPort.PARITY_NONE);
                     portsListDisplayArea.append("Connected to " + portsList.getSelectedItem().toString()+"\n");
                }
                else 
                    portsListDisplayArea.append("Error: Only serial ports are handled by this example.\n");

            }     

        } catch (NoSuchPortException ex) {
            Logger.getLogger(recieve.class.getName()).log(Level.SEVERE, null, ex);
        } catch (PortInUseException ex) {
            Logger.getLogger(recieve.class.getName()).log(Level.SEVERE, null, ex);
        } catch (UnsupportedCommOperationException ex) {
            Logger.getLogger(recieve.class.getName()).log(Level.SEVERE, null, ex);
        } 

    }                                          

    private void ledOnBtnActionPerformed(java.awt.event.ActionEvent evt) {                                         
        try {
            OutputStream out = serialPort.getOutputStream();
             (new Thread(new SerialWriter(out,1))).start();
        } catch (IOException ex) {
            Logger.getLogger(recieve.class.getName()).log(Level.SEVERE, null, ex);
        }
    }                                        

    private void ledOfBtnActionPerformed(java.awt.event.ActionEvent evt) {                                         
        try {
            OutputStream out = serialPort.getOutputStream();
             (new Thread(new SerialWriter(out,0))).start();
        } catch (IOException ex) {
            Logger.getLogger(recieve.class.getName()).log(Level.SEVERE, null, ex);
        }
    }                                        

    /**
     * @param args the command line arguments
     */
    /** */
    public static class SerialReader implements Runnable 
    {
        InputStream in;

        public SerialReader ( InputStream in )
        {
            this.in = in;
        }

        public void run ()
        {
            byte[] buffer = new byte[1024];
            int len = -1;
            try
            {
                while ( ( len = this.in.read(buffer)) > -1 )
                {
                    portsListDisplayArea.append(new String(buffer,0,len));
                }
            }
            catch ( IOException e )
            {
                e.printStackTrace();
            }            
        }
    }

    /** */
    public static class SerialWriter implements Runnable 
    {
        OutputStream out;
        int flag;

        public SerialWriter ( OutputStream out , int flag)
        {
            this.out = out;
            this.flag = flag;
        }

        public void run ()
        {
            try {
                if (flag == 1)
                    out.write('h');
                else 
                     out.write('l');
            } catch (IOException ex) {
                Logger.getLogger(recieve.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }
    public static void main(String args[]) {
        /* Set the Nimbus look and feel */
        //<editor-fold defaultstate="collapsed" desc=" Look and feel setting code (optional) ">
        /* If Nimbus (introduced in Java SE 6) is not available, stay with the default look and feel.
         * For details see http://download.oracle.com/javase/tutorial/uiswing/lookandfeel/plaf.html 
         */
        try {
            for (javax.swing.UIManager.LookAndFeelInfo info : javax.swing.UIManager.getInstalledLookAndFeels()) {
                if ("Nimbus".equals(info.getName())) {
                    javax.swing.UIManager.setLookAndFeel(info.getClassName());
                    break;
                }
            }
        } catch (ClassNotFoundException ex) {
            java.util.logging.Logger.getLogger(recieve.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (InstantiationException ex) {
            java.util.logging.Logger.getLogger(recieve.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (IllegalAccessException ex) {
            java.util.logging.Logger.getLogger(recieve.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (javax.swing.UnsupportedLookAndFeelException ex) {
            java.util.logging.Logger.getLogger(recieve.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        }
        //</editor-fold>

        /* Create and display the form */
        java.awt.EventQueue.invokeLater(new Runnable() {
            public void run() {
                new recieve().setVisible(true);
            }
        });

        try {
             in = serialPort.getInputStream();
             (new Thread(new SerialReader(in))).start();
        } catch (IOException ex) {
            Logger.getLogger(recieve.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    // Variables declaration - do not modify                     
    private javax.swing.JButton connectBtn;
    private javax.swing.JButton disconnectBtn;
    private javax.swing.JScrollPane jScrollPane1;
    private javax.swing.JButton ledOfBtn;
    private javax.swing.JButton ledOnBtn;
    private javax.swing.JComboBox<String> portsList;
    private static javax.swing.JTextArea portsListDisplayArea;
    private javax.swing.JButton searchAvailablePortsBtn;
    // End of variables declaration                   
}

void loop()
{ // Début de la boucle "infinie" de ton programme
  unsigned char a=0; // J'ai changé val en a et int en unsigned char, juste pour le kiff
  int buffer=0; // File d'attente
  buffer=Serial.available();
  while(buffer>0) { // Tant qu'il y a du monde qui attend
    /* DEBUT WHILE, WAZAAA */
    a=Serial.read(); // a : lecture du port série (byte en tête de liste)
    buffer=Serial.available(); // Mise à jour de la file d'attente
  } // Et là tant qu'il y a du monde dans la file d'attente on revient à WAZAAA...
  // Ici, a vaut le dernier byte que j'ai reçu du port série
  if(a=='l') {
    // Je suis l, je déploie mes ailes
  } else {
    // Je ne suis pas l, je me cache dans le nid
  }
  /* Je suis une machine, j'ai bien déployé mes ailes ou pas en fonction de la
     valeur a.
     Sauf qu'après la fin de ce commentaire, j'ai la fin de la boucle "infinie" de
     ton programme. Je remonte au début, tu me dis que a=0, si je ne reçois rien sur
     le port série entre ce moment précis et le moment où 
     je vais arriver sur buffer=Serial.available(),
     je n'irai pas à l'intérieur de while(buffer>0) (...)
  */
}

// Pas dans loop
unsigned char a=0;
void loop()
{
  while(Serial.available()) {
    a=Serial.read();
    if(a == 'h') {
      // Write HIGH
    } else {
      // Fais autre chose
    }
  }
}