緑之庵(緑之杜): Zygoteへの起動要求を出している箇所を探す（その2）

というわけで、先日の続きです。

Zygoteを使って新しいVMプロセスを生成していそうな箇所は

android.os.Process.start()を呼び出すコード
/system/bin/dvz

の二つにとりあえず絞りました。
というわけで、Process.start()を呼び出していそうな箇所をきちんと探してみたら、あっさり見つかりました。

frameworks/base/services/java/com/android/server/am/ActivityManagerService.java

private final void startProcessLocked(ProcessRecord app, String hostingType, String hostingNameStr) {
        :
        :
   int pid = Process.start("android.app.ActivityThread",
   mSimpleProcessManagement ? app.processName : null, uid, uid,
   gids, debugFlags, null);
        :
        :
}

しかしまぁ、このActivityManagerServiceさんは難敵です。
何せ、メソッドの行数の長いこと・・・・。このコード、なかなか難易度が高いです。
とりあえず、こういうときは焦らず最初から。

横浜PF部の勉強会ではちらりと述べたのですが、Zygoteは起動時に--start-system-serverという引数を受け取っており、プロセス生成後、最初の子プロセスとしてsystem_serverを生成しています。このSystemServerは、内部でServerThreadというスレッドをrunしています。

frameworks/base/services/java/com/android/server/SystemServer.java
public void run() {
        :
        :
   context = ActivityManagerService.main(factoryTest);
        :
        :
}

というわけで、mainが直接呼び出されています。mainはというと

frameworks/base/services/java/com/android/server/am/ActivityManagerService.java
public static final Context main(int factoryTest) {
   AThread thr = new AThread();
   thr.start();
   synchronized (thr) {
       while (thr.mService == null) {
           try {
               thr.wait();
           } catch (InterruptedException e) {
           }
       }
   }
   ActivityManagerService m = thr.mService;
   mSelf = m;
   ActivityThread at = ActivityThread.systemMain();
   mSystemThread = at;
   Context context = at.getSystemContext();

   m.mContext = context;
   m.mFactoryTest = factoryTest;
   m.mMainStack = new ActivityStack(m, context, true);
   m.mBatteryStatsService.publish(context);
   m.mUsageStatsService.publish(context);

   synchronized (thr) {
       thr.mReady = true;
       thr.notifyAll();
   }
   m.startRunning(null, null, null, null);
   return context;
}

まずは、Athreadを生成してrunした後、AThreadのmServiceが設定されるのを待っています。
Athreadとはというと

frameworks/base/services/java/com/android/server/am/ActivityManagerService.java
static class AThread extends Thread {
   ActivityManagerService mService;
   boolean mReady = false;

   public AThread() {
       super("ActivityManager");
   }

   public void run() {
       Looper.prepare();
       android.os.Process.setThreadPriority(
       android.os.Process.THREAD_PRIORITY_FOREGROUND);
       android.os.Process.setCanSelfBackground(false);
       ActivityManagerService m = new ActivityManagerService();
       synchronized (this) {
           mService = m;
           notifyAll();
       }
       synchronized (this) {
           while (!mReady) {
               try {
                   wait();
               } catch (InterruptedException e) {
               }
           }
       }
       Looper.loop();
   }
}

ということで、Looperのprepareを呼び出した後、ActivityManagerServiceの生成を行いmServiceに設定したうえで、mReadyのフラグが立つのを待っています。
スレッドを生成したmainに処理が戻ると、mServiceのActivityManagerServiceにcontext等を設定した上で、mReadyフラグを立てて、AThreadの処理を実行させた後、AThreadのActivityManagerService#startRunning()を呼び出します。
AThreadの方はというと、Looper.loop()でメッセージループを実行していますね。

一方、startRunning()はというと

public final void startRunning(String pkg, String cls, String action,String data) {
   synchronized(this) {
       if (mStartRunning) {
           return;
       }
       mStartRunning = true;
       mTopComponent = pkg != null && cls != null ? new ComponentName(pkg, cls) : null;
       mTopAction = action != null ? action : Intent.ACTION_MAIN;
       mTopData = data;
       if (!mSystemReady) {
           return;
       }
   }
   systemReady(null);
}

初回起動ですので、systemReady(null)が呼び出されます。
正直な話、真面目に話そうと思うと、PF部の発表時間の枠に収まりませんし、とりあえず、重要そうな処理だけを追いかけます。

public void systemReady(final Runnable goingCallback) {
        :
        :
   Intent intent = new Intent(Intent.ACTION_PRE_BOOT_COMPLETED);
   ris = AppGlobals.getPackageManager().queryIntentReceivers(intent, null, 0);
        :
        :
   for (int i=ris.size()-1; i>=0; i--) {
   if ((ris.get(i).activityInfo.applicationInfo.flags & ApplicationInfo.FLAG_SYSTEM) == 0) {
           ris.remove(i);
       }
   }
        :
        :

   intent.addFlags(Intent.FLAG_RECEIVER_BOOT_UPGRADE);

ArrayList<ComponentName> lastDoneReceivers = readLastDonePreBootReceivers();

   final ArrayList<ComponentName> doneReceivers = new ArrayList<ComponentName>();
   for (int i=0; i<ris.size(); i++) {
   ActivityInfo ai = ris.get(i).activityInfo;
   ComponentName comp = new ComponentName(ai.packageName, ai.name);
   if (lastDoneReceivers.contains(comp)) {
   ris.remove(i);
   i--;
   }
   }

   for (int i=0; i<ris.size(); i++) {
   ActivityInfo ai = ris.get(i).activityInfo;
   ComponentName comp = new ComponentName(ai.packageName, ai.name);
   doneReceivers.add(comp);
   intent.setComponent(comp);
   IIntentReceiver finisher = null;
   if (i == ris.size()-1) {
   finisher = new IIntentReceiver.Stub() {
   public void performReceive(Intent intent, int resultCode,
   String data, Bundle extras, boolean ordered,
   boolean sticky) {
   mHandler.post(new Runnable() {
   public void run() {
   synchronized (ActivityManagerService.this) {
   mDidUpdate = true;
   }
   writeLastDonePreBootReceivers(doneReceivers);
   systemReady(goingCallback);
   }
   });
   }
   };
   }
   Slog.i(TAG, "Sending system update to: " + intent.getComponent());
   broadcastIntentLocked(null, null, intent, null, finisher,
   0, null, null, null, true, false, MY_PID, Process.SYSTEM_UID);
   if (finisher != null) {
   mWaitingUpdate = true;
   }
   }

ということで、詳しいことは置いておいてコードを見る限り
1. PackageManagerからACTION_PRE_BOOT_COMPLETEDのReceiverのリストを取得
2. リストから、FLAG_SYSTEMを持たないものを削除
3. 既にreadLastDonePreBootReceiversで、既に起動済みのものを削除？
4. 残ったリストにintent処理の終了用コードを設定して
5. FLAG_RECEIVER_BOOT_UPGRADEフラグを追加したIntentを送信

といった処理のようですね。
割と込み入っているところを、かなり適当にこんな時間に追いかけているので、何か見落としもありそうですが、とりあえず、この辺りが起動処理に絡んでいそうだという雰囲気です。

追記：
とまぁ、ここまでコードを追いかけてみたもののここが当たりかはちょっと不安を抱いてます。
そもそもActivityManagerServiceとPackageManagerServiceだと、PackageManagerServiceの方が後に生成されたりとかしていますし。
ちょっとログを仕込んでビルドして、実際に動かしてみないと駄目だなぁ・・・。

緑之庵(緑之杜)

2011年2月2日水曜日

Zygoteへの起動要求を出している箇所を探す（その2）

0 件のコメント:

コメントを投稿