summaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_unix.c
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2013-12-18 14:12:39 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2013-12-18 14:12:39 +0000
commit1549d7144c6863c41b958d27e4bee30a84dfa4e6 (patch)
tree617120c1e926ff517a631b4ae0a6d823274871a0 /src/transport/plugin_transport_unix.c
parent2586acf3dc0401103f43bc6046a55f64374edc2a (diff)
session timeouts for unix
Diffstat (limited to 'src/transport/plugin_transport_unix.c')
-rw-r--r--src/transport/plugin_transport_unix.c10
1 files changed, 9 insertions, 1 deletions
diff --git a/src/transport/plugin_transport_unix.c b/src/transport/plugin_transport_unix.c
index 67c176633..3a2fa6516 100644
--- a/src/transport/plugin_transport_unix.c
+++ b/src/transport/plugin_transport_unix.c
@@ -911,7 +911,15 @@ unix_plugin_update_session_timeout (void *cls,
const struct GNUNET_PeerIdentity *peer,
struct Session *session)
{
+ struct Plugin *plugin = cls;
+
+ if (GNUNET_OK !=
+ GNUNET_CONTAINER_multipeermap_contains_value (plugin->session_map,
+ &session->target,
+ session))
+ return;
+ reschedule_session_timeout (session);
}
/**
@@ -978,7 +986,7 @@ unix_plugin_send (void *cls,
memcpy (&message->sender, plugin->env->my_identity,
sizeof (struct GNUNET_PeerIdentity));
memcpy (&message[1], msgbuf, msgbuf_size);
- reschedule_session_timeout (session);
+
wrapper = GNUNET_new (struct UNIXMessageWrapper);
wrapper->msg = message;
wrapper->msgsize = ssize;