| 63 | } |
| 64 | |
| 65 | int StorageManager::LoadFromCheckPoint() { |
| 66 | LogVerbose("%s load from check point", __func__); |
| 67 | EventData checkpoint_data; |
| 68 | MasterInfo master_info; |
| 69 | EventDataInfo event_data_info; |
| 70 | int ret = checkpoint_manager_->GetNewestCheckPoint(&checkpoint_data, &master_info, &event_data_info); |
| 71 | if (ret != 0 && ret != DATA_EMPTY) { |
| 72 | ColorLogError("%s get newest check point fail, ret %d", __func__, ret); |
| 73 | return ret; |
| 74 | } |
| 75 | |
| 76 | if (ret != DATA_EMPTY) { |
| 77 | initial_instanceid_ = checkpoint_data.instance_id(); |
| 78 | } else { |
| 79 | checkpoint_data.set_gtid(""); |
| 80 | checkpoint_data.set_data(""); |
| 81 | checkpoint_data.set_instance_id(0); |
| 82 | } |
| 83 | ColorLogInfo("%s start event storage load from checkpoint", __func__); |
| 84 | |
| 85 | ret = event_storage_->LoadFromCheckPoint(checkpoint_data, event_data_info.file_name()); |
| 86 | if (ret) { |
| 87 | return ret; |
| 88 | } |
| 89 | ColorLogInfo("%s event storage load from checkpoint done", __func__); |
| 90 | if (master_info.version() > 0) { |
| 91 | return master_storage_->LoadFromCheckPoint(master_info); |
| 92 | } else { |
| 93 | return ret; |
| 94 | } |
| 95 | } |
| 96 | |
| 97 | int StorageManager::MakeCheckPoint(const vector<string> >idlist) { |
| 98 | return checkpoint_manager_->MakeCheckPoint(gtidlist); |
nothing calls this directly
no test coverage detected