YugabyteDB (2.13.0.0-b42, bfc6a6643e7399ac8a0e81d06a3ee6d6571b33ab)

// Licensed to the Apache Software Foundation (ASF) under one

// or more contributor license agreements.  See the NOTICE file

// distributed with this work for additional information

// regarding copyright ownership.  The ASF licenses this file

// to you 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.

//

// The following only applies to changes made to this file as part of YugaByte development.

//

// Portions 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_PROMISE_H

#define YB_UTIL_PROMISE_H

#include "yb/gutil/macros.h"

#include "yb/util/countdown_latch.h"

namespace yb {

// A promise boxes a value which is to be provided at some time in the future.

// A single producer calls Set(...), and any number of consumers can call Get()

// to retrieve the produced value.

//

// In Guava terms, this is a SettableFuture<T>.

template<typename T>

class Promise {

 public:

  Promise() : latch_(1) {}

_ZN2yb7PromiseINS_6StatusEEC2Ev

Line

Count

Source

48

89.6k

  Promise() : latch_(1) {}

_ZN2yb7PromiseIiEC2Ev

Line

Count

Source

48

1

  Promise() : latch_(1) {}

  ~Promise() {}

_ZN2yb7PromiseINS_6StatusEED2Ev

Line

Count

Source

49

47.9k

  ~Promise() {}

_ZN2yb7PromiseIiED2Ev

Line

Count

Source

49

1

  ~Promise() {}

  // Reset the promise to be used again.

  // For this to be safe, there must be some kind of external synchronization

  // ensuring that no threads are still accessing the value from the previous

  // incarnation of the promise.

  void Reset() {

    latch_.Reset(1);

    val_ = T();

  }

  // Block until a value is available, and return a reference to it.

  const T& Get() const {

    latch_.Wait();

    return val_;

  }

_ZNK2yb7PromiseINS_6StatusEE3GetEv

Line

Count

Source

61

97.0k

  const T& Get() const {

62

97.0k

    latch_.Wait();

63

97.0k

    return val_;

64

97.0k

  }

_ZNK2yb7PromiseIiE3GetEv

Line

Count

Source

61

1

  const T& Get() const {

62

1

    latch_.Wait();

63

1

    return val_;

64

1

  }

  // Wait for the promised value to become available with the given timeout.

  //

  // Returns NULL if the timeout elapses before a value is available.

  // Otherwise returns a pointer to the value. This pointer's lifetime is

  // tied to the lifetime of the Promise object.

  const T* WaitFor(const MonoDelta& delta) const {

    if (latch_.WaitFor(delta)) {

      return &val_;

    } else {

      return NULL;

    }

  }

  // Set the value of this promise.

  // This may be called at most once.

  void Set(const T& val) {

    DCHECK_EQ(latch_.count(), 1) << "Already set!";

    val_ = val;

    latch_.CountDown();

  }

_ZN2yb7PromiseINS_6StatusEE3SetERKS1_

Line

Count

Source

81

97.0k

  void Set(const T& val) {

82

0

    DCHECK_EQ(latch_.count(), 1) << "Already set!";

83

97.0k

    val_ = val;

84

97.0k

    latch_.CountDown();

85

97.0k

  }

_ZN2yb7PromiseIiE3SetERKi

Line

Count

Source

81

1

  void Set(const T& val) {

82

0

    DCHECK_EQ(latch_.count(), 1) << "Already set!";

83

1

    val_ = val;

84

1

    latch_.CountDown();

85

1

  }

 private:

  CountDownLatch latch_;

  T val_;

  DISALLOW_COPY_AND_ASSIGN(Promise);

};

} // namespace yb

#endif /* YB_UTIL_PROMISE_H */