github-repos/mirai
1
0
Fork 0
mirror of https://github.com/mamoe/mirai.git synced 2025-03-25 06:50:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

rename UninitializedByteReadPacket as Uninitialized

Browse Source
This commit is contained in:
Him188 2019-10-28 21:40:11 +08:00
parent d8e1c87515
commit 8308e68467
1 changed files with 9 additions and 4 deletions

13
mirai-core/src/commonMain/kotlin/net.mamoe.mirai/network/protocol/tim/packet/OutgoingPacket.kt
View File

@ -26,15 +26,16 @@ abstract class OutgoingPacket : Packet(), Closeable {
companion object {
@JvmStatic
private val sequenceIdInternal = atomic(1)
internal fun atomicNextSequenceId() = sequenceIdInternal.getAndIncrement().toUShort()
}
/**
* 务必 [ByteReadPacket.close] 或 [close] 或使用 [Closeable.use]
*/
var packet: ByteReadPacket = UninitializedByteReadPacket
var packet: ByteReadPacket = Uninitialized
get() {
if (field === UninitializedByteReadPacket) build()
if (field === Uninitialized) build()
return field
}
private set
@ -52,7 +53,11 @@ abstract class OutgoingPacket : Packet(), Closeable {
override fun toString(): String = packetToString()
override fun close() = if (this.packet === UninitializedByteReadPacket) Unit else this.packet.close()
override fun close() {
if (this.packet !== Uninitialized) {
this.packet.close()
}
}
private fun BytePacketBuilder.writePacketId() {
writeUShort(this@OutgoingPacket.id)
@ -66,4 +71,4 @@ abstract class OutgoingPacket : Packet(), Closeable {
@Retention(AnnotationRetention.SOURCE)
annotation class PacketVersion(val date: String, val timVersion: String)
private val UninitializedByteReadPacket = ByteReadPacket(IoBuffer.Empty, IoBuffer.EmptyPool)
private val Uninitialized = ByteReadPacket(IoBuffer.Empty, IoBuffer.EmptyPool)