diff options
| author | Christian Grothoff <christian@grothoff.org> | 2016-01-25 15:08:29 +0100 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2016-01-25 15:08:29 +0100 |
| commit | bd3700e608daf2ae52400275b1957656ccf2d6aa (patch) | |
| tree | 72d8251b2eccd8a4103986f7e17fbe9f389785c9 /src/mint | |
| parent | 57c1d2318f14c4b5c21609cb96f32517d02752e7 (diff) | |
| download | exchange-bd3700e608daf2ae52400275b1957656ccf2d6aa.tar.gz exchange-bd3700e608daf2ae52400275b1957656ccf2d6aa.tar.bz2 exchange-bd3700e608daf2ae52400275b1957656ccf2d6aa.zip | |
getting aggregator structure laid out for #4141
Diffstat (limited to 'src/mint')
| -rw-r--r-- | src/mint/taler-mint-aggregator.c | 21 |
1 files changed, 13 insertions, 8 deletions
diff --git a/src/mint/taler-mint-aggregator.c b/src/mint/taler-mint-aggregator.c index d3c66f025..70a68d007 100644 --- a/src/mint/taler-mint-aggregator.c +++ b/src/mint/taler-mint-aggregator.c @@ -220,9 +220,11 @@ run (void *cls, return; } /* FIXME: finish aggregate computation */ - /* FIXME: insert pre-commit data for transaction into DB */ - /* FIXME: mark transactions selected for aggregate as finished */ + /* wire_plugin->prepare_wire_transfer () -- ASYNC! */ + /* db_plugin->wire_prepare_data_insert () -- transactional! */ + /* db_plugin->XXX () -- mark transactions selected for aggregate as finished */ + /* then finally: commit! */ if (GNUNET_OK != db_plugin->commit (db_plugin->cls, session)) @@ -231,12 +233,15 @@ run (void *cls, "Failed to commit database transaction!\n"); } - /* FIXME: run 2nd transaction: - - begin - - select pre-commit data from DB - - execute wire transfer - - insert aggregation tracking information into DB - - commit! + /* While possible, run 2nd type of transaction: + db_plugin->start() + - select pre-commit data from DB: + db_plugin->wire_prepare_data_iterate () + - execute wire transfer (successfully!) + wire_plugin->execute_wire_transfer() # ASYNC! + db_plugin->wire_prepare_data_mark_finished () + db_plugin->insert_aggregation_tracking () + db_plugin->commit() */ |