aboutsummaryrefslogtreecommitdiff
path: root/src/mesh/mesh_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/mesh/mesh_api.c')
-rw-r--r--src/mesh/mesh_api.c5
1 files changed, 2 insertions, 3 deletions
diff --git a/src/mesh/mesh_api.c b/src/mesh/mesh_api.c
index 0c96e2281..2f6ac26a1 100644
--- a/src/mesh/mesh_api.c
+++ b/src/mesh/mesh_api.c
@@ -454,7 +454,7 @@ create_tunnel (struct GNUNET_MESH_Handle *h, MESH_TunnelNumber tid)
454 { 454 {
455 t->tid = tid; 455 t->tid = tid;
456 } 456 }
457 t->max_send_pid = 1; 457 t->max_send_pid = 0;
458 return t; 458 return t;
459} 459}
460 460
@@ -2051,8 +2051,7 @@ GNUNET_MESH_notify_transmit_ready (struct GNUNET_MESH_Tunnel *tunnel, int cork,
2051 add_to_queue (tunnel->mesh, th); 2051 add_to_queue (tunnel->mesh, th);
2052 if (NULL != tunnel->mesh->th) 2052 if (NULL != tunnel->mesh->th)
2053 return th; 2053 return th;
2054 if (GNUNET_NO == PID_OVERFLOW(tunnel->next_send_pid, tunnel->max_send_pid) && 2054 if (GMC_is_pid_bigger(tunnel->next_send_pid, tunnel->max_send_pid))
2055 tunnel->max_send_pid <= tunnel->next_send_pid)
2056 return th; 2055 return th;
2057 LOG (GNUNET_ERROR_TYPE_DEBUG, " call notify tmt rdy\n"); 2056 LOG (GNUNET_ERROR_TYPE_DEBUG, " call notify tmt rdy\n");
2058 tunnel->mesh->th = 2057 tunnel->mesh->th =