justindossey

node.default.bar.tags = ['tag1-bar']

file "/tmp/bar.txt" do
  content lazy { node.bar.tags.join(',') }
end

ruby_block 'update second tag' do
  block { node.default.bar.tags << 'tag2-bar' }
  only_if { node.default.bar.tags << 'tag3-bar' }
  notifies :create, 'file[/tmp/bar.txt]', :delayed

justindossey

require 'bunny'
require 'logger'

class TestLoggerSubscribeMemleak
  def initialize(msg_count=10_000)
    @messages_to_write = msg_count
    @message_count = msg_count
    @connection = Bunny.new(:user=>"jbd_dev_reader", :pass=>"123456", :host=>"localhost", :vhost=>"jbd", :port=>5672)
    @connection.start
    @channel = @connection.create_channel

justindossey

require 'bunny'
require 'logger'

class TestLoggerSubscribeMemleak
  def initialize(msg_count=10_000)
    @message_count = msg_count
    @messages_to_write = msg_count
    @connection = Bunny.new(:user=>"test_user", :pass=>"123456", :host=>"localhost", :vhost => "test", :port => 5672)
    @connection.start
    @channel = @connection.create_channel

justindossey

     trap('USR2') do 
        # reconnect to MongoDB with read_secondary reversed
        result=MongoMapper.connection.instance_eval('@read_secondary = !@read_secondary')
        logger.notice("#{Time.now}: now reading from #{result ? 'secondary' : 'primary'}")
      end

justindossey

  def all_replicas_in_sync?(verbose=false)
    in_sync = true
    # connect to the primary
    mongo = Mongo::Connection.new(*MongoMapper.connection.primary)
    db = mongo.db('local')
    last_op=db.collection('oplog.rs').find.sort([['$natural',-1]]).limit(1).to_a[0]
    db.collection('slaves').find().to_a.each do |slave|
      opdiff = last_op['ts'].increment - slave['syncedTo'].increment
      diff = (last_op['ts'].seconds - slave['syncedTo'].seconds)/1000.0
      in_sync = false if diff > 60