The namer inflates the XOVER reply and reads the corpus from the prober's container
xoverRaw gives one zlib/gzip stream, as the corpus stores it; the namer fed the bytes as text and found nothing. The prober had no corpus mount, so every move went to the server. Co-Authored-By: Claude Fable 5.1 <noreply@anthropic.com>
This commit is contained in:
1 parent
f1381a9b43
commit
3c4fe324a1
2 files changed
+6
-2
No files matched your search
@@ -215,7 +215,9 @@ export class PendingNamer {
|
|||||||
this.usedAt = Date.now()
|
this.usedAt = Date.now()
|
||||||
try {
|
try {
|
||||||
await this.client.group(groupName)
|
await this.client.group(groupName)
|
||||||
return (await this.client.xoverRaw(row.first_article, row.last_article)).toString('latin1')
|
// One zlib/gzip stream, as the server sent it or deflated by the client (the corpus stores it so).
|
||||||
|
const raw = await this.client.xoverRaw(row.first_article, row.last_article)
|
||||||
|
return (await inflate(raw)).toString('latin1')
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
this.client.close()
|
this.client.close()
|
||||||
this.client = null
|
this.client = null
|
||||||
|
|||||||
+3
-1
@@ -126,7 +126,9 @@ services:
|
|||||||
prober:
|
prober:
|
||||||
<<: *app
|
<<: *app
|
||||||
command: ['node', 'ace', 'probe:run']
|
command: ['node', 'ace', 'probe:run']
|
||||||
volumes: []
|
# The pending namer reads a named release's articles again from the corpus (no spool).
|
||||||
|
volumes:
|
||||||
|
- ./corpus:/corpus:ro
|
||||||
environment:
|
environment:
|
||||||
<<: *app-env
|
<<: *app-env
|
||||||
PROBE_CONNECTIONS: ${PROBE_CONNECTIONS:-8}
|
PROBE_CONNECTIONS: ${PROBE_CONNECTIONS:-8}
|
||||||
|
|||||||
Reference in new issue
Block a user