mirror of
https://github.com/python/cpython.git
synced 2026-01-01 13:03:56 +00:00
1299 lines
44 KiB
C
Generated
1299 lines
44 KiB
C
Generated
/*[clinic input]
|
|
preserve
|
|
[clinic start generated code]*/
|
|
|
|
#if defined(Py_BUILD_CORE) && !defined(Py_BUILD_CORE_MODULE)
|
|
# include "pycore_gc.h" // PyGC_Head
|
|
# include "pycore_runtime.h" // _Py_ID()
|
|
#endif
|
|
#include "pycore_critical_section.h"// Py_BEGIN_CRITICAL_SECTION()
|
|
#include "pycore_long.h" // _PyLong_UnsignedLongLong_Converter()
|
|
#include "pycore_modsupport.h" // _PyArg_UnpackKeywords()
|
|
|
|
PyDoc_STRVAR(_remote_debugging_RemoteUnwinder___init____doc__,
|
|
"RemoteUnwinder(pid, *, all_threads=False, only_active_thread=False,\n"
|
|
" mode=0, debug=False, skip_non_matching_threads=True,\n"
|
|
" native=False, gc=False, opcodes=False,\n"
|
|
" cache_frames=False, stats=False)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Initialize a new RemoteUnwinder object for debugging a remote Python process.\n"
|
|
"\n"
|
|
"Args:\n"
|
|
" pid: Process ID of the target Python process to debug\n"
|
|
" all_threads: If True, initialize state for all threads in the process.\n"
|
|
" If False, only initialize for the main thread.\n"
|
|
" only_active_thread: If True, only sample the thread holding the GIL.\n"
|
|
" mode: Profiling mode: 0=WALL (wall-time), 1=CPU (cpu-time), 2=GIL (gil-time).\n"
|
|
" Cannot be used together with all_threads=True.\n"
|
|
" debug: If True, chain exceptions to explain the sequence of events that\n"
|
|
" lead to the exception.\n"
|
|
" skip_non_matching_threads: If True, skip threads that don\'t match the selected mode.\n"
|
|
" If False, include all threads regardless of mode.\n"
|
|
" native: If True, include artificial \"<native>\" frames to denote calls to\n"
|
|
" non-Python code.\n"
|
|
" gc: If True, include artificial \"<GC>\" frames to denote active garbage\n"
|
|
" collection.\n"
|
|
" opcodes: If True, gather bytecode opcode information for instruction-level\n"
|
|
" profiling.\n"
|
|
" cache_frames: If True, enable frame caching optimization to avoid re-reading\n"
|
|
" unchanged parent frames between samples.\n"
|
|
" stats: If True, collect statistics about cache hits, memory reads, etc.\n"
|
|
" Use get_stats() to retrieve the collected statistics.\n"
|
|
"\n"
|
|
"The RemoteUnwinder provides functionality to inspect and debug a running Python\n"
|
|
"process, including examining thread states, stack frames and other runtime data.\n"
|
|
"\n"
|
|
"Raises:\n"
|
|
" PermissionError: If access to the target process is denied\n"
|
|
" OSError: If unable to attach to the target process or access its memory\n"
|
|
" RuntimeError: If unable to read debug information from the target process\n"
|
|
" ValueError: If both all_threads and only_active_thread are True");
|
|
|
|
static int
|
|
_remote_debugging_RemoteUnwinder___init___impl(RemoteUnwinderObject *self,
|
|
int pid, int all_threads,
|
|
int only_active_thread,
|
|
int mode, int debug,
|
|
int skip_non_matching_threads,
|
|
int native, int gc,
|
|
int opcodes, int cache_frames,
|
|
int stats);
|
|
|
|
static int
|
|
_remote_debugging_RemoteUnwinder___init__(PyObject *self, PyObject *args, PyObject *kwargs)
|
|
{
|
|
int return_value = -1;
|
|
#if defined(Py_BUILD_CORE) && !defined(Py_BUILD_CORE_MODULE)
|
|
|
|
#define NUM_KEYWORDS 11
|
|
static struct {
|
|
PyGC_Head _this_is_not_used;
|
|
PyObject_VAR_HEAD
|
|
Py_hash_t ob_hash;
|
|
PyObject *ob_item[NUM_KEYWORDS];
|
|
} _kwtuple = {
|
|
.ob_base = PyVarObject_HEAD_INIT(&PyTuple_Type, NUM_KEYWORDS)
|
|
.ob_hash = -1,
|
|
.ob_item = { &_Py_ID(pid), &_Py_ID(all_threads), &_Py_ID(only_active_thread), &_Py_ID(mode), &_Py_ID(debug), &_Py_ID(skip_non_matching_threads), &_Py_ID(native), &_Py_ID(gc), &_Py_ID(opcodes), &_Py_ID(cache_frames), &_Py_ID(stats), },
|
|
};
|
|
#undef NUM_KEYWORDS
|
|
#define KWTUPLE (&_kwtuple.ob_base.ob_base)
|
|
|
|
#else // !Py_BUILD_CORE
|
|
# define KWTUPLE NULL
|
|
#endif // !Py_BUILD_CORE
|
|
|
|
static const char * const _keywords[] = {"pid", "all_threads", "only_active_thread", "mode", "debug", "skip_non_matching_threads", "native", "gc", "opcodes", "cache_frames", "stats", NULL};
|
|
static _PyArg_Parser _parser = {
|
|
.keywords = _keywords,
|
|
.fname = "RemoteUnwinder",
|
|
.kwtuple = KWTUPLE,
|
|
};
|
|
#undef KWTUPLE
|
|
PyObject *argsbuf[11];
|
|
PyObject * const *fastargs;
|
|
Py_ssize_t nargs = PyTuple_GET_SIZE(args);
|
|
Py_ssize_t noptargs = nargs + (kwargs ? PyDict_GET_SIZE(kwargs) : 0) - 1;
|
|
int pid;
|
|
int all_threads = 0;
|
|
int only_active_thread = 0;
|
|
int mode = 0;
|
|
int debug = 0;
|
|
int skip_non_matching_threads = 1;
|
|
int native = 0;
|
|
int gc = 0;
|
|
int opcodes = 0;
|
|
int cache_frames = 0;
|
|
int stats = 0;
|
|
|
|
fastargs = _PyArg_UnpackKeywords(_PyTuple_CAST(args)->ob_item, nargs, kwargs, NULL, &_parser,
|
|
/*minpos*/ 1, /*maxpos*/ 1, /*minkw*/ 0, /*varpos*/ 0, argsbuf);
|
|
if (!fastargs) {
|
|
goto exit;
|
|
}
|
|
pid = PyLong_AsInt(fastargs[0]);
|
|
if (pid == -1 && PyErr_Occurred()) {
|
|
goto exit;
|
|
}
|
|
if (!noptargs) {
|
|
goto skip_optional_kwonly;
|
|
}
|
|
if (fastargs[1]) {
|
|
all_threads = PyObject_IsTrue(fastargs[1]);
|
|
if (all_threads < 0) {
|
|
goto exit;
|
|
}
|
|
if (!--noptargs) {
|
|
goto skip_optional_kwonly;
|
|
}
|
|
}
|
|
if (fastargs[2]) {
|
|
only_active_thread = PyObject_IsTrue(fastargs[2]);
|
|
if (only_active_thread < 0) {
|
|
goto exit;
|
|
}
|
|
if (!--noptargs) {
|
|
goto skip_optional_kwonly;
|
|
}
|
|
}
|
|
if (fastargs[3]) {
|
|
mode = PyLong_AsInt(fastargs[3]);
|
|
if (mode == -1 && PyErr_Occurred()) {
|
|
goto exit;
|
|
}
|
|
if (!--noptargs) {
|
|
goto skip_optional_kwonly;
|
|
}
|
|
}
|
|
if (fastargs[4]) {
|
|
debug = PyObject_IsTrue(fastargs[4]);
|
|
if (debug < 0) {
|
|
goto exit;
|
|
}
|
|
if (!--noptargs) {
|
|
goto skip_optional_kwonly;
|
|
}
|
|
}
|
|
if (fastargs[5]) {
|
|
skip_non_matching_threads = PyObject_IsTrue(fastargs[5]);
|
|
if (skip_non_matching_threads < 0) {
|
|
goto exit;
|
|
}
|
|
if (!--noptargs) {
|
|
goto skip_optional_kwonly;
|
|
}
|
|
}
|
|
if (fastargs[6]) {
|
|
native = PyObject_IsTrue(fastargs[6]);
|
|
if (native < 0) {
|
|
goto exit;
|
|
}
|
|
if (!--noptargs) {
|
|
goto skip_optional_kwonly;
|
|
}
|
|
}
|
|
if (fastargs[7]) {
|
|
gc = PyObject_IsTrue(fastargs[7]);
|
|
if (gc < 0) {
|
|
goto exit;
|
|
}
|
|
if (!--noptargs) {
|
|
goto skip_optional_kwonly;
|
|
}
|
|
}
|
|
if (fastargs[8]) {
|
|
opcodes = PyObject_IsTrue(fastargs[8]);
|
|
if (opcodes < 0) {
|
|
goto exit;
|
|
}
|
|
if (!--noptargs) {
|
|
goto skip_optional_kwonly;
|
|
}
|
|
}
|
|
if (fastargs[9]) {
|
|
cache_frames = PyObject_IsTrue(fastargs[9]);
|
|
if (cache_frames < 0) {
|
|
goto exit;
|
|
}
|
|
if (!--noptargs) {
|
|
goto skip_optional_kwonly;
|
|
}
|
|
}
|
|
stats = PyObject_IsTrue(fastargs[10]);
|
|
if (stats < 0) {
|
|
goto exit;
|
|
}
|
|
skip_optional_kwonly:
|
|
return_value = _remote_debugging_RemoteUnwinder___init___impl((RemoteUnwinderObject *)self, pid, all_threads, only_active_thread, mode, debug, skip_non_matching_threads, native, gc, opcodes, cache_frames, stats);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_RemoteUnwinder_get_stack_trace__doc__,
|
|
"get_stack_trace($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Returns stack traces for all interpreters and threads in process.\n"
|
|
"\n"
|
|
"Each element in the returned list is a tuple of (interpreter_id, thread_list), where:\n"
|
|
"- interpreter_id is the interpreter identifier\n"
|
|
"- thread_list is a list of tuples (thread_id, frame_list) for threads in that interpreter\n"
|
|
" - thread_id is the OS thread identifier\n"
|
|
" - frame_list is a list of tuples (function_name, filename, line_number) representing\n"
|
|
" the Python stack frames for that thread, ordered from most recent to oldest\n"
|
|
"\n"
|
|
"The threads returned depend on the initialization parameters:\n"
|
|
"- If only_active_thread was True: returns only the thread holding the GIL across all interpreters\n"
|
|
"- If all_threads was True: returns all threads across all interpreters\n"
|
|
"- Otherwise: returns only the main thread of each interpreter\n"
|
|
"\n"
|
|
"Example:\n"
|
|
" [\n"
|
|
" (0, [ # Main interpreter\n"
|
|
" (1234, [\n"
|
|
" (\'process_data\', \'worker.py\', 127),\n"
|
|
" (\'run_worker\', \'worker.py\', 45),\n"
|
|
" (\'main\', \'app.py\', 23)\n"
|
|
" ]),\n"
|
|
" (1235, [\n"
|
|
" (\'handle_request\', \'server.py\', 89),\n"
|
|
" (\'serve_forever\', \'server.py\', 52)\n"
|
|
" ])\n"
|
|
" ]),\n"
|
|
" (1, [ # Sub-interpreter\n"
|
|
" (1236, [\n"
|
|
" (\'sub_worker\', \'sub.py\', 15)\n"
|
|
" ])\n"
|
|
" ])\n"
|
|
" ]\n"
|
|
"\n"
|
|
"Raises:\n"
|
|
" RuntimeError: If there is an error copying memory from the target process\n"
|
|
" OSError: If there is an error accessing the target process\n"
|
|
" PermissionError: If access to the target process is denied\n"
|
|
" UnicodeDecodeError: If there is an error decoding strings from the target process");
|
|
|
|
#define _REMOTE_DEBUGGING_REMOTEUNWINDER_GET_STACK_TRACE_METHODDEF \
|
|
{"get_stack_trace", (PyCFunction)_remote_debugging_RemoteUnwinder_get_stack_trace, METH_NOARGS, _remote_debugging_RemoteUnwinder_get_stack_trace__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_RemoteUnwinder_get_stack_trace_impl(RemoteUnwinderObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_RemoteUnwinder_get_stack_trace(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
PyObject *return_value = NULL;
|
|
|
|
Py_BEGIN_CRITICAL_SECTION(self);
|
|
return_value = _remote_debugging_RemoteUnwinder_get_stack_trace_impl((RemoteUnwinderObject *)self);
|
|
Py_END_CRITICAL_SECTION();
|
|
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_RemoteUnwinder_get_all_awaited_by__doc__,
|
|
"get_all_awaited_by($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Get all tasks and their awaited_by relationships from the remote process.\n"
|
|
"\n"
|
|
"This provides a tree structure showing which tasks are waiting for other tasks.\n"
|
|
"\n"
|
|
"For each task, returns:\n"
|
|
"1. The call stack frames leading to where the task is currently executing\n"
|
|
"2. The name of the task\n"
|
|
"3. A list of tasks that this task is waiting for, with their own frames/names/etc\n"
|
|
"\n"
|
|
"Returns a list of [frames, task_name, subtasks] where:\n"
|
|
"- frames: List of (func_name, filename, lineno) showing the call stack\n"
|
|
"- task_name: String identifier for the task\n"
|
|
"- subtasks: List of tasks being awaited by this task, in same format\n"
|
|
"\n"
|
|
"Raises:\n"
|
|
" RuntimeError: If AsyncioDebug section is not available in the remote process\n"
|
|
" MemoryError: If memory allocation fails\n"
|
|
" OSError: If reading from the remote process fails\n"
|
|
"\n"
|
|
"Example output:\n"
|
|
"[\n"
|
|
" [\n"
|
|
" [(\"c5\", \"script.py\", 10), (\"c4\", \"script.py\", 14)],\n"
|
|
" \"c2_root\",\n"
|
|
" [\n"
|
|
" [\n"
|
|
" [(\"c1\", \"script.py\", 23)],\n"
|
|
" \"sub_main_2\",\n"
|
|
" [...]\n"
|
|
" ],\n"
|
|
" [...]\n"
|
|
" ]\n"
|
|
" ]\n"
|
|
"]");
|
|
|
|
#define _REMOTE_DEBUGGING_REMOTEUNWINDER_GET_ALL_AWAITED_BY_METHODDEF \
|
|
{"get_all_awaited_by", (PyCFunction)_remote_debugging_RemoteUnwinder_get_all_awaited_by, METH_NOARGS, _remote_debugging_RemoteUnwinder_get_all_awaited_by__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_RemoteUnwinder_get_all_awaited_by_impl(RemoteUnwinderObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_RemoteUnwinder_get_all_awaited_by(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
PyObject *return_value = NULL;
|
|
|
|
Py_BEGIN_CRITICAL_SECTION(self);
|
|
return_value = _remote_debugging_RemoteUnwinder_get_all_awaited_by_impl((RemoteUnwinderObject *)self);
|
|
Py_END_CRITICAL_SECTION();
|
|
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_RemoteUnwinder_get_async_stack_trace__doc__,
|
|
"get_async_stack_trace($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Get the currently running async tasks and their dependency graphs from the remote process.\n"
|
|
"\n"
|
|
"This returns information about running tasks and all tasks that are waiting for them,\n"
|
|
"forming a complete dependency graph for each thread\'s active task.\n"
|
|
"\n"
|
|
"For each thread with a running task, returns the running task plus all tasks that\n"
|
|
"transitively depend on it (tasks waiting for the running task, tasks waiting for\n"
|
|
"those tasks, etc.).\n"
|
|
"\n"
|
|
"Returns a list of per-thread results, where each thread result contains:\n"
|
|
"- Thread ID\n"
|
|
"- List of task information for the running task and all its waiters\n"
|
|
"\n"
|
|
"Each task info contains:\n"
|
|
"- Task ID (memory address)\n"
|
|
"- Task name\n"
|
|
"- Call stack frames: List of (func_name, filename, lineno)\n"
|
|
"- List of tasks waiting for this task (recursive structure)\n"
|
|
"\n"
|
|
"Raises:\n"
|
|
" RuntimeError: If AsyncioDebug section is not available in the target process\n"
|
|
" MemoryError: If memory allocation fails\n"
|
|
" OSError: If reading from the remote process fails\n"
|
|
"\n"
|
|
"Example output (similar structure to get_all_awaited_by but only for running tasks):\n"
|
|
"[\n"
|
|
" (140234, [\n"
|
|
" (4345585712, \'main_task\',\n"
|
|
" [(\"run_server\", \"server.py\", 127), (\"main\", \"app.py\", 23)],\n"
|
|
" [\n"
|
|
" (4345585800, \'worker_1\', [...], [...]),\n"
|
|
" (4345585900, \'worker_2\', [...], [...])\n"
|
|
" ])\n"
|
|
" ])\n"
|
|
"]");
|
|
|
|
#define _REMOTE_DEBUGGING_REMOTEUNWINDER_GET_ASYNC_STACK_TRACE_METHODDEF \
|
|
{"get_async_stack_trace", (PyCFunction)_remote_debugging_RemoteUnwinder_get_async_stack_trace, METH_NOARGS, _remote_debugging_RemoteUnwinder_get_async_stack_trace__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_RemoteUnwinder_get_async_stack_trace_impl(RemoteUnwinderObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_RemoteUnwinder_get_async_stack_trace(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
PyObject *return_value = NULL;
|
|
|
|
Py_BEGIN_CRITICAL_SECTION(self);
|
|
return_value = _remote_debugging_RemoteUnwinder_get_async_stack_trace_impl((RemoteUnwinderObject *)self);
|
|
Py_END_CRITICAL_SECTION();
|
|
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_RemoteUnwinder_get_stats__doc__,
|
|
"get_stats($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Get collected statistics about profiling performance.\n"
|
|
"\n"
|
|
"Returns a dictionary containing statistics about cache performance,\n"
|
|
"memory reads, and other profiling metrics. Only available if the\n"
|
|
"RemoteUnwinder was created with stats=True.\n"
|
|
"\n"
|
|
"Returns:\n"
|
|
" dict: A dictionary containing:\n"
|
|
" - total_samples: Total number of get_stack_trace calls\n"
|
|
" - frame_cache_hits: Full cache hits (entire stack unchanged)\n"
|
|
" - frame_cache_misses: Cache misses requiring full walk\n"
|
|
" - frame_cache_partial_hits: Partial hits (stopped at cached frame)\n"
|
|
" - frames_read_from_cache: Total frames retrieved from cache\n"
|
|
" - frames_read_from_memory: Total frames read from remote memory\n"
|
|
" - memory_reads: Total remote memory read operations\n"
|
|
" - memory_bytes_read: Total bytes read from remote memory\n"
|
|
" - code_object_cache_hits: Code object cache hits\n"
|
|
" - code_object_cache_misses: Code object cache misses\n"
|
|
" - stale_cache_invalidations: Times stale cache entries were cleared\n"
|
|
" - frame_cache_hit_rate: Percentage of samples that hit the cache\n"
|
|
" - code_object_cache_hit_rate: Percentage of code object lookups that hit cache\n"
|
|
"\n"
|
|
"Raises:\n"
|
|
" RuntimeError: If stats collection was not enabled (stats=False)");
|
|
|
|
#define _REMOTE_DEBUGGING_REMOTEUNWINDER_GET_STATS_METHODDEF \
|
|
{"get_stats", (PyCFunction)_remote_debugging_RemoteUnwinder_get_stats, METH_NOARGS, _remote_debugging_RemoteUnwinder_get_stats__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_RemoteUnwinder_get_stats_impl(RemoteUnwinderObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_RemoteUnwinder_get_stats(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
PyObject *return_value = NULL;
|
|
|
|
Py_BEGIN_CRITICAL_SECTION(self);
|
|
return_value = _remote_debugging_RemoteUnwinder_get_stats_impl((RemoteUnwinderObject *)self);
|
|
Py_END_CRITICAL_SECTION();
|
|
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_RemoteUnwinder_pause_threads__doc__,
|
|
"pause_threads($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Pause all threads in the target process.\n"
|
|
"\n"
|
|
"This stops all threads in the target process to allow for consistent\n"
|
|
"memory reads during sampling. Must be paired with a call to resume_threads().\n"
|
|
"\n"
|
|
"Returns True if threads were successfully paused, False if they were already paused.\n"
|
|
"\n"
|
|
"Raises:\n"
|
|
" RuntimeError: If there is an error stopping the threads");
|
|
|
|
#define _REMOTE_DEBUGGING_REMOTEUNWINDER_PAUSE_THREADS_METHODDEF \
|
|
{"pause_threads", (PyCFunction)_remote_debugging_RemoteUnwinder_pause_threads, METH_NOARGS, _remote_debugging_RemoteUnwinder_pause_threads__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_RemoteUnwinder_pause_threads_impl(RemoteUnwinderObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_RemoteUnwinder_pause_threads(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
PyObject *return_value = NULL;
|
|
|
|
Py_BEGIN_CRITICAL_SECTION(self);
|
|
return_value = _remote_debugging_RemoteUnwinder_pause_threads_impl((RemoteUnwinderObject *)self);
|
|
Py_END_CRITICAL_SECTION();
|
|
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_RemoteUnwinder_resume_threads__doc__,
|
|
"resume_threads($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Resume all threads in the target process.\n"
|
|
"\n"
|
|
"This resumes threads that were previously paused with pause_threads().\n"
|
|
"\n"
|
|
"Returns True if threads were successfully resumed, False if they were not paused.");
|
|
|
|
#define _REMOTE_DEBUGGING_REMOTEUNWINDER_RESUME_THREADS_METHODDEF \
|
|
{"resume_threads", (PyCFunction)_remote_debugging_RemoteUnwinder_resume_threads, METH_NOARGS, _remote_debugging_RemoteUnwinder_resume_threads__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_RemoteUnwinder_resume_threads_impl(RemoteUnwinderObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_RemoteUnwinder_resume_threads(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
PyObject *return_value = NULL;
|
|
|
|
Py_BEGIN_CRITICAL_SECTION(self);
|
|
return_value = _remote_debugging_RemoteUnwinder_resume_threads_impl((RemoteUnwinderObject *)self);
|
|
Py_END_CRITICAL_SECTION();
|
|
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryWriter___init____doc__,
|
|
"BinaryWriter(filename, sample_interval_us, start_time_us, *,\n"
|
|
" compression=0)\n"
|
|
"--\n"
|
|
"\n"
|
|
"High-performance binary writer for profiling data.\n"
|
|
"\n"
|
|
"Arguments:\n"
|
|
" filename: Path to output file\n"
|
|
" sample_interval_us: Sampling interval in microseconds\n"
|
|
" start_time_us: Start timestamp in microseconds (from time.monotonic() * 1e6)\n"
|
|
" compression: 0=none, 1=zstd (default: 0)\n"
|
|
"\n"
|
|
"Use as a context manager or call finalize() when done.");
|
|
|
|
static int
|
|
_remote_debugging_BinaryWriter___init___impl(BinaryWriterObject *self,
|
|
const char *filename,
|
|
unsigned long long sample_interval_us,
|
|
unsigned long long start_time_us,
|
|
int compression);
|
|
|
|
static int
|
|
_remote_debugging_BinaryWriter___init__(PyObject *self, PyObject *args, PyObject *kwargs)
|
|
{
|
|
int return_value = -1;
|
|
#if defined(Py_BUILD_CORE) && !defined(Py_BUILD_CORE_MODULE)
|
|
|
|
#define NUM_KEYWORDS 4
|
|
static struct {
|
|
PyGC_Head _this_is_not_used;
|
|
PyObject_VAR_HEAD
|
|
Py_hash_t ob_hash;
|
|
PyObject *ob_item[NUM_KEYWORDS];
|
|
} _kwtuple = {
|
|
.ob_base = PyVarObject_HEAD_INIT(&PyTuple_Type, NUM_KEYWORDS)
|
|
.ob_hash = -1,
|
|
.ob_item = { &_Py_ID(filename), &_Py_ID(sample_interval_us), &_Py_ID(start_time_us), &_Py_ID(compression), },
|
|
};
|
|
#undef NUM_KEYWORDS
|
|
#define KWTUPLE (&_kwtuple.ob_base.ob_base)
|
|
|
|
#else // !Py_BUILD_CORE
|
|
# define KWTUPLE NULL
|
|
#endif // !Py_BUILD_CORE
|
|
|
|
static const char * const _keywords[] = {"filename", "sample_interval_us", "start_time_us", "compression", NULL};
|
|
static _PyArg_Parser _parser = {
|
|
.keywords = _keywords,
|
|
.fname = "BinaryWriter",
|
|
.kwtuple = KWTUPLE,
|
|
};
|
|
#undef KWTUPLE
|
|
PyObject *argsbuf[4];
|
|
PyObject * const *fastargs;
|
|
Py_ssize_t nargs = PyTuple_GET_SIZE(args);
|
|
Py_ssize_t noptargs = nargs + (kwargs ? PyDict_GET_SIZE(kwargs) : 0) - 3;
|
|
const char *filename;
|
|
unsigned long long sample_interval_us;
|
|
unsigned long long start_time_us;
|
|
int compression = 0;
|
|
|
|
fastargs = _PyArg_UnpackKeywords(_PyTuple_CAST(args)->ob_item, nargs, kwargs, NULL, &_parser,
|
|
/*minpos*/ 3, /*maxpos*/ 3, /*minkw*/ 0, /*varpos*/ 0, argsbuf);
|
|
if (!fastargs) {
|
|
goto exit;
|
|
}
|
|
if (!PyUnicode_Check(fastargs[0])) {
|
|
_PyArg_BadArgument("BinaryWriter", "argument 'filename'", "str", fastargs[0]);
|
|
goto exit;
|
|
}
|
|
Py_ssize_t filename_length;
|
|
filename = PyUnicode_AsUTF8AndSize(fastargs[0], &filename_length);
|
|
if (filename == NULL) {
|
|
goto exit;
|
|
}
|
|
if (strlen(filename) != (size_t)filename_length) {
|
|
PyErr_SetString(PyExc_ValueError, "embedded null character");
|
|
goto exit;
|
|
}
|
|
if (!_PyLong_UnsignedLongLong_Converter(fastargs[1], &sample_interval_us)) {
|
|
goto exit;
|
|
}
|
|
if (!_PyLong_UnsignedLongLong_Converter(fastargs[2], &start_time_us)) {
|
|
goto exit;
|
|
}
|
|
if (!noptargs) {
|
|
goto skip_optional_kwonly;
|
|
}
|
|
compression = PyLong_AsInt(fastargs[3]);
|
|
if (compression == -1 && PyErr_Occurred()) {
|
|
goto exit;
|
|
}
|
|
skip_optional_kwonly:
|
|
return_value = _remote_debugging_BinaryWriter___init___impl((BinaryWriterObject *)self, filename, sample_interval_us, start_time_us, compression);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryWriter_write_sample__doc__,
|
|
"write_sample($self, /, stack_frames, timestamp_us)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Write a sample to the binary file.\n"
|
|
"\n"
|
|
"Arguments:\n"
|
|
" stack_frames: List of InterpreterInfo objects\n"
|
|
" timestamp_us: Current timestamp in microseconds (from time.monotonic() * 1e6)");
|
|
|
|
#define _REMOTE_DEBUGGING_BINARYWRITER_WRITE_SAMPLE_METHODDEF \
|
|
{"write_sample", _PyCFunction_CAST(_remote_debugging_BinaryWriter_write_sample), METH_FASTCALL|METH_KEYWORDS, _remote_debugging_BinaryWriter_write_sample__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryWriter_write_sample_impl(BinaryWriterObject *self,
|
|
PyObject *stack_frames,
|
|
unsigned long long timestamp_us);
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryWriter_write_sample(PyObject *self, PyObject *const *args, Py_ssize_t nargs, PyObject *kwnames)
|
|
{
|
|
PyObject *return_value = NULL;
|
|
#if defined(Py_BUILD_CORE) && !defined(Py_BUILD_CORE_MODULE)
|
|
|
|
#define NUM_KEYWORDS 2
|
|
static struct {
|
|
PyGC_Head _this_is_not_used;
|
|
PyObject_VAR_HEAD
|
|
Py_hash_t ob_hash;
|
|
PyObject *ob_item[NUM_KEYWORDS];
|
|
} _kwtuple = {
|
|
.ob_base = PyVarObject_HEAD_INIT(&PyTuple_Type, NUM_KEYWORDS)
|
|
.ob_hash = -1,
|
|
.ob_item = { &_Py_ID(stack_frames), &_Py_ID(timestamp_us), },
|
|
};
|
|
#undef NUM_KEYWORDS
|
|
#define KWTUPLE (&_kwtuple.ob_base.ob_base)
|
|
|
|
#else // !Py_BUILD_CORE
|
|
# define KWTUPLE NULL
|
|
#endif // !Py_BUILD_CORE
|
|
|
|
static const char * const _keywords[] = {"stack_frames", "timestamp_us", NULL};
|
|
static _PyArg_Parser _parser = {
|
|
.keywords = _keywords,
|
|
.fname = "write_sample",
|
|
.kwtuple = KWTUPLE,
|
|
};
|
|
#undef KWTUPLE
|
|
PyObject *argsbuf[2];
|
|
PyObject *stack_frames;
|
|
unsigned long long timestamp_us;
|
|
|
|
args = _PyArg_UnpackKeywords(args, nargs, NULL, kwnames, &_parser,
|
|
/*minpos*/ 2, /*maxpos*/ 2, /*minkw*/ 0, /*varpos*/ 0, argsbuf);
|
|
if (!args) {
|
|
goto exit;
|
|
}
|
|
stack_frames = args[0];
|
|
if (!_PyLong_UnsignedLongLong_Converter(args[1], ×tamp_us)) {
|
|
goto exit;
|
|
}
|
|
return_value = _remote_debugging_BinaryWriter_write_sample_impl((BinaryWriterObject *)self, stack_frames, timestamp_us);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryWriter_finalize__doc__,
|
|
"finalize($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Finalize and close the binary file.\n"
|
|
"\n"
|
|
"Writes string/frame tables, footer, and updates header.");
|
|
|
|
#define _REMOTE_DEBUGGING_BINARYWRITER_FINALIZE_METHODDEF \
|
|
{"finalize", (PyCFunction)_remote_debugging_BinaryWriter_finalize, METH_NOARGS, _remote_debugging_BinaryWriter_finalize__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryWriter_finalize_impl(BinaryWriterObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryWriter_finalize(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
return _remote_debugging_BinaryWriter_finalize_impl((BinaryWriterObject *)self);
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryWriter_close__doc__,
|
|
"close($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Close the writer without finalizing (discards data).");
|
|
|
|
#define _REMOTE_DEBUGGING_BINARYWRITER_CLOSE_METHODDEF \
|
|
{"close", (PyCFunction)_remote_debugging_BinaryWriter_close, METH_NOARGS, _remote_debugging_BinaryWriter_close__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryWriter_close_impl(BinaryWriterObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryWriter_close(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
return _remote_debugging_BinaryWriter_close_impl((BinaryWriterObject *)self);
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryWriter___enter____doc__,
|
|
"__enter__($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Enter context manager.");
|
|
|
|
#define _REMOTE_DEBUGGING_BINARYWRITER___ENTER___METHODDEF \
|
|
{"__enter__", (PyCFunction)_remote_debugging_BinaryWriter___enter__, METH_NOARGS, _remote_debugging_BinaryWriter___enter____doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryWriter___enter___impl(BinaryWriterObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryWriter___enter__(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
return _remote_debugging_BinaryWriter___enter___impl((BinaryWriterObject *)self);
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryWriter___exit____doc__,
|
|
"__exit__($self, /, exc_type=None, exc_val=None, exc_tb=None)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Exit context manager, finalizing the file.");
|
|
|
|
#define _REMOTE_DEBUGGING_BINARYWRITER___EXIT___METHODDEF \
|
|
{"__exit__", _PyCFunction_CAST(_remote_debugging_BinaryWriter___exit__), METH_FASTCALL|METH_KEYWORDS, _remote_debugging_BinaryWriter___exit____doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryWriter___exit___impl(BinaryWriterObject *self,
|
|
PyObject *exc_type,
|
|
PyObject *exc_val,
|
|
PyObject *exc_tb);
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryWriter___exit__(PyObject *self, PyObject *const *args, Py_ssize_t nargs, PyObject *kwnames)
|
|
{
|
|
PyObject *return_value = NULL;
|
|
#if defined(Py_BUILD_CORE) && !defined(Py_BUILD_CORE_MODULE)
|
|
|
|
#define NUM_KEYWORDS 3
|
|
static struct {
|
|
PyGC_Head _this_is_not_used;
|
|
PyObject_VAR_HEAD
|
|
Py_hash_t ob_hash;
|
|
PyObject *ob_item[NUM_KEYWORDS];
|
|
} _kwtuple = {
|
|
.ob_base = PyVarObject_HEAD_INIT(&PyTuple_Type, NUM_KEYWORDS)
|
|
.ob_hash = -1,
|
|
.ob_item = { &_Py_ID(exc_type), &_Py_ID(exc_val), &_Py_ID(exc_tb), },
|
|
};
|
|
#undef NUM_KEYWORDS
|
|
#define KWTUPLE (&_kwtuple.ob_base.ob_base)
|
|
|
|
#else // !Py_BUILD_CORE
|
|
# define KWTUPLE NULL
|
|
#endif // !Py_BUILD_CORE
|
|
|
|
static const char * const _keywords[] = {"exc_type", "exc_val", "exc_tb", NULL};
|
|
static _PyArg_Parser _parser = {
|
|
.keywords = _keywords,
|
|
.fname = "__exit__",
|
|
.kwtuple = KWTUPLE,
|
|
};
|
|
#undef KWTUPLE
|
|
PyObject *argsbuf[3];
|
|
Py_ssize_t noptargs = nargs + (kwnames ? PyTuple_GET_SIZE(kwnames) : 0) - 0;
|
|
PyObject *exc_type = Py_None;
|
|
PyObject *exc_val = Py_None;
|
|
PyObject *exc_tb = Py_None;
|
|
|
|
args = _PyArg_UnpackKeywords(args, nargs, NULL, kwnames, &_parser,
|
|
/*minpos*/ 0, /*maxpos*/ 3, /*minkw*/ 0, /*varpos*/ 0, argsbuf);
|
|
if (!args) {
|
|
goto exit;
|
|
}
|
|
if (!noptargs) {
|
|
goto skip_optional_pos;
|
|
}
|
|
if (args[0]) {
|
|
exc_type = args[0];
|
|
if (!--noptargs) {
|
|
goto skip_optional_pos;
|
|
}
|
|
}
|
|
if (args[1]) {
|
|
exc_val = args[1];
|
|
if (!--noptargs) {
|
|
goto skip_optional_pos;
|
|
}
|
|
}
|
|
exc_tb = args[2];
|
|
skip_optional_pos:
|
|
return_value = _remote_debugging_BinaryWriter___exit___impl((BinaryWriterObject *)self, exc_type, exc_val, exc_tb);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryWriter_get_stats__doc__,
|
|
"get_stats($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Get encoding statistics for the writer.\n"
|
|
"\n"
|
|
"Returns a dict with encoding statistics including repeat/full/suffix/pop-push\n"
|
|
"record counts, frames written/saved, and compression ratio.");
|
|
|
|
#define _REMOTE_DEBUGGING_BINARYWRITER_GET_STATS_METHODDEF \
|
|
{"get_stats", (PyCFunction)_remote_debugging_BinaryWriter_get_stats, METH_NOARGS, _remote_debugging_BinaryWriter_get_stats__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryWriter_get_stats_impl(BinaryWriterObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryWriter_get_stats(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
return _remote_debugging_BinaryWriter_get_stats_impl((BinaryWriterObject *)self);
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryReader___init____doc__,
|
|
"BinaryReader(filename)\n"
|
|
"--\n"
|
|
"\n"
|
|
"High-performance binary reader for profiling data.\n"
|
|
"\n"
|
|
"Arguments:\n"
|
|
" filename: Path to input file\n"
|
|
"\n"
|
|
"Use as a context manager or call close() when done.");
|
|
|
|
static int
|
|
_remote_debugging_BinaryReader___init___impl(BinaryReaderObject *self,
|
|
const char *filename);
|
|
|
|
static int
|
|
_remote_debugging_BinaryReader___init__(PyObject *self, PyObject *args, PyObject *kwargs)
|
|
{
|
|
int return_value = -1;
|
|
#if defined(Py_BUILD_CORE) && !defined(Py_BUILD_CORE_MODULE)
|
|
|
|
#define NUM_KEYWORDS 1
|
|
static struct {
|
|
PyGC_Head _this_is_not_used;
|
|
PyObject_VAR_HEAD
|
|
Py_hash_t ob_hash;
|
|
PyObject *ob_item[NUM_KEYWORDS];
|
|
} _kwtuple = {
|
|
.ob_base = PyVarObject_HEAD_INIT(&PyTuple_Type, NUM_KEYWORDS)
|
|
.ob_hash = -1,
|
|
.ob_item = { &_Py_ID(filename), },
|
|
};
|
|
#undef NUM_KEYWORDS
|
|
#define KWTUPLE (&_kwtuple.ob_base.ob_base)
|
|
|
|
#else // !Py_BUILD_CORE
|
|
# define KWTUPLE NULL
|
|
#endif // !Py_BUILD_CORE
|
|
|
|
static const char * const _keywords[] = {"filename", NULL};
|
|
static _PyArg_Parser _parser = {
|
|
.keywords = _keywords,
|
|
.fname = "BinaryReader",
|
|
.kwtuple = KWTUPLE,
|
|
};
|
|
#undef KWTUPLE
|
|
PyObject *argsbuf[1];
|
|
PyObject * const *fastargs;
|
|
Py_ssize_t nargs = PyTuple_GET_SIZE(args);
|
|
const char *filename;
|
|
|
|
fastargs = _PyArg_UnpackKeywords(_PyTuple_CAST(args)->ob_item, nargs, kwargs, NULL, &_parser,
|
|
/*minpos*/ 1, /*maxpos*/ 1, /*minkw*/ 0, /*varpos*/ 0, argsbuf);
|
|
if (!fastargs) {
|
|
goto exit;
|
|
}
|
|
if (!PyUnicode_Check(fastargs[0])) {
|
|
_PyArg_BadArgument("BinaryReader", "argument 'filename'", "str", fastargs[0]);
|
|
goto exit;
|
|
}
|
|
Py_ssize_t filename_length;
|
|
filename = PyUnicode_AsUTF8AndSize(fastargs[0], &filename_length);
|
|
if (filename == NULL) {
|
|
goto exit;
|
|
}
|
|
if (strlen(filename) != (size_t)filename_length) {
|
|
PyErr_SetString(PyExc_ValueError, "embedded null character");
|
|
goto exit;
|
|
}
|
|
return_value = _remote_debugging_BinaryReader___init___impl((BinaryReaderObject *)self, filename);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryReader_replay__doc__,
|
|
"replay($self, /, collector, progress_callback=None)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Replay samples through a collector.\n"
|
|
"\n"
|
|
"Arguments:\n"
|
|
" collector: Collector object with collect() method\n"
|
|
" progress_callback: Optional callable(current, total)\n"
|
|
"\n"
|
|
"Returns:\n"
|
|
" Number of samples replayed");
|
|
|
|
#define _REMOTE_DEBUGGING_BINARYREADER_REPLAY_METHODDEF \
|
|
{"replay", _PyCFunction_CAST(_remote_debugging_BinaryReader_replay), METH_FASTCALL|METH_KEYWORDS, _remote_debugging_BinaryReader_replay__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryReader_replay_impl(BinaryReaderObject *self,
|
|
PyObject *collector,
|
|
PyObject *progress_callback);
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryReader_replay(PyObject *self, PyObject *const *args, Py_ssize_t nargs, PyObject *kwnames)
|
|
{
|
|
PyObject *return_value = NULL;
|
|
#if defined(Py_BUILD_CORE) && !defined(Py_BUILD_CORE_MODULE)
|
|
|
|
#define NUM_KEYWORDS 2
|
|
static struct {
|
|
PyGC_Head _this_is_not_used;
|
|
PyObject_VAR_HEAD
|
|
Py_hash_t ob_hash;
|
|
PyObject *ob_item[NUM_KEYWORDS];
|
|
} _kwtuple = {
|
|
.ob_base = PyVarObject_HEAD_INIT(&PyTuple_Type, NUM_KEYWORDS)
|
|
.ob_hash = -1,
|
|
.ob_item = { &_Py_ID(collector), &_Py_ID(progress_callback), },
|
|
};
|
|
#undef NUM_KEYWORDS
|
|
#define KWTUPLE (&_kwtuple.ob_base.ob_base)
|
|
|
|
#else // !Py_BUILD_CORE
|
|
# define KWTUPLE NULL
|
|
#endif // !Py_BUILD_CORE
|
|
|
|
static const char * const _keywords[] = {"collector", "progress_callback", NULL};
|
|
static _PyArg_Parser _parser = {
|
|
.keywords = _keywords,
|
|
.fname = "replay",
|
|
.kwtuple = KWTUPLE,
|
|
};
|
|
#undef KWTUPLE
|
|
PyObject *argsbuf[2];
|
|
Py_ssize_t noptargs = nargs + (kwnames ? PyTuple_GET_SIZE(kwnames) : 0) - 1;
|
|
PyObject *collector;
|
|
PyObject *progress_callback = Py_None;
|
|
|
|
args = _PyArg_UnpackKeywords(args, nargs, NULL, kwnames, &_parser,
|
|
/*minpos*/ 1, /*maxpos*/ 2, /*minkw*/ 0, /*varpos*/ 0, argsbuf);
|
|
if (!args) {
|
|
goto exit;
|
|
}
|
|
collector = args[0];
|
|
if (!noptargs) {
|
|
goto skip_optional_pos;
|
|
}
|
|
progress_callback = args[1];
|
|
skip_optional_pos:
|
|
return_value = _remote_debugging_BinaryReader_replay_impl((BinaryReaderObject *)self, collector, progress_callback);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryReader_get_info__doc__,
|
|
"get_info($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Get metadata about the binary file.\n"
|
|
"\n"
|
|
"Returns:\n"
|
|
" Dict with file metadata");
|
|
|
|
#define _REMOTE_DEBUGGING_BINARYREADER_GET_INFO_METHODDEF \
|
|
{"get_info", (PyCFunction)_remote_debugging_BinaryReader_get_info, METH_NOARGS, _remote_debugging_BinaryReader_get_info__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryReader_get_info_impl(BinaryReaderObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryReader_get_info(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
return _remote_debugging_BinaryReader_get_info_impl((BinaryReaderObject *)self);
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryReader_get_stats__doc__,
|
|
"get_stats($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Get reconstruction statistics from replay.\n"
|
|
"\n"
|
|
"Returns a dict with statistics about record types decoded and samples\n"
|
|
"reconstructed during replay.");
|
|
|
|
#define _REMOTE_DEBUGGING_BINARYREADER_GET_STATS_METHODDEF \
|
|
{"get_stats", (PyCFunction)_remote_debugging_BinaryReader_get_stats, METH_NOARGS, _remote_debugging_BinaryReader_get_stats__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryReader_get_stats_impl(BinaryReaderObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryReader_get_stats(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
return _remote_debugging_BinaryReader_get_stats_impl((BinaryReaderObject *)self);
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryReader_close__doc__,
|
|
"close($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Close the reader and free resources.");
|
|
|
|
#define _REMOTE_DEBUGGING_BINARYREADER_CLOSE_METHODDEF \
|
|
{"close", (PyCFunction)_remote_debugging_BinaryReader_close, METH_NOARGS, _remote_debugging_BinaryReader_close__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryReader_close_impl(BinaryReaderObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryReader_close(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
return _remote_debugging_BinaryReader_close_impl((BinaryReaderObject *)self);
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryReader___enter____doc__,
|
|
"__enter__($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Enter context manager.");
|
|
|
|
#define _REMOTE_DEBUGGING_BINARYREADER___ENTER___METHODDEF \
|
|
{"__enter__", (PyCFunction)_remote_debugging_BinaryReader___enter__, METH_NOARGS, _remote_debugging_BinaryReader___enter____doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryReader___enter___impl(BinaryReaderObject *self);
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryReader___enter__(PyObject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
return _remote_debugging_BinaryReader___enter___impl((BinaryReaderObject *)self);
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_BinaryReader___exit____doc__,
|
|
"__exit__($self, /, exc_type=None, exc_val=None, exc_tb=None)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Exit context manager, closing the file.");
|
|
|
|
#define _REMOTE_DEBUGGING_BINARYREADER___EXIT___METHODDEF \
|
|
{"__exit__", _PyCFunction_CAST(_remote_debugging_BinaryReader___exit__), METH_FASTCALL|METH_KEYWORDS, _remote_debugging_BinaryReader___exit____doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryReader___exit___impl(BinaryReaderObject *self,
|
|
PyObject *exc_type,
|
|
PyObject *exc_val,
|
|
PyObject *exc_tb);
|
|
|
|
static PyObject *
|
|
_remote_debugging_BinaryReader___exit__(PyObject *self, PyObject *const *args, Py_ssize_t nargs, PyObject *kwnames)
|
|
{
|
|
PyObject *return_value = NULL;
|
|
#if defined(Py_BUILD_CORE) && !defined(Py_BUILD_CORE_MODULE)
|
|
|
|
#define NUM_KEYWORDS 3
|
|
static struct {
|
|
PyGC_Head _this_is_not_used;
|
|
PyObject_VAR_HEAD
|
|
Py_hash_t ob_hash;
|
|
PyObject *ob_item[NUM_KEYWORDS];
|
|
} _kwtuple = {
|
|
.ob_base = PyVarObject_HEAD_INIT(&PyTuple_Type, NUM_KEYWORDS)
|
|
.ob_hash = -1,
|
|
.ob_item = { &_Py_ID(exc_type), &_Py_ID(exc_val), &_Py_ID(exc_tb), },
|
|
};
|
|
#undef NUM_KEYWORDS
|
|
#define KWTUPLE (&_kwtuple.ob_base.ob_base)
|
|
|
|
#else // !Py_BUILD_CORE
|
|
# define KWTUPLE NULL
|
|
#endif // !Py_BUILD_CORE
|
|
|
|
static const char * const _keywords[] = {"exc_type", "exc_val", "exc_tb", NULL};
|
|
static _PyArg_Parser _parser = {
|
|
.keywords = _keywords,
|
|
.fname = "__exit__",
|
|
.kwtuple = KWTUPLE,
|
|
};
|
|
#undef KWTUPLE
|
|
PyObject *argsbuf[3];
|
|
Py_ssize_t noptargs = nargs + (kwnames ? PyTuple_GET_SIZE(kwnames) : 0) - 0;
|
|
PyObject *exc_type = Py_None;
|
|
PyObject *exc_val = Py_None;
|
|
PyObject *exc_tb = Py_None;
|
|
|
|
args = _PyArg_UnpackKeywords(args, nargs, NULL, kwnames, &_parser,
|
|
/*minpos*/ 0, /*maxpos*/ 3, /*minkw*/ 0, /*varpos*/ 0, argsbuf);
|
|
if (!args) {
|
|
goto exit;
|
|
}
|
|
if (!noptargs) {
|
|
goto skip_optional_pos;
|
|
}
|
|
if (args[0]) {
|
|
exc_type = args[0];
|
|
if (!--noptargs) {
|
|
goto skip_optional_pos;
|
|
}
|
|
}
|
|
if (args[1]) {
|
|
exc_val = args[1];
|
|
if (!--noptargs) {
|
|
goto skip_optional_pos;
|
|
}
|
|
}
|
|
exc_tb = args[2];
|
|
skip_optional_pos:
|
|
return_value = _remote_debugging_BinaryReader___exit___impl((BinaryReaderObject *)self, exc_type, exc_val, exc_tb);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_zstd_available__doc__,
|
|
"zstd_available($module, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Check if zstd compression is available.\n"
|
|
"\n"
|
|
"Returns:\n"
|
|
" True if zstd available, False otherwise");
|
|
|
|
#define _REMOTE_DEBUGGING_ZSTD_AVAILABLE_METHODDEF \
|
|
{"zstd_available", (PyCFunction)_remote_debugging_zstd_available, METH_NOARGS, _remote_debugging_zstd_available__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_zstd_available_impl(PyObject *module);
|
|
|
|
static PyObject *
|
|
_remote_debugging_zstd_available(PyObject *module, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
return _remote_debugging_zstd_available_impl(module);
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_get_child_pids__doc__,
|
|
"get_child_pids($module, /, pid, *, recursive=True)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Get all child process IDs of the given process.\n"
|
|
"\n"
|
|
" pid\n"
|
|
" Process ID of the parent process\n"
|
|
" recursive\n"
|
|
" If True, return all descendants (children, grandchildren, etc.).\n"
|
|
" If False, return only direct children.\n"
|
|
"\n"
|
|
"Returns a list of child process IDs. Returns an empty list if no children\n"
|
|
"are found.\n"
|
|
"\n"
|
|
"This function provides a snapshot of child processes at a moment in time.\n"
|
|
"Child processes may exit or new ones may be created after the list is returned.\n"
|
|
"\n"
|
|
"Raises:\n"
|
|
" OSError: If unable to enumerate processes\n"
|
|
" NotImplementedError: If not supported on this platform");
|
|
|
|
#define _REMOTE_DEBUGGING_GET_CHILD_PIDS_METHODDEF \
|
|
{"get_child_pids", _PyCFunction_CAST(_remote_debugging_get_child_pids), METH_FASTCALL|METH_KEYWORDS, _remote_debugging_get_child_pids__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_get_child_pids_impl(PyObject *module, int pid,
|
|
int recursive);
|
|
|
|
static PyObject *
|
|
_remote_debugging_get_child_pids(PyObject *module, PyObject *const *args, Py_ssize_t nargs, PyObject *kwnames)
|
|
{
|
|
PyObject *return_value = NULL;
|
|
#if defined(Py_BUILD_CORE) && !defined(Py_BUILD_CORE_MODULE)
|
|
|
|
#define NUM_KEYWORDS 2
|
|
static struct {
|
|
PyGC_Head _this_is_not_used;
|
|
PyObject_VAR_HEAD
|
|
Py_hash_t ob_hash;
|
|
PyObject *ob_item[NUM_KEYWORDS];
|
|
} _kwtuple = {
|
|
.ob_base = PyVarObject_HEAD_INIT(&PyTuple_Type, NUM_KEYWORDS)
|
|
.ob_hash = -1,
|
|
.ob_item = { &_Py_ID(pid), &_Py_ID(recursive), },
|
|
};
|
|
#undef NUM_KEYWORDS
|
|
#define KWTUPLE (&_kwtuple.ob_base.ob_base)
|
|
|
|
#else // !Py_BUILD_CORE
|
|
# define KWTUPLE NULL
|
|
#endif // !Py_BUILD_CORE
|
|
|
|
static const char * const _keywords[] = {"pid", "recursive", NULL};
|
|
static _PyArg_Parser _parser = {
|
|
.keywords = _keywords,
|
|
.fname = "get_child_pids",
|
|
.kwtuple = KWTUPLE,
|
|
};
|
|
#undef KWTUPLE
|
|
PyObject *argsbuf[2];
|
|
Py_ssize_t noptargs = nargs + (kwnames ? PyTuple_GET_SIZE(kwnames) : 0) - 1;
|
|
int pid;
|
|
int recursive = 1;
|
|
|
|
args = _PyArg_UnpackKeywords(args, nargs, NULL, kwnames, &_parser,
|
|
/*minpos*/ 1, /*maxpos*/ 1, /*minkw*/ 0, /*varpos*/ 0, argsbuf);
|
|
if (!args) {
|
|
goto exit;
|
|
}
|
|
pid = PyLong_AsInt(args[0]);
|
|
if (pid == -1 && PyErr_Occurred()) {
|
|
goto exit;
|
|
}
|
|
if (!noptargs) {
|
|
goto skip_optional_kwonly;
|
|
}
|
|
recursive = PyObject_IsTrue(args[1]);
|
|
if (recursive < 0) {
|
|
goto exit;
|
|
}
|
|
skip_optional_kwonly:
|
|
return_value = _remote_debugging_get_child_pids_impl(module, pid, recursive);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_remote_debugging_is_python_process__doc__,
|
|
"is_python_process($module, /, pid)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Check if a process is a Python process.");
|
|
|
|
#define _REMOTE_DEBUGGING_IS_PYTHON_PROCESS_METHODDEF \
|
|
{"is_python_process", _PyCFunction_CAST(_remote_debugging_is_python_process), METH_FASTCALL|METH_KEYWORDS, _remote_debugging_is_python_process__doc__},
|
|
|
|
static PyObject *
|
|
_remote_debugging_is_python_process_impl(PyObject *module, int pid);
|
|
|
|
static PyObject *
|
|
_remote_debugging_is_python_process(PyObject *module, PyObject *const *args, Py_ssize_t nargs, PyObject *kwnames)
|
|
{
|
|
PyObject *return_value = NULL;
|
|
#if defined(Py_BUILD_CORE) && !defined(Py_BUILD_CORE_MODULE)
|
|
|
|
#define NUM_KEYWORDS 1
|
|
static struct {
|
|
PyGC_Head _this_is_not_used;
|
|
PyObject_VAR_HEAD
|
|
Py_hash_t ob_hash;
|
|
PyObject *ob_item[NUM_KEYWORDS];
|
|
} _kwtuple = {
|
|
.ob_base = PyVarObject_HEAD_INIT(&PyTuple_Type, NUM_KEYWORDS)
|
|
.ob_hash = -1,
|
|
.ob_item = { &_Py_ID(pid), },
|
|
};
|
|
#undef NUM_KEYWORDS
|
|
#define KWTUPLE (&_kwtuple.ob_base.ob_base)
|
|
|
|
#else // !Py_BUILD_CORE
|
|
# define KWTUPLE NULL
|
|
#endif // !Py_BUILD_CORE
|
|
|
|
static const char * const _keywords[] = {"pid", NULL};
|
|
static _PyArg_Parser _parser = {
|
|
.keywords = _keywords,
|
|
.fname = "is_python_process",
|
|
.kwtuple = KWTUPLE,
|
|
};
|
|
#undef KWTUPLE
|
|
PyObject *argsbuf[1];
|
|
int pid;
|
|
|
|
args = _PyArg_UnpackKeywords(args, nargs, NULL, kwnames, &_parser,
|
|
/*minpos*/ 1, /*maxpos*/ 1, /*minkw*/ 0, /*varpos*/ 0, argsbuf);
|
|
if (!args) {
|
|
goto exit;
|
|
}
|
|
pid = PyLong_AsInt(args[0]);
|
|
if (pid == -1 && PyErr_Occurred()) {
|
|
goto exit;
|
|
}
|
|
return_value = _remote_debugging_is_python_process_impl(module, pid);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
/*[clinic end generated code: output=34f50b18f317b9b6 input=a9049054013a1b77]*/
|