(server common.Server, cfg *config.Config)
| 85 | } |
| 86 | |
| 87 | func doStart(server common.Server, cfg *config.Config) (err error) { |
| 88 | s, ok := server.(*bcacheStore) |
| 89 | if !ok { |
| 90 | return errors.New("Invalid node Type!") |
| 91 | } |
| 92 | // parse the config file |
| 93 | var bconf *bcacheConfig |
| 94 | bconf, err = s.parserConf(cfg) |
| 95 | if err != nil { |
| 96 | err = errors.NewErrorf("block config parser error.") |
| 97 | panic(err) |
| 98 | } |
| 99 | // start bcache manage |
| 100 | bm := newBcacheManager(bconf) |
| 101 | if bm == nil { |
| 102 | err = errors.NewErrorf("block cache manager init fail.") |
| 103 | panic(err) |
| 104 | } |
| 105 | s.bcache = bm |
| 106 | s.conf = bconf |
| 107 | |
| 108 | // start unix domain socket |
| 109 | err = s.startServer() |
| 110 | return |
| 111 | } |
| 112 | |
| 113 | func doShutdown(server common.Server) { |
| 114 | s, ok := server.(*bcacheStore) |
nothing calls this directly
no test coverage detected