()
| 79 | } |
| 80 | |
| 81 | func startNodes() { |
| 82 | ctx := context.Background() |
| 83 | |
| 84 | // wait for ports to be available |
| 85 | var err error |
| 86 | |
| 87 | err = utils.WaitForPorts(ctx, "127.0.0.1", []int{ |
| 88 | 6122, |
| 89 | 6121, |
| 90 | 6120, |
| 91 | }, time.Millisecond*200) |
| 92 | |
| 93 | if err != nil { |
| 94 | log.Fatalf("wait for port ready timeout: %v", err) |
| 95 | } |
| 96 | |
| 97 | // start 3bps |
| 98 | var cmd *utils.CMD |
| 99 | if cmd, err = utils.RunCommandNB( |
| 100 | FJ(baseDir, "./bin/cqld.test"), |
| 101 | []string{"-config", FJ(testWorkingDir, "./fuse/node_0/config.yaml"), |
| 102 | "-test.coverprofile", FJ(baseDir, "./cmd/cql-fuse/leader.cover.out"), |
| 103 | }, |
| 104 | "leader", testWorkingDir, logDir, true, |
| 105 | ); err == nil { |
| 106 | nodeCmds = append(nodeCmds, cmd) |
| 107 | } else { |
| 108 | log.Errorf("start node failed: %v", err) |
| 109 | } |
| 110 | if cmd, err = utils.RunCommandNB( |
| 111 | FJ(baseDir, "./bin/cqld.test"), |
| 112 | []string{"-config", FJ(testWorkingDir, "./fuse/node_1/config.yaml"), |
| 113 | "-test.coverprofile", FJ(baseDir, "./cmd/cql-fuse/follower1.cover.out"), |
| 114 | }, |
| 115 | "follower1", testWorkingDir, logDir, false, |
| 116 | ); err == nil { |
| 117 | nodeCmds = append(nodeCmds, cmd) |
| 118 | } else { |
| 119 | log.Errorf("start node failed: %v", err) |
| 120 | } |
| 121 | if cmd, err = utils.RunCommandNB( |
| 122 | FJ(baseDir, "./bin/cqld.test"), |
| 123 | []string{"-config", FJ(testWorkingDir, "./fuse/node_2/config.yaml"), |
| 124 | "-test.coverprofile", FJ(baseDir, "./cmd/cql-fuse/follower2.cover.out"), |
| 125 | }, |
| 126 | "follower2", testWorkingDir, logDir, false, |
| 127 | ); err == nil { |
| 128 | nodeCmds = append(nodeCmds, cmd) |
| 129 | } else { |
| 130 | log.Errorf("start node failed: %v", err) |
| 131 | } |
| 132 | |
| 133 | ctx, cancel := context.WithTimeout(context.Background(), time.Second*30) |
| 134 | defer cancel() |
| 135 | err = utils.WaitToConnect(ctx, "127.0.0.1", []int{ |
| 136 | 6122, |
| 137 | 6121, |
| 138 | 6120, |
no test coverage detected