@@ -33,7 +33,6 @@ import (
3333
3434 "github.com/AliceO2Group/Control/common/controlmode"
3535 "github.com/AliceO2Group/Control/executor/executorcmd"
36- "github.com/AliceO2Group/Control/executor/executorcmd/transitioner/fairmq"
3736 pb "github.com/AliceO2Group/Control/executor/protos"
3837 "github.com/k0kubun/pp"
3938 "google.golang.org/grpc"
@@ -45,16 +44,27 @@ func main() {
4544 fmt .Printf ("target port: %d" , targetPort )
4645
4746 c := executorcmd .NewClient (uint64 (targetPort ), controlmode .FAIRMQ )
47+ if c == nil {
48+ fmt .Println ("client is nil" )
49+ }
50+
51+ for i := 0 ; i < 10 ; i ++ {
52+ time .Sleep (100 * time .Millisecond )
4853
49- time .Sleep (3 * time .Second )
50- gsr , err := c .GetState (context .TODO (), & pb.GetStateRequest {}, grpc.EmptyCallOption {})
51- if err != nil {
52- fmt .Println (err .Error ())
54+ gsr , err := c .GetState (context .TODO (), & pb.GetStateRequest {}, grpc.EmptyCallOption {})
55+ if err != nil {
56+ fmt .Println (err .Error ())
57+ continue
58+ }
59+ if gsr == nil {
60+ fmt .Println ("nil error and response" )
61+ continue
62+ }
63+ fmt .Println ("GetState RESPONSE:" )
64+ _ , _ = pp .Println (* gsr )
5365 }
54- fmt .Println ("GetState RESPONSE:" )
55- _ , _ = pp .Println (* gsr )
5666
57- tr , err := c .Transition (context .TODO (), & pb.TransitionRequest {
67+ /* tr, err := c.Transition(context.TODO(), &pb.TransitionRequest{
5868 SrcState: "IDLE",
5969 TransitionEvent: fairmq.EvtINIT_DEVICE,
6070 Arguments: nil,
@@ -70,6 +80,6 @@ func main() {
7080 fmt.Println(err.Error())
7181 }
7282 fmt.Println("GetState RESPONSE:")
73- _ , _ = pp .Println (* gsr )
83+ _, _ = pp.Println(*gsr)*/
7484
7585}
0 commit comments