/* hashset.vala * * Copyright (C) 1995-1997 Peter Mattis, Spencer Kimball and Josh MacDonald * Copyright (C) 1997-2000 GLib Team and others * Copyright (C) 2007-2009 Jürg Billeter * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * This library 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 * Lesser General Public License for more details. * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA * * Author: * Jürg Billeter */ using GLib; /** * Hashtable implementation of the Set interface. */ public class Vala.HashSet : Set { public override int size { get { return _nnodes; } } public HashFunc hash_func { set { _hash_func = value; } } public EqualFunc equal_func { set { _equal_func = value; } } private int _array_size; private int _nnodes; private Node[] _nodes; // concurrent modification protection private int _stamp = 0; private HashFunc _hash_func; private EqualFunc _equal_func; private const int MIN_SIZE = 11; private const int MAX_SIZE = 13845163; public HashSet (HashFunc hash_func = GLib.direct_hash, EqualFunc equal_func = GLib.direct_equal) { this.hash_func = hash_func; this.equal_func = equal_func; _array_size = MIN_SIZE; _nodes = new Node[_array_size]; } private Node** lookup_node (G key) { uint hash_value = _hash_func (key); Node** node = &_nodes[hash_value % _array_size]; while ((*node) != null && (hash_value != (*node)->key_hash || !_equal_func ((*node)->key, key))) { node = &((*node)->next); } return node; } public override bool contains (G key) { Node** node = lookup_node (key); return (*node != null); } public override Type get_element_type () { return typeof (G); } public override Vala.Iterator iterator () { return new Iterator (this); } public override bool add (G key) { Node** node = lookup_node (key); if (*node != null) { return false; } else { uint hash_value = _hash_func (key); *node = new Node (key, hash_value); _nnodes++; resize (); _stamp++; return true; } } public override bool remove (G key) { Node** node = lookup_node (key); if (*node != null) { Node next = (owned) (*node)->next; (*node)->key = null; delete *node; *node = (owned) next; _nnodes--; resize (); _stamp++; return true; } return false; } public override void clear () { for (int i = 0; i < _array_size; i++) { Node node = (owned) _nodes[i]; while (node != null) { Node next = (owned) node.next; node.key = null; node = (owned) next; } } _nnodes = 0; resize (); } private inline bool remove_helper (G key) { Node** node = lookup_node (key); if (*node != null) { assert (*node != null); Node next = (owned) (*node)->next; (*node)->key = null; delete *node; *node = (owned) next; _nnodes--; _stamp++; return true; } return false; } private void resize () { if ((_array_size >= 3 * _nnodes && _array_size >= MIN_SIZE) || (3 * _array_size <= _nnodes && _array_size < MAX_SIZE)) { int new_array_size = (int) SpacedPrimes.closest (_nnodes); new_array_size = new_array_size.clamp (MIN_SIZE, MAX_SIZE); Node[] new_nodes = new Node[new_array_size]; for (int i = 0; i < _array_size; i++) { Node node; Node next = null; for (node = (owned) _nodes[i]; node != null; node = (owned) next) { next = (owned) node.next; uint hash_val = node.key_hash % new_array_size; node.next = (owned) new_nodes[hash_val]; new_nodes[hash_val] = (owned) node; } } _nodes = (owned) new_nodes; _array_size = new_array_size; } } ~HashSet () { clear (); } [Compact] private class Node { public G key; public Node next; public uint key_hash; public Node (owned G k, uint hash) { key = (owned) k; key_hash = hash; } } private class Iterator : Vala.Iterator { public HashSet set { set { _set = value; _stamp = _set._stamp; } } private HashSet _set; private int _index = -1; private weak Node _node; private weak Node _next; // concurrent modification protection private int _stamp = 0; public Iterator (HashSet set) { this.set = set; } public override bool next () { assert (_stamp == _set._stamp); if (!has_next ()) { return false; } _node = _next; _next = null; return (_node != null); } public override bool has_next () { assert (_stamp == _set._stamp); if (_next == null) { _next = _node; if (_next != null) { _next = _next.next; } while (_next == null && _index + 1 < _set._array_size) { _index++; _next = _set._nodes[_index]; } } return (_next != null); } public override G? get () { assert (_stamp == _set._stamp); assert (_node != null); return _node.key; } public override void remove () { assert (_stamp == _set._stamp); assert (_node != null); has_next (); _set.remove_helper (_node.key); _node = null; _stamp = _set._stamp; } public override bool valid { get { return _node != null; } } } }