APISonar


com.orientechnologies.orient.distributed.impl.log.OOperationLog.log

> com > orientechnologies > orient > distributed > impl > log > OOperationLog > log
com APIs orientechnologies APIs orient APIs distributed APIs impl APIs log APIs OOperationLog APIs log APIs

Example 1
private final        OOperationLog                              operationLog;

  public void propagateAndApply(ORaftOperation operation, OpFinished finished) {
    executor.execute(() -> {
      OLogId id = operationLog.log(operation);
      contexts.put(id, new ORaftRequestContext(operation, quorum, finished));
      timer.schedule(new ORaftOperationTimeoutTimerTask(this, id), timeout, timeout);
      Set<ONodeIdentity> to = new HashSet<>(members);
      to.remove(nodeIdentity);
      network.propagate(to, id, operation);
      receiveAck(getOrientDB().getStructuralConfiguration().getCurrentNodeIdentity(), id);
    });
  }