disconnect will disconnect and stop the replicator, but not set the state - such that it will be reassigned and started again.
()
| 340 | |
| 341 | // disconnect will disconnect and stop the replicator, but not set the state - such that it will be reassigned and started again. |
| 342 | func (arc *activeReplicatorCommon) disconnect() error { |
| 343 | arc.lock.Lock() |
| 344 | base.TracefCtx(arc.ctx, base.KeyReplicate, "Calling disconnect without stopping the replicator") |
| 345 | err := arc._disconnect() |
| 346 | arc._publishStatus() |
| 347 | arc.lock.Unlock() |
| 348 | return err |
| 349 | } |
| 350 | |
| 351 | // stopAndDisconnect runs _disconnect and _stop on the replicator, and sets the Stopped replication state. |
| 352 | func (arc *activeReplicatorCommon) stopAndDisconnect() error { |
no test coverage detected