joy/android_packages_modules_Connectivity
Watch
1
Fork
You've already forked android_packages_modules_Connectivity
 0
Code Issues Pull requests Projects Releases Wiki Activity

Format MdnsServiceCacheTest

Browse source 
Use the ktlint.py script to correct Kotlin code formatting errors.

Test: m
Change-Id: I587c757f3c96be7a5f6c60ec16eaf662bf148df3
This commit is contained in:
Paul Hu 2025-03-05 06:52:02 +00:00
commit 47959aefd3
1 changed files with 42 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

58
tests/unit/java/com/android/server/connectivity/mdns/MdnsServiceCacheTest.kt
View file

@ -208,7 +208,10 @@ class MdnsServiceCacheTest {
@Test
fun testServiceExpiredAndSendCallbacks() {
val serviceCache = MdnsServiceCache(
thread.looper, makeFlags(isExpiredServicesRemovalEnabled = true), clock)
thread.looper,
makeFlags(isExpiredServicesRemovalEnabled = true),
clock
)
// Register service expired callbacks
val callback1 = ExpiredRecord()
val callback2 = ExpiredRecord()
@ -218,12 +221,21 @@ class MdnsServiceCacheTest {
doReturn(TEST_ELAPSED_REALTIME_MS).`when`(clock).elapsedRealtime()
// Add multiple services with different ttl time.
addOrUpdateService(serviceCache, cacheKey1, createResponse(SERVICE_NAME_1, SERVICE_TYPE_1,
DEFAULT_TTL_TIME_MS))
addOrUpdateService(serviceCache, cacheKey1, createResponse(SERVICE_NAME_2, SERVICE_TYPE_1,
DEFAULT_TTL_TIME_MS + 20L))
addOrUpdateService(serviceCache, cacheKey2, createResponse(SERVICE_NAME_3, SERVICE_TYPE_2,
DEFAULT_TTL_TIME_MS + 10L))
addOrUpdateService(serviceCache, cacheKey1, createResponse(
SERVICE_NAME_1,
SERVICE_TYPE_1,
DEFAULT_TTL_TIME_MS
))
addOrUpdateService(serviceCache, cacheKey1, createResponse(
SERVICE_NAME_2,
SERVICE_TYPE_1,
DEFAULT_TTL_TIME_MS + 20L
))
addOrUpdateService(serviceCache, cacheKey2, createResponse(
SERVICE_NAME_3,
SERVICE_TYPE_2,
DEFAULT_TTL_TIME_MS + 10L
))
// Check the service expiration immediately. Should be no callback.
assertEquals(2, getServices(serviceCache, cacheKey1).size)
@ -252,16 +264,25 @@ class MdnsServiceCacheTest {
@Test
fun testRemoveExpiredServiceWhenGetting() {
val serviceCache = MdnsServiceCache(
thread.looper, makeFlags(isExpiredServicesRemovalEnabled = true), clock)
thread.looper,
makeFlags(isExpiredServicesRemovalEnabled = true),
clock
)
doReturn(TEST_ELAPSED_REALTIME_MS).`when`(clock).elapsedRealtime()
addOrUpdateService(serviceCache, cacheKey1,
createResponse(SERVICE_NAME_1, SERVICE_TYPE_1, 1L /* ttlTime */))
addOrUpdateService(
serviceCache,
cacheKey1,
createResponse(SERVICE_NAME_1, SERVICE_TYPE_1, 1L /* ttlTime */)
)
doReturn(TEST_ELAPSED_REALTIME_MS + 2L).`when`(clock).elapsedRealtime()
assertNull(getService(serviceCache, SERVICE_NAME_1, cacheKey1))
addOrUpdateService(serviceCache, cacheKey2,
createResponse(SERVICE_NAME_2, SERVICE_TYPE_2, 3L /* ttlTime */))
addOrUpdateService(
serviceCache,
cacheKey2,
createResponse(SERVICE_NAME_2, SERVICE_TYPE_2, 3L /* ttlTime */)
)
doReturn(TEST_ELAPSED_REALTIME_MS + 4L).`when`(clock).elapsedRealtime()
assertEquals(0, getServices(serviceCache, cacheKey2).size)
}
@ -334,8 +355,11 @@ class MdnsServiceCacheTest {
): MdnsResponse {
val serviceName = "$serviceInstanceName.$serviceType".split(".").toTypedArray()
val response = MdnsResponse(
0 /* now */, "$serviceInstanceName.$serviceType".split(".").toTypedArray(),
socketKey.interfaceIndex, socketKey.network)
0 /* now */,
"$serviceInstanceName.$serviceType".split(".").toTypedArray(),
socketKey.interfaceIndex,
socketKey.network
)
// Set PTR record
val pointerRecord = MdnsPointerRecord(
@ -343,7 +367,8 @@ class MdnsServiceCacheTest {
TEST_ELAPSED_REALTIME_MS /* receiptTimeMillis */,
false /* cacheFlush */,
ttlTime /* ttlMillis */,
serviceName)
serviceName
)
response.addPointerRecord(pointerRecord)
// Set SRV record.
@ -355,7 +380,8 @@ class MdnsServiceCacheTest {
0 /* servicePriority */,
0 /* serviceWeight */,
12345 /* port */,
arrayOf("hostname"))
arrayOf("hostname")
)
response.serviceRecord = serviceRecord
return response
}