| 164 | }; |
| 165 | |
| 166 | DataPartitions(Env& env, SharedRocksDB& sharedDB) |
| 167 | : |
| 168 | _env(env), |
| 169 | _sharedDb(sharedDB), |
| 170 | _rotationCount(0), |
| 171 | _partitions({ |
| 172 | LogPartition{ |
| 173 | DATA_PARTITION_0_NAME, |
| 174 | LogsDBMetadataKey::PARTITION_0_FIRST_WRITE_TIME, |
| 175 | sharedDB.getCF(DATA_PARTITION_0_NAME), |
| 176 | 0, |
| 177 | 0, |
| 178 | 0 |
| 179 | }, |
| 180 | LogPartition{ |
| 181 | DATA_PARTITION_1_NAME, |
| 182 | LogsDBMetadataKey::PARTITION_1_FIRST_WRITE_TIME, |
| 183 | sharedDB.getCF(DATA_PARTITION_1_NAME), |
| 184 | 0, |
| 185 | 0, |
| 186 | 0 |
| 187 | } |
| 188 | }) |
| 189 | {} |
| 190 | |
| 191 | bool isInitialStart() { |
| 192 | auto it1 = std::unique_ptr<rocksdb::Iterator>(_sharedDb.db()->NewIterator({},_partitions[0].cf)); |