// Copyright 2019 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include <lib/fit/barrier.h>

namespace fit {

barrier::barrier() {
  // Capture a new consumer and intentionally abandon its associated
  // completer so that a promise chained onto the consumer using
  // |promise_or()| will become immediately runnable.
  fit::bridge<> bridge;
  prior_ = std::move(bridge.consumer);
}

barrier::~barrier() = default;

fit::consumer<> barrier::swap_prior(fit::consumer<> new_prior) {
  std::lock_guard<std::mutex> lock(mutex_);
  fit::consumer<> old_prior = std::move(prior_);
  prior_ = std::move(new_prior);
  return old_prior;
}

}  // namespace fit