()
| 152 | } |
| 153 | |
| 154 | func (dbms *DBMS) writeMeta() (err error) { |
| 155 | meta := NewDBMSMeta() |
| 156 | |
| 157 | dbms.dbMap.Range(func(key, value interface{}) bool { |
| 158 | dbID := key.(proto.DatabaseID) |
| 159 | meta.DBS[dbID] = true |
| 160 | return true |
| 161 | }) |
| 162 | |
| 163 | var buf *bytes.Buffer |
| 164 | if buf, err = utils.EncodeMsgPack(meta); err != nil { |
| 165 | return |
| 166 | } |
| 167 | |
| 168 | filePath := filepath.Join(dbms.cfg.RootDir, DBMetaFileName) |
| 169 | err = ioutil.WriteFile(filePath, buf.Bytes(), 0644) |
| 170 | |
| 171 | return |
| 172 | } |
| 173 | |
| 174 | // Init defines dbms init logic. |
| 175 | func (dbms *DBMS) Init() (err error) { |
no test coverage detected