--- rpl/src/instructions_c9.c 2023/08/07 17:42:53 1.29 +++ rpl/src/instructions_c9.c 2023/11/24 09:12:57 1.30 @@ -183,4 +183,117 @@ instruction_compress(struct_processus *s return; } + +void +instruction_clrsock(struct_processus *s_etat_processus) +{ + int socket; + + struct_liste_chainee *l_element_courant; + struct_liste_chainee *l_element_precedent; + + struct_objet *s_objet_argument; + + if ((*s_etat_processus).affichage_arguments == 'Y') + { + printf("\n CLRSOCK "); + + if ((*s_etat_processus).langue == 'F') + { + printf("(libération d'une socket)\n\n"); + } + else + { + printf("(free socket resources)\n\n"); + } + + printf(" 1: %s\n", d_SCK); + + return; + } + else if ((*s_etat_processus).test_instruction == 'Y') + { + (*s_etat_processus).nombre_arguments = -1; + return; + } + + if (depilement(s_etat_processus, &((*s_etat_processus).l_base_pile), + &s_objet_argument) == d_erreur) + { + (*s_etat_processus).erreur_execution = d_ex_manque_argument; + return; + } + + if ((*s_objet_argument).type == SCK) + { + l_element_courant = (*s_etat_processus).s_sockets; + l_element_precedent = NULL; + + while(l_element_courant != NULL) + { + if ((*((struct_socket *) (*(*l_element_courant).donnee).objet)) + .socket == (*((struct_socket *) (*s_objet_argument) + .objet)).socket) + { + socket = (*((struct_socket *) + (*(*l_element_courant).donnee).objet)).socket; + + if (l_element_precedent == NULL) + { + (*s_etat_processus).s_sockets = + (*l_element_courant).suivant; + } + else if ((*l_element_courant).suivant == NULL) + { + (*l_element_precedent).suivant = NULL; + } + else + { + (*l_element_precedent).suivant = + (*l_element_courant).suivant; + } + + liberation(s_etat_processus, (*l_element_courant).donnee); + free(l_element_courant); + + break; + } + + l_element_precedent = l_element_courant; + l_element_courant = (*l_element_courant).suivant; + } + + if (socket == -1) + { + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_execution = d_ex_erreur_acces_fichier; + return; + } + + /* + * Fermeture de la socket + */ + + if (close(socket) != 0) + { + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } + } + else + { + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_execution = d_ex_erreur_type_argument; + return; + } + + liberation(s_etat_processus, s_objet_argument); + + return; +} + // vim: ts=4