protected CacheResult do_PUT_ALL()

in jetcache-support/jetcache-redis-springdata/src/main/java/com/alicp/jetcache/redis/springdata/RedisSpringDataCache.java [145:166]

• 22 lines of code
• 6 McCabe index (conditional complexity)

    protected CacheResult do_PUT_ALL(Map<? extends K, ? extends V> map, long expireAfterWrite, TimeUnit timeUnit) {
        RedisConnection con = null;
        try {
            con = connectionFactory.getConnection();
            int failCount = 0;
            for (Map.Entry<? extends K, ? extends V> en : map.entrySet()) {
                CacheValueHolder<V> holder = new CacheValueHolder(en.getValue(), timeUnit.toMillis(expireAfterWrite));
                Boolean result = con.pSetEx(buildKey(en.getKey()),
                        timeUnit.toMillis(expireAfterWrite), valueEncoder.apply(holder));
                if(!Boolean.TRUE.equals(result)){
                    failCount++;
                }
            }
            return failCount == 0 ? CacheResult.SUCCESS_WITHOUT_MSG :
                    failCount == map.size() ? CacheResult.FAIL_WITHOUT_MSG : CacheResult.PART_SUCCESS_WITHOUT_MSG;
        } catch (Exception ex) {
            logError("PUT_ALL", "map(" + map.size() + ")", ex);
            return new CacheResult(ex);
        } finally {
            closeConnection(con);
        }
    }