(bypassSign bool)
| 223 | } |
| 224 | |
| 225 | func startNodesProfile(bypassSign bool) { |
| 226 | ctx := context.Background() |
| 227 | bypassArg := "" |
| 228 | if bypassSign { |
| 229 | bypassArg = "-bypass-signature" |
| 230 | } |
| 231 | |
| 232 | // wait for ports to be available |
| 233 | var err error |
| 234 | err = utils.WaitForPorts(ctx, "127.0.0.1", []int{ |
| 235 | 2144, |
| 236 | 2145, |
| 237 | 2146, |
| 238 | }, time.Millisecond*200) |
| 239 | |
| 240 | if err != nil { |
| 241 | log.Fatalf("wait for port ready timeout: %v", err) |
| 242 | } |
| 243 | |
| 244 | err = utils.WaitForPorts(ctx, "127.0.0.1", []int{ |
| 245 | 3122, |
| 246 | 3121, |
| 247 | 3120, |
| 248 | }, time.Millisecond*200) |
| 249 | |
| 250 | if err != nil { |
| 251 | log.Fatalf("wait for port ready timeout: %v", err) |
| 252 | } |
| 253 | |
| 254 | // start 3bps |
| 255 | var cmd *utils.CMD |
| 256 | if cmd, err = utils.RunCommandNB( |
| 257 | FJ(baseDir, "./bin/cqld"), |
| 258 | []string{"-config", FJ(testWorkingDir, "./integration/node_0/config.yaml"), |
| 259 | bypassArg, |
| 260 | }, |
| 261 | "leader", testWorkingDir, logDir, false, |
| 262 | ); err == nil { |
| 263 | nodeCmds = append(nodeCmds, cmd) |
| 264 | } else { |
| 265 | log.Errorf("start node failed: %v", err) |
| 266 | } |
| 267 | if cmd, err = utils.RunCommandNB( |
| 268 | FJ(baseDir, "./bin/cqld"), |
| 269 | []string{"-config", FJ(testWorkingDir, "./integration/node_1/config.yaml"), |
| 270 | bypassArg, |
| 271 | }, |
| 272 | "follower1", testWorkingDir, logDir, false, |
| 273 | ); err == nil { |
| 274 | nodeCmds = append(nodeCmds, cmd) |
| 275 | } else { |
| 276 | log.Errorf("start node failed: %v", err) |
| 277 | } |
| 278 | if cmd, err = utils.RunCommandNB( |
| 279 | FJ(baseDir, "./bin/cqld"), |
| 280 | []string{"-config", FJ(testWorkingDir, "./integration/node_2/config.yaml"), |
| 281 | bypassArg, |
| 282 | }, |
no test coverage detected