| /*[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]*/ |