aboutsummaryrefslogtreecommitdiff
path: root/src/namestore/gnunet-service-namestore.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2018-11-02 23:30:58 +0100
committerChristian Grothoff <christian@grothoff.org>2018-11-02 23:30:58 +0100
commit061c93625c8c5c96b2a8059b167cc3f637c80bd7 (patch)
tree61291a9f4bd80acd63918971939a6aa0cd915b78 /src/namestore/gnunet-service-namestore.c
parentc25fa6abad5893c052b05e2fd23d6fd8fee1a0cf (diff)
downloadgnunet-061c93625c8c5c96b2a8059b167cc3f637c80bd7.tar.gz
gnunet-061c93625c8c5c96b2a8059b167cc3f637c80bd7.zip
use separate message type to indicate end of transmission (much cleaner)
Diffstat (limited to 'src/namestore/gnunet-service-namestore.c')
-rw-r--r--src/namestore/gnunet-service-namestore.c10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/namestore/gnunet-service-namestore.c b/src/namestore/gnunet-service-namestore.c
index 6ad7354ad..1b9e01e18 100644
--- a/src/namestore/gnunet-service-namestore.c
+++ b/src/namestore/gnunet-service-namestore.c
@@ -11,7 +11,7 @@
11 WITHOUT ANY WARRANTY; without even the implied warranty of 11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 Affero General Public License for more details. 13 Affero General Public License for more details.
14 14
15 You should have received a copy of the GNU Affero General Public License 15 You should have received a copy of the GNU Affero General Public License
16 along with this program. If not, see <http://www.gnu.org/licenses/>. 16 along with this program. If not, see <http://www.gnu.org/licenses/>.
17*/ 17*/
@@ -1733,7 +1733,7 @@ run_zone_iteration_round (struct ZoneIteration *zi,
1733{ 1733{
1734 struct ZoneIterationProcResult proc; 1734 struct ZoneIterationProcResult proc;
1735 struct GNUNET_MQ_Envelope *env; 1735 struct GNUNET_MQ_Envelope *env;
1736 struct RecordResultMessage *rrm; 1736 struct GNUNET_NAMESTORE_Header *em;
1737 struct GNUNET_TIME_Absolute start; 1737 struct GNUNET_TIME_Absolute start;
1738 struct GNUNET_TIME_Relative duration; 1738 struct GNUNET_TIME_Relative duration;
1739 1739
@@ -1778,9 +1778,9 @@ run_zone_iteration_round (struct ZoneIteration *zi,
1778 (unsigned long long) (limit - proc.limit), 1778 (unsigned long long) (limit - proc.limit),
1779 (unsigned long long) limit); 1779 (unsigned long long) limit);
1780 /* send empty response to indicate end of list */ 1780 /* send empty response to indicate end of list */
1781 env = GNUNET_MQ_msg (rrm, 1781 env = GNUNET_MQ_msg (em,
1782 GNUNET_MESSAGE_TYPE_NAMESTORE_RECORD_RESULT); 1782 GNUNET_MESSAGE_TYPE_NAMESTORE_RECORD_RESULT_END);
1783 rrm->gns_header.r_id = htonl (zi->request_id); 1783 em->r_id = htonl (zi->request_id);
1784 GNUNET_MQ_send (zi->nc->mq, 1784 GNUNET_MQ_send (zi->nc->mq,
1785 env); 1785 env);
1786 GNUNET_CONTAINER_DLL_remove (zi->nc->op_head, 1786 GNUNET_CONTAINER_DLL_remove (zi->nc->op_head,