diff options
Diffstat (limited to 'src/client_list.c')
-rw-r--r-- | src/client_list.c | 137 |
1 files changed, 137 insertions, 0 deletions
diff --git a/src/client_list.c b/src/client_list.c new file mode 100644 index 0000000..141a3a4 --- /dev/null +++ b/src/client_list.c @@ -0,0 +1,137 @@ +/* + * rhctl + * + * Copyright (C) 2009-2014 Christian Pointner <equinox@helsinki.at> + * + * This file is part of rhctl. + * + * rhctl is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * any later version. + * + * rhctl is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with rhctl. If not, see <http://www.gnu.org/licenses/>. + */ + +#include <stdlib.h> +#include <unistd.h> + +#include "client_list.h" +#include "datatypes.h" + +char* client_type_tostring(client_type_t type) +{ + switch(type) + { + case MASTER: return "master"; + case STANDBY: return "standby"; + case HB_MASTER: return "hb_master"; + case HB_STANDBY: return "hb_standby"; + case DEFAULT: return "unspecified"; + } + return "<invalid>"; +} + +client_t* client_get_last(client_t* first) +{ + if(!first) + return NULL; + + while(first->next) { + first = first->next; + } + + return first; +} + +int client_add(client_t** first, int fd) +{ + if(!first) + return -1; + + client_t* new_client = malloc(sizeof(client_t)); + if(!new_client) + return -2; + + new_client->fd = fd; + new_client->type = DEFAULT; + new_client->request_listener = 0; + new_client->mode_listener = 0; + new_client->status_listener = 0; + new_client->gpi_listener = 0; + new_client->oc_listener = 0; + new_client->relay_listener = 0; + new_client->silence_listener = 0; + new_client->health_listener = 0; + new_client->next = NULL; + new_client->buffer.offset = 0; + + if(!(*first)) { + *first = new_client; + return 0; + } + + client_get_last(*first)->next = new_client; + + return 0; +} + +void client_remove(client_t** first, int fd) +{ + if(!first || !(*first)) + return; + + client_t* deletee = *first; + if((*first)->fd == fd) { + *first = (*first)->next; + close(deletee->fd); + free(deletee); + return; + } + + client_t* prev = deletee; + deletee = deletee->next; + while(deletee) { + if(deletee->fd == fd) { + prev->next = deletee->next; + close(deletee->fd); + free(deletee); + return; + } + prev = deletee; + deletee = deletee->next; + } +} + +client_t* client_find(client_t* first, int fd) +{ + if(!first) + return NULL; + + while(first) { + if(first->fd == fd) + return first; + + first = first->next; + } + return NULL; +} + +void client_clear(client_t** first) +{ + if(!first || !(*first)) + return; + + while(*first) { + client_t* deletee = *first; + *first = (*first)->next; + close(deletee->fd); + free(deletee); + } +} |