Commit 3d682f4f authored by William Lee Irwin III's avatar William Lee Irwin III Committed by Linus Torvalds

[PATCH] pidhashing: rewrite alloc_pidmap()

Rewrite alloc_pidmap() to clarify control flow by eliminating all usage of
goto, honor pid_max and first available pid after last_pid semantics, make
only a single pass over the used portion of the pid bitmap, and update
copyrights to reflect ongoing maintenance by Ingo and myself.
Signed-off-by: default avatarWilliam Irwin <wli@holomorphy.com>
Signed-off-by: default avatarAndrew Morton <akpm@osdl.org>
Signed-off-by: default avatarLinus Torvalds <torvalds@osdl.org>
parent 48716031
/* /*
* Generic pidhash and scalable, time-bounded PID allocator * Generic pidhash and scalable, time-bounded PID allocator
* *
* (C) 2002 William Irwin, IBM * (C) 2002-2004 William Irwin, Oracle
* (C) 2002 Ingo Molnar, Red Hat * (C) 2002-2004 Ingo Molnar, Red Hat
* *
* pid-structures are backing objects for tasks sharing a given ID to chain * pid-structures are backing objects for tasks sharing a given ID to chain
* against. There is very little to them aside from hashing them and * against. There is very little to them aside from hashing them and
...@@ -38,6 +38,9 @@ int last_pid; ...@@ -38,6 +38,9 @@ int last_pid;
#define PIDMAP_ENTRIES (PID_MAX_LIMIT/PAGE_SIZE/8) #define PIDMAP_ENTRIES (PID_MAX_LIMIT/PAGE_SIZE/8)
#define BITS_PER_PAGE (PAGE_SIZE*8) #define BITS_PER_PAGE (PAGE_SIZE*8)
#define BITS_PER_PAGE_MASK (BITS_PER_PAGE-1) #define BITS_PER_PAGE_MASK (BITS_PER_PAGE-1)
#define mk_pid(map, off) (((map) - pidmap_array)*BITS_PER_PAGE + (off))
#define find_next_offset(map, off) \
find_next_zero_bit((map)->page, BITS_PER_PAGE, off)
/* /*
* PID-map pages start out as NULL, they get allocated upon * PID-map pages start out as NULL, they get allocated upon
...@@ -53,8 +56,6 @@ typedef struct pidmap { ...@@ -53,8 +56,6 @@ typedef struct pidmap {
static pidmap_t pidmap_array[PIDMAP_ENTRIES] = static pidmap_t pidmap_array[PIDMAP_ENTRIES] =
{ [ 0 ... PIDMAP_ENTRIES-1 ] = { ATOMIC_INIT(BITS_PER_PAGE), NULL } }; { [ 0 ... PIDMAP_ENTRIES-1 ] = { ATOMIC_INIT(BITS_PER_PAGE), NULL } };
static pidmap_t *map_limit = pidmap_array + PIDMAP_ENTRIES;
static spinlock_t pidmap_lock __cacheline_aligned_in_smp = SPIN_LOCK_UNLOCKED; static spinlock_t pidmap_lock __cacheline_aligned_in_smp = SPIN_LOCK_UNLOCKED;
fastcall void free_pidmap(int pid) fastcall void free_pidmap(int pid)
...@@ -66,15 +67,18 @@ fastcall void free_pidmap(int pid) ...@@ -66,15 +67,18 @@ fastcall void free_pidmap(int pid)
atomic_inc(&map->nr_free); atomic_inc(&map->nr_free);
} }
/* int alloc_pidmap(void)
* Here we search for the next map that has free bits left.
* Normally the next map has free PIDs.
*/
static inline pidmap_t *next_free_map(pidmap_t *map, int *max_steps)
{ {
while (--*max_steps) { int i, offset, max_scan, pid, last = last_pid;
if (++map == map_limit) pidmap_t *map;
map = pidmap_array;
pid = last + 1;
if (pid >= pid_max)
pid = RESERVED_PIDS;
offset = pid & BITS_PER_PAGE_MASK;
map = &pidmap_array[pid/BITS_PER_PAGE];
max_scan = (pid_max + BITS_PER_PAGE - 1)/BITS_PER_PAGE - !offset;
for (i = 0; i <= max_scan; ++i) {
if (unlikely(!map->page)) { if (unlikely(!map->page)) {
unsigned long page = get_zeroed_page(GFP_KERNEL); unsigned long page = get_zeroed_page(GFP_KERNEL);
/* /*
...@@ -87,62 +91,39 @@ static inline pidmap_t *next_free_map(pidmap_t *map, int *max_steps) ...@@ -87,62 +91,39 @@ static inline pidmap_t *next_free_map(pidmap_t *map, int *max_steps)
else else
map->page = (void *)page; map->page = (void *)page;
spin_unlock(&pidmap_lock); spin_unlock(&pidmap_lock);
if (unlikely(!map->page))
if (!map->page)
break; break;
} }
if (atomic_read(&map->nr_free)) if (likely(atomic_read(&map->nr_free))) {
return map; do {
} if (!test_and_set_bit(offset, map->page)) {
return NULL; atomic_dec(&map->nr_free);
} last_pid = pid;
return pid;
int alloc_pidmap(void) }
{ offset = find_next_offset(map, offset);
int pid, offset, max_steps = PIDMAP_ENTRIES + 1; pid = mk_pid(map, offset);
pidmap_t *map; /*
* find_next_offset() found a bit, the pid from it
pid = last_pid + 1; * is in-bounds, and if we fell back to the last
if (pid >= pid_max) * bitmap block and the final block was the same
pid = RESERVED_PIDS; * as the starting point, pid is before last_pid.
*/
offset = pid & BITS_PER_PAGE_MASK; } while (offset < BITS_PER_PAGE && pid < pid_max &&
map = pidmap_array + pid / BITS_PER_PAGE; (i != max_scan || pid < last ||
!((last+1) & BITS_PER_PAGE_MASK)));
if (likely(map->page && !test_and_set_bit(offset, map->page))) { }
/* if (map < &pidmap_array[(pid_max-1)/BITS_PER_PAGE]) {
* There is a small window for last_pid updates to race, ++map;
* but in that case the next allocation will go into the offset = 0;
* slowpath and that fixes things up. } else {
*/ map = &pidmap_array[0];
return_pid: offset = RESERVED_PIDS;
atomic_dec(&map->nr_free); if (unlikely(last == offset))
last_pid = pid; break;
return pid; }
} pid = mk_pid(map, offset);
if (!offset || !atomic_read(&map->nr_free)) {
next_map:
map = next_free_map(map, &max_steps);
if (!map)
goto failure;
offset = 0;
} }
/*
* Find the next zero bit:
*/
scan_more:
offset = find_next_zero_bit(map->page, BITS_PER_PAGE, offset);
if (offset >= BITS_PER_PAGE)
goto next_map;
if (test_and_set_bit(offset, map->page))
goto scan_more;
/* we got the PID: */
pid = (map - pidmap_array) * BITS_PER_PAGE + offset;
goto return_pid;
failure:
return -1; return -1;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment