|
|
@ -1019,6 +1019,7 @@ func (ext *GQLExt) Process(ctx *Context, source NodeID, node *Node, signal Signa
|
|
|
|
ctx.Log.Logf("gql", "unknown gql state %s", sig.Str)
|
|
|
|
ctx.Log.Logf("gql", "unknown gql state %s", sig.Str)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else if signal.Type() == StartSignalType {
|
|
|
|
} else if signal.Type() == StartSignalType {
|
|
|
|
|
|
|
|
ctx.Log.Logf("gql", "starting with state: %s", ext.State)
|
|
|
|
switch ext.State {
|
|
|
|
switch ext.State {
|
|
|
|
case "running":
|
|
|
|
case "running":
|
|
|
|
err := ext.StartGQLServer(ctx, node)
|
|
|
|
err := ext.StartGQLServer(ctx, node)
|
|
|
|