tursom/TursomServer
0
0
Fork 0
mirror of https://github.com/tursom/TursomServer.git synced 2025-03-14 03:40:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

update buffers

Browse Source
This commit is contained in:
tursom 2021-07-14 10:32:57 +08:00
parent bf98749f44
commit 9ce5ab7779
3 changed files with 38 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ts-core/src/main/kotlin/cn/tursom/core/DataOperate.kt
View File

@ -7,6 +7,13 @@ import java.nio.ByteOrder
class WrongPushTypeException : Exception()
fun Char.reverseBytes() = Character.reverseBytes(this)
fun Short.reverseBytes() = java.lang.Short.reverseBytes(this)
fun Int.reverseBytes() = Integer.reverseBytes(this)
fun Long.reverseBytes() = java.lang.Long.reverseBytes(this)
fun Float.reverseBytes() = Float.fromBits(toBits().reverseBytes())
fun Double.reverseBytes() = Double.fromBits(toBits().reverseBytes())
fun Char.toByteArray(byteOrder: ByteOrder = ByteOrder.BIG_ENDIAN): ByteArray {
val array = ByteArray(2)
array.put(this, 0, byteOrder)

55
ts-core/ts-buffer/src/main/kotlin/cn/tursom/core/buffer/ByteBuffer.kt
View File

@ -3,6 +3,7 @@ package cn.tursom.core.buffer
import cn.tursom.core.AsyncFile
import cn.tursom.core.Utils.bufferThreadLocal
import cn.tursom.core.forEachIndex
import cn.tursom.core.reverseBytes
import java.io.Closeable
import java.io.IOException
import java.io.InputStream
@ -94,41 +95,53 @@ interface ByteBuffer : Closeable {
}
fun get(): Byte = read { it.get() }
//fun getChar(): Char = read { it.char }
//fun getShort(): Short = read { it.short }
//fun getInt(): Int = read { it.int }
//fun getLong(): Long = read { it.long }
//fun getFloat(): Float = read { it.float }
//fun getDouble(): Double = read { it.double }
fun getChar(byteOrder: ByteOrder = ByteOrder.BIG_ENDIAN): Char = read { buf ->
buf.order(byteOrder)
buf.char
when (byteOrder) {
ByteOrder.BIG_ENDIAN -> buf.char
ByteOrder.LITTLE_ENDIAN -> buf.char.reverseBytes()
else -> throw IllegalArgumentException()
}
}
fun getShort(byteOrder: ByteOrder = ByteOrder.BIG_ENDIAN): Short = read { buf ->
buf.order(byteOrder)
buf.short
when (byteOrder) {
ByteOrder.BIG_ENDIAN -> buf.short
ByteOrder.LITTLE_ENDIAN -> buf.short.reverseBytes()
else -> throw IllegalArgumentException()
}
}
fun getInt(byteOrder: ByteOrder = ByteOrder.BIG_ENDIAN): Int = read { buf ->
buf.order(byteOrder)
buf.int
when (byteOrder) {
ByteOrder.BIG_ENDIAN -> buf.int
ByteOrder.LITTLE_ENDIAN -> buf.int.reverseBytes()
else -> throw IllegalArgumentException()
}
}
fun getLong(byteOrder: ByteOrder = ByteOrder.BIG_ENDIAN): Long = read { buf ->
buf.order(byteOrder)
buf.long
when (byteOrder) {
ByteOrder.BIG_ENDIAN -> buf.long
ByteOrder.LITTLE_ENDIAN -> buf.long.reverseBytes()
else -> throw IllegalArgumentException()
}
}
fun getFloat(byteOrder: ByteOrder = ByteOrder.BIG_ENDIAN): Float = read { buf ->
buf.order(byteOrder)
buf.float
when (byteOrder) {
ByteOrder.BIG_ENDIAN -> buf.float
ByteOrder.LITTLE_ENDIAN -> buf.float.reverseBytes()
else -> throw IllegalArgumentException()
}
}
fun getDouble(byteOrder: ByteOrder = ByteOrder.BIG_ENDIAN): Double = read { buf ->
buf.order(byteOrder)
buf.double
when (byteOrder) {
ByteOrder.BIG_ENDIAN -> buf.double
ByteOrder.LITTLE_ENDIAN -> buf.double.reverseBytes()
else -> throw IllegalArgumentException()
}
}
fun getBytes(size: Int = readable): ByteArray = read {
@ -204,12 +217,6 @@ interface ByteBuffer : Closeable {
*/
fun put(byte: Byte): Unit = write { it.put(byte) }
//fun put(char: Char): Unit = write { it.putChar(char) }
//fun put(short: Short): Unit = write { it.putShort(short) }
//fun put(int: Int): Unit = write { it.putInt(int) }
//fun put(long: Long): Unit = write { it.putLong(long) }
//fun put(float: Float): Unit = write { it.putFloat(float) }
//fun put(double: Double): Unit = write { it.putDouble(double) }
fun put(char: Char, byteOrder: ByteOrder = ByteOrder.BIG_ENDIAN): Unit = write { buf ->
buf.order(byteOrder)

6
ts-core/ts-buffer/src/main/kotlin/cn/tursom/core/buffer/impl/NettyByteBuffer.kt
View File

@ -128,12 +128,6 @@ class NettyByteBuffer(
}
override fun get(): Byte = byteBuf.readByte()
//override fun getChar(): Char = byteBuf.readChar()
//override fun getShort(): Short = byteBuf.readShort()
//override fun getInt(): Int = byteBuf.readInt()
//override fun getLong(): Long = byteBuf.readLong()
//override fun getFloat(): Float = byteBuf.readFloat()
//override fun getDouble(): Double = byteBuf.readDouble()
override fun getChar(byteOrder: ByteOrder): Char = when (byteOrder) {
ByteOrder.BIG_ENDIAN -> byteBuf.readChar()