dstepanov-yadro/frostfs-node
1
0
Fork 0
forked from TrueCloudLab/frostfs-node
Code Issues Pull requests Projects Releases Packages Wiki Activity

[#476] cmd/containter: Make network handlers async

Browse source 
Make container handlers that do network
communication execute asynchronously.

Signed-off-by: Pavel Karpy <carpawell@nspcc.ru>
This commit is contained in:
Pavel Karpy 2021-04-15 13:27:33 +03:00 committed by Alex Vanin
parent a04f40d616
commit f02de33f8b
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
cmd/neofs-node/container.go
View file

@ -106,14 +106,14 @@ func initContainerService(c *cfg) {
) )
setContainerNotificationParser(c, startEstimationNotifyEvent, containerEvent.ParseStartEstimation) setContainerNotificationParser(c, startEstimationNotifyEvent, containerEvent.ParseStartEstimation)
addContainerNotificationHandler(c, startEstimationNotifyEvent, func(ev event.Event) { addContainerAsyncNotificationHandler(c, startEstimationNotifyEvent, func(ev event.Event) {
ctrl.Start(loadcontroller.StartPrm{ ctrl.Start(loadcontroller.StartPrm{
Epoch: ev.(containerEvent.StartEstimation).Epoch(), Epoch: ev.(containerEvent.StartEstimation).Epoch(),
}) })
}) })
setContainerNotificationParser(c, stopEstimationNotifyEvent, containerEvent.ParseStopEstimation) setContainerNotificationParser(c, stopEstimationNotifyEvent, containerEvent.ParseStopEstimation)
addContainerNotificationHandler(c, stopEstimationNotifyEvent, func(ev event.Event) { addContainerAsyncNotificationHandler(c, stopEstimationNotifyEvent, func(ev event.Event) {
ctrl.Stop(loadcontroller.StopPrm{ ctrl.Stop(loadcontroller.StopPrm{
Epoch: ev.(containerEvent.StopEstimation).Epoch(), Epoch: ev.(containerEvent.StopEstimation).Epoch(),
}) })