timeouts [Todt]

Esta página é apenas de leitura. Pode ver a fonte, mas não alterá-la. Informe-se com o administrador deste Wiki se achar que isto não está correto.
==== Implementando Timeouts ====

Um //timeout//, em sua definição mais genérica, é um evento que ocorre após um determinado tempo. Se especifica um determinado tempo, o //timeout interval//, e depois desse tempo, alguma coisa acontece. No contexto de redes isso é muito relevante, pois existe a chance de enviarmos algo e não obtermos uma confirmação, porque o outro lado não recebeu a nossa mensagem ou porque o outro lado não conseguiu mandar uma mensagem de resposta para nós. O razoável a se fazer é enviar a nossa mensagem novamente caso nenhuma mensagem seja recebida. No caso geral, é provado matematicamente que é impossível ter certeza que o outro lado recebeu a nossa mensagem, esse é o famoso [[https://en.wikipedia.org/wiki/Two_Generals%27_Problem|problema dos dois generais]], mas não nos custa ao menos tentar, e se der errado, é só culpar o usuário.

==== Sockets ====
Os //sockets// podem ter //timeout// nos seus métodos de ''send'' e ''recv'', como visto no [[raw_socket|artigo sobre sockets crus]]. Porém, isso não é suficiente para reenviarmos a mensagem só quando um determinado tempo passar, porque os //sockets// crus **recebem todos os pacotes da placa de rede**. Isso significa que se no meio tempo o seu computador decidir tentar configurar a Internet, o seu //socket// vai receber todas as mensagens dessa transação, mesmo não sendo as que você quer, e isso significa que o //timeout// dessas funções nunca //funciona//, pois ele sempre será reiniciado com essas outras mensagens da rede. A solução é além de usar o //timeout// no //socket//, é manter o seu próprio //timeout//. Isso pode ser feito simplesmente mantendo o seu próprio relógio.

<code C>
// usando long long pra (tentar) sobreviver ao ano 2038
long long timestamp() {
    struct timeval tp;
    gettimeofday(&tp, NULL);
    return tp.tv_sec*1000 + tp.tv_usec/1000;
}

int protocolo_e_valido(char* buffer, int tamanho_buffer) {
    if (tamanho_buffer <= 0) { return 0; }
    // insira a sua validação de protocolo aqui
    return buffer[0] == 0x7f;
}

// retorna -1 se deu timeout, ou quantidade de bytes lidos
int recebe_mensagem(int soquete, int timeoutMillis, char* buffer, int tamanho_buffer) {
    long long comeco = timestamp();
    struct timeval timeout = { .tv_sec = timeoutMillis/1000, .tv_usec = (timeoutMilis%1000) * 1000 };
    setsockopt(soquete, SOL_SOCKET, SO_RCVTIMEO, (char*) &timeout, sizeof(timeout));
    int bytes_lidos;
    do {
        bytes_lidos = recv(soquete, buffer, tamanho_buffer, 0);
        if (protocolo_e_valido(buffer, bytes_lidos)) { return bytes_lidos; }
    } while (timestamp() - comeco <= timeoutMillis);
    return -1;
}
</code>

==== Recuo Exponencial ====

Pode ser útil variar o tempo que se espera pela resposta de forma exponencial. Isso significa que na primeira retransmissão você espera um segundo para receber a mensagem, já na próxima espera dois, e na próxima quatro e assim por diante. Isso ajuda no caso por exemplo de um servidor ficar lento e não conseguir responder todas as mensagens que lhe foram enviadas. Assim, as mensagens vão enfileirando, e se elas chegarem num ritmo constante, o servidor nunca vai conseguir responder todas elas. Esse é o conceito do [[https://en.wikipedia.org/wiki/Exponential_backoff|recuo exponencial]], que é implementado em protocolos como o TCP mas se aplica a muito mais lugares, como por exemplo para evitar colisões na rede através da inserção de um componente probabilístico.