curioustorvald/tsvm
1
0
Fork 0
mirror of https://github.com/curioustorvald/tsvm.git synced 2026-03-11 05:31:51 +09:00
Code Issues Packages Projects Releases Wiki Activity

artificial delay on the http modem

Browse Source
This commit is contained in:
minjaesong
2022-11-29 21:59:05 +09:00
parent 239196d654
commit 6291d6df8b
2 changed files with 24 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
tsvm_core/src/net/torvald/tsvm/peripheral/HttpModem.kt
View File

@@ -15,9 +15,12 @@ import java.net.URL
*
* Note that there is no double-slash after the protocol (or scheme)
*
* @param artificialDelayBlockSize How many bytes should be retrieved in a single block-read
* @param artificialDelayWaitTime Delay in milliseconds between the block-reads. Put non-negative value to NOT introduce a delay.
*
* Created by minjaesong on 2022-09-22.
*/
class HttpModem(private val vm: VM) : BlockTransferInterface(false, true) {
class HttpModem(private val vm: VM, private val artificialDelayBlockSize: Int = 1024, private val artificialDelayWaitTime: Int = -1) : BlockTransferInterface(false, true) {
private val DBGPRN = true
@@ -134,17 +137,24 @@ class HttpModem(private val vm: VM) : BlockTransferInterface(false, true) {
// check the http connection before we do anything to the fs
httpIn = BufferedInputStream(URL(cnxUrl).openStream())
messageComposeBuffer.reset()
bufferedOut = BufferedOutputStream(messageComposeBuffer, 1024)
val data = ByteArray(1024)
bufferedOut = BufferedOutputStream(messageComposeBuffer, artificialDelayBlockSize)
val data = ByteArray(artificialDelayBlockSize)
var fileComplete = false
var count = 0
while (!fileComplete) {
count = httpIn.read(data, 0, 1024)
count = httpIn.read(data, 0, artificialDelayBlockSize)
if (count <= 0) {
fileComplete = true
} else {
bufferedOut.write(data, 0, count)
}
if (artificialDelayWaitTime >= 0) {
try {
Thread.sleep(artificialDelayWaitTime.toLong())
}
catch (e: InterruptedException) {}
}
}
statusCode = TestDiskDrive.STATE_CODE_STANDBY
}