namsnotifier.java

来自「This is a resource based on j2me embedde」· Java 代码 · 共 254 行

/*
 *  
 *
 * Copyright  1990-2007 Sun Microsystems, Inc. All Rights Reserved.
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER
 * 
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License version
 * 2 only, as published by the Free Software Foundation.
 * 
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 * General Public License version 2 for more details (a copy is
 * included at /legal/license.txt).
 * 
 * You should have received a copy of the GNU General Public License
 * version 2 along with this work; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
 * 02110-1301 USA
 * 
 * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa
 * Clara, CA 95054 or visit www.sun.com if you need additional
 * information or have any questions.
 */

package com.sun.midp.main;

import com.sun.midp.events.EventTypes;
import com.sun.midp.events.EventQueue;
import com.sun.midp.events.EventListener;
import com.sun.midp.events.Event;
import com.sun.midp.events.NativeEvent;

import com.sun.midp.log.Logging;
import com.sun.midp.log.LogChannels;

/**
 * Works as a simple (display) manager to test NAMS.
 */
public class NamsNotifier implements EventListener {
    
    /** 
     * array of sync objects for midlet state change notifications - 
     * one per midlet/per state
     */
    private Object syncState[][];

    /** 
     * array of sync objects for display FG notifications - 
     * one per midlet
     */
    private Object syncFG[];

    /** 
     * array of sync objects for display BG notifications - 
     * one for all midlets
     */
    private Object syncBG;
    
    /**
     * public constructor.
     * 
     * registers itself as an event listener for TEST_EVENT
     */
    public NamsNotifier() {
        
        int i, j;
        EventQueue eventQueue;
        
        // appId = 0 is reserved for NamsManager itself
        initNamsNotifier(MIDletSuiteUtils.getIsolateId());
        
        // register self as the listener for 
        eventQueue = EventQueue.getEventQueue();
        // if (eventQueue == null)
        //     Logging.report(Logging.ERROR, LogChannels.LC_CORE,
        //         "DEBUG: Notifier: constructor - event queue is null !!!");
        eventQueue.registerEventListener(EventTypes.TEST_EVENT, this);
        
        syncState = new Object[NamsStorage.NAMS_STORAGE_SIZE][6];
        syncFG = new Object[NamsStorage.NAMS_STORAGE_SIZE];
        syncBG = new Object();
        
        for (i = 0; i < NamsStorage.NAMS_STORAGE_SIZE; ++i) {
            for (j = 0; j < 6; ++j) {
                syncState[i][j] = new Object();
            }
            syncFG[i] = new Object();
        }
    }
    
    /**
     * initializes native part of NamsNotifier
     *
     * @param isolateId isolate where NamsNotifier is run 
     *        (where to sent events)
     */
    private native void initNamsNotifier(int isolateId);
    
    /**
     * event preprocessing event routine - empty
     *
     * @param event event to check
     * @param waitingEvent event to compare with 
     *
     * @return always returns true
     */
    public boolean preprocess(Event event, Event waitingEvent) {
        return true;
    }

    /**
     * main event event processing event routine 
     *
     * @param event event to process
     *
     */
    public void process(Event event) {
        NativeEvent e = (NativeEvent)event;
        int appId = e.intParam1;
        int callbackId = e.intParam2;
        int state = e.intParam3;
        int reason = e.intParam4;
        
        switch (callbackId) {
            case 0: 
                /* BG callback - no parameters */ 
                /*
                Logging.report(Logging.WARNING, LogChannels.LC_CORE,
                   "DEBUG: Got Notification: {" +
                   "appId=-1, " +
                   "BG=" + callbackId + ", " +
                   "x, " + 
                   "reason=" + reason + "}");
                 */
                synchronized (syncBG) { 
                    syncBG.notifyAll();
                }
                break;
            case 1: 
                /* FG callback */ 
                if (appId < 0 || appId > NamsStorage.NAMS_STORAGE_SIZE) {
                    /*
                    Logging.report(Logging.WARNING, LogChannels.LC_CORE,
                        "DEBUG: Notifier: FG callback - " +
                        "index out of bounds ..." +
                        " " + appId);
                     */
                } else {
                    /*
                    Logging.report(Logging.WARNING, LogChannels.LC_CORE,
                        "DEBUG: Got Notification: {" +
                        " appId=" + appId +  ", " +
                        "FG=" + callbackId + ", " +
                        "x, " + 
                        "reason=" + reason + "}");
                     */
                    synchronized (syncFG[appId]) { 
                        syncFG[appId].notifyAll();
                    }
                }
                break;
            case 2: 
                /* State callback */ 
                if (appId < 0 || appId >= NamsStorage.NAMS_STORAGE_SIZE ||
                    state < 1 || state > 5) {
                    /*
                    Logging.report(Logging.WARNING, LogChannels.LC_CORE,
                        "DEBUG: Notifier: State callback - " +
                        "index out of bounds ..." +
                         " " + appId +
                         " " + state);
                     */
                } else {
                    /*
                    Logging.report(Logging.WARNING, LogChannels.LC_CORE,
                        "DEBUG: Got Notification: {" +
                        " appId=" + appId +  ", " +
                        "STATE=" + callbackId + ", " +
                        "state=" + state + ", " +
                        "reason=" + reason + "}");
                     */
                    synchronized (syncState[appId][state]) { 
                        syncState[appId][state].notifyAll();
                    }
                }
                break;
        }
    }
    
    public boolean waitForBG(long timeout) {
        boolean value = true;
        
        synchronized (syncBG) {
            try {
                /*
                Logging.report(Logging.ERROR, LogChannels.LC_CORE,
                    "DEBUG: Enter Waiting for BG");
                 */
                syncBG.wait(timeout);
            } catch (InterruptedException ie) {
                value = false;
            } catch (IllegalMonitorStateException ime) {
                Logging.report(Logging.ERROR, LogChannels.LC_CORE,
                   "Unexpected monitor exception");
            }
        }
        return value;
    }

    public boolean waitForFG(int appId, long timeout) {
        boolean value = true;
        
        synchronized (syncFG[appId]) {
            try {
                /*
                Logging.report(Logging.ERROR, LogChannels.LC_CORE,
                    "DEBUG: Enter Waiting for appId=" + appId + "FG");
                 */
                syncFG[appId].wait(timeout);
            } catch (InterruptedException ie) {
                value = false;
            } catch (IllegalMonitorStateException ime) {
                Logging.report(Logging.ERROR, LogChannels.LC_CORE,
                   "Unexpected monitor exception");
            }
        }
        return value;
    }

    public boolean waitForState(int appId, int state, long timeout) {
        boolean value = true;
        
        synchronized (syncState[appId][state]) {
            try {
                /*
                Logging.report(Logging.ERROR, LogChannels.LC_CORE,
                    "DEBUG: Enter Waiting for appId=" + appId + 
                    " state=" + state);
                 */
                syncState[appId][state].wait(timeout);
            } catch (InterruptedException ie) {
                value = false;
            } catch (IllegalMonitorStateException ime) {
                Logging.report(Logging.ERROR, LogChannels.LC_CORE,
                   "Unexpected monitor exception");
            }
        }
        return value;
    }
}