cannam@167: /* cannam@167: * Copyright (c) 2003, 2007-14 Matteo Frigo cannam@167: * Copyright (c) 2003, 2007-14 Massachusetts Institute of Technology cannam@167: * cannam@167: * This program is free software; you can redistribute it and/or modify cannam@167: * it under the terms of the GNU General Public License as published by cannam@167: * the Free Software Foundation; either version 2 of the License, or cannam@167: * (at your option) any later version. cannam@167: * cannam@167: * This program is distributed in the hope that it will be useful, cannam@167: * but WITHOUT ANY WARRANTY; without even the implied warranty of cannam@167: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the cannam@167: * GNU General Public License for more details. cannam@167: * cannam@167: * You should have received a copy of the GNU General Public License cannam@167: * along with this program; if not, write to the Free Software cannam@167: * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA cannam@167: * cannam@167: */ cannam@167: cannam@167: #include "api/api.h" cannam@167: #include "threads/threads.h" cannam@167: cannam@167: static int threads_inited = 0; cannam@167: cannam@167: static void threads_register_hooks(void) cannam@167: { cannam@167: X(mksolver_ct_hook) = X(mksolver_ct_threads); cannam@167: X(mksolver_hc2hc_hook) = X(mksolver_hc2hc_threads); cannam@167: } cannam@167: cannam@167: static void threads_unregister_hooks(void) cannam@167: { cannam@167: X(mksolver_ct_hook) = 0; cannam@167: X(mksolver_hc2hc_hook) = 0; cannam@167: } cannam@167: cannam@167: /* should be called before all other FFTW functions! */ cannam@167: int X(init_threads)(void) cannam@167: { cannam@167: if (!threads_inited) { cannam@167: planner *plnr; cannam@167: cannam@167: if (X(ithreads_init)()) cannam@167: return 0; cannam@167: cannam@167: threads_register_hooks(); cannam@167: cannam@167: /* this should be the first time the_planner is called, cannam@167: and hence the time it is configured */ cannam@167: plnr = X(the_planner)(); cannam@167: X(threads_conf_standard)(plnr); cannam@167: cannam@167: threads_inited = 1; cannam@167: } cannam@167: return 1; cannam@167: } cannam@167: cannam@167: cannam@167: void X(cleanup_threads)(void) cannam@167: { cannam@167: X(cleanup)(); cannam@167: if (threads_inited) { cannam@167: X(threads_cleanup)(); cannam@167: threads_unregister_hooks(); cannam@167: threads_inited = 0; cannam@167: } cannam@167: } cannam@167: cannam@167: void X(plan_with_nthreads)(int nthreads) cannam@167: { cannam@167: planner *plnr; cannam@167: cannam@167: if (!threads_inited) { cannam@167: X(cleanup)(); cannam@167: X(init_threads)(); cannam@167: } cannam@167: A(threads_inited); cannam@167: plnr = X(the_planner)(); cannam@167: plnr->nthr = X(imax)(1, nthreads); cannam@167: } cannam@167: cannam@167: void X(make_planner_thread_safe)(void) cannam@167: { cannam@167: X(threads_register_planner_hooks)(); cannam@167: }