diff options
author | lurchi <lurchi@strangeplace.net> | 2017-10-13 22:00:26 +0200 |
---|---|---|
committer | lurchi <lurchi@strangeplace.net> | 2017-10-13 22:00:26 +0200 |
commit | 7ca96c1ceb078bcee0da73217b7019c1329939eb (patch) | |
tree | cb5a734eb60298b7e446375d87eb17ff7dd7216b /src/social | |
parent | 7478bbf75478b0df49ba06379888aae3632c2bf5 (diff) | |
download | gnunet-7ca96c1ceb078bcee0da73217b7019c1329939eb.tar.gz gnunet-7ca96c1ceb078bcee0da73217b7019c1329939eb.zip |
we were on the wood way
Diffstat (limited to 'src/social')
-rw-r--r-- | src/social/social_api.c | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/src/social/social_api.c b/src/social/social_api.c index a190b2f26..4b3655de4 100644 --- a/src/social/social_api.c +++ b/src/social/social_api.c | |||
@@ -1062,6 +1062,8 @@ place_cleanup (struct GNUNET_SOCIAL_Place *plc) | |||
1062 | } | 1062 | } |
1063 | if (NULL != plc->mq) | 1063 | if (NULL != plc->mq) |
1064 | { | 1064 | { |
1065 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, | ||
1066 | "destroying MQ (place_cleanup)\n"); | ||
1065 | GNUNET_MQ_destroy (plc->mq); | 1067 | GNUNET_MQ_destroy (plc->mq); |
1066 | plc->mq = NULL; | 1068 | plc->mq = NULL; |
1067 | } | 1069 | } |
@@ -1085,11 +1087,10 @@ place_disconnect (struct GNUNET_SOCIAL_Place *plc) | |||
1085 | plc); | 1087 | plc); |
1086 | if (NULL != plc->mq) | 1088 | if (NULL != plc->mq) |
1087 | { | 1089 | { |
1088 | //struct GNUNET_MQ_Envelope *env = GNUNET_MQ_get_last_envelope (plc->mq); | 1090 | struct GNUNET_MQ_Envelope *env = GNUNET_MQ_get_last_envelope (plc->mq); |
1089 | if (GNUNET_MQ_get_length (plc->mq) > 0) | 1091 | if (NULL != env) |
1090 | { | 1092 | { |
1091 | struct GNUNET_MQ_Envelope *env = GNUNET_MQ_get_last_envelope (plc->mq); | 1093 | GNUNET_MQ_notify_sent (env, (GNUNET_SCHEDULER_TaskCallback) place_cleanup, plc); |
1092 | GNUNET_MQ_notify_sent (env, (GNUNET_SCHEDULER_TaskCallback) place_disconnect, plc); | ||
1093 | } | 1094 | } |
1094 | else | 1095 | else |
1095 | { | 1096 | { |
@@ -1151,6 +1152,8 @@ host_disconnected (void *cls, enum GNUNET_MQ_Error error) | |||
1151 | } | 1152 | } |
1152 | if (NULL != plc->mq) | 1153 | if (NULL != plc->mq) |
1153 | { | 1154 | { |
1155 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, | ||
1156 | "destroying MQ (host_disconnected)\n"); | ||
1154 | GNUNET_MQ_destroy (plc->mq); | 1157 | GNUNET_MQ_destroy (plc->mq); |
1155 | plc->mq = NULL; | 1158 | plc->mq = NULL; |
1156 | } | 1159 | } |
@@ -1659,6 +1662,8 @@ guest_disconnected (void *cls, enum GNUNET_MQ_Error error) | |||
1659 | } | 1662 | } |
1660 | if (NULL != plc->mq) | 1663 | if (NULL != plc->mq) |
1661 | { | 1664 | { |
1665 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, | ||
1666 | "destroying MQ (guest_disconnected)\n"); | ||
1662 | GNUNET_MQ_destroy (plc->mq); | 1667 | GNUNET_MQ_destroy (plc->mq); |
1663 | plc->mq = NULL; | 1668 | plc->mq = NULL; |
1664 | } | 1669 | } |