blob: ebdd22afdb5c0e0267142159dae926f97ca1737a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
package org.pacien.tincapp.activities
import android.os.Bundle
import android.text.method.ScrollingMovementMethod
import android.view.Menu
import android.view.MenuItem
import kotlinx.android.synthetic.main.base.*
import kotlinx.android.synthetic.main.page_viewlog.*
import org.pacien.tincapp.R
import org.pacien.tincapp.commands.Executor
import org.pacien.tincapp.commands.Tinc
import org.pacien.tincapp.service.TincVpnService
import java.util.*
import kotlin.concurrent.timer
/**
* @author pacien
*/
class ViewLogActivity : BaseActivity() {
companion object {
private const val LOG_LINES = 250
private const val LOG_LEVEL = 5
private const val NEW_LINE = "\n"
private const val UPDATE_INTERVAL = 250L // ms
}
private val log = LinkedList<String>()
private var logUpdateTimer: Timer? = null
private var logger: Process? = null
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
supportActionBar!!.setDisplayHomeAsUpEnabled(true)
layoutInflater.inflate(R.layout.page_viewlog, main_content)
startLogging()
}
override fun onCreateOptionsMenu(m: Menu): Boolean {
menuInflater.inflate(R.menu.menu_viewlog, m)
return super.onCreateOptionsMenu(m)
}
override fun onSupportNavigateUp(): Boolean {
finish()
return true
}
override fun onDestroy() {
stopLogging()
super.onDestroy()
}
fun toggleLogging(menuItem: MenuItem) {
if (logger == null) {
startLogging()
text_log.movementMethod = null
text_log.setTextIsSelectable(false)
menuItem.setIcon(R.drawable.ic_pause_circle_outline_primary_24dp)
} else {
stopLogging()
text_log.movementMethod = ScrollingMovementMethod.getInstance()
text_log.setTextIsSelectable(true)
menuItem.setIcon(R.drawable.ic_pause_circle_filled_primary_24dp)
}
}
private fun startLogging(level: Int = LOG_LEVEL) {
appendLog(resources.getString(R.string.message_log_level_set, level))
Tinc.log(TincVpnService.getCurrentNetName()!!, level).let { process ->
logger = process
Executor.runAsyncTask { printLog(process) }
}
logUpdateTimer = timer(period = UPDATE_INTERVAL, action = { updateLog() })
}
private fun stopLogging() {
logger?.destroy()
logger = null
logUpdateTimer?.cancel()
logUpdateTimer?.purge()
logUpdateTimer = null
appendLog(resources.getString(R.string.message_log_paused))
updateLog()
}
private fun printLog(logger: Process) {
logger.inputStream?.use { inputStream ->
inputStream.bufferedReader().useLines { lines ->
lines.forEach { appendLog(it) }
}
}
}
private fun appendLog(line: String) = synchronized(this) {
if (log.size >= LOG_LINES) log.removeFirst()
log.addLast(line)
}
private fun updateLog() = synchronized(this) {
log.joinToString(NEW_LINE + NEW_LINE, NEW_LINE, NEW_LINE).let {
text_log.post { text_log.text = it }
}
}
}
|