deac
/
syslog2logan
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Log-Queue: first try

bdb
Denis Knauf 2010-02-22 16:20:35 +01:00
parent c2ff1cd941
commit 36aecb7197
1 changed files with 16 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
bin/s2l.rb
View File

@ -47,7 +47,7 @@ class Rotate
def initialize db, &e def initialize db, &e
@rdb, @env, @dbs = db, db.home, {} @rdb, @env, @dbs = db, db.home, {}
self.hash = e || lambda {|k| self.hash = e || lambda {|k|
[UUIDTools::UUID.parse_raw( k).timestamp.to_i/60/60/24].pack 'N' [k.timestamp.to_i/60/60/24].pack 'N'
} }
end end
@ -64,17 +64,24 @@ class Rotate
@hash_func.call k @hash_func.call k
end end
def db k def db_name id
h = hashing id
n = @rdb[ h] n = @rdb[ h]
if n if n
n = UUIDTools::UUID.parse_raw n n = UUIDTools::UUID.parse_raw n
else else
n = UUIDTools::UUID.timestamp_create n = UUIDTools::UUID.timestamp_create
@rdb[ h] = n.raw @rdb[ h] = n.raw
info :create => n.to_s
end end
info :open => n.to_s end
@env[ n.to_s, 'logs', SBDB::Btree, SBDB::CREATE | SBDB::AUTO_COMMIT]
@env[ "#{n}.newids", 'logs', SBDB::Queue, SBDB::CREATE | SBDB::AUTO_COMMIT] def db n
@env[ n.to_s, nil, SBDB::Btree, SBDB::CREATE | SBDB::AUTO_COMMIT]
end
def queue n
@env[ "#{n}.newids", nil, SBDB::Queue, SBDB::CREATE | SBDB::AUTO_COMMIT]
end end
def sync def sync
@ -90,7 +97,9 @@ class Rotate
def put v def put v
id = UUIDTools::UUID.timestamp_create id = UUIDTools::UUID.timestamp_create
s = [0x10, v].pack 'Na*' s = [0x10, v].pack 'Na*'
db(id.raw)[ id.raw] = s n = db_name id
db( n)[ id.raw] = s
queue( n).push id.raw
end end
alias emit put alias emit put
end end
@ -129,7 +138,7 @@ Dir.mkdir $conf[:home] rescue Errno::EEXIST
info :open => SBDB::Env info :open => SBDB::Env
SBDB::Env.new( $conf[:home], SBDB::CREATE | SBDB::Env::INIT_TRANSACTION | Bdb::DB_AUTO_COMMIT) do |dbenv| SBDB::Env.new( $conf[:home], SBDB::CREATE | SBDB::Env::INIT_TRANSACTION | Bdb::DB_AUTO_COMMIT) do |dbenv|
info :open => Rotate info :open => Rotate
dbs = Rotate.new dbenv[ 'rotates.db', 'rotates', SBDB::Btree, SBDB::CREATE | Bdb::DB_AUTO_COMMIT] dbs = Rotate.new dbenv[ 'rotates.db', nil, SBDB::Btree, SBDB::CREATE | Bdb::DB_AUTO_COMMIT]
info :open => S2L info :open => S2L
serv = S2L.new :sock => TCPServer.new( *$conf[:server]), :dbs => dbs serv = S2L.new :sock => TCPServer.new( *$conf[:server]), :dbs => dbs
retries = Retries.new *$conf[:retries] retries = Retries.new *$conf[:retries]