Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1764 from metamx/enableLogging 

Enable logging for memcached in factory
This commit is contained in:
Fangjin Yang 2015-09-23 16:53:58 -07:00
parent 5dd5fc7221 4308aa93e2
commit a5718ee8b7
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/src/main/java/io/druid/client/cache/MemcachedCache.java vendored
View File

@ -46,6 +46,7 @@ import net.spy.memcached.MemcachedClient;
import net.spy.memcached.MemcachedClientIF; import net.spy.memcached.MemcachedClientIF;
import net.spy.memcached.internal.BulkFuture; import net.spy.memcached.internal.BulkFuture;
import net.spy.memcached.metrics.MetricCollector; import net.spy.memcached.metrics.MetricCollector;
import net.spy.memcached.metrics.MetricType;
import net.spy.memcached.ops.LinkedOperationQueueFactory; import net.spy.memcached.ops.LinkedOperationQueueFactory;
import net.spy.memcached.ops.OperationQueueFactory; import net.spy.memcached.ops.OperationQueueFactory;
import org.apache.commons.codec.digest.DigestUtils; import org.apache.commons.codec.digest.DigestUtils;
@ -133,6 +134,9 @@ public class MemcachedCache implements Cache
for (Map.Entry<String, AtomicLong> entry : counters.entrySet()) { for (Map.Entry<String, AtomicLong> entry : counters.entrySet()) {
builder.put(entry.getKey(), entry.getValue().get()); builder.put(entry.getKey(), entry.getValue().get());
} }
for (Map.Entry<String, AtomicLong> entry : meters.entrySet()) {
builder.put(entry.getKey(), entry.getValue().get());
}
return builder.build(); return builder.build();
} }
}; };
@ -344,6 +348,7 @@ public class MemcachedCache implements Cache
.setReadBufferSize(config.getReadBufferSize()) .setReadBufferSize(config.getReadBufferSize())
.setOpQueueFactory(opQueueFactory) .setOpQueueFactory(opQueueFactory)
.setMetricCollector(metricCollector) .setMetricCollector(metricCollector)
.setEnableMetrics(MetricType.DEBUG) // Not as scary as it sounds
.build(); .build();
final List<InetSocketAddress> hosts = AddrUtil.getAddresses(config.getHosts()); final List<InetSocketAddress> hosts = AddrUtil.getAddresses(config.getHosts());