123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596 |
- /*
- * StarPU
- * Copyright (C) Université Bordeaux 1, CNRS 2008-2010 (see AUTHORS file)
- *
- * This program 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 program 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 in COPYING.LGPL for more details.
- */
- #include <pthread.h>
- #include <core/workers.h>
- #include <common/utils.h>
- #define NMAXHOOKS 16
- struct progression_hook {
- unsigned (*func)(void *arg);
- void *arg;
- unsigned active;
- };
- /* protect the hook table */
- static pthread_rwlock_t progression_hook_rwlock = PTHREAD_RWLOCK_INITIALIZER;
- static struct progression_hook hooks[NMAXHOOKS] = {{NULL, NULL, 0}};
- int starpu_progression_hook_register(unsigned (*func)(void *arg), void *arg)
- {
- int hook;
- PTHREAD_RWLOCK_WRLOCK(&progression_hook_rwlock);
- for (hook = 0; hook < NMAXHOOKS; hook++)
- {
- if (!hooks[hook].active)
- {
- /* We found an empty slot */
- hooks[hook].func = func;
- hooks[hook].arg = arg;
- hooks[hook].active = 1;
- PTHREAD_RWLOCK_UNLOCK(&progression_hook_rwlock);
-
- return hook;
- }
- }
- PTHREAD_RWLOCK_UNLOCK(&progression_hook_rwlock);
- starpu_wake_all_blocked_workers();
- /* We could not find an empty slot */
- return -1;
- }
- void starpu_progression_hook_deregister(int hook_id)
- {
- PTHREAD_RWLOCK_WRLOCK(&progression_hook_rwlock);
- hooks[hook_id].active = 0;
- PTHREAD_RWLOCK_UNLOCK(&progression_hook_rwlock);
- }
- unsigned _starpu_execute_registered_progression_hooks(void)
- {
- /* By default, it is possible to block, but if some progression hooks
- * requires that it's not blocking, we disable blocking. */
- unsigned may_block = 1;
- unsigned hook;
- for (hook = 0; hook < NMAXHOOKS; hook++)
- {
- unsigned active;
- PTHREAD_RWLOCK_RDLOCK(&progression_hook_rwlock);
- active = hooks[hook].active;
- PTHREAD_RWLOCK_UNLOCK(&progression_hook_rwlock);
- unsigned may_block_hook = 1;
- if (active)
- may_block_hook = hooks[hook].func(hooks[hook].arg);
- /* As soon as one hook tells that the driver cannot be
- * blocking, we don't allow it. */
- if (!may_block_hook)
- may_block = 0;
- }
- return may_block;
- }
|