[lng-odp] [API-NEXT PATCH 4/4] thread: implemented thrmask_worker and control

[Petri Savolainen]

Signed-off-by: Petri Savolainen <petri.savolai...@nokia.com>
---
 platform/linux-generic/odp_thread.c | 28 ++++++++++++++++++++++++----
 1 file changed, 24 insertions(+), 4 deletions(-)

diff --git a/platform/linux-generic/odp_thread.c 
b/platform/linux-generic/odp_thread.c
index 42afc5f..9905c78 100644
--- a/platform/linux-generic/odp_thread.c
+++ b/platform/linux-generic/odp_thread.c
@@ -36,6 +36,8 @@ typedef struct {
        odp_thrmask_t  worker;
        odp_thrmask_t  control;
        uint32_t       num;
+       uint32_t       num_worker;
+       uint32_t       num_control;
        odp_spinlock_t lock;
 } thread_globals_t;
 
@@ -93,10 +95,13 @@ static int alloc_id(odp_thread_type_t type)
                if (odp_thrmask_isset(all, thr) == 0) {
                        odp_thrmask_set(all, thr);
 
-                       if (type == ODP_THREAD_WORKER)
+                       if (type == ODP_THREAD_WORKER) {
                                odp_thrmask_set(&thread_globals->worker, thr);
-                       else
+                               thread_globals->num_worker++;
+                       } else {
                                odp_thrmask_set(&thread_globals->control, thr);
+                               thread_globals->num_control++;
+                       }
 
                        thread_globals->num++;
                        return thr;
@@ -118,10 +123,13 @@ static int free_id(int thr)
 
        odp_thrmask_clr(all, thr);
 
-       if (thread_globals->thr[thr].type == ODP_THREAD_WORKER)
+       if (thread_globals->thr[thr].type == ODP_THREAD_WORKER) {
                odp_thrmask_clr(&thread_globals->worker, thr);
-       else
+               thread_globals->num_worker--;
+       } else {
                odp_thrmask_clr(&thread_globals->control, thr);
+               thread_globals->num_control--;
+       }
 
        thread_globals->num--;
        return thread_globals->num;
@@ -192,3 +200,15 @@ int odp_cpu_id(void)
 {
        return this_thread->cpu;
 }
+
+int odp_thrmask_worker(odp_thrmask_t *mask)
+{
+       odp_thrmask_copy(mask, &thread_globals->worker);
+       return thread_globals->num_worker;
+}
+
+int odp_thrmask_control(odp_thrmask_t *mask)
+{
+       odp_thrmask_copy(mask, &thread_globals->control);
+       return thread_globals->num_control;
+}
-- 
2.4.3

_______________________________________________
lng-odp mailing list
lng-odp@lists.linaro.org
https://lists.linaro.org/mailman/listinfo/lng-odp