Class: Msf::Aggregator::MsgPackServer

Inherits:
Object
  • Object
show all
Defined in:
lib/msf/aggregator.rb

Overview

class Server

Instance Method Summary collapse

Constructor Details

#initialize(host, port) ⇒ MsgPackServer

Returns a new instance of MsgPackServer.



224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
 
# File 'lib/msf/aggregator.rb', line 224

def initialize(host, port)
  @host = host
  @port = port

  # server = TCPServer.new(@host, @port)
  # sslContext = OpenSSL::SSL::SSLContext.new
  # sslContext.key, sslContext.cert = Msf::Aggregator::ConnectionManager.ssl_generate_certificate
  # sslServer = OpenSSL::SSL::SSLServer.new(server, sslContext)
  #
  @svr = MessagePack::RPC::Server.new # need to initialize this as ssl server
  # @svr.listen(sslServer, Server.new)
  @svr.listen(@host, @port, Server.new)

  Thread.new { @svr.run }
end

Instance Method Details

#start ⇒ Object 



240
241
242
243
244
245
246
 
# File 'lib/msf/aggregator.rb', line 240

def start
  c = MessagePack::RPC::Client.new(@host,@port)
  c.call(:start)
  c.close
rescue MessagePack::RPC::TimeoutError => e
  Logger.log(e.to_s)
end

#stop ⇒ Object 



248
249
250
251
252
253
 
# File 'lib/msf/aggregator.rb', line 248

def stop
  c = MessagePack::RPC::Client.new(@host,@port)
  c.call(:stop)
  c.close
  @svr.close
end