DBot/overdrive_that_matters
DBot/overdrive_that_matters
3
1
Fork 0
Code Issues 63 Pull Requests Packages Releases Wiki Activity

Avoid unnecessary comparison

Browse Source
This commit is contained in:
DBotThePony 2023-03-17 23:34:35 +07:00
parent 1e68baea9d
commit 34ed1322ba
Signed by: DBot
GPG Key ID: DCC23B5715498507
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/kotlin/ru/dbotthepony/mc/otm/network/FieldSynchronizer.kt
View File

@ -643,6 +643,7 @@ class FieldSynchronizer(private val callback: Runnable, private val alwaysCallCa
override fun observe(): Boolean {
check(!isRemoved) { "Field was removed" }
if (!isDirty && !codec.compare(remote, field)) {
notifyEndpoints(this@Field)
isDirty = true
@ -669,10 +670,6 @@ class FieldSynchronizer(private val callback: Runnable, private val alwaysCallCa
return
}
if (this.field == value) {
return
}
if (!isDirty && !codec.compare(remote, value)) {
notifyEndpoints(this@Field)
isDirty = true
@ -726,6 +723,9 @@ class FieldSynchronizer(private val callback: Runnable, private val alwaysCallCa
override fun observe(): Boolean {
check(!isRemoved) { "Field was removed" }
val value = value
if (!isDirty && (remote == null || !codec.compare(remote ?: throw ConcurrentModificationException(), value))) {
notifyEndpoints(this)
isDirty = true
@ -746,7 +746,6 @@ class FieldSynchronizer(private val callback: Runnable, private val alwaysCallCa
override fun write(stream: DataOutputStream, endpoint: Endpoint) {
check(!isRemoved) { "Field was removed" }
val value = value
codec.write(stream, value)
isDirty = false
}
@ -795,6 +794,8 @@ class FieldSynchronizer(private val callback: Runnable, private val alwaysCallCa
override fun observe(): Boolean {
check(!isRemoved) { "Field was removed" }
val value = value
if (!isDirty && !codec.compare(remote, value)) {
notifyEndpoints(this)
isDirty = true
@ -812,7 +813,6 @@ class FieldSynchronizer(private val callback: Runnable, private val alwaysCallCa
override fun write(stream: DataOutputStream, endpoint: Endpoint) {
check(!isRemoved) { "Field was removed" }
val value = value
codec.write(stream, value)
isDirty = false
}
@ -835,8 +835,9 @@ class FieldSynchronizer(private val callback: Runnable, private val alwaysCallCa
private var isRemote = false
init {
if (observingBackingMap != null)
if (observingBackingMap != null) {
observers.add(this)
}
}
private fun pushBacklog(key: Any?, value: (DataOutputStream) -> Unit) {