Commited05acc

committed

Fix queue_srv stop race condition.

1 parentfab37c4 commited05accCopy full SHA for ed05acc

File tree

-7

lines changed

-7

lines changed

Lines changed: 1 addition & 7 deletions

Original file line number	Diff line number	Diff line change
`@@ -38,11 +38,7 @@ start_link(Mod) ->`
`38`	`38`	`gen_server:start_link({local,?SERVER},?MODULE, [Mod], []).`
`39`	`39`
`40`	`40`	`stop()->`
`41`		`-trycall(stop)`
`42`		`-catch`
`43`		`-exit:{noproc,_} ->ok;`
`44`		`-exit:{normal,_} ->ok`
`45`		`-end.`
	`41`	`+gen_server:stop(?SERVER).`
`46`	`42`
`47`	`43`	`call(M)->`
`48`	`44`	`gen_server:call(?SERVER,M,infinity).`
`@@ -107,8 +103,6 @@ init([Mod]) ->`
`107`	`103`	`%% {stop, Reason, State}`
`108`	`104`	`%% @end`
`109`	`105`	`%%--------------------------------------------------------------------`
`110`		`-handle_call(stop,_F,S)->`
`111`		`- {stop,normal,ok,S};`
`112`	`106`	`handle_call({in,Item},_F,#state {q=Q,mod=M }=S)->`
`113`	`107`	`NQ=M:in(Item,Q),`
`114`	`108`	`{reply,ok,S#state {q=NQ }};`

Comments

(0)