aboutsummaryrefslogtreecommitdiff
path: root/src/messenger/gnunet-service-messenger_message_recv.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/messenger/gnunet-service-messenger_message_recv.c')
-rw-r--r--src/messenger/gnunet-service-messenger_message_recv.c16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/messenger/gnunet-service-messenger_message_recv.c b/src/messenger/gnunet-service-messenger_message_recv.c
index bb6ee6f17..4e96cf552 100644
--- a/src/messenger/gnunet-service-messenger_message_recv.c
+++ b/src/messenger/gnunet-service-messenger_message_recv.c
@@ -1,6 +1,6 @@
1/* 1/*
2 This file is part of GNUnet. 2 This file is part of GNUnet.
3 Copyright (C) 2020--2021 GNUnet e.V. 3 Copyright (C) 2020--2022 GNUnet e.V.
4 4
5 GNUnet is free software: you can redistribute it and/or modify it 5 GNUnet is free software: you can redistribute it and/or modify it
6 under the terms of the GNU Affero General Public License as published 6 under the terms of the GNU Affero General Public License as published
@@ -36,7 +36,7 @@ forward_about_members (struct GNUNET_MESSENGER_SrvRoom *room,
36 if (session->prev) 36 if (session->prev)
37 forward_about_members (room, tunnel, session->prev, map); 37 forward_about_members (room, tunnel, session->prev, map);
38 38
39 struct GNUNET_MESSENGER_MessageStore *message_store = get_room_message_store(room); 39 struct GNUNET_MESSENGER_MessageStore *message_store = get_srv_room_message_store(room);
40 struct GNUNET_MESSENGER_ListMessage *element; 40 struct GNUNET_MESSENGER_ListMessage *element;
41 41
42 for (element = session->messages.head; element; element = element->next) 42 for (element = session->messages.head; element; element = element->next)
@@ -92,7 +92,7 @@ recv_message_info (struct GNUNET_MESSENGER_SrvRoom *room,
92 92
93 if (room->host) 93 if (room->host)
94 { 94 {
95 const struct GNUNET_MESSENGER_Ego *ego = get_handle_ego(room->host); 95 const struct GNUNET_MESSENGER_Ego *ego = get_srv_handle_ego(room->host);
96 96
97 send_tunnel_message (tunnel, room->host, create_message_info(ego)); 97 send_tunnel_message (tunnel, room->host, create_message_info(ego));
98 } 98 }
@@ -102,12 +102,12 @@ recv_message_info (struct GNUNET_MESSENGER_SrvRoom *room,
102 102
103 if (GNUNET_YES != contains_list_tunnels(&(room->basement), &peer)) 103 if (GNUNET_YES != contains_list_tunnels(&(room->basement), &peer))
104 { 104 {
105 struct GNUNET_MESSENGER_MemberStore *member_store = get_room_member_store(room); 105 struct GNUNET_MESSENGER_MemberStore *member_store = get_srv_room_member_store(room);
106 106
107 iterate_store_members(member_store, iterate_forward_members, tunnel); 107 iterate_store_members(member_store, iterate_forward_members, tunnel);
108 } 108 }
109 109
110 check_room_peer_status(room, tunnel); 110 check_srv_room_peer_status(room, tunnel);
111 111
112 return GNUNET_NO; 112 return GNUNET_NO;
113} 113}
@@ -142,7 +142,7 @@ callback_found_message (void *cls,
142 142
143 if (!message) 143 if (!message)
144 { 144 {
145 struct GNUNET_MESSENGER_OperationStore *operation_store = get_room_operation_store(room); 145 struct GNUNET_MESSENGER_OperationStore *operation_store = get_srv_room_operation_store(room);
146 146
147 use_store_operation( 147 use_store_operation(
148 operation_store, 148 operation_store,
@@ -165,7 +165,7 @@ recv_message_request (struct GNUNET_MESSENGER_SrvRoom *room,
165 const struct GNUNET_MESSENGER_Message *message, 165 const struct GNUNET_MESSENGER_Message *message,
166 const struct GNUNET_HashCode *hash) 166 const struct GNUNET_HashCode *hash)
167{ 167{
168 struct GNUNET_MESSENGER_MemberStore *member_store = get_room_member_store(room); 168 struct GNUNET_MESSENGER_MemberStore *member_store = get_srv_room_member_store(room);
169 struct GNUNET_MESSENGER_Member *member = get_store_member_of(member_store, message); 169 struct GNUNET_MESSENGER_Member *member = get_store_member_of(member_store, message);
170 170
171 GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Request for message (%s)\n", GNUNET_h2s (hash)); 171 GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Request for message (%s)\n", GNUNET_h2s (hash));
@@ -178,7 +178,7 @@ recv_message_request (struct GNUNET_MESSENGER_SrvRoom *room,
178 if ((!session) || (GNUNET_YES != check_member_session_history(session, hash, GNUNET_NO))) 178 if ((!session) || (GNUNET_YES != check_member_session_history(session, hash, GNUNET_NO)))
179 return GNUNET_NO; 179 return GNUNET_NO;
180 180
181 if (GNUNET_NO == request_room_message(room, &(message->body.request.hash), session, callback_found_message, tunnel)) 181 if (GNUNET_NO == request_srv_room_message(room, &(message->body.request.hash), session, callback_found_message, tunnel))
182 return GNUNET_YES; 182 return GNUNET_YES;
183 183
184 return GNUNET_NO; 184 return GNUNET_NO;