Administrace komentářů

int buffsize = 1024*1024;
setsockopt(sockfd, SOL_SOCKET, SO_RCVBUF, &buffsize, sizeof(buffsize));

void *thread_reader(void **_client) {
    
    client_t *client = *_client;  
    int meslen = 0;
    int len = 0;
    int i, j;
    char *meschar;
    int buffsize = 1024*1024;
    setsockopt(sockfd, SOL_SOCKET, SO_RCVBUF, &buffsize, sizeof(buffsize));
    char *buf;
    
    while (1) {
        buf = (char *) malloc(buffsize);

        if (buf == NULL) {
            free(buf);
            buf = NULL;
            exit(1);
        } 
        len += recv(client->fd, buf, buffsize, 0);
        
        for (i = 0; i < len; i++) {
            /* zjisti delku zpravy */
            if (buf[i] == '^'){
                meschar = (char*)malloc (i-1);
                
                for(j = 0; j < i; j++){
                    meschar[j] = buf[j];                  
                }            
                meslen = atoi(meschar);              
                j++;                             
            }          
            if(i == (meslen + j))
                break;                               
        }
        handle_msg(buf, meslen, j);
        broadcast(client->id, buf, i + 1);
        free(meschar);
        free(buf);
    }
}

flag: 8
isdir: 0
hmlen: 30
parlen: 30
fsize: 1655
path: /home/tomesh/Dropbox/C/dropbox/test
home: /home/tomesh/Dropbox/C/sync/test

flag: 0
isdir: 0
hmlen: 0
parlen: 0
fsize: 0
path: 
home: ./srv