diff options
Diffstat (limited to 'lib/mogilefs/mysql.rb')
| -rw-r--r-- | lib/mogilefs/mysql.rb | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/lib/mogilefs/mysql.rb b/lib/mogilefs/mysql.rb index 9d59a0a..e2a16e5 100644 --- a/lib/mogilefs/mysql.rb +++ b/lib/mogilefs/mysql.rb @@ -21,7 +21,7 @@ class MogileFS::Mysql def initialize(args = {}) @my = args[:mysql] @query_method = @my.respond_to?(:c_async_query) ? :c_async_query : :query - @last_update_device = @last_update_domain = Time.at(0) + @last_update_device = @last_update_domain = 0 @cache_domain = @cache_device = nil end @@ -139,7 +139,9 @@ class MogileFS::Mysql }.freeze def refresh_device(force = false) - return @cache_device if ! force && ((Time.now - @last_update_device) < 60) + if ! force && ((MogileFS.now - @last_update_device) < 60) + return @cache_device + end tmp = {} res = query(GET_DEVICES) res.each do |devid, hostip, altip, http_port, http_get_port, @@ -154,16 +156,18 @@ class MogileFS::Mysql :http_get_port => http_get_port ? http_get_port.to_i : http_port, }.freeze end - @last_update_device = Time.now + @last_update_device = MogileFS.now @cache_device = tmp.freeze end def refresh_domain(force = false) - return @cache_domain if ! force && ((Time.now - @last_update_domain) < 5) + if ! force && ((MogileFS.now - @last_update_domain) < 5) + return @cache_domain + end tmp = {} res = query(GET_DOMAINS) res.each { |dmid,namespace| tmp[namespace] = dmid.to_i } - @last_update_domain = Time.now + @last_update_domain = MogileFS.now @cache_domain = tmp.freeze end |