Class: Rex::Post::Meterpreter::Extensions::Stdapi::Sys::Thread
- Includes:
- ObjectAliasesContainer
- Defined in:
- lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb
Overview
This class implements the Rex::Post::Thread interface which wrappers a logical thread for a given process.
Instance Attribute Summary collapse
-
#handle ⇒ Object
:nodoc:.
-
#process ⇒ Object
:nodoc:.
-
#tid ⇒ Object
:nodoc:.
Attributes included from ObjectAliasesContainer
Class Method Summary collapse
-
.close(client, handle) ⇒ Object
Closes the thread handle.
- .finalize(client, handle) ⇒ Object
Instance Method Summary collapse
-
#close ⇒ Object
Instance method.
-
#initialize(process, handle, tid) ⇒ Thread
constructor
Initialize the thread instance.
-
#pretty_regs ⇒ Object
Formats the registers in a pretty way.
-
#query_regs ⇒ Object
Queries the register state of the thread.
-
#resume ⇒ Object
Resumes the thread's execution.
-
#set_regs(regs_hash) ⇒ Object
Sets the register state of the thread.
-
#suspend ⇒ Object
Suspends the thread's execution.
-
#terminate(code) ⇒ Object
Terminates the thread's execution.
Methods included from ObjectAliasesContainer
#dump_alias_tree, #initialize_aliases, #method_missing
Constructor Details
#initialize(process, handle, tid) ⇒ Thread
Initialize the thread instance.
33 34 35 36 37 38 39 40 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 33 def initialize(process, handle, tid) self.process = process self.handle = handle self.tid = tid # Ensure the remote object is closed when all references are removed ObjectSpace.define_finalizer(self, self.class.finalize(process.client, handle)) end |
Dynamic Method Handling
This class handles dynamic methods through the method_missing method in the class Rex::Post::Meterpreter::ObjectAliasesContainer
Instance Attribute Details
#handle ⇒ Object
:nodoc:
180 181 182 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 180 def handle @handle end |
#process ⇒ Object
:nodoc:
180 181 182 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 180 def process @process end |
#tid ⇒ Object
:nodoc:
180 181 182 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 180 def tid @tid end |
Class Method Details
.close(client, handle) ⇒ Object
Closes the thread handle.
163 164 165 166 167 168 169 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 163 def self.close(client, handle) request = Packet.create_request(COMMAND_ID_STDAPI_SYS_PROCESS_THREAD_CLOSE) request.add_tlv(TLV_TYPE_THREAD_HANDLE, handle) client.send_request(request, nil) handle = nil return true end |
.finalize(client, handle) ⇒ Object
42 43 44 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 42 def self.finalize(client,handle) proc { self.close(client,handle) } end |
Instance Method Details
#close ⇒ Object
Instance method
172 173 174 175 176 177 178 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 172 def close unless self.handle.nil? ObjectSpace.undefine_finalizer(self) self.class.close(self.process.client, self.handle) self.handle = nil end end |
#pretty_regs ⇒ Object
Formats the registers in a pretty way.
141 142 143 144 145 146 147 148 149 150 151 152 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 141 def pretty_regs regs = query_regs buf = sprintf("eax=%.8x ebx=%.8x ecx=%.8x edx=%.8x esi=%.8x edi=%.8x\n", regs['eax'], regs['ebx'], regs['ecx'], regs['edx'], regs['esi'], regs['edi']) buf += sprintf("eip=%.8x esp=%.8x ebp=%.8x\n", regs['eip'], regs['esp'], regs['ebp']) buf += sprintf("cs=%.4x ss=%.4x ds=%.4x es=%.4x fs=%.4x gs=%.4x\n", regs['cs'], regs['ss'], regs['ds'], regs['es'], regs['fs'], regs['gs']) return buf end |
#query_regs ⇒ Object
Queries the register state of the thread.
101 102 103 104 105 106 107 108 109 110 111 112 113 114 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 101 def query_regs request = Packet.create_request(COMMAND_ID_STDAPI_SYS_PROCESS_THREAD_QUERY_REGS) regs = {} request.add_tlv(TLV_TYPE_THREAD_HANDLE, handle) response = process.client.send_request(request) response.each(TLV_TYPE_REGISTER) { |reg| regs[reg.get_tlv_value(TLV_TYPE_REGISTER_NAME)] = reg.get_tlv_value(TLV_TYPE_REGISTER_VALUE_32) } return regs end |
#resume ⇒ Object
Resumes the thread's execution.
68 69 70 71 72 73 74 75 76 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 68 def resume request = Packet.create_request(COMMAND_ID_STDAPI_SYS_PROCESS_THREAD_RESUME) request.add_tlv(TLV_TYPE_THREAD_HANDLE, handle) process.client.send_request(request) return true end |
#set_regs(regs_hash) ⇒ Object
Sets the register state of the thread. The registers are supplied in the form of a hash.
120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 120 def set_regs(regs_hash) request = Packet.create_request(COMMAND_ID_STDAPI_SYS_PROCESS_THREAD_SET_REGS) request.add_tlv(TLV_TYPE_THREAD_HANDLE, handle) # Add all of the register that we're setting regs_hash.each_key { |name| t = request.add_tlv(TLV_TYPE_REGISTER) t.add_tlv(TLV_TYPE_REGISTER_NAME, name) t.add_tlv(TLV_TYPE_REGISTER_VALUE_32, regs_hash[name]) } process.client.send_request(request) return true end |
#suspend ⇒ Object
Suspends the thread's execution.
55 56 57 58 59 60 61 62 63 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 55 def suspend request = Packet.create_request(COMMAND_ID_STDAPI_SYS_PROCESS_THREAD_SUSPEND) request.add_tlv(TLV_TYPE_THREAD_HANDLE, handle) process.client.send_request(request) return true end |
#terminate(code) ⇒ Object
Terminates the thread's execution.
81 82 83 84 85 86 87 88 89 90 |
# File 'lib/rex/post/meterpreter/extensions/stdapi/sys/thread.rb', line 81 def terminate(code) request = Packet.create_request(COMMAND_ID_STDAPI_SYS_PROCESS_THREAD_TERMINATE) request.add_tlv(TLV_TYPE_THREAD_HANDLE, handle) request.add_tlv(TLV_TYPE_EXIT_CODE, code) process.client.send_request(request) return true end |