/* * $Id: hslot.c 1858 2007-03-16 09:37:21Z miconda $ * * Hash table collision slot related functions * * Copyright (C) 2001-2003 FhG Fokus * * This file is part of openser, a free SIP server. * * openser 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 2 of the License, or * (at your option) any later version * * openser 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 this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ #include "hslot.h" int ul_locks_no=4; gen_lock_set_t* ul_locks=0; /* * Initialize locks */ int ul_init_locks() { int i; i = ul_locks_no; do { if ((( ul_locks=lock_set_alloc(i))!=0)&& (lock_set_init(ul_locks)!=0)) { ul_locks_no = i; LOG(L_INFO, "INFO:ul_init_locks: locks array size %d\n", ul_locks_no); return 0; } if (ul_locks){ lock_set_dealloc(ul_locks); ul_locks=0; } i--; if(i==0) { LOG(L_ERR, "INFO:ul_init_locks: error - cannot allocate locks\n"); return -1; } } while (1); } void ul_destroy_locks() { if (ul_locks !=0){ lock_set_destroy(ul_locks); lock_set_dealloc(ul_locks); }; } #ifndef GEN_LOCK_T_PREFERED void ul_lock_idx(int idx) { lock_set_get(ul_locks, idx); } void ul_release_idx(int idx) { lock_set_release(ul_locks, idx); } #endif /* * Initialize cache slot structure */ int init_slot(struct udomain* _d, hslot_t* _s, int n) { _s->n = 0; _s->first = 0; _s->last = 0; _s->d = _d; #ifdef GEN_LOCK_T_PREFERED _s->lock = &ul_locks->locks[n%ul_locks_no]; #else _s->lockidx = n%ul_locks_no; #endif return 0; } /* * Deinitialize given slot structure */ void deinit_slot(hslot_t* _s) { struct urecord* ptr; /* Remove all elements */ while(_s->first) { ptr = _s->first; _s->first = _s->first->next; free_urecord(ptr); } _s->n = 0; _s->last = 0; _s->d = 0; } /* * Add an element to an slot's linked list */ void slot_add(hslot_t* _s, struct urecord* _r) { if (_s->n == 0) { _s->first = _s->last = _r; } else { _r->prev = _s->last; _s->last->next = _r; _s->last = _r; } _s->n++; _r->slot = _s; } /* * Remove an element from slot linked list */ void slot_rem(hslot_t* _s, struct urecord* _r) { if (_r->prev) { _r->prev->next = _r->next; } else { _s->first = _r->next; } if (_r->next) { _r->next->prev = _r->prev; } else { _s->last = _r->prev; } _r->prev = _r->next = 0; _r->slot = 0; _s->n--; }