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_UTIL_STATUS_LOG_H

#define YB_UTIL_STATUS_LOG_H

#include <glog/logging.h>

#include "yb/util/status.h"

#define YB_DFATAL_OR_RETURN_NOT_OK(s) do { \

    LOG_IF(DFATAL, !s.ok()) << s; \

    YB_RETURN_NOT_OK(s); \

  } while (0);

#define YB_DFATAL_OR_RETURN_ERROR_IF(condition, s) do { \

    if (PREDICT_FALSE(condition)) { \

      DCHECK(!s.ok()) << "Invalid OK status"; \

      LOG(DFATAL) << s; \

      return s; \

    } \

  } while (0);

// Emit a warning if 'to_call' returns a bad status.

#define YB_WARN_NOT_OK(to_call, warning_prefix) do { \

    ::yb::Status _s = (to_call); \

cassandra_cpp_driver-test.cc:_ZZN2yb22TestBackfillIndexTableEPNS_27CppCassandraDriverTestIndexENS_17StronglyTypedBoolINS_15PKOnlyIndex_TagEEENS2_INS_12IsUnique_TagEEENS2_INS_21IncludeAllColumns_TagEEENS2_INS_16UserEnforced_TagEEEENK3$_3clENS_6ResultINS_6master13BackfillJobPBEEE

Line

Count

Source

36

1.05k

    ::yb::Status _s = (to_call); \

consensus_queue.cc:_ZZN2yb9consensus16PeerMessageQueue15NotifyObserversIZNS1_18NumSSTFilesChangedEvE3$_0EEvPKcOT_ENKUlvE_clEv

Line

Count

Source

36

2.88k

    ::yb::Status _s = (to_call); \

consensus_queue.cc:_ZZN2yb9consensus16PeerMessageQueue15NotifyObserversIZNS1_27NotifyObserversOfTermChangeExE3$_1EEvPKcOT_ENKUlvE_clEv

Line

Count

Source

36

37

    ::yb::Status _s = (to_call); \

consensus_queue.cc:_ZZN2yb9consensus16PeerMessageQueue15NotifyObserversIZNS1_31NotifyObserversOfFailedFollowerERKNSt3__112basic_stringIcNS3_11char_traitsIcEENS3_9allocatorIcEEEExSB_E3$_2EEvPKcOT_ENKUlvE_clEv

Line

Count

Source

36

320

    ::yb::Status _s = (to_call); \

Unexecuted instantiation: mini_cluster.cc:_ZZN2yb15ListTabletPeersEPNS_11MiniClusterERKNSt3__18functionIFbRKNS2_10shared_ptrINS_6tablet10TabletPeerEEEEEEENK3$_9clEv

catalog_manager.cc:_ZZZN2yb6master14CatalogManager26RebuildYQLSystemPartitionsEvENK4$_18clERKNS_6StatusEENKUlvE_clEv

Line

Count

Source

36

10.6k

    ::yb::Status _s = (to_call); \

sys_catalog.cc:_ZZN2yb6master15SysCatalogTable22SysCatalogStateChangedERKNSt3__112basic_stringIcNS2_11char_traitsIcEENS2_9allocatorIcEEEENS2_10shared_ptrINS_9consensus18StateChangeContextEEEENK3$_0clEv

Line

Count

Source

36

134

    ::yb::Status _s = (to_call); \

Unexecuted instantiation: ysql_transaction_ddl.cc:_ZZN2yb6master18YsqlTransactionDdl19TransactionReceivedERKNS_19TransactionMetadataENSt3__18functionIFNS_6StatusEbEEES7_RKNS_7tserver30GetTransactionStatusResponsePBEENK3$_1clEv

Unexecuted instantiation: ysql_transaction_ddl.cc:_ZZN2yb6master18YsqlTransactionDdl19TransactionReceivedERKNS_19TransactionMetadataENSt3__18functionIFNS_6StatusEbEEES7_RKNS_7tserver30GetTransactionStatusResponsePBEENK3$_2clEv

ysql_transaction_ddl.cc:_ZZN2yb6master18YsqlTransactionDdl19TransactionReceivedERKNS_19TransactionMetadataENSt3__18functionIFNS_6StatusEbEEES7_RKNS_7tserver30GetTransactionStatusResponsePBEENK3$_3clEv

Line

Count

Source

36

5.76k

    ::yb::Status _s = (to_call); \

ts_tablet_manager.cc:_ZZN2yb7tserver15TSTabletManager10OpenTabletERK13scoped_refptrINS_6tablet17RaftGroupMetadataEERKS2_INS0_27TransitionInProgressDeleterEEENK3$_6clEv

Line

Count

Source

36

84

    ::yb::Status _s = (to_call); \

    if (PREDICT_FALSE(!_s.ok())) { \

      YB_LOG(WARNING) << (warning_prefix) << ": " << _s.ToString();  \

    } \

  } while (0);

#define WARN_WITH_PREFIX_NOT_OK(to_call, warning_prefix) do { \

    ::yb::Status _s = (to_call); \

    if (PREDICT_FALSE(!_s.ok())) { \

      YB_LOG(WARNING) << LogPrefix() << (warning_prefix) << ": " << _s; \

    } \

  } while (0);

// Emit a error if 'to_call' returns a bad status.

#define ERROR_NOT_OK(to_call, error_prefix) do { \

    ::yb::Status _s = (to_call); \

Unexecuted instantiation: flush-test.cc:_ZZN2yb7tserver10FlushITest49TestFlushPicksOldestInactiveTabletAfterCompactionEbENK3$_2clEv

Unexecuted instantiation: flush-test.cc:_ZZN2yb7tserver10FlushITest49TestFlushPicksOldestInactiveTabletAfterCompactionEbENK3$_3clEv

    if (PREDICT_FALSE(!_s.ok())) { \

      YB_LOG(ERROR) << (error_prefix) << ": " << _s.ToString();  \

    } \

  } while (0);

// Log the given status and return immediately.

#define YB_LOG_AND_RETURN(level, status) do { \

    ::yb::Status _s = (status); \

    YB_LOG(level) << _s.ToString(); \

    return _s; \

  } while (0);

// If 'to_call' returns a bad status, CHECK immediately with a logged message of 'msg' followed by

// the status.

#define YB_CHECK_OK_PREPEND(to_call, msg) do { \

  auto&& _s = (to_call); \

_ZZN2yb6tablet14TabletPeerTest22ExecuteWriteAndRollLogEPNS0_10TabletPeerERKNS_7tserver14WriteRequestPBEENKUlvE_clEv

Line

Count

Source

67

13

  auto&& _s = (to_call); \

thread_posix.cc:_ZZN7rocksdb10ThreadPool14StartBGThreadsEvENK3$_0clEv

Line

Count

Source

67

63.1k

  auto&& _s = (to_call); \

  YB_CHECK(_s.ok()) << (msg) << ": " << StatusToString(_s); \

  } while (0);

// If the status is bad, CHECK immediately, appending the status to the logged message.

#define YB_CHECK_OK(s) YB_CHECK_OK_PREPEND(s, "Bad status")

// If status is not OK, this will FATAL in debug mode, or return the error otherwise.

#define DFATAL_OR_RETURN_NOT_OK YB_DFATAL_OR_RETURN_NOT_OK

#define DFATAL_OR_RETURN_ERROR_IF  YB_DFATAL_OR_RETURN_ERROR_IF

#define WARN_NOT_OK             YB_WARN_NOT_OK

#define LOG_AND_RETURN          YB_LOG_AND_RETURN

#define CHECK_OK_PREPEND        YB_CHECK_OK_PREPEND

#define CHECK_OK                YB_CHECK_OK

// These are standard glog macros.

#define YB_LOG              LOG

#define YB_CHECK            CHECK

// Checks that result is ok, extracts result value is case of success.

#define CHECK_RESULT(expr) \

  RESULT_CHECKER_HELPER(expr, CHECK_OK(__result))

#endif  // YB_UTIL_STATUS_LOG_H