#include "id_generator.h"
#include <new>
#include <stdlib.h>
#include <string.h>
#include <KernelExport.h>
#include <util/AutoLock.h>
#include <util/DoublyLinkedList.h>
#ifdef TRACE_ID_GENERATOR
# define TRACE(x) dprintf x
#else
# define TRACE(x) ;
#endif
#define GENERATOR_MAX_ID 64
struct id_generator : DoublyLinkedListLinkImpl<id_generator> {
id_generator(const char* name)
:
ref_count(1),
name(strdup(name)),
num_ids(0)
{
memset(&alloc_map, 0, sizeof(alloc_map));
}
~id_generator()
{
free(name);
}
int32 ref_count;
char* name;
uint32 num_ids;
uint8 alloc_map[(GENERATOR_MAX_ID + 7) / 8];
};
typedef DoublyLinkedList<id_generator> GeneratorList;
static GeneratorList sGenerators;
static mutex sLock = MUTEX_INITIALIZER("id generator");
static id_generator*
create_generator(const char* name)
{
TRACE(("create_generator(name: %s)\n", name));
id_generator* generator = new(std::nothrow) id_generator(name);
if (generator == NULL)
return NULL;
if (generator->name == NULL) {
delete generator;
return NULL;
}
sGenerators.Add(generator);
return generator;
}
static int32
create_id_internal(id_generator* generator)
{
uint32 id;
TRACE(("create_id_internal(name: %s)\n", generator->name));
MutexLocker _(sLock);
for (id = 0; id < GENERATOR_MAX_ID; ++id) {
if ((generator->alloc_map[id / 8] & (1 << (id & 7))) == 0) {
TRACE((" id: %lu\n", id));
generator->alloc_map[id / 8] |= 1 << (id & 7);
generator->num_ids++;
return id;
}
}
return B_ERROR;
}
static id_generator*
get_generator(const char* name)
{
TRACE(("find_generator(name: %s)\n", name));
GeneratorList::Iterator iterator = sGenerators.GetIterator();
while (iterator.HasNext()) {
id_generator* generator = iterator.Next();
if (!strcmp(generator->name, name)) {
generator->ref_count++;
return generator;
}
}
return NULL;
}
static void
release_generator(id_generator *generator)
{
TRACE(("release_generator(name: %s)\n", generator->name));
MutexLocker _(sLock);
if (--generator->ref_count == 0) {
if (generator->num_ids == 0) {
TRACE((" Destroy %s\n", generator->name));
sGenerators.Remove(generator);
delete generator;
}
}
}
void
dm_init_id_generator(void)
{
new(&sGenerators) GeneratorList;
}
int32
dm_create_id(const char* name)
{
mutex_lock(&sLock);
id_generator* generator = get_generator(name);
if (generator == NULL)
generator = create_generator(name);
mutex_unlock(&sLock);
if (generator == NULL)
return B_NO_MEMORY;
int32 id = create_id_internal(generator);
release_generator(generator);
TRACE(("dm_create_id: name: %s, id: %ld\n", name, id));
return id;
}
status_t
dm_free_id(const char* name, uint32 id)
{
TRACE(("dm_free_id(name: %s, id: %ld)\n", name, id));
mutex_lock(&sLock);
id_generator* generator = get_generator(name);
mutex_unlock(&sLock);
if (generator == NULL) {
TRACE((" Generator %s doesn't exist\n", name));
return B_NAME_NOT_FOUND;
}
if ((generator->alloc_map[id / 8] & (1 << (id & 7))) == 0) {
dprintf("id %" B_PRIu32 " of generator %s wasn't allocated\n", id,
generator->name);
release_generator(generator);
return B_BAD_VALUE;
}
generator->alloc_map[id / 8] &= ~(1 << (id & 7));
generator->num_ids--;
release_generator(generator);
return B_OK;
}