Lines Matching refs:workqs

65     pUM->workqs.instq.pUM = pUM;
67 strcpy(pUM->workqs.instq.taskqName, pUM->devName);
68 strcat(pUM->workqs.instq.taskqName, "_inst_q");
70 mutex_init(&pUM->workqs.instq.workQueueMutex, NULL,
73 if ((pUM->workqs.instq.pTaskq =
75 pUM->workqs.instq.taskqName,
80 BnxeLogWarn(pUM, "Failed to create the workqs instq");
84 pUM->workqs.instq.pUM = pUM;
86 strcpy(pUM->workqs.delayq.taskqName, pUM->devName);
87 strcat(pUM->workqs.delayq.taskqName, "_delay_q");
89 mutex_init(&pUM->workqs.delayq.workQueueMutex, NULL,
92 if ((pUM->workqs.delayq.pTaskq =
94 pUM->workqs.delayq.taskqName,
99 BnxeLogWarn(pUM, "Failed to create the workqs delayq");
100 BnxeWorkQueueInstanceWaitAndDestroy(&pUM->workqs.instq);
104 pUM->workqs.delayq.pUM = pUM;
112 BnxeWorkQueueInstanceWaitAndDestroy(&pUM->workqs.instq);
113 BnxeWorkQueueInstanceWaitAndDestroy(&pUM->workqs.delayq);
200 mutex_enter(&pUM->workqs.instq.workQueueMutex);
201 cnt = s_list_entry_cnt(&pUM->workqs.instq.workQueue);
202 mutex_exit(&pUM->workqs.instq.workQueueMutex);
206 BnxeWorkQueueTrigger(pUM, &pUM->workqs.instq);
209 mutex_enter(&pUM->workqs.delayq.workQueueMutex);
210 cnt = s_list_entry_cnt(&pUM->workqs.delayq.workQueue);
211 mutex_exit(&pUM->workqs.delayq.workQueueMutex);
215 BnxeWorkQueueTrigger(pUM, &pUM->workqs.delayq);
243 mutex_enter(&pUM->workqs.instq.workQueueMutex);
245 s_list_push_tail(&pUM->workqs.instq.workQueue, &pWorkItem->link);
246 pUM->workqs.instq.workItemQueued++;
247 if (s_list_entry_cnt(&pUM->workqs.instq.workQueue) >
248 pUM->workqs.instq.highWater)
250 pUM->workqs.instq.highWater =
251 s_list_entry_cnt(&pUM->workqs.instq.workQueue);
254 mutex_exit(&pUM->workqs.instq.workQueueMutex);
256 BnxeWorkQueueTrigger(pUM, &pUM->workqs.instq);
281 mutex_enter(&pUM->workqs.instq.workQueueMutex);
283 s_list_push_tail(&pUM->workqs.instq.workQueue, &pWorkItem->link);
284 pUM->workqs.instq.workItemQueued++;
285 if (s_list_entry_cnt(&pUM->workqs.instq.workQueue) >
286 pUM->workqs.instq.highWater)
288 pUM->workqs.instq.highWater =
289 s_list_entry_cnt(&pUM->workqs.instq.workQueue);
292 mutex_exit(&pUM->workqs.instq.workQueueMutex);
294 BnxeWorkQueueTrigger(pUM, &pUM->workqs.instq);
318 mutex_enter(&pUM->workqs.instq.workQueueMutex);
320 s_list_push_tail(&pUM->workqs.instq.workQueue, &pWorkItem->link);
321 pUM->workqs.instq.workItemQueued++;
322 if (s_list_entry_cnt(&pUM->workqs.instq.workQueue) >
323 pUM->workqs.instq.highWater)
325 pUM->workqs.instq.highWater =
326 s_list_entry_cnt(&pUM->workqs.instq.workQueue);
329 mutex_exit(&pUM->workqs.instq.workQueueMutex);
331 BnxeWorkQueueTrigger(pUM, &pUM->workqs.instq);
361 mutex_enter(&pUM->workqs.delayq.workQueueMutex);
363 s_list_push_tail(&pUM->workqs.delayq.workQueue, &pWorkItem->link);
364 pUM->workqs.delayq.workItemQueued++;
365 if (s_list_entry_cnt(&pUM->workqs.delayq.workQueue) >
366 pUM->workqs.delayq.highWater)
368 pUM->workqs.delayq.highWater =
369 s_list_entry_cnt(&pUM->workqs.delayq.workQueue);
372 mutex_exit(&pUM->workqs.delayq.workQueueMutex);
374 BnxeWorkQueueTrigger(pUM, &pUM->workqs.delayq);
400 mutex_enter(&pUM->workqs.delayq.workQueueMutex);
402 s_list_push_tail(&pUM->workqs.delayq.workQueue, &pWorkItem->link);
403 pUM->workqs.delayq.workItemQueued++;
404 if (s_list_entry_cnt(&pUM->workqs.delayq.workQueue) >
405 pUM->workqs.delayq.highWater)
407 pUM->workqs.delayq.highWater =
408 s_list_entry_cnt(&pUM->workqs.delayq.workQueue);
411 mutex_exit(&pUM->workqs.delayq.workQueueMutex);
413 BnxeWorkQueueTrigger(pUM, &pUM->workqs.delayq);
438 mutex_enter(&pUM->workqs.delayq.workQueueMutex);
440 s_list_push_tail(&pUM->workqs.delayq.workQueue, &pWorkItem->link);
441 pUM->workqs.delayq.workItemQueued++;
442 if (s_list_entry_cnt(&pUM->workqs.delayq.workQueue) >
443 pUM->workqs.delayq.highWater)
445 pUM->workqs.delayq.highWater =
446 s_list_entry_cnt(&pUM->workqs.delayq.workQueue);
449 mutex_exit(&pUM->workqs.delayq.workQueueMutex);
451 BnxeWorkQueueTrigger(pUM, &pUM->workqs.delayq);