pythonVSCode/pythonFiles/PythonTools/ptvsd/attach_server.py at master · roofxixi/pythonVSCode · GitHub

History

330 lines (282 loc) · 13.2 KB

Raw

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

311

312

313

314

315

316

317

318

319

320

321

322

323

324

325

326

327

328

329

330

# Python Tools for Visual Studio

# Copyright(c) Microsoft Corporation

# Licensed under the Apache License, Version 2.0 (the License); you may not use

# this file except in compliance with the License. You may obtain a copy of the

# License at http://www.apache.org/licenses/LICENSE-2.0

# THIS CODE IS PROVIDED ON AN *AS IS* BASIS, WITHOUT WARRANTIES OR CONDITIONS

# OF ANY KIND, EITHER EXPRESS OR IMPLIED, INCLUDING WITHOUT LIMITATION ANY

# IMPLIED WARRANTIES OR CONDITIONS OF TITLE, FITNESS FOR A PARTICULAR PURPOSE,

# MERCHANTABLITY OR NON-INFRINGEMENT.

# See the Apache Version 2.0 License for specific language governing

# permissions and limitations under the License.

__author__ = "Microsoft Corporation <ptvshelp@microsoft.com>"

__version__ = "3.0.0.0"

__all__ = ['enable_attach', 'wait_for_attach', 'break_into_debugger', 'settrace', 'is_attached', 'AttachAlreadyEnabledError']

import atexit

import getpass

import os

import os.path

import platform

import socket

import struct

import sys

import threading

try:

import thread

except ImportError:

import _thread as thread

try:

import ssl

except ImportError:

ssl = None

import ptvsd.visualstudio_py_debugger as vspd

import ptvsd.visualstudio_py_repl as vspr

from ptvsd.visualstudio_py_util import to_bytes, read_bytes, read_int, read_string, write_bytes, write_int, write_string

# The server (i.e. the Python app) waits on a TCP port provided. Whenever anything connects to that port,

# it immediately sends the octet sequence 'PTVSDBG', followed by version number represented as int64,

# and then waits for the client to respond with the same exact byte sequence. After signatures are thereby

# exchanged and found to match, the client is expected to provide a string secret (in the usual debugger

# string format, None/ACII/Unicode prefix + length + data), which can be an empty string to designate the

# lack of a specified secret.

# If the secret does not match the one expected by the server, it responds with 'RJCT', and then closes

# the connection. Otherwise, the server responds with 'ACPT', and awaits a 4-octet command. The following

# commands are recognized:

# 'INFO'

# Report information about the process. The server responds with the following information, in order:

# - Process ID (int64)

# - Executable name (string)

# - User name (string)

# - Implementation name (string)

# and then immediately closes connection. Note, all string fields can be empty or null strings.

# 'ATCH'

# Attach debugger to the process. If successful, the server responds with 'ACPT', followed by process ID

# (int64), and then the Python language version that the server is running represented by three int64s -

# major, minor, micro; From there on the socket is assumed to be using the normal PTVS debugging protocol.

# If attaching was not successful (which can happen if some other debugger is already attached), the server

# responds with 'RJCT' and closes the connection.

# 'REPL'

# Attach REPL to the process. If successful, the server responds with 'ACPT', and from there on the socket

# is assumed to be using the normal PTVS REPL protocol. If not successful (which can happen if there is

# no debugger attached), the server responds with 'RJCT' and closes the connection.

PTVS_VER = '2.2'

DEFAULT_PORT = 5678

PTVSDBG_VER = 6 # must be kept in sync with DebuggerProtocolVersion in PythonRemoteProcess.cs

PTVSDBG = to_bytes('PTVSDBG')

ACPT = to_bytes('ACPT')

RJCT = to_bytes('RJCT')

INFO = to_bytes('INFO')

ATCH = to_bytes('ATCH')

REPL = to_bytes('REPL')

_attach_enabled = False

_attached = threading.Event()

vspd.DONT_DEBUG.append(os.path.normcase(__file__))

class AttachAlreadyEnabledError(Exception):

"""`ptvsd.enable_attach` has already been called in this process."""

def enable_attach(secret, address = ('0.0.0.0', DEFAULT_PORT), certfile = None, keyfile = None, redirect_output = True):

"""Enables Python Tools for Visual Studio to attach to this process remotely

to debug Python code.

Parameters

----------

secret : str

Used to validate the clients - only those clients providing the valid

secret will be allowed to connect to this server. On client side, the

secret is prepended to the Qualifier string, separated from the

hostname by ``'@'``, e.g.: ``'secret@myhost.cloudapp.net:5678'``. If

secret is ``None``, there's no validation, and any client can connect

freely.

address : (str, int), optional

Specifies the interface and port on which the debugging server should

listen for TCP connections. It is in the same format as used for

regular sockets of the `socket.AF_INET` family, i.e. a tuple of

``(hostname, port)``. On client side, the server is identified by the

Qualifier string in the usual ``'hostname:port'`` format, e.g.:

``'myhost.cloudapp.net:5678'``. Default is ``('0.0.0.0', 5678)``.

certfile : str, optional

Used to enable SSL. If not specified, or if set to ``None``, the

connection between this program and the debugger will be unsecure,

and can be intercepted on the wire. If specified, the meaning of this

parameter is the same as for `ssl.wrap_socket`.

keyfile : str, optional

Used together with `certfile` when SSL is enabled. Its meaning is the

same as for ``ssl.wrap_socket``.

redirect_output : bool, optional

Specifies whether any output (on both `stdout` and `stderr`) produced

by this program should be sent to the debugger. Default is ``True``.

Notes

-----

This function returns immediately after setting up the debugging server,

and does not block program execution. If you need to block until debugger

is attached, call `ptvsd.wait_for_attach`. The debugger can be detached

and re-attached multiple times after `enable_attach` is called.

This function can only be called once during the lifetime of the process.

On a second call, `AttachAlreadyEnabledError` is raised. In circumstances

where the caller does not control how many times the function will be

called (e.g. when a script with a single call is run more than once by

a hosting app or framework), the call should be wrapped in ``try..except``.

Only the thread on which this function is called, and any threads that are

created after it returns, will be visible in the debugger once it is

attached. Any threads that are already running before this function is

called will not be visible.

"""

if not ssl and (certfile or keyfile):

raise ValueError('could not import the ssl module - SSL is not supported on this version of Python')

if sys.platform == 'cli':

# Check that IronPython was launched with -X:Frames and -X:Tracing, since we can't register our trace

# func on the thread that calls enable_attach otherwise

import clr

x_tracing = clr.GetCurrentRuntime().GetLanguageByExtension('py').Options.Tracing

x_frames = clr.GetCurrentRuntime().GetLanguageByExtension('py').Options.Frames

if not x_tracing or not x_frames:

raise RuntimeError('IronPython must be started with -X:Tracing and -X:Frames options to support PTVS remote debugging.')

global _attach_enabled

if _attach_enabled:

raise AttachAlreadyEnabledError('ptvsd.enable_attach() has already been called in this process.')

_attach_enabled = True

atexit.register(vspd.detach_process_and_notify_debugger)

server = socket.socket(proto=socket.IPPROTO_TCP)

server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

server.bind(address)

server.listen(1)

def server_thread_func():

while True:

client = None

raw_client = None

try:

client, addr = server.accept()

if certfile:

client = ssl.wrap_socket(client, server_side = True, ssl_version = ssl.PROTOCOL_TLSv1, certfile = certfile, keyfile = keyfile)

write_bytes(client, PTVSDBG)

write_int(client, PTVSDBG_VER)

response = read_bytes(client, 7)

if response != PTVSDBG:

continue

dbg_ver = read_int(client)

if dbg_ver != PTVSDBG_VER:

continue

client_secret = read_string(client)

if secret is None or secret == client_secret:

write_bytes(client, ACPT)

else:

write_bytes(client, RJCT)

continue

response = read_bytes(client, 4)

if response == INFO:

try:

pid = os.getpid()

except AttributeError:

pid = 0

write_int(client, pid)

exe = sys.executable or ''

write_string(client, exe)

try:

username = getpass.getuser()

except AttributeError:

username = ''

write_string(client, username)

try:

impl = platform.python_implementation()

except AttributeError:

try:

impl = sys.implementation.name

except AttributeError:

impl = 'Python'

major, minor, micro, release_level, serial = sys.version_info

os_and_arch = platform.system()

if os_and_arch == "":

os_and_arch = sys.platform

try:

if sys.maxsize > 2**32:

os_and_arch += ' 64-bit'

else:

os_and_arch += ' 32-bit'

except AttributeError:

pass

version = '%s %s.%s.%s (%s)' % (impl, major, minor, micro, os_and_arch)

write_string(client, version)

# Don't just drop the connection - let the debugger close it after it finishes reading.

client.recv(1)

elif response == ATCH:

debug_options = vspd.parse_debug_options(read_string(client))

if redirect_output:

debug_options.add('RedirectOutput')

if vspd.DETACHED:

write_bytes(client, ACPT)

try:

pid = os.getpid()

except AttributeError:

pid = 0

write_int(client, pid)

major, minor, micro, release_level, serial = sys.version_info

write_int(client, major)

write_int(client, minor)

write_int(client, micro)

vspd.attach_process_from_socket(client, debug_options, report = True)

vspd.mark_all_threads_for_break(vspd.STEPPING_ATTACH_BREAK)

_attached.set()

client = None

else:

write_bytes(client, RJCT)

elif response == REPL:

if not vspd.DETACHED:

write_bytes(client, ACPT)

vspd.connect_repl_using_socket(client)

client = None

else:

write_bytes(client, RJCT)

except (socket.error, OSError):

pass

finally:

if client is not None:

client.close()

server_thread = threading.Thread(target = server_thread_func)

server_thread.setDaemon(True)

server_thread.start()

frames = []

f = sys._getframe()

while True:

f = f.f_back

if f is None:

break

frames.append(f)

frames.reverse()

cur_thread = vspd.new_thread()

for f in frames:

cur_thread.push_frame(f)

def replace_trace_func():

for f in frames:

f.f_trace = cur_thread.trace_func

replace_trace_func()

sys.settrace(cur_thread.trace_func)

vspd.intercept_threads(for_attach = True)

# Alias for convenience of users of pydevd

settrace = enable_attach

def wait_for_attach(timeout = None):

"""If a PTVS remote debugger is attached, returns immediately. Otherwise,

blocks until a remote debugger attaches to this process, or until the

optional timeout occurs.

Parameters

----------

timeout : float, optional

The timeout for the operation in seconds (or fractions thereof).

"""

if vspd.DETACHED:

_attached.clear()

_attached.wait(timeout)

def break_into_debugger():

"""If a PTVS remote debugger is attached, pauses execution of all threads,

and breaks into the debugger with current thread as active.

"""

if not vspd.DETACHED:

vspd.SEND_BREAK_COMPLETE = thread.get_ident()

vspd.mark_all_threads_for_break()

def is_attached():

"""Returns ``True`` if debugger is attached, ``False`` otherwise."""

return not vspd.DETACHED

pythonVSCode/pythonFiles/PythonTools/ptvsd/attach_server.py at master · roofxixi/pythonVSCode · GitHub

Expand file tree

Breadcrumbs

attach_server.py

Latest commit

History

Breadcrumbs

attach_server.py

File metadata and controls