// Copyright (c) 2011 The LevelDB Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file. See the AUTHORS file for names of contributors.

#include "port/port_chromium.h"

#include "base/threading/platform_thread.h"
#include "util/logging.h"

#if defined(USE_SNAPPY)
#  include "third_party/snappy/src/snappy.h"
#endif

namespace leveldb {
namespace port {

Mutex::Mutex() {
}

Mutex::~Mutex() {
}

void Mutex::Lock() {
  mu_.Acquire();
}

void Mutex::Unlock() {
  mu_.Release();
}

void Mutex::AssertHeld() {
  mu_.AssertAcquired();
}

CondVar::CondVar(Mutex* mu)
    : cv_(&mu->mu_) {
}

CondVar::~CondVar() { }

void CondVar::Wait() {
  cv_.Wait();
}

void CondVar::Signal(){
  cv_.Signal();
}

void CondVar::SignalAll() {
  cv_.Broadcast();
}

void InitOnceImpl(OnceType* once, void (*initializer)()) {
  OnceType state = ::base::subtle::Acquire_Load(once);
  if (state == ONCE_STATE_DONE)
    return;

  state = ::base::subtle::NoBarrier_CompareAndSwap(
              once,
              ONCE_STATE_UNINITIALIZED,
              ONCE_STATE_EXECUTING_CLOSURE);

  if (state == ONCE_STATE_UNINITIALIZED) {
    // We are the first thread, we have to call the closure.
    (*initializer)();
    ::base::subtle::Release_Store(once, ONCE_STATE_DONE);
  } else {
    // Another thread is running the closure, wait until completion.
    while (state == ONCE_STATE_EXECUTING_CLOSURE) {
      ::base::PlatformThread::YieldCurrentThread();
      state = ::base::subtle::Acquire_Load(once);
    }
  }
}

bool Snappy_Compress(const char* input, size_t input_length,
                     std::string* output) {
#if defined(USE_SNAPPY)
  output->resize(snappy::MaxCompressedLength(input_length));
  size_t outlen;
  snappy::RawCompress(input, input_length, &(*output)[0], &outlen);
  output->resize(outlen);
  return true;
#else
  return false;
#endif
}

bool Snappy_GetUncompressedLength(const char* input_data,
                                  size_t input_length,
                                  size_t* result) {
#if defined(USE_SNAPPY)
  return snappy::GetUncompressedLength(input_data, input_length, result);
#else
  return false;
#endif
}

bool Snappy_Uncompress(const char* input_data, size_t input_length,
                       char* output) {
#if defined(USE_SNAPPY)
  return snappy::RawUncompress(input_data, input_length, output);
#else
  return false;
#endif
}

}
}