iframe-proxy | Sunbelt Computer Software

138 lines (123 loc) · 2.85 KB

// Copyright (c) 2022 Vinnie Falco (vinnie.falco@gmail.com)
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
// Official repository: https://github.com/cppalliance/http
#include <boost/http/application.hpp>
#include <boost/http/detail/except.hpp>
#include <boost/assert.hpp>
#include <mutex>
#include <vector>
namespace boost {
namespace http {
enum application::state : char
    starting,
    running,
    stopping,
    stopped
struct application::impl
    std::mutex m;
    state st = state::none;
application::
~application()
        std::lock_guard<std::mutex> lock(impl_->m);
        if( impl_->st != state::stopped &&
            impl_->st != state::none)
            // stop() hasn't returned yet
            detail::throw_invalid_argument();
    delete impl_;
application::
application()
    : impl_(new impl)
application::
    struct action
        action(application& self)
            : self_(self)
            std::lock_guard<
                std::mutex> lock(self_.impl_->m);
            // can't call twice
            if(self_.impl_->st != state::none)
                detail::throw_invalid_argument();
            self_.impl_->st = state::starting;
        ~action()
            if(n_ == 0)
                return;
                std::lock_guard<
                    std::mutex> lock(self_.impl_->m);
                BOOST_ASSERT(
                    self_.impl_->st == state::stopping);
                self_.impl_->st = state::stopping;
            // stop what we started
            auto v = self_.get_elements();
            while(n_-- > 0)
                v[n_].stop();
                std::lock_guard<std::mutex> lock(
                    self_.impl_->m);
                self_.impl_->st = state::stopped;
        void apply()
            auto v = self_.get_elements();
            while(n_ < v.size())
                v[n_].start();
                ++n_;
            n_ = 0;
            std::lock_guard<
                std::mutex> lock(self_.impl_->m);
            self_.impl_->st = state::running;
    private:
        application& self_;
        std::size_t n_ = 0;
    action(*this).apply();
application::
        std::lock_guard<std::mutex> lock(impl_->m);
        if(impl_->st != state::running)
            detail::throw_invalid_argument();
        impl_->st = state::stopping;
    auto v = get_elements();
    for(std::size_t i = v.size(); i--;)
        v[i].stop();
        std::lock_guard<std::mutex> lock(impl_->m);
        impl_->st = state::stopped;

Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

application.cpp

Latest commit

History

application.cpp

File metadata and controls