Class: CPEE::ModelManagement::StatReceive
- Inherits:
-
Riddl::Implementation
- Object
- Riddl::Implementation
- CPEE::ModelManagement::StatReceive
- Defined in:
- lib/cpee-model-management/implementation.rb
Overview
}}}
Instance Method Summary collapse
-
#response ⇒ Object
{{{.
Instance Method Details
#response ⇒ Object
{{{
668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 |
# File 'lib/cpee-model-management/implementation.rb', line 668 def response redis = @a[0] receivers = @a[1] topic = @p[1].value event_name = @p[2].value notification = JSON.parse(@p[3].value.read) instancenr = notification['instance'] content = notification['content'] attr = content['attributes'] engine = notification['cpee'] prefix = File.join(engine,notification['instance-uuid'].to_s) if topic == 'state' && event_name == 'change' if %w{abandoned finished}.include?(content['state']) parent = redis.get(File.join(prefix,'parent')) oldstate = redis.get(File.join(prefix,'state')) children = redis.lrange(File.join(prefix,'children'),0,-1) redis.multi do |multi| multi.decr(File.join(engine,oldstate)) rescue nil multi.incr(File.join(engine,'total_' + content['state'])) multi.lrem(File.join(engine,'instances'),0,notification['instance-uuid']) multi.del(File.join(prefix,'instance-url')) multi.del(File.join(prefix,'author')) multi.del(File.join(prefix,'path')) multi.del(File.join(prefix,'name')) multi.del(File.join(prefix,'state')) multi.del(File.join(prefix,'cpu')) multi.del(File.join(prefix,'mem')) multi.del(File.join(prefix,'time')) children.each do |child| if parent multi.set(File.join(engine,child,'parent'),parent) else multi.del(File.join(engine,child,'parent')) end end multi.del(File.join(prefix,'children')) multi.del(File.join(prefix,'parent')) if parent multi.lrem(File.join(engine,parent,'children'),0,notification['instance-uuid'].to_s) end end elsif %w{ready}.include?(content['state']) exi = true if redis.lrange(File.join(engine,'instances'),0,-1).include?(notification['instance-uuid']) redis.multi do |multi| unless exi multi.incr(File.join(engine,'total_created')) multi.incr(File.join(engine,'ready')) multi.rpush(File.join(engine,'instances'),notification['instance-uuid']) end multi.set(File.join(prefix,'instance-url'),notification['instance-url']) multi.set(File.join(prefix,'author'),attr['author']) multi.set(File.join(prefix,'state'),content['state']) multi.set(File.join(prefix,'path'),File.join(attr['design_dir'],attr['info']+'.xml')) unless attr['design_dir'].nil? || attr['info'].nil? multi.set(File.join(prefix,'name'),attr['info']) multi.set(File.join(prefix,'cpu'),0) multi.set(File.join(prefix,'mem'),0) multi.set(File.join(prefix,'time'),0) end elsif %w{stopping}.include?(content['state']) redis.set(File.join(prefix,'state'),content['state']) elsif %w{stopped}.include?(content['state']) redis.multi do |multi| multi.decr(File.join(engine,'running')) multi.incr(File.join(engine,'stopped')) multi.set(File.join(prefix,'state'),content['state']) multi.set(File.join(prefix,'cpu'),0) multi.set(File.join(prefix,'mem'),0) multi.set(File.join(prefix,'time'),0) end elsif %w{running}.include?(content['state']) oldstate = redis.get(File.join(prefix,'state')) redis.multi do |multi| multi.decr(File.join(engine,oldstate)) rescue nil multi.incr(File.join(engine,'running')) multi.set(File.join(prefix,'name'),attr['info']) multi.set(File.join(prefix,'state'),content['state']) multi.set(File.join(prefix,'time'),Time.now.to_i) end end url, , path, name, state, parent = redis.mget( File.join(prefix,'instance-url'), File.join(prefix,'author'), File.join(prefix,'path'), File.join(prefix,'name'), File.join(prefix,'state'), File.join(prefix,'parent') ) receivers.each do |conn| conn.send JSON::generate(:topic => topic, :event => event_name, :engine => engine, :uuid => notification['instance-uuid'], :url => url, :author => , :path => path.to_s, :name => name, :state => content['state'], :parent => parent.to_s) end elsif topic == 'task' && event_name == 'instantiation' redis.multi do |multi| multi.rpush(File.join(engine,notification['instance-uuid'],'children'),content['received']['CPEE-INSTANCE-UUID']) multi.set(File.join(engine,content['received']['CPEE-INSTANCE-UUID'],'parent'),notification['instance-uuid']) end prefix = File.join(engine,content['received']['CPEE-INSTANCE-UUID'].to_s) url, , path, name, state, parent = redis.mget( File.join(prefix,'instance-url'), File.join(prefix,'author'), File.join(prefix,'path'), File.join(prefix,'name'), File.join(prefix,'state'), File.join(prefix,'parent') ) receivers.each do |conn| conn.send JSON::generate(:topic => 'state', :event => 'change', :engine => engine, :uuid => content['received']['CPEE-INSTANCE-UUID'], :url => url, :author => , :path => path.to_s, :name => name, :state => state, :parent => parent.to_s) end elsif topic == 'status' && event_name == 'resource_utilization' redis.multi do |multi| multi.set(File.join(prefix,'name'),attr['info']) multi.set(File.join(prefix,'cpu'),content['utime'] + content['stime']) multi.set(File.join(prefix,'mem'),content['mib']) end receivers.each do |conn| conn.send JSON::generate(:topic => topic, :event => event_name, :engine => engine, :uuid => notification['instance-uuid'], :cpu => content['utime'] + content['stime'], :mem => content['mib']) end elsif topic == 'node' && event_name == 'resource_utilization' redis.multi do |multi| multi.set(File.join(engine,'cpu_usage'),content['cpu_usage']) multi.set(File.join(engine,'mem_free'),content['mem_free']) multi.set(File.join(engine,'mem_total'),content['mem_total']) multi.set(File.join(engine,'mem_available'),content['mem_available']) end receivers.each do |conn| conn.send JSON::generate(:topic => topic, :event => event_name, :engine => engine, :cpu_usage => content['cpu_usage'], :mem_free => content['mem_free'], :mem_total => content['mem_total'], :mem_available => content['mem_available']) end end end |