back out 9a7369b9bc9d (bug 814579) for B2G Arm opt Mn & X orange

dom/system/gonk/RadioInterfaceLayer.js

@@ -331,7 +331,7 @@ function RadioInterfaceLayer() {
   this.worker.postMessage({rilMessageType: "setDebugEnabled",
                            enabled: debugPref});
 
-  gSystemWorkerManager.registerRilWorker(0, this.worker);
+  gSystemWorkerManager.registerRilWorker(this.worker);
 }
 RadioInterfaceLayer.prototype = {
 

dom/system/gonk/SystemWorkerManager.cpp

@@ -60,35 +60,26 @@ SystemWorkerManager *gInstance = nullptr;
 
 class ConnectWorkerToRIL : public WorkerTask
 {
-  const unsigned long mClientId;
-
 public:
-  ConnectWorkerToRIL(unsigned long aClientId)
-    : mClientId(aClientId)
-  { }
-
   virtual bool RunTask(JSContext *aCx);
 };
 
 class SendRilSocketDataTask : public nsRunnable
 {
 public:
-  SendRilSocketDataTask(unsigned long aClientId,
+  SendRilSocketDataTask(UnixSocketRawData *aRawData)
-                        UnixSocketRawData *aRawData)
     : mRawData(aRawData)
-    , mClientId(aClientId)
   { }
 
   NS_IMETHOD Run()
   {
     MOZ_ASSERT(NS_IsMainThread());
-    SystemWorkerManager::SendRilRawData(mClientId, mRawData);
+    SystemWorkerManager::SendRilRawData(mRawData);
     return NS_OK;
   }
 
 private:
   UnixSocketRawData *mRawData;
-  unsigned long mClientId;
 };
 
 JSBool
@@ -96,15 +87,12 @@ PostToRIL(JSContext *cx, unsigned argc, jsval *vp)
 {
   NS_ASSERTION(!NS_IsMainThread(), "Expecting to be on the worker thread");
 
-  if (argc != 2) {
+  if (argc != 1) {
-    JS_ReportError(cx, "Expecting two arguments with the RIL message");
+    JS_ReportError(cx, "Expecting a single argument with the RIL message");
     return false;
   }
 
-  jsval cv = JS_ARGV(cx, vp)[0];
+  jsval v = JS_ARGV(cx, vp)[0];
-  int clientId = cv.toInt32();
-
-  jsval v = JS_ARGV(cx, vp)[1];
 
   JSAutoByteString abs;
   void *data;
@@ -143,7 +131,7 @@ PostToRIL(JSContext *cx, unsigned argc, jsval *vp)
   UnixSocketRawData* raw = new UnixSocketRawData(size);
   memcpy(raw->mData, data, raw->mSize);
 
-  nsRefPtr<SendRilSocketDataTask> task = new SendRilSocketDataTask(clientId, raw);
+  nsRefPtr<SendRilSocketDataTask> task = new SendRilSocketDataTask(raw);
   NS_DispatchToMainThread(task);
   return true;
 }
@@ -157,11 +145,6 @@ ConnectWorkerToRIL::RunTask(JSContext *aCx)
   NS_ASSERTION(!JS_IsRunning(aCx), "Are we being called somehow?");
   JSObject *workerGlobal = JS_GetGlobalObject(aCx);
 
-  if (!JS_DefineProperty(aCx, workerGlobal, "CLIENT_ID",
-                         INT_TO_JSVAL(mClientId), nullptr, nullptr, 0)) {
-    return false;
-  }
-
   return !!JS_DefineFunction(aCx, workerGlobal, "postRILMessage", PostToRIL, 1,
                              0);
 }
@@ -390,11 +373,9 @@ SystemWorkerManager::Shutdown()
   ShutdownAutoMounter();
 #endif
 
-  for (unsigned long i = 0; i < mRilConsumers.Length(); i++) {
+  if (mRilConsumer) {
-    if (mRilConsumers[i]) {
+    mRilConsumer->Shutdown();
-      mRilConsumers[i]->Shutdown();
+    mRilConsumer = nullptr;
-      mRilConsumers[i] = nullptr;
-    }
   }
 
 #ifdef MOZ_WIDGET_GONK
@@ -445,16 +426,14 @@ SystemWorkerManager::GetInterfaceRequestor()
 }
 
 bool
-SystemWorkerManager::SendRilRawData(unsigned long aClientId,
+SystemWorkerManager::SendRilRawData(UnixSocketRawData* aRaw)
-                                    UnixSocketRawData* aRaw)
 {
-  if ((gInstance->mRilConsumers.Length() <= aClientId) ||
+  if (!gInstance->mRilConsumer) {
-      !gInstance->mRilConsumers[aClientId]) {
     // Probably shuting down.
     delete aRaw;
     return true;
   }
-  return gInstance->mRilConsumers[aClientId]->SendSocketData(aRaw);
+  return gInstance->mRilConsumer->SendSocketData(aRaw);
 }
 
 NS_IMETHODIMP
@@ -479,40 +458,27 @@ SystemWorkerManager::GetInterface(const nsIID &aIID, void **aResult)
 }
 
 nsresult
-SystemWorkerManager::RegisterRilWorker(unsigned int aClientId,
+SystemWorkerManager::RegisterRilWorker(const JS::Value& aWorker,
-                                       const JS::Value& aWorker,
                                        JSContext *aCx)
 {
   NS_ENSURE_TRUE(!JSVAL_IS_PRIMITIVE(aWorker), NS_ERROR_UNEXPECTED);
 
-  if (!mRilConsumers.EnsureLengthAtLeast(aClientId + 1)) {
-    NS_WARNING("Failed to ensure minimum length of mRilConsumers");
-    return NS_ERROR_FAILURE;
-  }
-
-  if (mRilConsumers[aClientId]) {
-    NS_WARNING("RilConsumer already registered");
-    return NS_ERROR_FAILURE;
-  }
-
   JSAutoRequest ar(aCx);
   JSAutoCompartment ac(aCx, JSVAL_TO_OBJECT(aWorker));
 
   WorkerCrossThreadDispatcher *wctd =
     GetWorkerCrossThreadDispatcher(aCx, aWorker);
   if (!wctd) {
-    NS_WARNING("Failed to GetWorkerCrossThreadDispatcher for ril");
     return NS_ERROR_FAILURE;
   }
 
-  nsRefPtr<ConnectWorkerToRIL> connection = new ConnectWorkerToRIL(aClientId);
+  nsRefPtr<ConnectWorkerToRIL> connection = new ConnectWorkerToRIL();
   if (!wctd->PostTask(connection)) {
-    NS_WARNING("Failed to connect worker to ril");
     return NS_ERROR_UNEXPECTED;
   }
 
   // Now that we're set up, connect ourselves to the RIL thread.
-  mRilConsumers[aClientId] = new RilConsumer(aClientId, wctd);
+  mRilConsumer = new RilConsumer(wctd);
   return NS_OK;
 }
 
@@ -534,7 +500,7 @@ SystemWorkerManager::InitNetd(JSContext *cx)
   WorkerCrossThreadDispatcher *wctd =
     GetWorkerCrossThreadDispatcher(cx, workerval);
   if (!wctd) {
-    NS_WARNING("Failed to GetWorkerCrossThreadDispatcher for netd");
+    NS_WARNING("Failed to GetWorkerCrossThreadDispatcher");
     return NS_ERROR_FAILURE;
   }
 

dom/system/gonk/SystemWorkerManager.h

@@ -59,8 +59,7 @@ public:
   static nsIInterfaceRequestor*
   GetInterfaceRequestor();
 
-  static bool SendRilRawData(unsigned long aClientId,
+  static bool SendRilRawData(ipc::UnixSocketRawData* aRaw);
-                             ipc::UnixSocketRawData* aRaw);
 
 private:
   SystemWorkerManager();
@@ -76,7 +75,7 @@ private:
 #endif
   nsCOMPtr<nsIWorkerHolder> mWifiWorker;
 
-  nsTArray<nsRefPtr<ipc::RilConsumer> > mRilConsumers;
+  nsRefPtr<ipc::RilConsumer> mRilConsumer;
 
   bool mShutdown;
 };

dom/system/gonk/nsISystemWorkerManager.idl

@@ -11,6 +11,5 @@
 interface nsISystemWorkerManager : nsISupports
 {
   [implicit_jscontext]
-  void registerRilWorker(in unsigned long aClientId,
+  void registerRilWorker(in jsval aWorker);
-                         in jsval aWorker);
 };

dom/system/gonk/ril_worker.js

@@ -693,7 +693,7 @@ let Buf = {
     // right away!
     let parcel = this.outgoingBytes.subarray(0, this.outgoingIndex);
     if (DEBUG) debug("Outgoing parcel: " + Array.slice(parcel));
-    postRILMessage(CLIENT_ID, parcel);
+    postRILMessage(parcel);
     this.outgoingIndex = PARCEL_SIZE_SIZE;
   },
 
@@ -9950,7 +9950,7 @@ let ICCContactHelper = {
 if (!this.debug) {
   // Debugging stub that goes nowhere.
   this.debug = function debug(message) {
-    dump("RIL Worker[" + CLIENT_ID + "]: " + message + "\n");
+    dump("RIL Worker: " + message + "\n");
   };
 }
 

ipc/ril/Ril.cpp

@@ -63,9 +63,6 @@ DispatchRILEvent::RunTask(JSContext *aCx)
 class RilConnector : public mozilla::ipc::UnixSocketConnector
 {
 public:
-  RilConnector(unsigned long aClientId) : mClientId(aClientId)
-  {}
-
   virtual ~RilConnector()
   {}
 
@@ -77,9 +74,6 @@ public:
   virtual bool SetUp(int aFd);
   virtual void GetSocketAddr(const sockaddr& aAddr,
                              nsAString& aAddrStr);
-
-private:
-  unsigned long mClientId;
 };
 
 int
@@ -140,7 +134,7 @@ RilConnector::CreateAddr(bool aIsServer,
 
     memset(&addr_in, 0, sizeof(addr_in));
     addr_in.sin_family = hp->h_addrtype;
-    addr_in.sin_port = htons(RIL_TEST_PORT + mClientId);
+    addr_in.sin_port = htons(RIL_TEST_PORT);
     memcpy(&addr_in.sin_addr, hp->h_addr, hp->h_length);
 
     aAddrSize = sizeof(addr_in);
@@ -168,24 +162,11 @@ RilConnector::GetSocketAddr(const sockaddr& aAddr,
 namespace mozilla {
 namespace ipc {
 
-RilConsumer::RilConsumer(unsigned long aClientId,
+RilConsumer::RilConsumer(WorkerCrossThreadDispatcher* aDispatcher)
-                         WorkerCrossThreadDispatcher* aDispatcher)
     : mDispatcher(aDispatcher)
-    , mClientId(aClientId)
     , mShutdown(false)
 {
-    // Only append client id after RIL_SOCKET_NAME when it's not connected to
+    ConnectSocket(new RilConnector(), RIL_SOCKET_NAME);
-    // the first(0) rilproxy for compatibility.
-    if (!aClientId) {
-        mAddress = RIL_SOCKET_NAME;
-    } else {
-        struct sockaddr_un addr_un;
-        snprintf(addr_un.sun_path, sizeof addr_un.sun_path, "%s%lu",
-                 RIL_SOCKET_NAME, aClientId);
-        mAddress = addr_un.sun_path;
-    }
-
-    ConnectSocket(new RilConnector(mClientId), mAddress.get());
 }
 
 void
@@ -223,7 +204,7 @@ RilConsumer::OnDisconnect()
 {
     LOG("%s\n", __FUNCTION__);
     if (!mShutdown) {
-        ConnectSocket(new RilConnector(mClientId), mAddress.get(), 1000);
+        ConnectSocket(new RilConnector(), RIL_SOCKET_NAME, 1000);
     }
 }
 

ipc/ril/Ril.h

@@ -16,8 +16,7 @@ namespace ipc {
 class RilConsumer : public mozilla::ipc::UnixSocketConsumer
 {
 public:
-  RilConsumer(unsigned long aClientId,
+  RilConsumer(mozilla::dom::workers::WorkerCrossThreadDispatcher* aDispatcher);
-              mozilla::dom::workers::WorkerCrossThreadDispatcher* aDispatcher);
   virtual ~RilConsumer() { }
 
   void Shutdown();
@@ -31,8 +30,6 @@ private:
 
 private:
   nsRefPtr<mozilla::dom::workers::WorkerCrossThreadDispatcher> mDispatcher;
-  unsigned long mClientId;
-  nsCString mAddress;
   bool mShutdown;
 };