LINUX.ORG.RU
Форум — Development  

Recv снова в ожидании,в то время как Send уже все передал.

 , , ,


0

1

Доброе утро! Столкнулся с проблемой: через отладчик gdb посмотрел,что функция recv получает данные и далее снова в ожидании получения данных,в то время как send уже передал данные и завершил работу. Возможно, что-то упустил ...

Куски кода: Server.c 


int sendall(int s, char *buf, int len, int flags)
{
    int total = 0;
    int n = 0;
    while(total < len)
    {
        n = (int) send(s, buf+total, (size_t) (len-total), flags);
        if(n == -1) break;
        total += n;
    }
    return (n==-1 ? -1 : total);
}
//Если вместо sendall использовать send - проблема актуальна.
int fileTransferSend(int sock, char pathToFile[]){

    FILE *f;
    if (!(f = fopen(pathToFile, "rb"))) {
        perror("fopen");
        return 1;
    }
    fseek(f, 0, SEEK_END);
    int fsize = (int) ftell(f);
    rewind(f);

    char buffer[BUF_SIZE];
    long sended = 0, readed = 0;
    do {
        readed = fread(buffer, 1, BUF_SIZE, f);

        if ((sendall(sock, buffer, (int) readed, 0)) < 0) {
            perror("send[7]");
        }
        sended += readed;
    } while (sended != fsize);

    fclose(f);

    return 0;
}

Client.c 

int fileTransferRecv(int sock){

    char buffer[BUF_SIZE];
    long rcv_len = 0;
    memset(buffer, 0, sizeof buffer);

    FILE *f;
    if (!(f = fopen(pathToList, "wb+"))) {
        perror("fopen");
        return 1;
    }

    do {
        rcv_len = recv(sock, buffer, BUF_SIZE, 0);
        fwrite(buffer, 1, (size_t) rcv_len, f);
    } while (rcv_len != 0);
    fclose(f);

    return 0;
}

а что ты, собственно, ожидал от recv? сказал ей получить - она и получает. ты наверно думал, что она будет телепатически узнавать что тебе от неё надо.

ckotinko ☆☆☆
()
Ответ на: комментарий от anonymous

байрон кроет аффтара отборным русским матом за такое издевательство над языком

ckotinko ☆☆☆
()
Ответ на: комментарий от BladzheR

через alarm() и обработку sig_alarm. Примерно так: 

int flag;
void sig_alarm( int ) {
   flag = 0;
}

int fileTransferRecv(int sock) {
  flag = 1;
  signal( SIGALRM, sig_alarm );
  alarm( 1 );
  while( flag )
 {
   ...
   fwrite();
   alarm( 1 );
 }
alarm( 0 );
}

sigurd ★★★★★
()
Последнее исправление: sigurd (всего исправлений: 2)
Вы не можете добавлять комментарии в эту тему. Тема перемещена в архив.
Development