0

我正在玩一个名为 mad_flute 的长笛协议应用程序。 http://mad.cs.tut.fi/

一切正常，除非我尝试发送大于 30GB 的文件。（或超过 65536 个）块。该应用程序有 1 个发送部分和 1 个接收部分。发送侧接缝正在工作，您可以看到它发送所有块“88462/88462 Source Blocks sent (TOI=1 SBN=88461)”接收方始终停止在“65536/88462 Source Blocks decoded (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

来自 C 国王/王后的任何指示都会令人惊叹。

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;

}

4

0 回答 0