Class: Roby::Log::Client

Inherits:
Object show all
Defined in:
lib/roby/log/server.rb

Constant Summary collapse

MIN_DISPLAY_DURATION = 
5

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(server) ⇒ Client

Returns a new instance of Client.



419
420
421
422
423
 
# File 'lib/roby/log/server.rb', line 419

def initialize(server)
		@server  = server
		@pending = Hash.new
		connect
end

Instance Attribute Details

#last_update ⇒ Object (readonly)

Returns the value of attribute last_update.



443
444
445
 
# File 'lib/roby/log/server.rb', line 443

def last_update
  @last_update
end

#server ⇒ Object (readonly)

The remote display server



417
418
419
 
# File 'lib/roby/log/server.rb', line 417

def server
  @server
end

Class Method Details

.remote_streams_finalizer(server, drb_object) ⇒ Object 



508
509
510
511
512
513
514
515
516
517
 
# File 'lib/roby/log/server.rb', line 508

def self.remote_streams_finalizer(server, drb_object)
		Proc.new do
 begin
			server.disconnect(drb_object)
 rescue DRb::DRbConnError
 rescue Exception => e
			STDERR.puts e.full_message
 end
		end
end

Instance Method Details

#added_stream(klass_name, id, name, type) ⇒ Object 



429
430
431
432
433
434
435
436
437
 
# File 'lib/roby/log/server.rb', line 429

def added_stream(klass_name, id, name, type)
		begin
 require klass_name.underscore
		rescue LoadError
		end
		
		@streams[id] = RemoteStream.new(klass_name.constantize, id, name, type)
		super if defined? super
end

#connect ⇒ Object 



490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
 
# File 'lib/roby/log/server.rb', line 490

def connect
		if connected?
 raise ArgumentError, "already connected"
		end

		@streams = Hash.new
		server.connect(DRbObject.new(self)).
 each do |klass, id, name, type|
			added_stream(klass, id, name, type)
 end

		ObjectSpace.define_finalizer(self, Client.remote_streams_finalizer(server, DRbObject.new(self)))

rescue Exception
		disconnect
		raise
end

#connected? ⇒ Boolean

Returns:

  • (Boolean) 


489
 
# File 'lib/roby/log/server.rb', line 489

def connected?; !!@streams end

#demux(calls) ⇒ Object 



445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
 
# File 'lib/roby/log/server.rb', line 445

def demux(calls)
		calls.each do |args|
 send(*args)
		end

		streams.each do |s|
 while s.has_sample?
			s.synchronize do
  s.advance
			end
 end
		end

		sleep(0.5)
end

#disconnect ⇒ Object 



519
520
521
522
523
 
# File 'lib/roby/log/server.rb', line 519

def disconnect
		@streams = nil
		server.disconnect(DRbObject.new(self))
rescue DRb::DRbConnError
end

#init(id, data) ⇒ Object 



469
470
471
472
473
474
475
476
477
478
479
 
# File 'lib/roby/log/server.rb', line 469

def init(id, data)
		s = @streams[id]
		Server.info "initializing #{s}"
		s.synchronize do
 s.init(data) do |sample|
			s.decoders.each do |dec|
  dec.process(sample)
			end
 end
		end
end

#push(id, time, data) ⇒ Object 



485
486
487
 
# File 'lib/roby/log/server.rb', line 485

def push(id, time, data)
		@streams[id].push(time, data)
end

#quit ⇒ Object 



525
526
527
528
 
# File 'lib/roby/log/server.rb', line 525

def quit
		@streams = nil
		@server  = nil
end

#reinit(id) ⇒ Object 



481
482
483
 
# File 'lib/roby/log/server.rb', line 481

def reinit(id)
		@streams[id].reinit = true
end

#removed_stream(id) ⇒ Object 



438
439
440
441
 
# File 'lib/roby/log/server.rb', line 438

def removed_stream(id)
		@streams.delete(id)
		super if defined? super
end

#streams ⇒ Object 



425
426
427
 
# File 'lib/roby/log/server.rb', line 425

def streams
		@streams.values
end

#subscribe(stream) ⇒ Object 



461
462
463
 
# File 'lib/roby/log/server.rb', line 461

def subscribe(stream)
		@server.subscribe(stream.id, DRbObject.new(self))
end

#unsubscribe(stream) ⇒ Object 



465
466
467
 
# File 'lib/roby/log/server.rb', line 465

def unsubscribe(stream)
		@server.unsubscribe(stream.id, DRbObject.new(self))
end