aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-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,
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;