File Manager

X7ROOT File Manager

Current Path: /opt/hc_python/lib/python3.12/site-packages/greenlet

opt / hc_python / lib / python3.12 / site-packages / greenlet /

?? ..
?? CObjects.cpp(3.43 KB)
?? PyGreenlet.cpp(23.63 KB)
?? PyGreenlet.hpp(1.43 KB)
?? PyGreenletUnswitchable.cpp(4.27 KB)
?? PyModule.cpp(8.39 KB)
?? TBrokenGreenlet.cpp(1021 B)
?? TExceptionState.cpp(1.33 KB)
?? TGreenlet.cpp(25.13 KB)
?? TGreenlet.hpp(27.85 KB)
?? TGreenletGlobals.cpp(3.19 KB)
?? TMainGreenlet.cpp(3.2 KB)
?? TPythonState.cpp(15.6 KB)
?? TStackState.cpp(7.21 KB)
?? TThreadState.hpp(18.68 KB)
?? TThreadStateCreator.hpp(2.55 KB)
?? TThreadStateDestroy.cpp(7.98 KB)
?? TUserGreenlet.cpp(23 KB)
?? __init__.py(1.68 KB)
?? __pycache__
?? _greenlet.cpython-312-x86_64-linux-gnu.so(1.38 MB)
?? greenlet.cpp(10.74 KB)
?? greenlet.h(4.64 KB)
?? greenlet_allocator.hpp(2.55 KB)
?? greenlet_compiler_compat.hpp(4.24 KB)
?? greenlet_cpython_compat.hpp(4.05 KB)
?? greenlet_exceptions.hpp(4.4 KB)
?? greenlet_internal.hpp(2.65 KB)
?? greenlet_msvc_compat.hpp(2.91 KB)
?? greenlet_refs.hpp(33.63 KB)
?? greenlet_slp_switch.hpp(3.12 KB)
?? greenlet_thread_support.hpp(867 B)
?? platform
?? slp_platformselect.h(3.87 KB)
?? tests

Editing: TThreadStateCreator.hpp

#ifndef GREENLET_THREAD_STATE_CREATOR_HPP
#define GREENLET_THREAD_STATE_CREATOR_HPP

#include <ctime>
#include <stdexcept>

#include "greenlet_internal.hpp"
#include "greenlet_refs.hpp"
#include "greenlet_thread_support.hpp"

#include "TThreadState.hpp"

namespace greenlet {

typedef void (*ThreadStateDestructor)(ThreadState* const);

template<ThreadStateDestructor Destructor>
class ThreadStateCreator
{
private:
    // Initialized to 1, and, if still 1, created on access.
    // Set to 0 on destruction.
    ThreadState* _state;
    G_NO_COPIES_OF_CLS(ThreadStateCreator);

inline bool has_initialized_state() const noexcept
    {
        return this->_state != (ThreadState*)1;
    }

inline bool has_state() const noexcept
    {
        return this->has_initialized_state() && this->_state != nullptr;
    }

public:

// Only one of these, auto created per thread.
    // Constructing the state constructs the MainGreenlet.
    ThreadStateCreator() :
        _state((ThreadState*)1)
    {
    }

~ThreadStateCreator()
    {
        if (this->has_state()) {
            Destructor(this->_state);
        }

this->_state = nullptr;
    }

inline ThreadState& state()
    {
        // The main greenlet will own this pointer when it is created,
        // which will be right after this. The plan is to give every
        // greenlet a pointer to the main greenlet for the thread it
        // runs in; if we are doing something cross-thread, we need to
        // access the pointer from the main greenlet. Deleting the
        // thread, and hence the thread-local storage, will delete the
        // state pointer in the main greenlet.
        if (!this->has_initialized_state()) {
            // XXX: Assuming allocation never fails
            this->_state = new ThreadState;
            // For non-standard threading, we need to store an object
            // in the Python thread state dictionary so that it can be
            // DECREF'd when the thread ends (ideally; the dict could
            // last longer) and clean this object up.
        }
        if (!this->_state) {
            throw std::runtime_error("Accessing state after destruction.");
        }
        return *this->_state;
    }

operator ThreadState&()
    {
        return this->state();
    }

operator ThreadState*()
    {
        return &this->state();
    }

inline int tp_traverse(visitproc visit, void* arg)
    {
        if (this->has_state()) {
            return this->_state->tp_traverse(visit, arg);
        }
        return 0;
    }

};

}; // namespace greenlet

#endif

X7ROOT File Manager

Editing: TThreadStateCreator.hpp

Upload File

Create Folder