YugabyteDB (2.13.0.0-b42, bfc6a6643e7399ac8a0e81d06a3ee6d6571b33ab)

// Copyright (c) YugaByte, Inc.

//

// Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except

// in compliance with the License.  You may obtain a copy of the License at

//

// http://www.apache.org/licenses/LICENSE-2.0

//

// Unless required by applicable law or agreed to in writing, software distributed under the License

// is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express

// or implied.  See the License for the specific language governing permissions and limitations

// under the License.

//

#ifndef YB_TABLET_OPERATIONS_SNAPSHOT_OPERATION_H

#define YB_TABLET_OPERATIONS_SNAPSHOT_OPERATION_H

#include <mutex>

#include <string>

#include "yb/tablet/tablet_fwd.h"

#include "yb/gutil/macros.h"

#include "yb/tablet/operation_filter.h"

#include "yb/tablet/operations/operation.h"

#include "yb/tserver/backup.pb.h"

#include "yb/util/locks.h"

namespace yb {

namespace tablet {

// Operation Context for the TabletSnapshot operation.

// Keeps track of the Operation states (request, result, ...)

// Executes the TabletSnapshotOp operation.

class SnapshotOperation :

    public ExclusiveSchemaOperation<OperationType::kSnapshot, tserver::TabletSnapshotOpRequestPB>,

    public OperationFilter {

 public:

  template <class... Args>

  explicit SnapshotOperation(Args&&... args)

      : ExclusiveSchemaOperation(std::forward<Args>(args)...) {

  }

_ZN2yb6tablet17SnapshotOperationC2IJPNS0_6TabletEPNS_7tserver25TabletSnapshotOpRequestPBEEEEDpOT_

Line

Count

Source

39

373

      : ExclusiveSchemaOperation(std::forward<Args>(args)...) {

40

373

  }

Unexecuted instantiation: _ZN2yb6tablet17SnapshotOperationC2IJDnEEEDpOT_

Unexecuted instantiation: _ZN2yb6tablet17SnapshotOperationC2IJPNS0_6TabletERKPNS_7tserver25TabletSnapshotOpRequestPBEEEEDpOT_

_ZN2yb6tablet17SnapshotOperationC2IJPNS0_6TabletEEEEDpOT_

Line

Count

Source

39

500

      : ExclusiveSchemaOperation(std::forward<Args>(args)...) {

40

500

  }

_ZN2yb6tablet17SnapshotOperationC2IJPNS0_6TabletERPKNS_7tserver25TabletSnapshotOpRequestPBEEEEDpOT_

Line

Count

Source

39

3

      : ExclusiveSchemaOperation(std::forward<Args>(args)...) {

40

3

  }

  tserver::TabletSnapshotOpRequestPB::Operation operation() const {

    return request() == nullptr ?

        tserver::TabletSnapshotOpRequestPB::UNKNOWN : request()->operation();

  }

  // Returns the snapshot directory, based on the tablet's top directory for all snapshots, and any

  // overrides for the snapshot directory this operation might have.

  Result<std::string> GetSnapshotDir() const;

  bool CheckOperationRequirements();

  static bool ShouldAllowOpDuringRestore(consensus::OperationType op_type);

  static CHECKED_STATUS RejectionStatus(OpId rejected_op_id, consensus::OperationType op_type);

  CHECKED_STATUS Prepare() override;

 private:

  // Starts the TabletSnapshotOp operation by assigning it a timestamp.

  CHECKED_STATUS DoReplicated(int64_t leader_term, Status* complete_status) override;

  CHECKED_STATUS DoAborted(const Status& status) override;

  CHECKED_STATUS Apply(int64_t leader_term, Status* complete_status);

  void AddedAsPending() override;

  void RemovedFromPending() override;

  bool NeedOperationFilter() const;

  CHECKED_STATUS CheckOperationAllowed(

      const OpId& id, consensus::OperationType op_type) const override;

  CHECKED_STATUS DoCheckOperationRequirements();

};

}  // namespace tablet

}  // namespace yb

#endif  // YB_TABLET_OPERATIONS_SNAPSHOT_OPERATION_H