too_far = NR_BUFS;

nbuffered = 0; /* вначале буфер пуст */

for (i = 0; i < NR_BUFS; i++) arrived[i] = false;

while (true) {

wait_for_event(&event); /* пять возможных событий: см. event_type выше */

switch(event) {

case network_layer_ready: /* получить, сохранить и передать новый фрейм */

nbuffered = nbuffered + 1; /* увеличить окно отправителя */

from_network_layer(&out_buf[next_frame_to_send % NR_BUFS]); /* получить новый пакет у сетевого уровня */

send_frame(data, next_frame_to_send, frame_expected, out_buf); /* передать фрейм */

inc(next_frame_to_send); /* увеличить верхний край окна отправителя */

break;

case frame_arrival: /* пришел фрейм данных или с подтверждением */

from_physical_layer(&r); /* получить пришедший фрейм у физического уровня */

if (r.kind == data) {

/* Фрейм пришел в целости. */

if ((r.seq != frame_expected) && no_nak)

send_frame(nak, 0, frame_expected, out_buf); else start_ack_timer;

if (between(frame_expected,r.seq,too_far) && (arrived[r.seq%NR_BUFS]==false)) {

/* Фреймы могут приниматься в любом порядке. */

arrived[r.seq % NR_BUFS] = true; /* пометить буфер как занятый */

in_buf[r.seq % NR_BUFS] = r.info; /* поместить данные в буфер */

while (arrived[frame_expected % NR_BUFS]) {

/* Передать пакет сетевому уровню и сдвинуть окно

to_network_layer(&in_buf[frame_expected % NR_BUFS]);

no_nak = true;

arrived[frame_expected % NR_BUFS] = false;

inc(frame_expected); /* передвинуть нижний край окна получателя */

inc(too_far); /* передвинуть верхний край окна получателя */

start_ack_timer; /* запустить вспомогательный таймер на случай, если потре-буется пересылка подтверждения отдельным фреймом */

}

}

}

if((r.kind==nak) && between(ack_expected,(r.ack+1)%(MAX_SEQ+1), next_frame_to_send))

send_frame(data, (r.ack+1) % (MAX_SEQ + 1), frame_expected, out_buf);

while (between(ack_expected, r.ack, next_frame_to_send)) {

nbuffered = nbuffered – 1; /* отправить подтверждение вместе с информационным фреймом */

stop_timer(ack_expected % NR_BUFS); /* фрейм пришел в целости */

inc(ack_expected); /* передвинуть нижний край окна отправителя */

}

break;

case cksum_err:

if (no_nak) send_frame(nak, 0, frame_expected, out_buf); /* поврежденный фрейм */

break;

case timeout:

send_frame(data, oldest_frame, frame_expected, out_buf); /* время истекло */

break;

case ack_timeout:

send_frame(ack,0,frame_expected, out_buf); /* истек период ожидания «попутки» для подтверждения; послать подтверждение */

}

if (nbuffered < NR_BUFS) enable_network_layer; else disable_network_layer;

}

}

Илл. 3.21. Протокол раздвижного окна с выборочным повтором

Илл. 3.22. Пример работы протокола. (а) Начальная ситуация при размере окна 7. (б) Семь фреймов были посланы и приняты, но не подтверждены. (в) Начальная ситуация при размере окна 4. (г) Ситуация после того, как четыре фрейма были отправлены и получены, но не подтверждены

По этой же причине количество необходимых таймеров также равно числу буферов, а не диапазону порядковых номеров; то есть с каждым буфером связывается один таймер. Когда интервал времени истекает, содержимое буфера высылается повторно.

Протокол 6 также ослабляет неявное допущение, что загрузка канала довольно высока. Мы сделали это предположение в протоколе 5, в котором подтверждения вкладывались во фреймы данных, отсылаемые в обратном направлении. Если обратный поток информации невелик, подтверждения могут задерживаться на довольно большой период времени, создавая проблемы. В исключительной ситуации, когда в одном направлении посылается много информации, а во встречном — вообще ничего, протокол останавливается, как только окно отправителя достигает максимума.