diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2013-12-18 14:12:39 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2013-12-18 14:12:39 +0000 |
commit | 1549d7144c6863c41b958d27e4bee30a84dfa4e6 (patch) | |
tree | 617120c1e926ff517a631b4ae0a6d823274871a0 /src/transport/plugin_transport_unix.c | |
parent | 2586acf3dc0401103f43bc6046a55f64374edc2a (diff) | |
download | gnunet-1549d7144c6863c41b958d27e4bee30a84dfa4e6.tar.gz gnunet-1549d7144c6863c41b958d27e4bee30a84dfa4e6.zip |
session timeouts for unix
Diffstat (limited to 'src/transport/plugin_transport_unix.c')
-rw-r--r-- | src/transport/plugin_transport_unix.c | 10 |
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, | |||
911 | const struct GNUNET_PeerIdentity *peer, | 911 | const struct GNUNET_PeerIdentity *peer, |
912 | struct Session *session) | 912 | struct Session *session) |
913 | { | 913 | { |
914 | struct Plugin *plugin = cls; | ||
915 | |||
916 | if (GNUNET_OK != | ||
917 | GNUNET_CONTAINER_multipeermap_contains_value (plugin->session_map, | ||
918 | &session->target, | ||
919 | session)) | ||
920 | return; | ||
914 | 921 | ||
922 | reschedule_session_timeout (session); | ||
915 | } | 923 | } |
916 | 924 | ||
917 | /** | 925 | /** |
@@ -978,7 +986,7 @@ unix_plugin_send (void *cls, | |||
978 | memcpy (&message->sender, plugin->env->my_identity, | 986 | memcpy (&message->sender, plugin->env->my_identity, |
979 | sizeof (struct GNUNET_PeerIdentity)); | 987 | sizeof (struct GNUNET_PeerIdentity)); |
980 | memcpy (&message[1], msgbuf, msgbuf_size); | 988 | memcpy (&message[1], msgbuf, msgbuf_size); |
981 | reschedule_session_timeout (session); | 989 | |
982 | wrapper = GNUNET_new (struct UNIXMessageWrapper); | 990 | wrapper = GNUNET_new (struct UNIXMessageWrapper); |
983 | wrapper->msg = message; | 991 | wrapper->msg = message; |
984 | wrapper->msgsize = ssize; | 992 | wrapper->msgsize = ssize; |