mirror of
https://github.com/R0m1k3/Loki.git
synced 2026-10-21 14:08:11 +02:00
Jauge de contexte, espace disque sur partage agrégé, panneau Fichiers
Trois défauts sans rapport entre eux, tous visibles à l'écran. Jauge de contexte bloquée à « 0 / N (0 %) » : le comptage exact vient de usage.prompt_tokens (include_usage), qu'un llama-server récent a cessé de renvoyer. On note désormais si l'usage est arrivé ; sinon la fin de tour publie l'estimation qui pilote déjà la compaction — approximative, mais jamais absente. Et la souscription envoie la valeur courante juste après le rattrapage : une page rechargée affichait zéro sur une discussion pourtant pleine, faute d'événement ctx_used dans la fenêtre rejouée. Espace disque : « il ne reste que 11,9 Go » sur un partage Unraid qui en a des centaines. /mnt/user est servi par shfs, un FUSE qui agrège plusieurs disques — statfs y renvoie l'espace d'un seul, et ce chiffre REFUSAIT l'installation du modèle. Les systèmes de fichiers qui approximent (FUSE, overlay, NFS, CIFS, Ceph, Gluster) sont reconnus par leur magie : leur chiffre reste affiché, précédé d'un « ~ », mais ne bloque plus rien. Panneau Fichiers : le panneau entier défilait, emportant vers le haut l'en-tête, le fil d'Ariane et le pied (occupation disque, bouton .zip) dès qu'il y avait quelques fichiers. Seule la liste défile maintenant ; le pied reste en bas et l'état vide se centre. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
This commit is contained in:
1 parent
895ff92ed8
commit
b405adea6c
5118 files changed
+1264007
-23
No files matched your search
+144
@@ -0,0 +1,144 @@
|
||||
'use strict'
|
||||
/*
|
||||
* merge2
|
||||
* https://github.com/teambition/merge2
|
||||
*
|
||||
* Copyright (c) 2014-2020 Teambition
|
||||
* Licensed under the MIT license.
|
||||
*/
|
||||
const Stream = require('stream')
|
||||
const PassThrough = Stream.PassThrough
|
||||
const slice = Array.prototype.slice
|
||||
|
||||
module.exports = merge2
|
||||
|
||||
function merge2 () {
|
||||
const streamsQueue = []
|
||||
const args = slice.call(arguments)
|
||||
let merging = false
|
||||
let options = args[args.length - 1]
|
||||
|
||||
if (options && !Array.isArray(options) && options.pipe == null) {
|
||||
args.pop()
|
||||
} else {
|
||||
options = {}
|
||||
}
|
||||
|
||||
const doEnd = options.end !== false
|
||||
const doPipeError = options.pipeError === true
|
||||
if (options.objectMode == null) {
|
||||
options.objectMode = true
|
||||
}
|
||||
if (options.highWaterMark == null) {
|
||||
options.highWaterMark = 64 * 1024
|
||||
}
|
||||
const mergedStream = PassThrough(options)
|
||||
|
||||
function addStream () {
|
||||
for (let i = 0, len = arguments.length; i < len; i++) {
|
||||
streamsQueue.push(pauseStreams(arguments[i], options))
|
||||
}
|
||||
mergeStream()
|
||||
return this
|
||||
}
|
||||
|
||||
function mergeStream () {
|
||||
if (merging) {
|
||||
return
|
||||
}
|
||||
merging = true
|
||||
|
||||
let streams = streamsQueue.shift()
|
||||
if (!streams) {
|
||||
process.nextTick(endStream)
|
||||
return
|
||||
}
|
||||
if (!Array.isArray(streams)) {
|
||||
streams = [streams]
|
||||
}
|
||||
|
||||
let pipesCount = streams.length + 1
|
||||
|
||||
function next () {
|
||||
if (--pipesCount > 0) {
|
||||
return
|
||||
}
|
||||
merging = false
|
||||
mergeStream()
|
||||
}
|
||||
|
||||
function pipe (stream) {
|
||||
function onend () {
|
||||
stream.removeListener('merge2UnpipeEnd', onend)
|
||||
stream.removeListener('end', onend)
|
||||
if (doPipeError) {
|
||||
stream.removeListener('error', onerror)
|
||||
}
|
||||
next()
|
||||
}
|
||||
function onerror (err) {
|
||||
mergedStream.emit('error', err)
|
||||
}
|
||||
// skip ended stream
|
||||
if (stream._readableState.endEmitted) {
|
||||
return next()
|
||||
}
|
||||
|
||||
stream.on('merge2UnpipeEnd', onend)
|
||||
stream.on('end', onend)
|
||||
|
||||
if (doPipeError) {
|
||||
stream.on('error', onerror)
|
||||
}
|
||||
|
||||
stream.pipe(mergedStream, { end: false })
|
||||
// compatible for old stream
|
||||
stream.resume()
|
||||
}
|
||||
|
||||
for (let i = 0; i < streams.length; i++) {
|
||||
pipe(streams[i])
|
||||
}
|
||||
|
||||
next()
|
||||
}
|
||||
|
||||
function endStream () {
|
||||
merging = false
|
||||
// emit 'queueDrain' when all streams merged.
|
||||
mergedStream.emit('queueDrain')
|
||||
if (doEnd) {
|
||||
mergedStream.end()
|
||||
}
|
||||
}
|
||||
|
||||
mergedStream.setMaxListeners(0)
|
||||
mergedStream.add = addStream
|
||||
mergedStream.on('unpipe', function (stream) {
|
||||
stream.emit('merge2UnpipeEnd')
|
||||
})
|
||||
|
||||
if (args.length) {
|
||||
addStream.apply(null, args)
|
||||
}
|
||||
return mergedStream
|
||||
}
|
||||
|
||||
// check and pause streams for pipe.
|
||||
function pauseStreams (streams, options) {
|
||||
if (!Array.isArray(streams)) {
|
||||
// Backwards-compat with old-style streams
|
||||
if (!streams._readableState && streams.pipe) {
|
||||
streams = streams.pipe(PassThrough(options))
|
||||
}
|
||||
if (!streams._readableState || !streams.pause || !streams.pipe) {
|
||||
throw new Error('Only readable stream can be merged.')
|
||||
}
|
||||
streams.pause()
|
||||
} else {
|
||||
for (let i = 0, len = streams.length; i < len; i++) {
|
||||
streams[i] = pauseStreams(streams[i], options)
|
||||
}
|
||||
}
|
||||
return streams
|
||||
}
|
||||
Reference in new issue
Block a user