MCPcopy Create free account
hub / github.com/0xUnixIO/pulse / WaitAck

Method WaitAck

internal/nodeagent/agent.go:49–49  ·  view source on GitHub ↗

WaitAck 阻塞等待对应 seq 的 ack(usage_push 用),ctx 控制超时。 在 WaitAck 之前调用 PushEvent;同一个 seq 仅会被 Wait 一次。

(ctx context.Context, seq uint64)

Source from the content-addressed store, hash-verified

47 // WaitAck 阻塞等待对应 seq 的 ack(usage_push 用),ctx 控制超时。
48 // 在 WaitAck 之前调用 PushEvent;同一个 seq 仅会被 Wait 一次。
49 WaitAck(ctx context.Context, seq uint64) error
50}
51
52// Config 是 Run 的输入。

Callers 2

TestAgent_UsagePushAckFunction · 0.65
tickMethod · 0.65

Implementers 3

fakeSenderinternal/nodeagent/dispatch_test.go
mockSenderinternal/nodeagent/usage_test.go
sessioninternal/nodeagent/session.go

Calls

no outgoing calls

Tested by 1

TestAgent_UsagePushAckFunction · 0.52