Cancel a move before mirror promotion has taken place.
972243
private void moveCancel(TableJson json, Storage src, Storage dest) {
        Delta delta = json.newMoveCancel(src);
        Audit audit = new AuditBuilder()
                .set("_op", "doMoveCancel")
                .set("_srcUuid", src.getUuidString())
                .set("_srcPlacement", src.getPlacement())
                .set("_destUuid", dest.getUuidString())
                .set("_destPlacement", dest.getPlacement())
                .build();
        updateTableMetadata(json.getTable(), delta, audit, InvalidationScope.GLOBAL);
    }
472973
def cancel(id)
      have_key?
      address = @url_private + "/me/cancelchildorder"
      body = {
        "product_code"              => @product_code,
        "child_order_acceptance_id" => id
      }
      h = post_ssl_with_sign(address, body)
      {
        "success" => h
      }
    end
649732
public void cancelSubscription() throws NotConnectedException, InterruptedException {
        Presence unsubscribed = new Presence(item.getJid(), Type.unsubscribed);
        connection().sendStanza(unsubscribed);
    }
1264420
def cancelPendingResultsFor( self, ps ):
        """"""
        k = self._parametersAsIndex(ps)

        if k in self._results.keys():
            # remove from results
            rs = self._results[k]
            js = [ j for j in rs if not isinstance(j, dict) ]
            self._results[k] = [ rc for rc in rs if isinstance(rc, dict) ]

            # ...and from pending jobs list
            for j in js:
                del self._pending[j]
246228
def cancel(self, cancel_running=True, mark_completed_as_cancelled=False):
    

    with self._lock:
      for future in self._queue:
        future.cancel(mark_completed_as_cancelled)
      if cancel_running:
        for future in self._running:
          future.cancel(mark_completed_as_cancelled)
      self._queue.clear()
278553
def ensure_stopped(self):
        """"""
        if not self.active:
            return self
        self.stop()
        self.observer.cancel()
        self._manager.remove_routes(self, self.get_routing_keys())
        self._active = False
        return self
876291
@Weight(value = Weight.Unit.VARIABLE, comment = "Depends on the current call stack depth")
  public static void cancelDeferredActions() {
    final int stackDepth = ThreadUtils.stackDepth();

    final List<Deferred> list = REGISTRY.get();

    list.removeIf(deferred -> deferred.getStackDepth() >= stackDepth);
    if (list.isEmpty()) {
      REGISTRY.remove();
    }
  }
500680
def cancelAllPendingResults( self ):
        """"""
        for k in self._results.keys():
            rs = self._results[k]
            self._results[k] = [ j for j in rs if isinstance(j, dict) ]
        self._pending = dict()
1226495
def cancel(self, *args, **kwargs):
        
        self._cancel_called = True
        self.clear_waiting_coordinators(cancel=True)
        super(AsperaTransferCoordinatorController, self).cancel(*args, **kwargs)
653259
def cancel(self, session):
        ''''''
        request = TOPRequest('taobao.crm.shopvip.cancel')
        self.create(self.execute(request, session))
        return self.is_success
1134795
@Override
    public boolean cancel(final String appName, final String id,
                          final boolean isReplication) {
        if (super.cancel(appName, id, isReplication)) {
            replicateToPeers(Action.Cancel, appName, id, null, null, isReplication);
            synchronized (lock) {
                if (this.expectedNumberOfClientsSendingRenews > 0) {
                    // Since the client wants to cancel it, reduce the number of clients to send renews
                    this.expectedNumberOfClientsSendingRenews = this.expectedNumberOfClientsSendingRenews - 1;
                    updateRenewsPerMinThreshold();
                }
            }
            return true;
        }
        return false;
    }
333164
public void cancel() {

        if (m_lockActionRecord.getChange() == LockChange.locked) {
            CmsObject cms = A_CmsUI.getCmsObject();
            try {
                CmsResource res = cms.readResource(m_editId);
                cms.unlockResource(res);
            } catch (CmsException e) {
                LOG.warn("Failed to unlock resource " + m_editId.toString(), e);
            }
        }
        CmsAppWorkplaceUi.get().enableGlobalShortcuts();
    }
397324
def cancel_confirmation(self, confirmation_id):
        
        return self._create_put_request(
            resource=CONFIRMATIONS,
            billomat_id=confirmation_id,
            command=CANCEL,
        )
841150
def cancel(self):
        """"""
        if self.OBSERVE_UPDATES:
            self.detach()
        self.ioloop.add_callback(self.cancel_timeouts)
30763
def cancel(self):
        
        conn = self._assert_open()
        conn._try_activate_cursor(self)
        self._session.cancel_if_pending()
1133892
def cancel(self):
        
        self.event.clear()
        if self.__timer is not None:
            self.__timer.cancel()
323665
protected function cancelPurchase()
    {
        $this->controller->setMessage($this->controller->text('Payment has been canceled'), 'warning');
        $gateway_message = $this->response->getMessage();
        if (!empty($gateway_message)) {
            $this->controller->setMessage($gateway_message, 'warning');
        }
    }