taler/exchange
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

-fix

Browse Source
This commit is contained in:
Christian Grothoff 2022-05-22 14:46:23 +02:00
parent 21bcc5fa0b
commit 96fb11bed0
No known key found for this signature in database
GPG Key ID: 939E6BE1E29FC3CC
3 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/bank-lib/fakebank.c
View File

@ -497,9 +497,10 @@ lp_trigger (struct LongPoller *lp,
GNUNET_free (lp); GNUNET_free (lp);
h->mhd_again = true; h->mhd_again = true;
#ifdef __linux__ #ifdef __linux__
if (-1 != h->lp_event) if (-1 == h->lp_event)
#else #else
if (-1 != h->lp_event_in && -1 != h->lp_event_out) if ( (-1 == h->lp_event_in) &&
(-1 == h->lp_event_out) )
#endif #endif
{ {
if (NULL != h->mhd_task) if (NULL != h->mhd_task)
@ -2745,6 +2746,7 @@ TALER_FAKEBANK_start2 (uint16_t port,
#else #else
{ {
int pipefd[2]; int pipefd[2];
if (0 != pipe (pipefd)) if (0 != pipe (pipefd))
{ {
GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR,

2
src/exchangedb/exchange-0001-part.sql
View File

@ -925,7 +925,7 @@ CREATE INDEX IF NOT EXISTS work_shards_by_job_name_completed_last_attempt_index
ON work_shards ON work_shards
(job_name (job_name
,completed ,completed
,last_attempt ,last_attempt ASC
); );

4
src/exchangedb/plugin_exchangedb_postgres.c
View File

@ -3362,8 +3362,8 @@ prepare_statements (struct PostgresClosure *pg)
",end_row" ",end_row"
" FROM work_shards" " FROM work_shards"
" WHERE job_name=$1" " WHERE job_name=$1"
" AND last_attempt<$2"
" AND completed=FALSE" " AND completed=FALSE"
" AND last_attempt<$2"
" ORDER BY last_attempt ASC" " ORDER BY last_attempt ASC"
" LIMIT 1;", " LIMIT 1;",
2), 2),
@ -12626,7 +12626,7 @@ postgres_begin_shard (void *cls,
{ {
struct PostgresClosure *pg = cls; struct PostgresClosure *pg = cls;
for (unsigned int retries = 0; retries<3; retries++) for (unsigned int retries = 0; retries<10; retries++)
{ {
if (GNUNET_OK != if (GNUNET_OK !=
postgres_start (pg, postgres_start (pg,