TODO ergaenzt. loganinc mit anfaenglicher Verarbeitung.
This commit is contained in:
parent
c289c1e9bc
commit
b9cb56b673
2 changed files with 37 additions and 14 deletions
42
TODO
42
TODO
|
@ -2,25 +2,43 @@
|
||||||
* BDB/SBDB
|
* BDB/SBDB
|
||||||
+ Enthaelt noch einen fiesen Fehler.
|
+ Enthaelt noch einen fiesen Fehler.
|
||||||
Kann aber auch an falscher Benutzung liegen.
|
Kann aber auch an falscher Benutzung liegen.
|
||||||
|
-> TXN-Logging-Overflow
|
||||||
|
|
||||||
|
* Sandbox (90%)
|
||||||
|
|
||||||
|
* Persistenter Speicher
|
||||||
|
+ BDB
|
||||||
|
|
||||||
|
* Transactionsuche
|
||||||
|
+ Sandbox
|
||||||
|
+ Pers. Speicher
|
||||||
|
|
||||||
|
+ Config
|
||||||
|
+ BDB
|
||||||
|
+ String in Object umwandeln
|
||||||
|
- Sandbox
|
||||||
|
+ Objectcache
|
||||||
|
- Hash
|
||||||
|
|
||||||
* LogAn
|
* LogAn
|
||||||
+ Ablauf (siehe Bild) (0%)
|
+ Ablauf (siehe Bild) (0%)
|
||||||
+ Sandbox (80%)
|
+ Sandbox
|
||||||
+ Einlesen (0%)
|
+ Dequeue
|
||||||
+ Persistenter Speicher (80%)
|
- SBDB
|
||||||
+ Configlogik (0%)
|
+ Pers. Speicher
|
||||||
- BDB
|
+ Config
|
||||||
- "Klassenbauen"
|
+ emit
|
||||||
- Sandbox
|
- SBDB
|
||||||
|
|
||||||
* File2LogAn
|
* File2LogAn
|
||||||
+ Server (50%)
|
+ Server (50%)
|
||||||
- select (100%)
|
- select (100%)
|
||||||
+ Speichern (0%)
|
+ emit (0%)
|
||||||
- BDB
|
* SBDB
|
||||||
+ Sandbox
|
+ Sandbox
|
||||||
+ Ablauf (50%)
|
+ Config
|
||||||
|
|
||||||
* push2mysql
|
* push2mysql
|
||||||
+ Einlesen
|
+ Dequeue
|
||||||
+ insert (50%)
|
- SBDB
|
||||||
|
+ SQL-Insert
|
||||||
|
|
|
@ -43,10 +43,15 @@ end
|
||||||
|
|
||||||
SBDB::Env.new 'conf' do |conf|
|
SBDB::Env.new 'conf' do |conf|
|
||||||
SBDB::Env.new 'logs' do |logs|
|
SBDB::Env.new 'logs' do |logs|
|
||||||
SBDB::Env.new 'cache' do |cache|
|
SBDB::Env.new 'persist' do |persist|
|
||||||
test = cache[ 'test']
|
test = cache[ 'test']
|
||||||
while line = logs[ 'newids'].get( nil, "\0\0\0\0", nil, SBDB::CONSUME_WAIT)
|
while line = logs[ 'newids'].get( nil, "\0\0\0\0", nil, SBDB::CONSUME_WAIT)
|
||||||
|
type, obj = line.unpack 'Na*'
|
||||||
|
case type
|
||||||
|
when 11
|
||||||
|
sid, log = obj.unpack 'Na*'
|
||||||
|
parser = conf[ 'sids.cnf', 'parser'][sid]
|
||||||
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
Loading…
Reference in a new issue