Web   ·   Wiki   ·   Activities   ·   Blog   ·   Lists   ·   Chat   ·   Meeting   ·   Bugs   ·   Git   ·   Translate   ·   Archive   ·   People   ·   Donate
summaryrefslogtreecommitdiffstats
path: root/sugar_network/node/stats.py
diff options
context:
space:
mode:
authorAleksey Lim <alsroot@sugarlabs.org>2013-02-12 17:00:32 (GMT)
committer Aleksey Lim <alsroot@sugarlabs.org>2013-02-13 17:28:52 (GMT)
commit35cd60ed71d5a23e5d209bb54ef3d5842472925c (patch)
treea8eac89fc9bcba043a5ef500ae69235bee35215c /sugar_network/node/stats.py
parent91d0dc78baf24b90d827f20f08a959bdaa1387ed (diff)
parent610a9c14543aa9c92d1646b1ae60f9270aee0b3b (diff)
Merge active_document
Diffstat (limited to 'sugar_network/node/stats.py')
-rw-r--r--sugar_network/node/stats.py15
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()