mirror of
https://github.com/Wei-Shaw/sub2api.git
synced 2026-09-24 16:05:44 +08:00
chore: remove temporary harvester diagnostic logging
This commit is contained in:
@@ -51,7 +51,6 @@ func (h *Harvester) Wrap(ctx context.Context, body io.ReadCloser, opts HarvestOp
|
||||
if h == nil || h.pool == nil || h.capacity <= 0 || opts.Bucket == "" {
|
||||
return body
|
||||
}
|
||||
slog.Info("harvester.wrap", "bucket", opts.Bucket, "capacity", h.capacity, "streaming", opts.Streaming)
|
||||
chunks := make(chan []byte, harvestChanCap)
|
||||
r := &harvestReader{
|
||||
src: body,
|
||||
@@ -241,6 +240,5 @@ func (s *parseState) emit(sig string) {
|
||||
return
|
||||
}
|
||||
s.seen[sig] = struct{}{}
|
||||
err := s.pool.Add(s.ctx, s.bucket, sig, time.Now(), s.cap)
|
||||
slog.Info("harvester.emit", "bucket", s.bucket, "sig_len", len(sig), "error", err)
|
||||
_ = s.pool.Add(s.ctx, s.bucket, sig, time.Now(), s.cap)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user