Lines Matching refs:rel
278 reliable_init (struct reliable *rel, int buf_size, int offset, int array_size, bool hold)
282 CLEAR (*rel);
284 rel->hold = hold;
285 rel->size = array_size;
286 rel->offset = offset;
287 for (i = 0; i < rel->size; ++i)
289 struct reliable_entry *e = &rel->array[i];
296 reliable_free (struct reliable *rel)
299 for (i = 0; i < rel->size; ++i)
301 struct reliable_entry *e = &rel->array[i];
308 reliable_empty (const struct reliable *rel)
311 for (i = 0; i < rel->size; ++i)
313 const struct reliable_entry *e = &rel->array[i];
322 reliable_send_purge (struct reliable *rel, struct reliable_ack *ack)
328 for (j = 0; j < rel->size; ++j)
330 struct reliable_entry *e = &rel->array[j];
355 reliable_print_ids (const struct reliable *rel, struct gc_arena *gc)
360 buf_printf (&out, "[" packet_id_format "]", (packet_id_print_type)rel->packet_id);
361 for (i = 0; i < rel->size; ++i)
363 const struct reliable_entry *e = &rel->array[i];
372 reliable_can_get (const struct reliable *rel)
376 for (i = 0; i < rel->size; ++i)
378 const struct reliable_entry *e = &rel->array[i];
382 dmsg (D_REL_LOW, "ACK no free receive buffer available: %s", reliable_print_ids (rel, &gc));
389 reliable_not_replay (const struct reliable *rel, packet_id_type id)
393 if (reliable_pid_min (id, rel->packet_id))
395 for (i = 0; i < rel->size; ++i)
397 const struct reliable_entry *e = &rel->array[i];
405 dmsg (D_REL_DEBUG, "ACK " packet_id_format " is a replay: %s", (packet_id_print_type)id, reliable_print_ids (rel, &gc));
412 reliable_wont_break_sequentiality (const struct reliable *rel, packet_id_type id)
416 const int ret = reliable_pid_in_range2 (id, rel->packet_id, rel->size);
421 (packet_id_print_type)id, reliable_print_ids (rel, &gc));
424 dmsg (D_REL_DEBUG, "ACK RWBS rel->size=%d rel->packet_id=%08x id=%08x ret=%d\n", rel->size, rel->packet_id, id, ret);
432 reliable_get_buf (struct reliable *rel)
435 for (i = 0; i < rel->size; ++i)
437 struct reliable_entry *e = &rel->array[i];
440 ASSERT (buf_init (&e->buf, rel->offset));
449 reliable_get_buf_output_sequenced (struct reliable *rel)
458 for (i = 0; i < rel->size; ++i)
460 const struct reliable_entry *e = &rel->array[i];
471 if (!min_id_defined || reliable_pid_in_range1 (rel->packet_id, min_id, rel->size))
473 ret = reliable_get_buf (rel);
477 dmsg (D_REL_LOW, "ACK output sequence broken: %s", reliable_print_ids (rel, &gc));
485 reliable_get_buf_sequenced (struct reliable *rel)
488 for (i = 0; i < rel->size; ++i)
490 struct reliable_entry *e = &rel->array[i];
491 if (e->active && e->packet_id == rel->packet_id)
501 reliable_can_send (const struct reliable *rel)
506 for (i = 0; i < rel->size; ++i)
508 const struct reliable_entry *e = &rel->array[i];
519 reliable_print_ids (rel, &gc));
522 return n_current > 0 && !rel->hold;
528 reliable_unique_retry (struct reliable *rel, time_t retry)
533 for (i = 0; i < rel->size; ++i)
535 struct reliable_entry *e = &rel->array[i];
549 reliable_send (struct reliable *rel, int *opcode)
555 for (i = 0; i < rel->size; ++i)
557 struct reliable_entry *e = &rel->array[i];
568 best->next_try = reliable_unique_retry (rel, local_now + best->timeout);
585 reliable_schedule_now (struct reliable *rel)
589 rel->hold = false;
590 for (i = 0; i < rel->size; ++i)
592 struct reliable_entry *e = &rel->array[i];
596 e->timeout = rel->initial_timeout;
604 reliable_send_timeout (const struct reliable *rel)
611 for (i = 0; i < rel->size; ++i)
613 const struct reliable_entry *e = &rel->array[i];
630 reliable_print_ids (rel, &gc));
641 reliable_mark_active_incoming (struct reliable *rel, struct buffer *buf,
645 for (i = 0; i < rel->size; ++i)
647 struct reliable_entry *e = &rel->array[i];
656 ASSERT (!reliable_pid_min (pid, rel->packet_id));
665 ASSERT (0); /* buf not found in rel */
673 reliable_mark_active_outgoing (struct reliable *rel, struct buffer *buf, int opcode)
676 for (i = 0; i < rel->size; ++i)
678 struct reliable_entry *e = &rel->array[i];
684 e->packet_id = rel->packet_id++;
690 e->timeout = rel->initial_timeout;
695 ASSERT (0); /* buf not found in rel */
700 reliable_mark_deleted (struct reliable *rel, struct buffer *buf, bool inc_pid)
703 for (i = 0; i < rel->size; ++i)
705 struct reliable_entry *e = &rel->array[i];
710 rel->packet_id = e->packet_id + 1;
732 reliable_debug_print (const struct reliable *rel, char *desc)
738 printf (" initial_timeout=%d\n", (int)rel->initial_timeout);
739 printf (" packet_id=" packet_id_format "\n", rel->packet_id);
741 for (i = 0; i < rel->size; ++i)
743 const struct reliable_entry *e = &rel->array[i];