aboutsummaryrefslogtreecommitdiff
path: root/src/messenger/gnunet-service-messenger_tunnel.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/messenger/gnunet-service-messenger_tunnel.c')
-rw-r--r--src/messenger/gnunet-service-messenger_tunnel.c14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/messenger/gnunet-service-messenger_tunnel.c b/src/messenger/gnunet-service-messenger_tunnel.c
index 45c10c1af..83973bbbe 100644
--- a/src/messenger/gnunet-service-messenger_tunnel.c
+++ b/src/messenger/gnunet-service-messenger_tunnel.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
@@ -157,13 +157,13 @@ static void
157update_tunnel_last_message (struct GNUNET_MESSENGER_SrvTunnel *tunnel, 157update_tunnel_last_message (struct GNUNET_MESSENGER_SrvTunnel *tunnel,
158 const struct GNUNET_HashCode *hash) 158 const struct GNUNET_HashCode *hash)
159{ 159{
160 struct GNUNET_MESSENGER_OperationStore *operation_store = get_room_operation_store(tunnel->room); 160 struct GNUNET_MESSENGER_OperationStore *operation_store = get_srv_room_operation_store(tunnel->room);
161 161
162 const int requested = (GNUNET_MESSENGER_OP_REQUEST == get_store_operation_type(operation_store, hash)? 162 const int requested = (GNUNET_MESSENGER_OP_REQUEST == get_store_operation_type(operation_store, hash)?
163 GNUNET_YES : GNUNET_NO 163 GNUNET_YES : GNUNET_NO
164 ); 164 );
165 165
166 struct GNUNET_MESSENGER_MessageStore *message_store = get_room_message_store(tunnel->room); 166 struct GNUNET_MESSENGER_MessageStore *message_store = get_srv_room_message_store(tunnel->room);
167 167
168 const struct GNUNET_MESSENGER_Message *message = get_store_message(message_store, hash); 168 const struct GNUNET_MESSENGER_Message *message = get_store_message(message_store, hash);
169 169
@@ -221,7 +221,7 @@ handle_tunnel_message (void *cls, const struct GNUNET_MessageHeader *header)
221 221
222 if (GNUNET_YES == forward_message) 222 if (GNUNET_YES == forward_message)
223 { 223 {
224 forward_room_message (tunnel->room, tunnel, &message, &hash); 224 forward_srv_room_message (tunnel->room, tunnel, &message, &hash);
225 callback_room_handle_message (tunnel->room, NULL, &message, &hash); 225 callback_room_handle_message (tunnel->room, NULL, &message, &hash);
226 } 226 }
227 227
@@ -241,8 +241,8 @@ connect_tunnel (struct GNUNET_MESSENGER_SrvTunnel *tunnel)
241 241
242 const struct GNUNET_PeerIdentity *door = GNUNET_PEER_resolve2 (tunnel->peer); 242 const struct GNUNET_PeerIdentity *door = GNUNET_PEER_resolve2 (tunnel->peer);
243 243
244 struct GNUNET_CADET_Handle *cadet = get_room_cadet (tunnel->room); 244 struct GNUNET_CADET_Handle *cadet = get_srv_room_cadet (tunnel->room);
245 const struct GNUNET_HashCode *key = get_room_key (tunnel->room); 245 const struct GNUNET_HashCode *key = get_srv_room_key (tunnel->room);
246 246
247 struct GNUNET_MQ_MessageHandler handlers[] = { GNUNET_MQ_hd_var_size(tunnel_message, GNUNET_MESSAGE_TYPE_CADET_CLI, 247 struct GNUNET_MQ_MessageHandler handlers[] = { GNUNET_MQ_hd_var_size(tunnel_message, GNUNET_MESSAGE_TYPE_CADET_CLI,
248 struct GNUNET_MessageHeader, NULL), 248 struct GNUNET_MessageHeader, NULL),
@@ -323,7 +323,7 @@ send_tunnel_message (struct GNUNET_MESSENGER_SrvTunnel *tunnel,
323 return GNUNET_NO; 323 return GNUNET_NO;
324 324
325 struct GNUNET_HashCode hash; 325 struct GNUNET_HashCode hash;
326 struct GNUNET_MQ_Envelope *env = pack_room_message ( 326 struct GNUNET_MQ_Envelope *env = pack_srv_room_message (
327 tunnel->room, (struct GNUNET_MESSENGER_SrvHandle*) handle, 327 tunnel->room, (struct GNUNET_MESSENGER_SrvHandle*) handle,
328 message, &hash, GNUNET_MESSENGER_PACK_MODE_ENVELOPE 328 message, &hash, GNUNET_MESSENGER_PACK_MODE_ENVELOPE
329 ); 329 );