()
| 525 | } |
| 526 | |
| 527 | func (n *Node) Close() error { |
| 528 | if !n.isRunning.CompareAndSwap(true, false) { |
| 529 | return nil |
| 530 | } |
| 531 | close(n.shutdown) |
| 532 | n.raftNode.Stop() |
| 533 | n.transport.Stop() |
| 534 | if err := n.httpServer.Close(); err != nil { |
| 535 | return err |
| 536 | } |
| 537 | |
| 538 | n.dataStore.Close() |
| 539 | n.wg.Wait() |
| 540 | return nil |
| 541 | } |
no test coverage detected