Lines Matching refs:self
92 def __init__(self): argument
93 self.packetLog = []
95 def respond(self, packet): argument
100 self.packetLog.append(packet)
102 return self.interrupt()
104 return self.cont()
106 return self.vCont(packet)
108 return self.A(packet)
110 return self.D(packet)
112 return self.readRegisters()
116 return self.writeRegisters(packet[1:].split(';')[0])
119 return self.readRegister(int(regnum, 16))
122 return self.writeRegister(int(register, 16), value)
125 return self.readMemory(addr, length)
129 return self.writeMemory(addr, encoded_data)
131 return self.qSymbol(packet[8:])
133 return self.qSupported(packet[11:].split(";"))
135 return self.qfThreadInfo()
137 return self.qsThreadInfo()
139 return self.qC()
141 return self.QEnableErrorStrings()
143 return self.haltReason()
145 return self.haltReason()
152 return self.selectThread(packet[1], int(tid, 16))
156 data, has_more = self.qXferRead(obj, annex, offset, length)
158 return self._qXferResponse(data, has_more)
162 return self.vAttach(int(pid, 16))
164 return self.setBreakpoint(packet)
167 return self.threadStopInfo(threadnum)
169 return self.QThreadSuffixSupported()
171 return self.QListThreadsInStopReply()
173 return self.qMemoryRegionInfo(int(packet.split(':')[1], 16))
175 return self.qQueryGDBServer()
177 return self.qHostInfo()
179 return self.qGetWorkingDir()
181 return self.qOffsets();
183 return self.qProcessInfo()
185 return self.qsProcessInfo()
187 return self.qfProcessInfo(packet)
189 return self.jGetLoadedDynamicLibrariesInfos(packet)
191 return self.qPathComplete()
193 return self.vFile(packet)
195 return self.vRun(packet)
197 return self.qLaunchSuccess()
199 return self.QEnvironment(packet)
201 return self.QEnvironmentHexEncoded(packet)
204 return self.qRegisterInfo(regnum)
206 return self.k()
208 return self.other(packet)
210 def qsProcessInfo(self): argument
213 def qfProcessInfo(self, packet): argument
216 def jGetLoadedDynamicLibrariesInfos(self, packet): argument
219 def qGetWorkingDir(self): argument
222 def qOffsets(self): argument
225 def qProcessInfo(self): argument
228 def qHostInfo(self): argument
231 def qQueryGDBServer(self): argument
234 def interrupt(self): argument
235 raise self.UnexpectedPacketException()
237 def cont(self): argument
238 raise self.UnexpectedPacketException()
240 def vCont(self, packet): argument
241 raise self.UnexpectedPacketException()
243 def A(self, packet): argument
246 def D(self, packet): argument
249 def readRegisters(self): argument
250 return "00000000" * self.registerCount
252 def readRegister(self, register): argument
255 def writeRegisters(self, registers_hex): argument
258 def writeRegister(self, register, value_hex): argument
261 def readMemory(self, addr, length): argument
264 def writeMemory(self, addr, data_hex): argument
267 def qSymbol(self, symbol_args): argument
270 def qSupported(self, client_supported): argument
273 def qfThreadInfo(self): argument
276 def qsThreadInfo(self): argument
279 def qC(self): argument
282 def QEnableErrorStrings(self): argument
285 def haltReason(self): argument
289 def qXferRead(self, obj, annex, offset, length): argument
292 def _qXferResponse(self, data, has_more): argument
295 def vAttach(self, pid): argument
296 raise self.UnexpectedPacketException()
298 def selectThread(self, op, thread_id): argument
301 def setBreakpoint(self, packet): argument
302 raise self.UnexpectedPacketException()
304 def threadStopInfo(self, threadnum): argument
307 def other(self, packet): argument
311 def QThreadSuffixSupported(self): argument
314 def QListThreadsInStopReply(self): argument
317 def qMemoryRegionInfo(self, addr): argument
320 def qPathComplete(self): argument
323 def vFile(self, packet): argument
326 def vRun(self, packet): argument
329 def qLaunchSuccess(self): argument
332 def QEnvironment(self, packet): argument
335 def QEnvironmentHexEncoded(self, packet): argument
338 def qRegisterInfo(self, num): argument
341 def k(self): argument
342 return ["W01", self.RESPONSE_DISCONNECT]
358 def get_connect_address(self): argument
361 def get_connect_url(self): argument
364 def close_server(self): argument
367 def accept(self): argument
370 def close_connection(self): argument
373 def recv(self): argument
376 def sendall(self, data): argument
381 def __init__(self, family, type, proto, addr): argument
382 self._server_socket = socket.socket(family, type, proto)
383 self._connection = None
385 self._server_socket.bind(addr)
386 self._server_socket.listen(1)
388 def close_server(self): argument
389 self._server_socket.close()
391 def accept(self): argument
392 assert self._connection is None
395 self._server_socket.settimeout(30.0)
396 client, client_addr = self._server_socket.accept()
400 self._connection = client
402 def close_connection(self): argument
403 assert self._connection is not None
404 self._connection.close()
405 self._connection = None
407 def recv(self): argument
408 assert self._connection is not None
409 return self._connection.recv(4096)
411 def sendall(self, data): argument
412 assert self._connection is not None
413 return self._connection.sendall(data)
417 def __init__(self): argument
422 def get_connect_address(self): argument
423 return "[{}]:{}".format(*self._server_socket.getsockname())
425 def get_connect_url(self): argument
426 return "connect://" + self.get_connect_address()
430 def __init__(self, addr): argument
433 def get_connect_address(self): argument
434 return self._server_socket.getsockname()
436 def get_connect_url(self): argument
437 return "unix-connect://" + self.get_connect_address()
441 def __init__(self): argument
446 self._primary = io.FileIO(primary, 'r+b')
447 self._secondary = io.FileIO(secondary, 'r+b')
449 def get_connect_address(self): argument
453 return libc.ptsname(self._primary.fileno()).decode()
455 def get_connect_url(self): argument
456 return "serial://" + self.get_connect_address()
458 def close_server(self): argument
459 self._secondary.close()
460 self._primary.close()
462 def recv(self): argument
464 return self._primary.read(4096)
471 def sendall(self, data): argument
472 return self._primary.write(data)
491 def __init__(self, socket): argument
492 self._socket = socket
493 self.responder = MockGDBServerResponder()
495 def start(self): argument
497 self._thread = threading.Thread(target=self.run)
498 self._thread.start()
500 def stop(self): argument
501 self._thread.join()
502 self._thread = None
504 def get_connect_address(self): argument
505 return self._socket.get_connect_address()
507 def get_connect_url(self): argument
508 return self._socket.get_connect_url()
510 def run(self): argument
514 self._socket.accept()
518 self._shouldSendAck = True
519 self._receivedData = ""
520 self._receivedDataOffset = 0
524 data = seven.bitcast_to_string(self._socket.recv())
527 self._receive(data)
528 except self.TerminateConnectionException:
534 self._socket.close_connection()
535 self._socket.close_server()
537 def _receive(self, data): argument
542 self._receivedData += data
543 packet = self._parsePacket()
545 self._handlePacket(packet)
546 packet = self._parsePacket()
548 def _parsePacket(self): argument
561 data = self._receivedData
562 i = self._receivedDataOffset
571 self._receivedData = data[1:]
572 return self.PACKET_ACK
574 self._receivedData = data[1:]
575 return self.PACKET_INTERRUPT
579 raise self.InvalidPacketException(
591 self._receivedDataOffset = i
601 raise self.InvalidPacketException("Checksum is not valid hex")
604 raise self.InvalidPacketException(
609 self._receivedData = data[i:]
610 self._receivedDataOffset = 0
613 def _sendPacket(self, packet): argument
614 self._socket.sendall(seven.bitcast_to_bytes(frame_packet(packet)))
616 def _handlePacket(self, packet): argument
617 if packet is self.PACKET_ACK:
625 if self._shouldSendAck:
626 self._socket.sendall(seven.bitcast_to_bytes('+'))
628 self._shouldSendAck = False
630 elif self.responder is not None:
632 response = self.responder.respond(packet)
637 raise self.TerminateConnectionException()
638 self._sendPacket(part)