(Set<Object> keys)
| 122 | } |
| 123 | |
| 124 | @Override |
| 125 | public Map<Object, Object> getAll(Set<Object> keys) { |
| 126 | if (keys.isEmpty()) { |
| 127 | return Collections.emptyMap(); |
| 128 | } |
| 129 | long start = System.nanoTime(); |
| 130 | Map<Object, Object> map = new LinkedHashMap<>(); |
| 131 | List<Object> keyList = new ArrayList<>(keys); |
| 132 | try (Jedis resource = jedisPool.getResource()) { |
| 133 | List<byte[]> valsAsBytes = resource.mget(keysAsBytes(keyList)); |
| 134 | for (int i = 0; i < keyList.size(); i++) { |
| 135 | Object val = valueDecode(valsAsBytes.get(i)); |
| 136 | if (val != null) { |
| 137 | map.put(keyList.get(i), val); |
| 138 | } |
| 139 | } |
| 140 | int hits = map.size(); |
| 141 | int miss = keys.size() - hits; |
| 142 | if (hits > 0) { |
| 143 | hitCount.add(hits); |
| 144 | } |
| 145 | if (miss > 0) { |
| 146 | missCount.add(miss); |
| 147 | } |
| 148 | metricGetAll.addSinceNanos(start); |
| 149 | return map; |
| 150 | } catch (Exception e) { |
| 151 | errorOnRead(e); |
| 152 | return Collections.emptyMap(); |
| 153 | } |
| 154 | } |
| 155 | |
| 156 | @Override |
| 157 | public Object get(Object id) { |
nothing calls this directly
no test coverage detected