import com.codename1.io.Log; //导入依赖的package包/类
private void listenToMessages() {
    try {
        pb = new Pubnub(PUBNUB_PUB_KEY, PUBNUB_SUB_KEY);
        pb.subscribe(tokenPrefix + uniqueId, new Callback() {
            @Override
            public void successCallback(String channel, Object message, String timetoken) {
                if(message instanceof String) {
                    pendingAck.remove(channel);
                    return;
                }
                Message m = new Message((JSONObject)message);
                pb.publish(tokenPrefix + m.getSenderId(),  "ACK", new Callback() {});
                Display.getInstance().callSerially(() -> {
                    addMessage(m);
                    respond(m);
                });
            }
        });
    } catch(PubnubException err) {
        Log.e(err);
        Dialog.show("Error", "There was a communication error: " + err, "OK", null);
    }
}
 

import com.codename1.io.Log; //导入依赖的package包/类
/**
 * 
 */
private ArrayList<T> getDiskCache() throws IOException, JSONException{
    ArrayList<T> cacheArray = new ArrayList<>();
    
    InputStream fileStream = FileSystemStorage.getInstance().openInputStream(localCacheFile.getAbsolutePath());
    String fileContents = Util.readToString(fileStream);
    if(fileContents.length() > 1){
        JSONArray cacheJson = new JSONArray(fileContents);
        Log.p(this.getClass().getSimpleName() + ": Read " + cacheJson.length() + " entries from JSON cache", Log.INFO);

        for(int i = 0;i < cacheJson.length();i++){
            T obj = serializer.deserialize(cacheJson.getJSONObject(i));
            cacheArray.add(obj);
        }
    }else{
        Log.p(this.getClass().getSimpleName() + ": JSON cache empty", Log.INFO);
    }
    return cacheArray;
}
 

import com.codename1.io.Log; //导入依赖的package包/类
/**
 * 
 * @param obj Object to update 
 * @param notifier ignored if memory caching is used
 * @throws java.io.IOException if file doesn't exist
 * @throws ca.weblite.codename1.json.JSONException if the cache file has been corrupted 
 */
public void update(T obj, CacheErrorNotifier notifier) throws IOException, JSONException {
    if(cacheMap != null){
        cacheMap.put(serializer.getObjectId(obj), obj);
        return;
    }

    ArrayList<T> all = getDiskCache();
    for(int i = 0;i < all.size();i++){
        Object o = all.get(i);
        if(serializer.getObjectId((T)o).equals(serializer.getObjectId(obj))){
            all.add(i, obj);
            syncAll(all, notifier);
            return;
        }
    }
    Log.p(this.getClass().getSimpleName() + ": Attempted object update failed - "
            + "object with id " + serializer.getObjectId(obj) + " not found", Log.WARNING);
}
 

import com.codename1.io.Log; //导入依赖的package包/类
private void syncDiskCache(Collection<T> data, CacheErrorNotifier notifier){
    try {
                JSONArray dataArray = new JSONArray();
                for(T t: data)
                    dataArray.put(serializer.serialize(t));

                if (!localCacheFile.exists()) {
                    localCacheFile.createNewFile();
                }
                OutputStream outputStream = FileSystemStorage.getInstance().openOutputStream(localCacheFile.getAbsolutePath());
                    outputStream.write(dataArray.toString().getBytes());
                    outputStream.flush();
                
                Log.p(this.getClass().getSimpleName() + ": Synced " + dataArray.length() + " entries to cache file " + localCacheFile.getName(), Log.INFO);
            } catch (IOException ex) {
                ex.printStackTrace();
                if (notifier != null) {
                    notifier.notify(ex);
                }
            }
}
 

import com.codename1.io.Log; //导入依赖的package包/类
/**
 * Convenience JavaBean method, see other version of this method
 * @param uri the URL for the media
 */
public void setDataSource(final String uri) {
    if(!isInitialized()) {
        pendingDataURI = uri;
        return;
    }
    if(dataSource == null || !dataSource.equals(uri)) {
        Display.getInstance().startThread(new Runnable() {
            public void run() {
                try {
                    setDataSource(uri, null);
                } catch(Throwable t) {
                    Log.e(t);
                }
            }
        }, "Media Thread").start();
    }
}
 

import com.codename1.io.Log; //导入依赖的package包/类
private String formatErrorMessage(String message) {
    if (message.indexOf('\n') < 0) {
        return message;
    }
    
    List<String> lines = StringUtil.tokenize(message, '\n');
    StringBuilder sb = new StringBuilder();
    for (int i=1; i<lines.size(); i++) { // Note: Deliberately skip first line
        String line = lines.get(i);
        line = StringUtil.replaceAll(line, "\r", "");
        line = StringUtil.replaceAll(line, "at ", "");
        line = StringUtil.replaceAll(line, "userclasses.", "");
        line = StringUtil.replaceAll(line, "generated.", "");
        line = StringUtil.replaceAll(line, "com.codename1.", "");
        line = StringUtil.replaceAll(line, "com.codenameone.music.", "");
        sb.append(line);
    }
    Log.p(sb.toString());
    return sb.toString();
}
 

import com.codename1.io.Log; //导入依赖的package包/类
private synchronized void setStatus(PlayerStatus status)
{
    Log.p("PlayerStatus changed to: " + status);
    this.status = status;

    statusChangeEvent.fireDataChangeEvent(0, status.ordinal());

    switch (status) {
        case STOPPED:
        case PAUSED:
            timer.cancel();
            timer = new Timer();
            break;

        case PLAYING:
            timer.scheduleAtFixedRate(new TimerTask() {
                @Override
                public void run() {
                    playingEvent.fireActionEvent(null);
                }
            }, 0, 1000);
            break;
    }
}
 

import com.codename1.io.Log; //导入依赖的package包/类
@Override
public boolean equals(Object o) {
    int id = MediaHelper.getId(track);
    String language = (String)track.get("language");

    if (o instanceof Map) {
        if (((Map) o).containsKey("type") && "track".equals(((Map) o).get("type"))) {
            if (language.equals(((Map) o).get("language")) && id == MediaHelper.getId((Map) o)) {
                Log.p("MediaRunnable: Instance is equal - " + id + " " + language);
                return true;
            }
        }
    }

    if (o instanceof MediaItem) {
        if (this.track == ((MediaItem) o).track) {
            Log.p("MediaRunnable: Instance is equal - " + id + " " + language);
            return true;
        }
    }

    Log.p("MediaRunnable: Instance is not equal - " + id + " " + language);

    return false;
}
 

import com.codename1.io.Log; //导入依赖的package包/类
@Override
protected void exitForm(Form f) {
    super.exitForm(f);

    requests = (java.util.List<ConnectionRequest>) f.getClientProperty("requests");

    if (requests == null) {
        return;
    }

    for(ConnectionRequest request : requests) {
        Log.p("Killed request " + request.getUrl());

        request.kill();
    }

    requests.clear();

    f.putClientProperty("requests", requests);
}
 

import com.codename1.io.Log; //导入依赖的package包/类
public void start() {
    if(current != null){
        current.show();
        return;
    }
    s = new StateMachine("/theme");        
    
    Display.getInstance().addEdtErrorHandler(new ActionListener() {
        public void actionPerformed(ActionEvent evt) {
            evt.consume();
            Log.p("Exception in AppName version " + Display.getInstance().getProperty("AppVersion", "Unknown"));
            Log.p("OS " + Display.getInstance().getPlatformName());
            Log.p("Error " + evt.getSource());
            Log.p("Current Form " + Display.getInstance().getCurrent().getName());
            Log.e((Throwable)evt.getSource());
            Log.sendLog();
        }
    });
}
 

import com.codename1.io.Log; //导入依赖的package包/类
public Message(JSONObject obj) {
    try {
        time = Long.parseLong(obj.getString("time"));
        senderId = obj.getString("fromId");
        recepientId = obj.getString("toId");
        message = obj.getString("message");
        name = obj.getString("name");
        picture = obj.getString("pic");
        
        // update the push id for the given user
        if(obj.has("pushId")) {
            String pushId = obj.getString("pushId");
            if(pushId != null) {
                Preferences.set("pid-" + senderId, pushId);
            }
        }
    } catch (JSONException ex) {
        // will this ever happen?
        Log.e(ex);
    }        
}
 

import com.codename1.io.Log; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
public byte[] getImageData() {
    if(data != null) {
        return data;
    }
    InputStream i = null;
    try {
        byte[] imageData = new byte[(int) FileSystemStorage.getInstance().getLength(fileName)];
        i = FileSystemStorage.getInstance().openInputStream(fileName);
        Util.readFully(i, imageData);
        if(keep) {
            data = imageData;
        }
        return imageData;
    } catch (IOException ex) {
        Log.e(ex);
        return null;
    } finally {
        Util.cleanup(i);
    }
}
 

import com.codename1.io.Log; //导入依赖的package包/类
void refreshZoom(Container solitairContainer) {
    int dpi =  DPIS[currentZoom / 5];
    Preferences.set("dpi", dpi);
    Preferences.set("zoom", currentZoom);
    try {
        cards = Resources.open("/gamedata.res",dpi);
        cardImageCache.clear();
        Image cardBack = getCardImage("card_back.png");
        for(Component c : solitairContainer) {
            CardComponent crd = (CardComponent)c;
            crd.setImages(getCardImage(crd.getCard().getFileName()), cardBack);
        }
        solitairContainer.revalidate();
        solitairContainer.getParent().replace(solitairContainer.getParent().getComponentAt(0), createPlacementContainer(solitairContainer), null);
    } catch(IOException e) {
        Log.e(e);
    }        
}
 

import com.codename1.io.Log; //导入依赖的package包/类
@Override
protected boolean initListModelSqlData(List cmp) {
    Database d = getDb();
    if(d != null) {
        try {
            Cursor c = d.executeQuery("select title, description from log");
            Vector entries = new Vector();
            while (c.next()) {
                Row r = c.getRow();
                String title = r.getString(0);
                String desc = r.getString(1);

                Hashtable value = new Hashtable();
                value.put("Line1", title);
                value.put("Line2", desc);
                entries.addElement(value);
                cmp.setModel(new DefaultListModel(entries));
            }
        } catch (IOException ex) {
            Log.e(ex);
        }

    }
    return true;
}
 

import com.codename1.io.Log; //导入依赖的package包/类
/**
 * Installs a crash reporter within the system
 * @param promptUser indicates whether the user should be prompted on crash reporting
 * @param frequency the frequency with which we send the log to the server in debug mode in minutes
 * frequency must be at least 1. Any lower level automatically disables this feature
 */
public static void init(boolean promptUser, int frequency) {
    if(Preferences.get("$CN1_crashBlocked", false) || Log.getReportingLevel() == Log.REPORTING_NONE) {
        return;
    }
    if(Preferences.get("$CN1_pendingCrash", false)) {
        // we must have crashed during a report, send it.
        Log.sendLog();
        Preferences.set("$CN1_pendingCrash", false);
    }
    if(Log.getReportingLevel() == Log.REPORTING_DEBUG && frequency > 0) {
        java.util.Timer t = new java.util.Timer();
        t.schedule(new TimerTask() {
            public void run() {
                if(!Display.getInstance().isEdt()) {
                    Display.getInstance().callSerially(this);
                    return;
                }
                Log.sendLog();
            }
        }, frequency * 60000, frequency * 60000);
    }
    DefaultCrashReporter d = new DefaultCrashReporter();
    d.promptUser = promptUser && Preferences.get("$CN1_prompt", true);
    Display.getInstance().setCrashReporter(d);
}
 

import com.codename1.io.Log; //导入依赖的package包/类
@Override
public void nativeLogout() {
    
    getClient(new SuccessCallback<GoogleApiClient>() {

        @Override
        public void onSucess(final GoogleApiClient client) {
            Auth.GoogleSignInApi.signOut(client).setResultCallback(
                new ResultCallback<Status>() {
                    @Override
                    public void onResult(Status status) {
                        Log.p("Finished signing out "+status);
                        setAccessToken(null);
                        mGoogleApiClient = null;
                        client.disconnect();
                    }
                });
        }
        
    });
}
 

import com.codename1.io.Log; //导入依赖的package包/类
void showModal(int top, int bottom, int left, int right, boolean includeTitle, boolean modal, boolean reverse) {
    if(Display.isInitialized() && Display.getInstance().isMinimized()){
        Log.p("Modal dialogs cannot be displayed on a minimized app");
        return;
    }
    this.top = top;
    this.bottom = bottom;
    this.left = left;
    this.right = right;
    
    // hide the title if no text is there to allow the styles of the dialog title to disappear
    if(dialogTitle != null && getUIManager().isThemeConstant("hideEmptyTitleBool", false)) {
        boolean b = dialogTitle.getText().length() > 0;
        getTitleArea().setVisible(b);
        getTitleComponent().setVisible(b);
    }
    super.showModal(top, bottom, left, right, includeTitle, modal, reverse);
}
 

import com.codename1.io.Log; //导入依赖的package包/类
GeofenceListener getGeofenceListener(String id) {
    if (geofenceListeners().containsKey(id)) {
        Class cls = null;
        try {
            cls = Class.forName(geofenceListeners.get(id)); 
            if (cls == null) {
                return null;
            }
            return (GeofenceListener)cls.newInstance();
        } catch (Throwable t) {
            Log.e(t);
        }
        
    }
    return null;
}
 

import com.codename1.io.Log; //导入依赖的package包/类
/**
 * Fills a shape in the graphics context.
 * @param shape
 */
void nativeFillShape(Shape shape) {
    if (shape.getClass() == GeneralPath.class) {
        // GeneralPath gives us some easy access to the points
        GeneralPath p = (GeneralPath)shape;
        int commandsLen = p.getTypesSize();
        int pointsLen = p.getPointsSize();
        byte[] commandsArr = getTmpNativeDrawShape_commands(commandsLen);
        float[] pointsArr = getTmpNativeDrawShape_coords(pointsLen);
        p.getTypes(commandsArr);
        p.getPoints(pointsArr);
        
        nativeInstance.nativeFillShapeMutable(color, alpha, commandsLen, commandsArr, pointsLen, pointsArr);
    } else {
        Log.p("Drawing shapes that are not GeneralPath objects is not yet supported on mutable images.");
    }
}
 

import com.codename1.io.Log; //导入依赖的package包/类
@Override
public String getHostOrIP() {
    try {
        InetAddress i = java.net.InetAddress.getLocalHost();
        if(i.isLoopbackAddress()) {
            Enumeration<NetworkInterface> nie = NetworkInterface.getNetworkInterfaces();
            while(nie.hasMoreElements()) {
                NetworkInterface current = nie.nextElement();
                if(!current.isLoopback()) {
                    Enumeration<InetAddress> iae = current.getInetAddresses();
                    while(iae.hasMoreElements()) {
                        InetAddress currentI = iae.nextElement();
                        if(!currentI.isLoopbackAddress()) {
                            return currentI.getHostAddress();
                        }
                    }
                }
            }
        }
        return i.getHostAddress();
    } catch(Throwable t) {
        Log.e(t);
        return null;
    }
}