Remove code which generates a deprecation warning

use monotonic time for retry timeout check

.github/workflows/CI.yml

@@ -0,0 +1,38 @@
+name: CI
+
+on:
+  push:
+    branches:
+      - master
+  pull_request:
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    strategy:
+      fail-fast: false
+      matrix:
+        ruby:
+          - '2.5'
+          - '2.6'
+          - '2.7'
+          - '3.0'
+          - ruby-head
+    continue-on-error: ${{ matrix.ruby == 'ruby-head' }}
+    services:
+      memcached:
+        image: memcached
+        ports:
+          - 11211:11211
+      redis:
+        image: redis
+        ports:
+          - 6379:6379
+    steps:
+      - uses: actions/checkout@v2
+      - uses: ruby/setup-ruby@v1
+        with:
+          ruby-version: ${{ matrix.ruby }}
+          bundler-cache: true
+      - run: |
+          bundle exec rake

.travis.yml

@@ -1,9 +0,0 @@
-language: ruby
-rvm:
-  - 2.2.6
-  - 2.3.7
-  - 2.4.4
-  - 2.5.1
-services:
-  - memcached
-  - redis-server

CHANGELOG.md

@@ -1,3 +1,14 @@
+## 0.4.0
+
+- Monotonic clock for locks, avoiding issues with DST (thanks @doits)
+- Pooled connection support (thanks @mlarraz)
+- Switch to Github actions for tests (thanks @mlarraz)
+- Update supported Ruby versions (thanks @mlarraz & @pat)
+
+## 0.3.4
+
+- Support for connection pooling when using memcached locks, via `with` blocks using Dalli (thanks to Lev).
+
 ## 0.3.3
 
 - Default TTL for keys to allow for short-lived locking keys (thanks to Ian Remillard) without leaking memory.

README.md

@@ -1,4 +1,4 @@
-# Suo [![Build Status](https://travis-ci.org/nickelser/suo.svg?branch=master)](https://travis-ci.org/nickelser/suo) [![Code Climate](https://codeclimate.com/github/nickelser/suo/badges/gpa.svg)](https://codeclimate.com/github/nickelser/suo) [![Test Coverage](https://codeclimate.com/github/nickelser/suo/badges/coverage.svg)](https://codeclimate.com/github/nickelser/suo) [![Gem Version](https://badge.fury.io/rb/suo.svg)](http://badge.fury.io/rb/suo)
+# Suo [![Build Status](https://github.com/nickelser/suo/workflows/CI/badge.svg)](https://github.com/nickelser/suo/actions?query=workflow%3ACI) [![Code Climate](https://codeclimate.com/github/nickelser/suo/badges/gpa.svg)](https://codeclimate.com/github/nickelser/suo) [![Gem Version](https://badge.fury.io/rb/suo.svg)](http://badge.fury.io/rb/suo)
 
 :lock: Distributed semaphores using Memcached or Redis in Ruby.
 

lib/suo.rb

@@ -2,7 +2,6 @@ require "securerandom"
 require "monitor"
 
 require "dalli"
-require "dalli/cas/client"
 
 require "redis"
 

lib/suo/client/base.rb

@@ -132,10 +132,10 @@ module Suo
       end
 
       def retry_with_timeout
-        start = Time.now.to_f
+        start = Process.clock_gettime(Process::CLOCK_MONOTONIC)
 
         retry_count.times do
-          elapsed = Time.now.to_f - start
+          elapsed = Process.clock_gettime(Process::CLOCK_MONOTONIC) - start
           break if elapsed >= options[:acquisition_timeout]
 
           synchronize do

lib/suo/client/memcached.rb

@@ -7,27 +7,29 @@ module Suo
       end
 
       def clear
-        @client.delete(@key)
+        @client.with { |client| client.delete(@key) }
       end
 
       private
 
       def get
-        @client.get_cas(@key)
+        @client.with { |client| client.get_cas(@key) }
       end
 
       def set(newval, cas, expire: false)
         if expire
-          @client.set_cas(@key, newval, cas, @options[:ttl])
+          @client.with { |client| client.set_cas(@key, newval, cas, @options[:ttl]) }
         else
-          @client.set_cas(@key, newval, cas)
+          @client.with { |client| client.set_cas(@key, newval, cas) }
         end
       end
 
       def initial_set(val = BLANK_STR)
-        @client.set(@key, val)
+        @client.with do |client|
-        _val, cas = @client.get_cas(@key)
+          client.set(@key, val)
-        cas
+          _val, cas = client.get_cas(@key)
+          cas
+        end
       end
     end
   end

lib/suo/client/redis.rb

@@ -9,21 +9,31 @@ module Suo
       end
 
       def clear
-        @client.del(@key)
+        with { |r| r.del(@key) }
       end
 
       private
 
+      def with(&block)
+        if @client.respond_to?(:with)
+          @client.with(&block)
+        else
+          yield @client
+        end
+      end
+
       def get
-        [@client.get(@key), nil]
+        [with { |r| r.get(@key) }, nil]
       end
 
       def set(newval, _, expire: false)
-        ret = @client.multi do |multi|
+        ret = with do |r|
-          if expire
+          r.multi do |rr|
-            multi.setex(@key, @options[:ttl], newval)
+            if expire
-          else
+              rr.setex(@key, @options[:ttl], newval)
-            multi.set(@key, newval)
+            else
+              rr.set(@key, newval)
+            end
           end
         end
 
@@ -31,11 +41,9 @@ module Suo
       end
 
       def synchronize
-        @client.watch(@key) do
+        with { |r| r.watch(@key) { yield } }
-          yield
-        end
       ensure
-        @client.unwatch
+        with { |r| r.unwatch }
       end
 
       def initial_set(val = BLANK_STR)

lib/suo/version.rb

@@ -1,3 +1,3 @@
 module Suo
-  VERSION = "0.3.3".freeze
+  VERSION = "0.4.0".freeze
 end

suo.gemspec

@@ -19,14 +19,14 @@ Gem::Specification.new do |spec|
   spec.test_files    = spec.files.grep(%r{^(test|spec|features)/})
   spec.require_paths = ["lib"]
 
-  spec.required_ruby_version = "~> 2.0"
+  spec.required_ruby_version = ">= 2.5"
 
   spec.add_dependency "dalli"
   spec.add_dependency "redis"
   spec.add_dependency "msgpack"
 
-  spec.add_development_dependency "bundler", "~> 1.5"
+  spec.add_development_dependency "bundler"
-  spec.add_development_dependency "rake", "~> 10.0"
+  spec.add_development_dependency "rake", "~> 13.0"
   spec.add_development_dependency "rubocop", "~> 0.49.0"
   spec.add_development_dependency "minitest", "~> 5.5.0"
   spec.add_development_dependency "codeclimate-test-reporter", "~> 0.4.7"