aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2021-08-22 11:44:22 +0200
committerChristian Grothoff <christian@grothoff.org>2021-08-22 11:44:22 +0200
commit9ef7f0704fa0458f2e27ba188aec5102dbb780b2 (patch)
tree956a6ec2866121c127671b66780e935345a2fb04 /src
parent71a70133ad41085750ee1018fe026838d0aab5ac (diff)
downloadgnunet-9ef7f0704fa0458f2e27ba188aec5102dbb780b2.tar.gz
gnunet-9ef7f0704fa0458f2e27ba188aec5102dbb780b2.zip
-prepend X to ensure identifiers do not start with a number
Diffstat (limited to 'src')
-rw-r--r--src/pq/pq_event.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/pq/pq_event.c b/src/pq/pq_event.c
index e6c2d07fd..2890869a3 100644
--- a/src/pq/pq_event.c
+++ b/src/pq/pq_event.c
@@ -388,7 +388,7 @@ register_notify (void *cls,
388 struct GNUNET_DB_EventHandler *eh = value; 388 struct GNUNET_DB_EventHandler *eh = value;
389 389
390 manage_subscribe (db, 390 manage_subscribe (db,
391 "LISTEN ", 391 "LISTEN X",
392 eh); 392 eh);
393 return GNUNET_OK; 393 return GNUNET_OK;
394} 394}
@@ -440,7 +440,7 @@ GNUNET_PQ_event_listen (struct GNUNET_PQ_Context *db,
440 fd); 440 fd);
441 } 441 }
442 manage_subscribe (db, 442 manage_subscribe (db,
443 "LISTEN ", 443 "LISTEN X",
444 eh); 444 eh);
445 GNUNET_assert (0 == 445 GNUNET_assert (0 ==
446 pthread_mutex_unlock (&db->notify_lock)); 446 pthread_mutex_unlock (&db->notify_lock));
@@ -461,7 +461,7 @@ GNUNET_PQ_event_listen_cancel (struct GNUNET_DB_EventHandler *eh)
461 eh)); 461 eh));
462 462
463 manage_subscribe (db, 463 manage_subscribe (db,
464 "UNLISTEN ", 464 "UNLISTEN X",
465 eh); 465 eh);
466 if ( (NULL != db->sc) && 466 if ( (NULL != db->sc) &&
467 (0 == GNUNET_CONTAINER_multishortmap_size (db->channel_map)) ) 467 (0 == GNUNET_CONTAINER_multishortmap_size (db->channel_map)) )
@@ -486,7 +486,7 @@ GNUNET_PQ_event_notify (struct GNUNET_PQ_Context *db,
486 PGresult *result; 486 PGresult *result;
487 487
488 end = stpcpy (sql, 488 end = stpcpy (sql,
489 "NOTIFY "); 489 "NOTIFY X");
490 end = es_to_channel (es, 490 end = es_to_channel (es,
491 end); 491 end);
492 end = stpcpy (end, 492 end = stpcpy (end,