github上的网络测速demo

/* Copyright 2012 Google Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.google.wireless.speed.speedometer; import com.google.myjson.reflect.TypeToken; import com.google.wireless.speed.speedometer.BatteryCapPowerManager.PowerAwareTask; import com.google.wireless.speed.speedometer.util.MeasurementJsonConvertor; import com.google.wireless.speed.speedometer.util.PhoneUtils; import android.app.AlarmManager; import android.app.Notification; import android.app.NotificationManager; import android.app.PendingIntent; import android.app.Service; import android.content.BroadcastReceiver; import android.content.Context; import android.content.Intent; import android.content.IntentFilter; import android.content.SharedPreferences; import android.os.Binder; import android.os.IBinder; import android.preference.PreferenceManager; import android.util.Log; import android.widget.ArrayAdapter; import java.io.IOException; import java.io.PrintWriter; import java.io.StringWriter; import java.io.Writer; import java.lang.reflect.Type; import java.util.ArrayList; import java.util.Calendar; import java.util.Collections; import java.util.Comparator; import java.util.ConcurrentModificationException; import java.util.Date; import java.util.Iterator; import java.util.List; import java.util.Vector; import java.util.concurrent.Callable; import java.util.concurrent.CancellationException; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.PriorityBlockingQueue; /** * The single scheduler thread that monitors the task queue, runs tasks at their specified * times, and finally retrieves and reports results once they finish. * * All method invocations on the singleton object are thread-safe. * * @author wenjiezeng@google.com (Steve Zeng) */ public class MeasurementScheduler extends Service { // This arbitrary id is private to Speedometer private static final int NOTIFICATION_ID = 1234; private ExecutorService measurementExecutor; private BroadcastReceiver broadcastReceiver; private Boolean pauseRequested = true; private boolean stopRequested = false; private boolean isSchedulerStarted = false; private Checkin checkin; private long checkinIntervalSec; private long checkinRetryIntervalSec; private int checkinRetryCnt; private CheckinTask checkinTask; private Calendar lastCheckinTime; private PendingIntent checkinIntentSender; /** * Intent for checkin retries. Reusing checkinIntentSender for retries will cancel any * previously configured periodic checkin schedule. Thus we need a separate intent sender */ private PendingIntent checkinRetryIntentSender; private PendingIntent measurementIntentSender; private AlarmManager alarmManager; private BatteryCapPowerManager powerManager; /* Both taskQueue and pendingTasks are thread safe and operations on them are atomic. * To guarantee reliable value propagation between threads, use volatile keyword. */ private volatile PriorityBlockingQueue<MeasurementTask> taskQueue; private volatile ConcurrentHashMap<MeasurementTask, Future<MeasurementResult>> pendingTasks; // Binder given to clients private final IBinder binder = new SchedulerBinder(); private MeasurementTask currentTask; private NotificationManager notificationManager; private int completedMeasurementCnt = 0; private int failedMeasurementCnt = 0; private ArrayList<String> userResults; private ArrayList<String> systemResults; private ArrayList<String> systemConsole; private PhoneUtils phoneUtils; /** * The Binder class that returns an instance of running scheduler */ public class SchedulerBinder extends Binder { public MeasurementScheduler getService() { return MeasurementScheduler.this; } } /* Returns a IBinder that contains the instance of the MeasurementScheduler object * @see android.app.Service#onBind(android.content.Intent) */ @Override public IBinder onBind(Intent intent) { Logger.d("Service onBind called"); return this.binder; } // Service objects are by nature singletons enforced by Android @Override public void onCreate() { Logger.d("Service onCreate called"); PhoneUtils.setGlobalContext(this.getApplicationContext()); phoneUtils = PhoneUtils.getPhoneUtils(); phoneUtils.registerSignalStrengthListener(); this.checkin = new Checkin(this); this.checkinRetryIntervalSec = Config.MIN_CHECKIN_RETRY_INTERVAL_SEC; this.checkinRetryCnt = 0; this.checkinTask = new CheckinTask(); this.pauseRequested = true; this.stopRequested = false; this.measurementExecutor = Executors.newSingleThreadExecutor(); this.taskQueue = new PriorityBlockingQueue<MeasurementTask>(Config.MAX_TASK_QUEUE_SIZE, new TaskComparator()); this.pendingTasks = new ConcurrentHashMap<MeasurementTask, Future<MeasurementResult>>(); this.notificationManager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE); this.alarmManager = (AlarmManager) this.getSystemService(Context.ALARM_SERVICE); this.powerManager = new BatteryCapPowerManager(Config.DEFAULT_BATTERY_THRESH_PRECENT, this); restoreState(); // Register activity specific BroadcastReceiver here IntentFilter filter = new IntentFilter(); filter.addAction(UpdateIntent.PREFERENCE_ACTION); filter.addAction(UpdateIntent.MSG_ACTION); filter.addAction(UpdateIntent.CHECKIN_ACTION); filter.addAction(UpdateIntent.CHECKIN_RETRY_ACTION); filter.addAction(UpdateIntent.MEASUREMENT_ACTION); filter.addAction(UpdateIntent.MEASUREMENT_PROGRESS_UPDATE_ACTION); broadcastReceiver = new BroadcastReceiver() { // Handles various broadcast intents. @Override public void onReceive(Context context, Intent intent) { if (intent.getAction().equals(UpdateIntent.PREFERENCE_ACTION)) { updateFromPreference(); } else if (intent.getAction().equals(UpdateIntent.CHECKIN_ACTION) || intent.getAction().equals(UpdateIntent.CHECKIN_RETRY_ACTION)) { Logger.d("Checkin intent received"); handleCheckin(false); } else if (intent.getAction().equals(UpdateIntent.MEASUREMENT_ACTION)) { Logger.d("MeasurementIntent intent received"); handleMeasurement(); } else if (intent.getAction().equals(UpdateIntent.MEASUREMENT_PROGRESS_UPDATE_ACTION)) { Logger.d("MeasurementIntent update intent received"); if (intent.getIntExtra(UpdateIntent.PROGRESS_PAYLOAD, Config.INVALID_PROGRESS) == Config.MEASUREMENT_END_PROGRESS) { if (intent.getStringExtra(UpdateIntent.ERROR_STRING_PAYLOAD) != null) { failedMeasurementCnt++; } else { completedMeasurementCnt++; } updateResultsConsole(intent); } } else if (intent.getAction().equals(UpdateIntent.MSG_ACTION)) { String msg = intent.getExtras().getString(UpdateIntent.STRING_PAYLOAD); Date now = Calendar.getInstance().getTime(); insertStringToConsole(systemConsole, now + "\n\n" + msg); } } }; this.registerReceiver(broadcastReceiver, filter); // TODO(mdw):