cmd/pkgserver: use IR cache for ident

This removes requirement to open full cache.

Signed-off-by: Ophestra <cat@gensokyo.uk>
This commit is contained in:
2026-05-02 03:32:43 +09:00
parent 52f32dc248
commit 7f89068f26
2 changed files with 8 additions and 27 deletions

View File

@@ -50,7 +50,7 @@ type metadata struct {
} }
// populate deterministically populates packageIndex, optionally with a report. // populate deterministically populates packageIndex, optionally with a report.
func (index *packageIndex) populate(cache *pkg.Cache, report *rosa.Report) (err error) { func (index *packageIndex) populate(report *rosa.Report) (err error) {
if report != nil { if report != nil {
defer report.HandleAccess(&err)() defer report.HandleAccess(&err)()
index.handleAccess = report.HandleAccess index.handleAccess = report.HandleAccess
@@ -58,6 +58,7 @@ func (index *packageIndex) populate(cache *pkg.Cache, report *rosa.Report) (err
var work [rosa.PresetUnexportedStart]*metadata var work [rosa.PresetUnexportedStart]*metadata
index.names = make(map[string]*metadata) index.names = make(map[string]*metadata)
ir := pkg.NewIR()
for p := range rosa.PresetUnexportedStart { for p := range rosa.PresetUnexportedStart {
m := metadata{ m := metadata{
p: p, p: p,
@@ -72,8 +73,8 @@ func (index *packageIndex) populate(cache *pkg.Cache, report *rosa.Report) (err
m.Version = "" m.Version = ""
} }
if cache != nil && report != nil { if report != nil {
id := cache.Ident(rosa.Std.Load(p)) id := ir.Ident(rosa.Std.Load(p))
m.ids = pkg.Encode(id.Value()) m.ids = pkg.Encode(id.Value())
m.status, m.Size = report.ArtifactOf(id) m.status, m.Size = report.ArtifactOf(id)
m.HasReport = m.Size >= 0 m.HasReport = m.Size >= 0

View File

@@ -10,12 +10,9 @@ import (
"syscall" "syscall"
"time" "time"
"hakurei.app/check"
"hakurei.app/cmd/pkgserver/internal/ui" "hakurei.app/cmd/pkgserver/internal/ui"
"hakurei.app/command" "hakurei.app/command"
"hakurei.app/internal/pkg"
"hakurei.app/internal/rosa" "hakurei.app/internal/rosa"
"hakurei.app/message"
) )
const shutdownTimeout = 15 * time.Second const shutdownTimeout = 15 * time.Second
@@ -25,17 +22,14 @@ func main() {
log.SetPrefix("pkgserver: ") log.SetPrefix("pkgserver: ")
var ( var (
flagBaseDir string flagAddr string
flagAddr string
) )
ctx, stop := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM, syscall.SIGHUP) ctx, stop := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM, syscall.SIGHUP)
defer stop() defer stop()
msg := message.New(log.Default())
c := command.New(os.Stderr, log.Printf, "pkgserver", func(args []string) error { c := command.New(os.Stderr, log.Printf, "pkgserver", func(args []string) error {
var ( var (
cache *pkg.Cache
report *rosa.Report report *rosa.Report
) )
switch len(args) { switch len(args) {
@@ -43,17 +37,8 @@ func main() {
break break
case 1: case 1:
baseDir, err := check.NewAbs(flagBaseDir) var err error
if err != nil { rosa.DropCaches(rosa.OptLLVMNoLTO)
return err
}
cache, err = pkg.Open(ctx, msg, 0, 0, 0, baseDir)
if err != nil {
return err
}
defer cache.Close()
report, err = rosa.OpenReport(args[0]) report, err = rosa.OpenReport(args[0])
if err != nil { if err != nil {
return err return err
@@ -61,12 +46,11 @@ func main() {
default: default:
return errors.New("pkgserver requires 1 argument") return errors.New("pkgserver requires 1 argument")
} }
var index packageIndex var index packageIndex
index.search = make(searchCache) index.search = make(searchCache)
if err := index.populate(cache, report); err != nil { if err := index.populate(report); err != nil {
return err return err
} }
ticker := time.NewTicker(1 * time.Minute) ticker := time.NewTicker(1 * time.Minute)
@@ -98,10 +82,6 @@ func main() {
}() }()
return server.ListenAndServe() return server.ListenAndServe()
}).Flag( }).Flag(
&flagBaseDir,
"b", command.StringFlag(""),
"base directory for cache",
).Flag(
&flagAddr, &flagAddr,
"addr", command.StringFlag(":8067"), "addr", command.StringFlag(":8067"),
"TCP network address to listen on", "TCP network address to listen on",