Remove native scan
Summary: This is obsolete and maintaining it as the protocol changes no longer makes sense Reviewed By: lblasa Differential Revision: D41845247 fbshipit-source-id: c4ead597ca66223ccfa091ac79a6a80784a3c8e4
This commit is contained in:
Luke De Feo
committed by
Facebook GitHub Bot
Facebook GitHub Bot
parent
fc43580134
commit
97cca42822
@@ -1,106 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright (c) Meta Platforms, Inc. and affiliates.
|
|
||||||
*
|
|
||||||
* This source code is licensed under the MIT license found in the
|
|
||||||
* LICENSE file in the root directory of this source tree.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package com.facebook.flipper.plugins.uidebugger.core
|
|
||||||
|
|
||||||
import android.os.Looper
|
|
||||||
import android.util.Log
|
|
||||||
import com.facebook.flipper.plugins.uidebugger.LogTag
|
|
||||||
import com.facebook.flipper.plugins.uidebugger.descriptors.ApplicationRefDescriptor
|
|
||||||
import com.facebook.flipper.plugins.uidebugger.descriptors.MetadataRegister
|
|
||||||
import com.facebook.flipper.plugins.uidebugger.model.MetadataUpdateEvent
|
|
||||||
import com.facebook.flipper.plugins.uidebugger.model.Node
|
|
||||||
import com.facebook.flipper.plugins.uidebugger.model.PerfStatsEvent
|
|
||||||
import com.facebook.flipper.plugins.uidebugger.model.SubtreeUpdateEvent
|
|
||||||
import com.facebook.flipper.plugins.uidebugger.observers.TreeObserverFactory
|
|
||||||
import com.facebook.flipper.plugins.uidebugger.scheduler.Scheduler
|
|
||||||
import com.facebook.flipper.plugins.uidebugger.traversal.PartialLayoutTraversal
|
|
||||||
import com.facebook.flipper.plugins.uidebugger.util.MaybeDeferred
|
|
||||||
import kotlinx.serialization.json.Json
|
|
||||||
|
|
||||||
data class ScanResult(
|
|
||||||
val txId: Long,
|
|
||||||
val scanStart: Long,
|
|
||||||
val scanEnd: Long,
|
|
||||||
val nodes: List<MaybeDeferred<Node>>
|
|
||||||
)
|
|
||||||
|
|
||||||
const val observerType = "FullScan"
|
|
||||||
|
|
||||||
/** This is used to stress test the ui debugger, should not be used in production */
|
|
||||||
class NativeScanScheduler(val context: Context) : Scheduler.Task<ScanResult> {
|
|
||||||
/**
|
|
||||||
* when you supply no observers the traversal will never halt and will effectively scan the entire
|
|
||||||
* hierarchy
|
|
||||||
*/
|
|
||||||
private val emptyObserverFactory = TreeObserverFactory()
|
|
||||||
private val traversal = PartialLayoutTraversal(context.descriptorRegister, emptyObserverFactory)
|
|
||||||
private var txId = 100000L
|
|
||||||
|
|
||||||
override fun execute(): ScanResult {
|
|
||||||
val start = System.currentTimeMillis()
|
|
||||||
val (nodes) = traversal.traverse(context.applicationRef)
|
|
||||||
val scanEnd = System.currentTimeMillis()
|
|
||||||
|
|
||||||
Log.d(
|
|
||||||
LogTag,
|
|
||||||
"${Thread.currentThread().name}${Looper.myLooper()} produced: ${nodes.count()} nodes")
|
|
||||||
|
|
||||||
return ScanResult(txId++, start, scanEnd, nodes)
|
|
||||||
}
|
|
||||||
|
|
||||||
private fun sendMetadata() {
|
|
||||||
val metadata = MetadataRegister.getPendingMetadata()
|
|
||||||
if (metadata.size > 0) {
|
|
||||||
context.connectionRef.connection?.send(
|
|
||||||
MetadataUpdateEvent.name,
|
|
||||||
Json.encodeToString(MetadataUpdateEvent.serializer(), MetadataUpdateEvent(metadata)))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private fun sendSubtreeUpdate(input: ScanResult) {
|
|
||||||
val nodes = input.nodes.map { it.value() }
|
|
||||||
val deferredComputationComplete = System.currentTimeMillis()
|
|
||||||
|
|
||||||
val serialized =
|
|
||||||
Json.encodeToString(
|
|
||||||
SubtreeUpdateEvent.serializer(),
|
|
||||||
SubtreeUpdateEvent(
|
|
||||||
input.txId,
|
|
||||||
observerType,
|
|
||||||
ApplicationRefDescriptor.getId(context.applicationRef),
|
|
||||||
nodes))
|
|
||||||
val serializationEnd = System.currentTimeMillis()
|
|
||||||
|
|
||||||
context.connectionRef.connection?.send(
|
|
||||||
SubtreeUpdateEvent.name,
|
|
||||||
serialized,
|
|
||||||
)
|
|
||||||
val socketEnd = System.currentTimeMillis()
|
|
||||||
|
|
||||||
context.connectionRef.connection?.send(
|
|
||||||
PerfStatsEvent.name,
|
|
||||||
Json.encodeToString(
|
|
||||||
PerfStatsEvent.serializer(),
|
|
||||||
PerfStatsEvent(
|
|
||||||
input.txId,
|
|
||||||
observerType,
|
|
||||||
input.scanStart,
|
|
||||||
input.scanStart,
|
|
||||||
input.scanEnd,
|
|
||||||
input.scanEnd,
|
|
||||||
deferredComputationComplete,
|
|
||||||
serializationEnd,
|
|
||||||
socketEnd,
|
|
||||||
input.nodes.size)))
|
|
||||||
}
|
|
||||||
|
|
||||||
override fun process(input: ScanResult) {
|
|
||||||
sendMetadata()
|
|
||||||
sendSubtreeUpdate(input)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,110 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright (c) Meta Platforms, Inc. and affiliates.
|
|
||||||
*
|
|
||||||
* This source code is licensed under the MIT license found in the
|
|
||||||
* LICENSE file in the root directory of this source tree.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package com.facebook.flipper.plugins.uidebugger.scheduler
|
|
||||||
|
|
||||||
import android.os.Handler
|
|
||||||
import android.os.HandlerThread
|
|
||||||
import android.os.Looper
|
|
||||||
import java.util.concurrent.locks.ReentrantLock
|
|
||||||
import kotlin.concurrent.withLock
|
|
||||||
|
|
||||||
class Scheduler<T>(val task: Task<T>, val rate: Long = 500L) {
|
|
||||||
interface Task<T> {
|
|
||||||
fun execute(): T?
|
|
||||||
fun process(input: T)
|
|
||||||
}
|
|
||||||
|
|
||||||
private val mainLooper: Handler = Handler(Looper.getMainLooper())
|
|
||||||
|
|
||||||
private val mainRunnable = MainThreadRunnable()
|
|
||||||
private val backgroundRunnable = BackgroundThreadRunnable()
|
|
||||||
|
|
||||||
private var backgroundHandler: HandlerThread? = null
|
|
||||||
private var backgroundLooper: Handler? = null
|
|
||||||
|
|
||||||
private var isRunning = false
|
|
||||||
|
|
||||||
private val lock = ReentrantLock()
|
|
||||||
private val condition = lock.newCondition()
|
|
||||||
private val queue = mutableListOf<T>()
|
|
||||||
|
|
||||||
fun start() {
|
|
||||||
backgroundHandler = HandlerThread("INSPECTOR_WORKER")
|
|
||||||
backgroundHandler?.let { handlerThread ->
|
|
||||||
handlerThread.start()
|
|
||||||
backgroundLooper = Handler(handlerThread.looper)
|
|
||||||
}
|
|
||||||
|
|
||||||
isRunning = true
|
|
||||||
mainLooper.postDelayed(mainRunnable, rate)
|
|
||||||
}
|
|
||||||
|
|
||||||
fun stop() {
|
|
||||||
backgroundLooper?.post(CancellationRunnable())
|
|
||||||
}
|
|
||||||
|
|
||||||
fun execute() {
|
|
||||||
if (Looper.myLooper() == Looper.getMainLooper()) {
|
|
||||||
mainRunnable.run()
|
|
||||||
} else {
|
|
||||||
mainLooper.post(mainRunnable)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
inner class MainThreadRunnable : Runnable {
|
|
||||||
override fun run() {
|
|
||||||
if (!isRunning) {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
try {
|
|
||||||
val output = task.execute()
|
|
||||||
output?.let { output ->
|
|
||||||
lock.withLock {
|
|
||||||
queue.add(output)
|
|
||||||
condition.signal()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} catch (e: Exception) {}
|
|
||||||
|
|
||||||
mainLooper.postDelayed(mainRunnable, rate)
|
|
||||||
backgroundLooper?.post(backgroundRunnable)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
inner class BackgroundThreadRunnable : Runnable {
|
|
||||||
override fun run() {
|
|
||||||
if (!isRunning) {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
try {
|
|
||||||
var input: T?
|
|
||||||
lock.withLock {
|
|
||||||
while (queue.isEmpty()) {
|
|
||||||
condition.await()
|
|
||||||
}
|
|
||||||
input = queue.removeFirst()
|
|
||||||
}
|
|
||||||
input?.let { input -> task.process(input) }
|
|
||||||
} catch (e: Exception) {}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
inner class CancellationRunnable : Runnable {
|
|
||||||
override fun run() {
|
|
||||||
backgroundHandler?.interrupt()
|
|
||||||
|
|
||||||
mainLooper.removeCallbacks(mainRunnable)
|
|
||||||
backgroundLooper?.removeCallbacks(backgroundRunnable)
|
|
||||||
|
|
||||||
backgroundHandler = null
|
|
||||||
|
|
||||||
isRunning = false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user