diff options
Diffstat (limited to 'src/main/kotlin/Connection.kt')
| -rw-r--r-- | src/main/kotlin/Connection.kt | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/src/main/kotlin/Connection.kt b/src/main/kotlin/Connection.kt index 984b345..6630567 100644 --- a/src/main/kotlin/Connection.kt +++ b/src/main/kotlin/Connection.kt @@ -210,7 +210,7 @@ class Connection(transLay: TransportLayer) : ProtocolTranslator { return imsg.fieldsRaw["data"]!! } - override fun write(fid: UInt, offset: ULong, count: UInt, data: Iterable<UByte>): Pair<String?, UInt> { + override fun write(fid: UInt, offset: ULong, count: UInt, data: Iterable<UByte>): UInt { val data = data.take(count.toInt()).toTypedArray() val omsg = OutMessage(NinePMessageType.TWRITE, this.tagGen.generate(), listOf("offset", "count", "data"), mapOf( @@ -224,15 +224,11 @@ class Connection(transLay: TransportLayer) : ProtocolTranslator { this.maxSize ) omsg.write(this.tl) - val checkErr = checkedInMessage(omsg.tag) - if (checkErr.first != null) { - return Pair(checkErr.first, 0u) - } - val imsg = checkErr.second!! + val imsg = checkedInMessage(omsg.tag) imsg.applyField(InMessage.Field("count", InMessage.Field.Type.INTEGER, 4u)) val count = imsg.fieldsInt["count"]!! - return Pair(null, count.toInt().toUInt()) + return count.toInt().toUInt() } override fun clunk(path: String) { |