package voldemort.store.routed;

import java.util.Iterator;
import java.util.Map.Entry;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicLong;

import voldemort.annotations.jmx.JmxGetter;
import voldemort.store.InsufficientOperationalNodesException;
import voldemort.store.InsufficientZoneResponsesException;
import voldemort.store.InvalidMetadataException;
import voldemort.store.StoreTimeoutException;
import voldemort.store.UnreachableStoreException;

/**
 * Tracks all the exceptions we see, down at the routing layer also including
 * ones that will be eventually propagated up to the client from the routing
 * layer
 * 
 */
public class PipelineRoutedStats {

    private ConcurrentHashMap<Class<? extends Exception>, AtomicLong> errCountMap;
    private AtomicLong severeExceptionCount;
    private AtomicLong benignExceptionCount;

    PipelineRoutedStats() {
        errCountMap = new ConcurrentHashMap<Class<? extends Exception>, AtomicLong>();
        errCountMap.put(InvalidMetadataException.class, new AtomicLong(0));
        errCountMap.put(InsufficientOperationalNodesException.class, new AtomicLong(0));
        errCountMap.put(InsufficientZoneResponsesException.class, new AtomicLong(0));
        errCountMap.put(UnreachableStoreException.class, new AtomicLong(0));
        errCountMap.put(StoreTimeoutException.class, new AtomicLong(0));

        severeExceptionCount = new AtomicLong(0);
        benignExceptionCount = new AtomicLong(0);
    }

    @JmxGetter(name = "numSevereExceptions", description = "Number of exceptions considered serious errors")
    public long getNumSevereExceptions() {
        return severeExceptionCount.get();
    }

    @JmxGetter(name = "numBenignExceptions", description = "Number of exceptions considered benign")
    public long getNumBenignExceptions() {
        return benignExceptionCount.get();
    }

    @JmxGetter(name = "numInsufficientOperationalNodesExceptions", description = "Number of client operations failed due to sufficient nodes not being up")
    public long getNumInsufficientOperationalNodesExceptions() {
        return errCountMap.get(InsufficientOperationalNodesException.class).get();
    }

    @JmxGetter(name = "numInsufficientZoneResponsesExceptions", description = "Number of client operations failed due to sufficient nodes not up across zones")
    public long getNumInsufficientZoneResponsesExceptions() {
        return errCountMap.get(InsufficientZoneResponsesException.class).get();
    }

    @JmxGetter(name = "numInvalidMetadataExceptions", description = "Number of times the metadata was invalid at the client")
    public long getNumInvalidMetadataExceptions() {
        return errCountMap.get(InvalidMetadataException.class).get();
    }

    @JmxGetter(name = "numUnreachableStoreExceptions", description = "Number of requests incomplete since some server could not be reached")
    public long getNumUnreachableStoreExceptions() {
        return errCountMap.get(UnreachableStoreException.class).get();
    }

    @JmxGetter(name = "numStoreTimeoutExceptions", description = "Number of requests timed out since some server was overloaded/unavailable")
    public long getNumStoreTimeoutExceptions() {
        return errCountMap.get(StoreTimeoutException.class).get();
    }

    @JmxGetter(name = "getExceptionCountsAsString", description = "Returns counts of all the Exceptions seen so far as a string")
    public String getExceptionCountsAsString() {
        StringBuilder result = new StringBuilder();
        Iterator<Entry<Class<? extends Exception>, AtomicLong>> itr = errCountMap.entrySet()
                                                                                 .iterator();
        while(itr.hasNext()) {
            Entry<Class<? extends Exception>, AtomicLong> pair = itr.next();
            result.append(pair.getKey().getName() + ":" + pair.getValue().get() + "\n");
        }
        return result.toString();
    }

    public void reportException(Exception e) {
        if(isSevere(e))
            severeExceptionCount.incrementAndGet();
        else
            benignExceptionCount.incrementAndGet();
        errCountMap.putIfAbsent(e.getClass(), new AtomicLong(0));
        errCountMap.get(e.getClass()).incrementAndGet();
    }

    private boolean isSevere(Exception ve) {
        if(ve instanceof InsufficientOperationalNodesException
           || ve instanceof InsufficientZoneResponsesException
           || ve instanceof InvalidMetadataException)
            return true;
        else
            return false;
    }
}

@@ -485,16 +485,70 @@
 ception;
+%0Aimport voldemort.versioning.ObsoleteVersionException;
 %0A%0A/**%0A *
@@ -1442,16 +1442,92 @@
 ong(0));
+%0A        errCountMap.put(ObsoleteVersionException.class, new AtomicLong(0));
 %0A%0A      
@@ -3427,32 +3427,299 @@
 ).get();%0A    %7D%0A%0A
+    @JmxGetter(name = %22numObsoleteVersionExceptions%22, description = %22Number of requests that got a ObsoleteVersionException as response%22)%0A    public long getNumObsoleteVersionExceptions() %7B%0A        return errCountMap.get(ObsoleteVersionException.class).get();%0A    %7D%0A%0A
     @JmxGetter(n

Include ObsoleteVersionException