Riferimenti per il file comandi.h

#include <signal.h>
#include <pthread.h>
#include "common.h"
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include "com_defs.h"
#include "common.h"
#include "fat_defs.h"
#include "fat.h"

Vai al codice sorgente di questo file.

Funzioni
void *	thread_servernte (void *)

---

Descrizione dettagliata

Autore:

Tranchida Giulio, No Matricola 241732
Si dichiara che il contenuto di questo file e', in ogni sua parte, opera originale dell'autore.

This program is free software; you can redistribuite it and/or modify it under the terms of the GNU/General Pubblic License as published the Free software Foundation; either version 2 of the License, or (at your opinion) any later version.

Definizione nel file comandi.h.

---

Documentazione delle funzioni

void* thread_servernte

(

void *

)

Thread delegato all'esecuzione dei messaggi mandati dai client

Definizione alla linea 126 del file comandi.c.

                                 {
        extern struct lista my_socket;
        extern pthread_mutex_t lock;
        extern pthread_cond_t wait_me;
        extern int num_threads;
        sigset_t set;           
        channel_t sk_cl;
        message_t msg;
        int recive_val=0;

        sk_cl = *(int *)sk;
        msg.buffer = NULL;

        /* Blocco i segnali */
        if (sigfillset(&set) == -1){
                errore(__FILE__,__LINE__,"Server: error sigfillset",errno);
                return 0;
        }
        if (pthread_sigmask(SIG_SETMASK, &set, NULL) != 0) {
                errore(__FILE__,__LINE__,"Server: pthread_sigmask error 'sigsetmask'",errno);
                return 0;
        }

        while (recive_val!=SEOF){
                if ((recive_val = receiveMessage(sk_cl, &msg)) == -1) break;
                else if (recive_val != SEOF){   /* !SIGPIPE */
                        switch(msg.type){
                                case MSG_MKDIR:
                                        msg_mkdir(&msg);
                                break;
                                case MSG_LS:
                                        msg_ls(&msg);
                                break;
                                case MSG_MKFILE:
                                        msg_mkfile(&msg);
                                break;
                                case MSG_FREAD:
                                        msg_fread(&msg);
                                break;
                                case MSG_FWRITE:
                                        msg_fwrite(&msg);
                                break;
                        }
                        if (sendMessage(sk_cl, &msg) == -1) break;
                }
        }
        /* Chiudo il socket di comunicazione tra client e server */
        closeSocket(sk_cl);
        /* Rimuovo il thread dalla lista dei thread */
        pthread_mutex_lock(&lock);
        num_threads--;
        rimuovi(sk_cl, &my_socket);
        pthread_mutex_unlock(&lock);
        pthread_cond_signal(&wait_me);
        
        return 0;
}