// Package : omnithread // omnithread/threaddata.cc Created : 10/2000 dpg1 // // Copyright (C) 2000 AT&T Laboratories Cambridge // // This file is part of the omnithread library // // The omnithread library is free software; you can redistribute it and/or // modify it under the terms of the GNU Library General Public // License as published by the Free Software Foundation; either // version 2 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 // Library General Public License for more details. // // You should have received a copy of the GNU Library General Public // License along with this library; if not, write to the Free // Software Foundation, Inc., 51 Franklin Street, Boston, MA // 02110-1301, USA // // Implementation of per-thread data #ifndef INSIDE_THREAD_IMPL_CC #error "threaddata.cc must be #included by a thread implementation." #endif static omni_thread::key_t allocated_keys = 0; omni_thread::key_t omni_thread::allocate_key() { omni_mutex_lock l(*next_id_mutex); return ++allocated_keys; } omni_thread::value_t* omni_thread::set_value(key_t k, value_t* v) { if (k == 0) return 0; if (k > _value_alloc) { next_id_mutex->lock(); key_t alloc = allocated_keys; next_id_mutex->unlock(); if (k > alloc) return 0; value_t** nv = new value_t*[alloc]; key_t i = 0; if (_values) { for (; i < _value_alloc; i++) nv[i] = _values[i]; delete [] _values; } for (; i < alloc; i++) nv[i] = 0; _values = nv; _value_alloc = alloc; } if (_values[k-1]) delete _values[k-1]; _values[k-1] = v; return v; } omni_thread::value_t* omni_thread::get_value(key_t k) { if (k > _value_alloc) return 0; return _values[k-1]; } omni_thread::value_t* omni_thread::remove_value(key_t k) { if (k > _value_alloc) return 0; value_t* v = _values[k-1]; _values[k-1] = 0; return v; }