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
fix pusher concurrent close channel #7473
fix pusher concurrent close channel #7473
Conversation
Hi @lengrongfu. Thanks for your PR. I'm waiting for a containerd member to verify that this patch is reasonable to test. If it is, they should reply with Once the patch is verified, the new status will be reflected by the I understand the commands that are listed here. Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes/test-infra repository. |
7b9e3b6
to
0791663
Compare
da3da4e
to
7318653
Compare
Signed-off-by: rongfu.leng <rongfu.leng@daocloud.io>
7318653
to
63a7d8a
Compare
@akhilerm please take a look. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@lengrongfu have a question on the change in the test. The change in Close() looks good.
@dcantah Hi,can you help review this PR? thanks! |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Was on my list 😆. LGTM
/ok-to-test |
@lengrongfu: Cannot trigger testing until a trusted user reviews the PR and leaves an In response to this:
Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes/test-infra repository. |
/ok-to-test |
@samuelkarp k8s jobs are ✅ |
I think this should be cherry-picked to 1.6 and 1.5 |
Perfect! I'm not going to have time tomorrow so thanks a bunch |
cherry-picked this PR to #7479 |
goroutine1:
containerd/remotes/docker/pusher.go
Line 290 in 8abee9c
goroutine2:
containerd/remotes/docker/pusher_test.go
Line 152 in 8abee9c
Use
sync.Once
to ensure thatclose(pw.pipeC)
is executed only once.issue: #7471