|
|
@ -889,8 +889,8 @@ var gql_actions ThreadActions = ThreadActions{
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
context := NewWriteContext(ctx)
|
|
|
|
context := NewWriteContext(ctx)
|
|
|
|
err = UpdateStates(context, gql_thread, NewLockMap(
|
|
|
|
err = UpdateStates(context, node, NewLockMap(
|
|
|
|
NewLockInfo(gql_thread, []string{"http_server"}),
|
|
|
|
NewLockInfo(node, []string{"http_server"}),
|
|
|
|
), func(context *StateContext) error {
|
|
|
|
), func(context *StateContext) error {
|
|
|
|
gql_thread.tcp_listener = listener
|
|
|
|
gql_thread.tcp_listener = listener
|
|
|
|
gql_thread.http_server = http_server
|
|
|
|
gql_thread.http_server = http_server
|
|
|
|