| 153 | return _connect(); |
| 154 | } |
| 155 | int maybe_reconnect(rsptr _cluster) { |
| 156 | std::scoped_lock lock(cluster_mutex); |
| 157 | if (!cluster || cluster == _cluster) { |
| 158 | ldout(cct, 10) << "reconnecting to RADOS" << dendl; |
| 159 | _disconnect(); |
| 160 | return _connect(); |
| 161 | } else { |
| 162 | ldout(cct, 10) << "already reconnected" << dendl; |
| 163 | return 0; |
| 164 | } |
| 165 | } |
| 166 | int open(CephContext* _cct) { |
| 167 | std::scoped_lock lock(cluster_mutex); |
| 168 | return _open(_cct); |