Mad_Flute перестает получать после 65535 блоков - PullRequest
Новая
       10

Mad_Flute перестает получать после 65535 блоков

0 голосов
/ 27 ноября 2018

Я играю с приложением протокола флейты под названием mad_flute.http://mad.cs.tut.fi/

Все работает хорошо, за исключением случаев, когда я пытаюсь отправить файл размером более 30 ГБ.(Или более 65536) блоков.Приложение имеет 1 отправляющую часть и 1 получающую.Работающая сторона швов работает, и вы можете видеть, что она отправляет все блоки "88462/88462 Исходные блоки отправлены (TOI = 1 SBN = 88461)" Сторона приемника всегда останавливается на "65536/88462 декодированных исходных блоках (TOI = 1 SBN = 65535)) "

Я нашел одну переменную INT16 в источнике, но настройка, которая не решила проблему.

Далее я нашел логическое «Delta2 = 65535 - Delat1;»часть в mad_rlc.c и увеличила это значение, но получатель по-прежнему останавливается на «65536/88462 декодированные исходные блоки (TOI = 1 SBN = 65535)»

Источник можно скачать здесь: http://mad.cs.tut.fi/download/mad_fcl_v1.7_src.zip

Любые указатели от короля / королевы Си были бы потрясающими. 

int mad_rlc_check_sequence(alc_session_t *s, int layer, int seqid) {
unsigned short Delta1;
unsigned short Delta2;

int i;
int late_limit;

if(s->rlc->rx_wait_for[layer] == seqid) {
    /* This is the packet we're waiting for, let's go on! */
    s->rlc->rx_wait_for[layer]++;
    return 0;
}

/* This is not the one we're waiting for... */
if(s->rlc->rx_wait_for[layer] < seqid) {

    Delta1 = seqid - s->rlc->rx_wait_for[layer];
    Delta2 = 65535 - Delta1;

    if(Delta1 < Delta2) {

        late_limit = RLC_MAX_LATES;

        for(i = s->rlc->rx_wait_for[layer]; i < seqid; i++) {
            mad_rlc_add_late(s, layer, i);
            late_limit--;
            if(late_limit <= 0 ) {
                printf("RLC Warning*** Max number of LATE packets reached\n");
                fflush(stdout);
                break;
            }
        }
        /* EOFIX */
        s->rlc->rx_wait_for[layer] = seqid + 1;
    }
    else {
        /* Late arrival packet (uint16 overflow) */
        /* eg. we're waiting seq 4 and we get seq 65532 */
        mad_rlc_remove_late(s, layer, seqid);
    }
}
else { /* rx_wait_for > rlc_seqid */

    Delta1 = s->rlc->rx_wait_for[layer] - seqid;
    Delta2 = 65535 - Delta1;
    if (Delta1 < Delta2) { /* Late arrival packet */
    /* ie: we're waiting seq 501 and we get seq 498 */
        mad_rlc_remove_late(s, layer, seqid);
    }
    else {
    /* Some packet(s) are missing (uint16 overflow) */
    /* ie: waiting seq 65531 and get seq 3 */
        /* FIX 14/12/01 */
        late_limit = RLC_MAX_LATES;
        for(i = s->rlc->rx_wait_for[layer]; i != (seqid-1); i++) {
            mad_rlc_add_late(s, layer, i);
            late_limit--;
            if(late_limit <= 0 ) {
                printf("RLC Warning*** Max number of LATE packets reached\n");
                fflush(stdout);
                break;
            }
        }
        /* EOFIX */
        s->rlc->rx_wait_for[layer] = seqid + 1;
    }
}

return 0;

}

...