/* * Copyright (c) Meta Platforms, Inc. and affiliates. * * 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. */ #pragma once #include namespace folly { namespace fibers { namespace thread_clock { inline std::chrono::steady_clock::time_point now() { #ifdef __linux__ using std::chrono::nanoseconds; using std::chrono::seconds; timespec tp; clockid_t clockid; if (!pthread_getcpuclockid(pthread_self(), &clockid) && !clock_gettime(clockid, &tp)) { return std::chrono::steady_clock::time_point( nanoseconds(tp.tv_nsec) + seconds(tp.tv_sec)); } #endif return std::chrono::steady_clock::now(); } } // namespace thread_clock template void Fiber::setFunction(F&& func, TaskOptions taskOptions) { assert(state_ == INVALID); func_ = std::forward(func); state_ = NOT_STARTED; taskOptions_ = std::move(taskOptions); } template void Fiber::setFunctionFinally(F&& resultFunc, G&& finallyFunc) { assert(state_ == INVALID); resultFunc_ = std::forward(resultFunc); finallyFunc_ = std::forward(finallyFunc); state_ = NOT_STARTED; taskOptions_ = TaskOptions(); } inline void* Fiber::getUserBuffer() { return &userBuffer_; } template T& Fiber::LocalData::getSlow() { vtable_ = VTable::get(); T* data = nullptr; if constexpr (sizeof(T) <= sizeof(Buffer) && alignof(T) <= alignof(Buffer)) { data = new (&buffer_) T(); } else { data = new T(); } data_ = data; return *data; } } // namespace fibers } // namespace folly