badgeasynchronousthread.java

来自「First of all, the Applet-phone is a SIP 」· Java 代码 · 共 88 行

/*
 * BadgeAsynchronousThread.java
 *
 * Created on August 1, 2003, 5:43 PM
 */

package gov.nist.examples.bps.reader.baselistener;

/**
 *
 * @author Deruelle olivier
 */
public class BadgeAsynchronousThread extends Thread {
    
    private CommandManager commandManager;
    private BadgeNotification badgeNotification;
    private boolean QUERY;
    
    /** Creates a new instance of BadgeAsynchronousThread */
    public BadgeAsynchronousThread(CommandManager commandManager,BadgeNotification badgeNotification) {
        this.commandManager=commandManager;
        this.badgeNotification=badgeNotification;
        QUERY=true;
    }
    
    public void run() {
         try{
            commandManager.setTransferMode(CommandManager.ASYNCHRONOUS_TRANSFER_MODE);
            QUERY=true;
            int counter=1;
            long totalPackets=0;
            int[] badgeBytes=new int[4];
            while (QUERY) {
                
                StringBuffer inputBuffer = new StringBuffer();
                int newData = 0;
                
                newData = commandManager.is.read();
                inputBuffer.append((char)newData);
                String s=new String(inputBuffer);
                //SerialDebug.println("Received from the base: -  char: "+
                //s+" (dec/hex code: "+newData+"/"+Integer.toHexString(newData)+")");
                
                if (counter==1) {
                   badgeBytes[0]=newData;
                }
                else
                if (counter==2) {
                   badgeBytes[1]=newData;
                }
                else
                if (counter==3) {
                    badgeBytes[2]=newData;
                }
                else
                if (counter==4) {
                   badgeBytes[3]=newData; 
                }
                else                
                if ( Integer.toHexString(newData).equals("aa")) {
                   // A complete packet has been received:
                   Badge badge=new Badge(badgeBytes);
                  
                   badgeNotification.processBadge(badge);
               
                   badgeBytes=new int[4];
                   counter=0;
                   //totalPackets++;
                  // SerialDebug.println("Total number of packets received: "+totalPackets); 
                   
                }
                
                counter++;
            }
            
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    public void stopThread() {
        QUERY=false;
    }
    
    
}