/home/mrjunejune/zenbu: seobeo/s

annotate seobeo/s_worker.c @ 279:b3b547563ec7

Add Google connector service and agent wiki Implement the C/Seobeo Google Drive and Gmail connector with encrypted OAuth storage, Zenbu authentication, browser testing, AI tool discovery, chunked HTTP decoding, and Bazel coverage. Consolidate repository guidance into progressive wiki documentation and enforce arena-first allocation for new first-party C code. Co-authored-by: Copilot <[email protected]> Copilot-Session: 84c338fd-0939-4bb3-b7f3-1062eb213e5d

author	MrJuneJune <me@mrjunejune.com>
date	Mon, 17 Aug 2026 22:22:36 -0700
parents	745fd127b2a1
children

rev	line source
250 745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	1 #include "seobeo/seobeo_worker.h"
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	2
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	3 #include <pthread.h>
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	4 #include <stdlib.h>
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	5 #include <string.h>
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	6
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	7 typedef struct {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	8 Seobeo_Work_Function function;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	9 void *p_context;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	10 Seobeo_Work_Cleanup cleanup;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	11 } Seobeo_Work_Item;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	12
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	13 struct Seobeo_Thread {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	14 pthread_t thread;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	15 Seobeo_Work_Item item;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	16 };
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	17
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	18 struct Seobeo_Worker_Pool {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	19 pthread_t *p_threads;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	20 Seobeo_Work_Item *p_queue;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	21 uint32 worker_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	22 uint32 queue_capacity;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	23 uint32 queue_head;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	24 uint32 queue_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	25 uint32 active_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	26 uint32 cleanup_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	27 boolean accepting;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	28 boolean stopping;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	29 boolean drain;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	30 boolean shutdown_started;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	31 boolean joined;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	32 pthread_mutex_t mutex;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	33 pthread_cond_t work_available;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	34 pthread_cond_t idle;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	35 };
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	36
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	37 static _Thread_local Seobeo_Worker_Pool *g_current_worker_pool = NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	38
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	39 static void Seobeo_Work_Item_Run(Seobeo_Work_Item *p_item)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	40 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	41 p_item->function(p_item->p_context);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	42 if (p_item->cleanup)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	43 p_item->cleanup(p_item->p_context);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	44 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	45
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	46 static void Seobeo_Thread_Run(void p_argument)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	47 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	48 Seobeo_Thread *p_thread = p_argument;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	49 Seobeo_Work_Item_Run(&p_thread->item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	50 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	51 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	52
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	53 Seobeo_Thread *Seobeo_Thread_Start(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	54 Seobeo_Work_Function function,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	55 void *p_context,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	56 Seobeo_Work_Cleanup cleanup)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	57 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	58 if (!function)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	59 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	60
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	61 Seobeo_Thread p_thread = calloc(1, sizeof(p_thread));
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	62 if (!p_thread)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	63 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	64 p_thread->item = (Seobeo_Work_Item){
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	65 .function = function,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	66 .p_context = p_context,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	67 .cleanup = cleanup,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	68 };
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	69 if (pthread_create(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	70 &p_thread->thread,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	71 NULL,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	72 Seobeo_Thread_Run,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	73 p_thread) != 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	74 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	75 free(p_thread);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	76 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	77 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	78 return p_thread;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	79 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	80
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	81 Seobeo_Worker_Result Seobeo_Thread_Join(Seobeo_Thread *p_thread)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	82 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	83 if (!p_thread)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	84 return SEOBEO_WORKER_INVALID_ARGUMENT;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	85 if (pthread_equal(pthread_self(), p_thread->thread))
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	86 return SEOBEO_WORKER_INVALID_ARGUMENT;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	87
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	88 int result = pthread_join(p_thread->thread, NULL);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	89 free(p_thread);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	90 return result == 0
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	91 ? SEOBEO_WORKER_OK
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	92 : SEOBEO_WORKER_THREAD_ERROR;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	93 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	94
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	95 static void Seobeo_Thread_Run_Detached(void p_argument)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	96 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	97 Seobeo_Work_Item *p_item = p_argument;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	98 Seobeo_Work_Item_Run(p_item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	99 free(p_item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	100 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	101 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	102
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	103 Seobeo_Worker_Result Seobeo_Thread_Start_Detached(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	104 Seobeo_Work_Function function,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	105 void *p_context,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	106 Seobeo_Work_Cleanup cleanup)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	107 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	108 if (!function)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	109 return SEOBEO_WORKER_INVALID_ARGUMENT;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	110
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	111 Seobeo_Work_Item p_item = malloc(sizeof(p_item));
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	112 if (!p_item)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	113 return SEOBEO_WORKER_OUT_OF_MEMORY;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	114 *p_item = (Seobeo_Work_Item){
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	115 .function = function,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	116 .p_context = p_context,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	117 .cleanup = cleanup,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	118 };
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	119
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	120 pthread_attr_t attributes;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	121 if (pthread_attr_init(&attributes) != 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	122 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	123 free(p_item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	124 return SEOBEO_WORKER_THREAD_ERROR;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	125 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	126 int result = pthread_attr_setdetachstate(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	127 &attributes,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	128 PTHREAD_CREATE_DETACHED);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	129 pthread_t thread;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	130 if (result == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	131 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	132 result = pthread_create(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	133 &thread,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	134 &attributes,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	135 Seobeo_Thread_Run_Detached,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	136 p_item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	137 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	138 pthread_attr_destroy(&attributes);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	139 if (result != 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	140 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	141 free(p_item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	142 return SEOBEO_WORKER_THREAD_ERROR;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	143 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	144 return SEOBEO_WORKER_OK;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	145 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	146
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	147 uint64 Seobeo_Thread_Current_Id(void)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	148 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	149 pthread_t thread = pthread_self();
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	150 const uint8 p_bytes = (const uint8 )&thread;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	151 uint64 hash = 1469598103934665603ULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	152 for (size_t i = 0; i < sizeof(thread); i++)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	153 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	154 hash ^= p_bytes[i];
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	155 hash *= 1099511628211ULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	156 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	157 return hash;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	158 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	159
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	160 static boolean Seobeo_Worker_Pool_Is_Current_Thread(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	161 Seobeo_Worker_Pool *p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	162 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	163 pthread_t current = pthread_self();
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	164 for (uint32 i = 0; i < p_pool->worker_count; i++)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	165 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	166 if (pthread_equal(current, p_pool->p_threads[i]))
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	167 return TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	168 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	169 return FALSE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	170 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	171
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	172 static void Seobeo_Worker_Pool_Run(void p_argument)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	173 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	174 Seobeo_Worker_Pool *p_pool = p_argument;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	175 while (TRUE)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	176 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	177 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	178 while (p_pool->queue_count == 0 && !p_pool->stopping)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	179 pthread_cond_wait(&p_pool->work_available, &p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	180
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	181 if (p_pool->stopping &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	182 (!p_pool->drain \|\| p_pool->queue_count == 0))
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	183 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	184 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	185 break;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	186 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	187
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	188 Seobeo_Work_Item item = p_pool->p_queue[p_pool->queue_head];
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	189 p_pool->queue_head =
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	190 (p_pool->queue_head + 1) % p_pool->queue_capacity;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	191 p_pool->queue_count--;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	192 p_pool->active_count++;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	193 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	194
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	195 Seobeo_Worker_Pool *p_previous_pool = g_current_worker_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	196 g_current_worker_pool = p_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	197 Seobeo_Work_Item_Run(&item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	198 g_current_worker_pool = p_previous_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	199
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	200 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	201 p_pool->active_count--;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	202 if (p_pool->queue_count == 0 &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	203 p_pool->active_count == 0 &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	204 p_pool->cleanup_count == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	205 pthread_cond_broadcast(&p_pool->idle);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	206 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	207 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	208 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	209 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	210
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	211 Seobeo_Worker_Pool *Seobeo_Worker_Pool_Create(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	212 uint32 worker_count,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	213 uint32 queue_capacity)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	214 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	215 if (worker_count == 0 \|\| queue_capacity == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	216 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	217
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	218 Seobeo_Worker_Pool p_pool = calloc(1, sizeof(p_pool));
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	219 if (!p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	220 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	221 p_pool->p_threads = calloc(worker_count, sizeof(*p_pool->p_threads));
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	222 p_pool->p_queue = calloc(queue_capacity, sizeof(*p_pool->p_queue));
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	223 if (!p_pool->p_threads \|\| !p_pool->p_queue)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	224 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	225 free(p_pool->p_threads);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	226 free(p_pool->p_queue);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	227 free(p_pool);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	228 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	229 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	230
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	231 p_pool->worker_count = worker_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	232 p_pool->queue_capacity = queue_capacity;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	233 p_pool->accepting = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	234 boolean mutex_initialized = FALSE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	235 boolean work_condition_initialized = FALSE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	236 boolean idle_condition_initialized = FALSE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	237 if (pthread_mutex_init(&p_pool->mutex, NULL) == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	238 mutex_initialized = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	239 if (mutex_initialized &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	240 pthread_cond_init(&p_pool->work_available, NULL) == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	241 work_condition_initialized = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	242 if (work_condition_initialized &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	243 pthread_cond_init(&p_pool->idle, NULL) == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	244 idle_condition_initialized = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	245 if (!idle_condition_initialized)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	246 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	247 if (work_condition_initialized)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	248 pthread_cond_destroy(&p_pool->work_available);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	249 if (mutex_initialized)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	250 pthread_mutex_destroy(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	251 free(p_pool->p_threads);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	252 free(p_pool->p_queue);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	253 free(p_pool);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	254 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	255 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	256
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	257 uint32 created = 0;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	258 for (; created < worker_count; created++)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	259 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	260 if (pthread_create(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	261 &p_pool->p_threads[created],
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	262 NULL,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	263 Seobeo_Worker_Pool_Run,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	264 p_pool) != 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	265 break;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	266 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	267 if (created != worker_count)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	268 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	269 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	270 p_pool->stopping = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	271 pthread_cond_broadcast(&p_pool->work_available);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	272 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	273 for (uint32 i = 0; i < created; i++)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	274 pthread_join(p_pool->p_threads[i], NULL);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	275 pthread_cond_destroy(&p_pool->idle);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	276 pthread_cond_destroy(&p_pool->work_available);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	277 pthread_mutex_destroy(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	278 free(p_pool->p_threads);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	279 free(p_pool->p_queue);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	280 free(p_pool);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	281 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	282 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	283 return p_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	284 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	285
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	286 Seobeo_Worker_Result Seobeo_Worker_Pool_Submit(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	287 Seobeo_Worker_Pool *p_pool,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	288 Seobeo_Work_Function function,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	289 void *p_context,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	290 Seobeo_Work_Cleanup cleanup)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	291 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	292 if (!p_pool \|\| !function)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	293 return SEOBEO_WORKER_INVALID_ARGUMENT;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	294
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	295 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	296 if (!p_pool->accepting)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	297 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	298 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	299 return SEOBEO_WORKER_STOPPED;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	300 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	301 if (p_pool->queue_count == p_pool->queue_capacity)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	302 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	303 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	304 return SEOBEO_WORKER_QUEUE_FULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	305 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	306
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	307 uint32 tail =
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	308 (p_pool->queue_head + p_pool->queue_count) %
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	309 p_pool->queue_capacity;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	310 p_pool->p_queue[tail] = (Seobeo_Work_Item){
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	311 .function = function,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	312 .p_context = p_context,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	313 .cleanup = cleanup,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	314 };
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	315 p_pool->queue_count++;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	316 pthread_cond_signal(&p_pool->work_available);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	317 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	318 return SEOBEO_WORKER_OK;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	319 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	320
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	321 Seobeo_Worker_Result Seobeo_Worker_Pool_Wait(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	322 Seobeo_Worker_Pool *p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	323 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	324 if (!p_pool \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	325 Seobeo_Worker_Pool_Is_Current_Thread(p_pool) \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	326 g_current_worker_pool == p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	327 return SEOBEO_WORKER_INVALID_ARGUMENT;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	328
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	329 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	330 while (p_pool->queue_count > 0 \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	331 p_pool->active_count > 0 \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	332 p_pool->cleanup_count > 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	333 pthread_cond_wait(&p_pool->idle, &p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	334 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	335 return SEOBEO_WORKER_OK;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	336 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	337
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	338 Seobeo_Worker_Result Seobeo_Worker_Pool_Shutdown(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	339 Seobeo_Worker_Pool *p_pool,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	340 boolean drain)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	341 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	342 if (!p_pool \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	343 Seobeo_Worker_Pool_Is_Current_Thread(p_pool) \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	344 g_current_worker_pool == p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	345 return SEOBEO_WORKER_INVALID_ARGUMENT;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	346
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	347 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	348 if (p_pool->joined)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	349 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	350 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	351 return SEOBEO_WORKER_OK;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	352 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	353 if (p_pool->shutdown_started)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	354 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	355 while (!p_pool->joined)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	356 pthread_cond_wait(&p_pool->idle, &p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	357 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	358 return SEOBEO_WORKER_OK;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	359 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	360 p_pool->shutdown_started = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	361 p_pool->accepting = FALSE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	362 p_pool->stopping = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	363 p_pool->drain = drain;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	364
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	365 if (!drain)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	366 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	367 while (p_pool->queue_count > 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	368 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	369 Seobeo_Work_Item item = p_pool->p_queue[p_pool->queue_head];
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	370 p_pool->queue_head =
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	371 (p_pool->queue_head + 1) % p_pool->queue_capacity;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	372 p_pool->queue_count--;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	373 p_pool->cleanup_count++;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	374 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	375 if (item.cleanup)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	376 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	377 Seobeo_Worker_Pool *p_previous_pool = g_current_worker_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	378 g_current_worker_pool = p_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	379 item.cleanup(item.p_context);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	380 g_current_worker_pool = p_previous_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	381 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	382 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	383 p_pool->cleanup_count--;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	384 if (p_pool->queue_count == 0 &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	385 p_pool->active_count == 0 &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	386 p_pool->cleanup_count == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	387 pthread_cond_broadcast(&p_pool->idle);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	388 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	389 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	390 pthread_cond_broadcast(&p_pool->work_available);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	391 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	392
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	393 for (uint32 i = 0; i < p_pool->worker_count; i++)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	394 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	395 if (pthread_join(p_pool->p_threads[i], NULL) != 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	396 return SEOBEO_WORKER_THREAD_ERROR;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	397 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	398
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	399 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	400 p_pool->joined = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	401 if (p_pool->active_count == 0 &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	402 p_pool->cleanup_count == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	403 pthread_cond_broadcast(&p_pool->idle);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	404 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	405 return SEOBEO_WORKER_OK;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	406 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	407
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	408 void Seobeo_Worker_Pool_Destroy(Seobeo_Worker_Pool *p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	409 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	410 if (!p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	411 return;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	412 if (Seobeo_Worker_Pool_Is_Current_Thread(p_pool) \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	413 g_current_worker_pool == p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	414 return;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	415 if (!p_pool->joined)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	416 (void)Seobeo_Worker_Pool_Shutdown(p_pool, TRUE);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	417 pthread_cond_destroy(&p_pool->idle);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	418 pthread_cond_destroy(&p_pool->work_available);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	419 pthread_mutex_destroy(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	420 free(p_pool->p_threads);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	421 free(p_pool->p_queue);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	422 free(p_pool);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	423 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	424
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	425 uint32 Seobeo_Worker_Pool_Pending(Seobeo_Worker_Pool *p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	426 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	427 if (!p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	428 return 0;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	429 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	430 uint32 count = p_pool->queue_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	431 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	432 return count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	433 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	434
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	435 uint32 Seobeo_Worker_Pool_Active(Seobeo_Worker_Pool *p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	436 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	437 if (!p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	438 return 0;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	439 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	440 uint32 count = p_pool->active_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	441 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	442 return count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	443 }

Mercurial

annotate seobeo/s_worker.c @ 279:b3b547563ec7