Skip to content

fix processEntry mode on caching tool #7515

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 3 commits into from
May 12, 2025
Merged

fix processEntry mode on caching tool #7515

merged 3 commits into from
May 12, 2025

Conversation

gregns1
Copy link
Contributor

@gregns1 gregns1 commented May 7, 2025

After #7483 got merged processEnrty mode was broken due to some changes. Also needed to add ability to add configured number of channels per doc from system channels.

Pre-review checklist

  • Removed debug logging (fmt.Print, log.Print, ...)
  • Logging sensitive data? Make sure it's tagged (e.g. base.UD(docID), base.MD(dbName))
  • Updated relevant information in the API specifications (such as endpoint descriptions, schemas, ...) in docs/api

Integration Tests

@@ -74,6 +85,16 @@ func (p *processEntryGen) nodeWrites(ctx context.Context, node *sgwNode, delay t
ticker := time.NewTicker(delay)
defer ticker.Stop()
for {
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Should this be a function to deduplicate above where this passes in a time.Ticker with 0 so that the first one is deduplicated from this?

If the delay is actually 0, are we supposed to run this function twice?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Can't pass 0 into ticket hence why I just went for this approach. No wouldn't expect this to run twice if node has 0 delay.

@torcolvin torcolvin assigned gregns1 and unassigned torcolvin May 12, 2025
@gregns1 gregns1 merged commit 94499e5 into main May 12, 2025
27 checks passed
@gregns1 gregns1 deleted the channel_init_fix branch May 12, 2025 16:42
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants