staLUN: EMC LUN statistics

from gevent.pool import Pool

from gevent.timeout import Timeout

from django.core.cache import cache

def analyze(luns):

    results = []

    graphs = []

    for l in luns:

        graphs.extend(l.getGraphs())

    p = Pool(30)

    def _analyze_graphs(graph):

        t = Timeout(5)

        t.start()

        try:

            results.extend(graph.analyze_graph())

        except (Timeout):

            pass

        finally:

            t.cancel()

    p.imap(_analyze_graphs, graphs)

    res = sorted(results,  key=lambda k: k['dev'], reverse=True)

    cache.set('lun:stats', res, 600)

    return res