diff options
Diffstat (limited to 'src/datastore/datastore_api.c')
-rw-r--r-- | src/datastore/datastore_api.c | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c index 3f8ef9db4..d75a58552 100644 --- a/src/datastore/datastore_api.c +++ b/src/datastore/datastore_api.c | |||
@@ -848,20 +848,20 @@ handle_data_end (void *cls, | |||
848 | static void | 848 | static void |
849 | try_reconnect (void *cls) | 849 | try_reconnect (void *cls) |
850 | { | 850 | { |
851 | GNUNET_MQ_hd_var_size (status, | ||
852 | GNUNET_MESSAGE_TYPE_DATASTORE_STATUS, | ||
853 | struct StatusMessage); | ||
854 | GNUNET_MQ_hd_var_size (data, | ||
855 | GNUNET_MESSAGE_TYPE_DATASTORE_DATA, | ||
856 | struct DataMessage); | ||
857 | GNUNET_MQ_hd_fixed_size (data_end, | ||
858 | GNUNET_MESSAGE_TYPE_DATASTORE_DATA_END, | ||
859 | struct GNUNET_MessageHeader); | ||
860 | struct GNUNET_DATASTORE_Handle *h = cls; | 851 | struct GNUNET_DATASTORE_Handle *h = cls; |
861 | struct GNUNET_MQ_MessageHandler handlers[] = { | 852 | struct GNUNET_MQ_MessageHandler handlers[] = { |
862 | make_status_handler (h), | 853 | GNUNET_MQ_hd_var_size (status, |
863 | make_data_handler (h), | 854 | GNUNET_MESSAGE_TYPE_DATASTORE_STATUS, |
864 | make_data_end_handler (h), | 855 | struct StatusMessage, |
856 | h), | ||
857 | GNUNET_MQ_hd_var_size (data, | ||
858 | GNUNET_MESSAGE_TYPE_DATASTORE_DATA, | ||
859 | struct DataMessage, | ||
860 | h), | ||
861 | GNUNET_MQ_hd_fixed_size (data_end, | ||
862 | GNUNET_MESSAGE_TYPE_DATASTORE_DATA_END, | ||
863 | struct GNUNET_MessageHeader, | ||
864 | h), | ||
865 | GNUNET_MQ_handler_end () | 865 | GNUNET_MQ_handler_end () |
866 | }; | 866 | }; |
867 | 867 | ||