diff options
author | Aleksey Lim <alsroot@sugarlabs.org> | 2013-02-12 17:00:32 (GMT) |
---|---|---|
committer | Aleksey Lim <alsroot@sugarlabs.org> | 2013-02-13 17:28:52 (GMT) |
commit | 35cd60ed71d5a23e5d209bb54ef3d5842472925c (patch) | |
tree | a8eac89fc9bcba043a5ef500ae69235bee35215c /sugar_network/node/stats.py | |
parent | 91d0dc78baf24b90d827f20f08a959bdaa1387ed (diff) | |
parent | 610a9c14543aa9c92d1646b1ae60f9270aee0b3b (diff) |
Merge active_document
Diffstat (limited to 'sugar_network/node/stats.py')
-rw-r--r-- | sugar_network/node/stats.py | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/sugar_network/node/stats.py b/sugar_network/node/stats.py index d3eb073..a77b4b7 100644 --- a/sugar_network/node/stats.py +++ b/sugar_network/node/stats.py @@ -1,4 +1,4 @@ -# Copyright (C) 2012 Aleksey Lim +# Copyright (C) 2012-2013 Aleksey Lim # # This program is free software: you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by @@ -19,10 +19,8 @@ from os.path import join, exists, isdir from pylru import lrucache -import active_document as ad -from active_toolkit.options import Option from sugar_network.toolkit.rrd import Rrd -from sugar_network.toolkit import PersistentSequence +from sugar_network.toolkit import Option, util stats_root = Option( @@ -77,11 +75,11 @@ def pull(in_seq, packet): for db in rrd: seq = in_seq[user].get(db.name) if seq is None: - seq = in_seq[user][db.name] = PersistentSequence( + seq = in_seq[user][db.name] = util.PersistentSequence( join(rrd.root, db.name + '.push'), [1, None]) elif seq is not dict: - seq = in_seq[user][db.name] = ad.Sequence(seq) - out_seq = ad.Sequence() + seq = in_seq[user][db.name] = util.Sequence(seq) + out_seq = util.Sequence() def dump(): for start, end in seq: @@ -100,7 +98,8 @@ def pull(in_seq, packet): def commit(sequences): for user, dbs in sequences.items(): for db, merged in dbs.items(): - seq = PersistentSequence(_rrd_path(user, db + '.push'), [1, None]) + seq = util.PersistentSequence( + _rrd_path(user, db + '.push'), [1, None]) seq.exclude(merged) seq.commit() |