| 678 | } |
| 679 | |
| 680 | void Open() { |
| 681 | assert(db_ == nullptr); |
| 682 | Options options; |
| 683 | options.env = g_env; |
| 684 | options.create_if_missing = !FLAGS_use_existing_db; |
| 685 | options.block_cache = cache_; |
| 686 | options.write_buffer_size = FLAGS_write_buffer_size; |
| 687 | options.max_file_size = FLAGS_max_file_size; |
| 688 | options.block_size = FLAGS_block_size; |
| 689 | options.max_open_files = FLAGS_open_files; |
| 690 | options.filter_policy = filter_policy_; |
| 691 | options.reuse_logs = FLAGS_reuse_logs; |
| 692 | Status s = DB::Open(options, FLAGS_db, &db_); |
| 693 | if (!s.ok()) { |
| 694 | fprintf(stderr, "open error: %s\n", s.ToString().c_str()); |
| 695 | exit(1); |
| 696 | } |
| 697 | } |
| 698 | |
| 699 | void OpenBench(ThreadState* thread) { |
| 700 | for (int i = 0; i < num_; i++) { |