Lines Matching defs:p_FmHc
143 static t_Error FillBufPool(t_FmHc *p_FmHc)
147 ASSERT_COND(p_FmHc);
152 p_FmHc->p_Frm[i] = (t_HcFrame *)XX_MallocSmart((sizeof(t_HcFrame) + (16 - (sizeof(t_FmHc) % 16))),
153 p_FmHc->dataMemId,
156 p_FmHc->p_Frm[i] = (t_HcFrame *)XX_MallocSmart(sizeof(t_HcFrame),
157 p_FmHc->dataMemId,
160 if (!p_FmHc->p_Frm[i])
167 p_FmHc->seqNum[i] = i;
169 p_FmHc->nextSeqNumLocation = 0;
174 static __inline__ t_HcFrame * GetBuf(t_FmHc *p_FmHc, uint32_t *p_SeqNum)
178 ASSERT_COND(p_FmHc);
180 intFlags = FmPcdLock(p_FmHc->h_FmPcd);
182 if (p_FmHc->nextSeqNumLocation == HC_CMD_POOL_SIZE)
185 FmPcdUnlock(p_FmHc->h_FmPcd, intFlags);
189 *p_SeqNum = p_FmHc->seqNum[p_FmHc->nextSeqNumLocation];
190 p_FmHc->nextSeqNumLocation++;
192 FmPcdUnlock(p_FmHc->h_FmPcd, intFlags);
193 return p_FmHc->p_Frm[*p_SeqNum];
196 static __inline__ void PutBuf(t_FmHc *p_FmHc, t_HcFrame *p_Buf, uint32_t seqNum)
202 intFlags = FmPcdLock(p_FmHc->h_FmPcd);
203 ASSERT_COND(p_FmHc->nextSeqNumLocation);
204 p_FmHc->nextSeqNumLocation--;
205 p_FmHc->seqNum[p_FmHc->nextSeqNumLocation] = seqNum;
206 FmPcdUnlock(p_FmHc->h_FmPcd, intFlags);
209 static __inline__ t_Error EnQFrm(t_FmHc *p_FmHc, t_DpaaFD *p_FmFd, uint32_t seqNum)
215 intFlags = FmPcdLock(p_FmHc->h_FmPcd);
216 ASSERT_COND(!p_FmHc->enqueued[seqNum]);
217 p_FmHc->enqueued[seqNum] = TRUE;
218 FmPcdUnlock(p_FmHc->h_FmPcd, intFlags);
223 err = p_FmHc->f_QmEnqueue(p_FmHc->h_QmArg, (void *)p_FmFd);
227 while (p_FmHc->enqueued[seqNum] && --timeout)
239 t_FmHc *p_FmHc;
243 p_FmHc = (t_FmHc *)XX_Malloc(sizeof(t_FmHc));
244 if (!p_FmHc)
249 memset(p_FmHc,0,sizeof(t_FmHc));
251 p_FmHc->h_FmPcd = p_FmHcParams->h_FmPcd;
252 p_FmHc->f_QmEnqueue = p_FmHcParams->params.f_QmEnqueue;
253 p_FmHc->h_QmArg = p_FmHcParams->params.h_QmArg;
254 p_FmHc->dataMemId = DEFAULT_dataMemId;
256 err = FillBufPool(p_FmHc);
260 FmHcFree(p_FmHc);
265 return (t_Handle)p_FmHc;
278 p_FmHc->h_HcPortDev = FM_PORT_Config(&fmPortParam);
279 if (!p_FmHc->h_HcPortDev)
282 XX_Free(p_FmHc);
286 err = FM_PORT_ConfigMaxFrameLength(p_FmHc->h_HcPortDev,
292 FmHcFree(p_FmHc);
297 err = FM_PORT_Init(p_FmHc->h_HcPortDev);
301 FmHcFree(p_FmHc);
305 err = FM_PORT_Enable(p_FmHc->h_HcPortDev);
309 FmHcFree(p_FmHc);
313 return (t_Handle)p_FmHc;
318 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
321 if (!p_FmHc)
325 if (p_FmHc->p_Frm[i])
326 XX_FreeSmart(p_FmHc->p_Frm[i]);
330 if (p_FmHc->h_HcPortDev)
331 FM_PORT_Free(p_FmHc->h_HcPortDev);
333 XX_Free(p_FmHc);
340 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
343 SANITY_CHECK_RETURN_ERROR(p_FmHc, E_INVALID_HANDLE);
345 p_FmHc->dataMemId = memId;
348 if (p_FmHc->p_Frm[i])
349 XX_FreeSmart(p_FmHc->p_Frm[i]);
351 return FillBufPool(p_FmHc);
356 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
360 ASSERT_COND(p_FmHc);
362 intFlags = FmPcdLock(p_FmHc->h_FmPcd);
368 if (!(p_FmHc->enqueued[p_HcFrame->commandSequence]))
371 p_FmHc->enqueued[p_HcFrame->commandSequence] = FALSE;
372 FmPcdUnlock(p_FmHc->h_FmPcd, intFlags);
380 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
387 p_HcFrame = GetBuf(p_FmHc, &seqNum);
409 err = EnQFrm(p_FmHc, &fmFd, seqNum);
411 PutBuf(p_FmHc, p_HcFrame, seqNum);
421 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
428 p_HcFrame = GetBuf(p_FmHc, &seqNum);
441 err = EnQFrm(p_FmHc, &fmFd, seqNum);
443 PutBuf(p_FmHc, p_HcFrame, seqNum);
453 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
467 relativeSchemeId = FmPcdKgGetRelativeSchemeId(p_FmHc->h_FmPcd, physicalSchemeId);
471 if (!FmPcdKgGetRequiredActionFlag(p_FmHc->h_FmPcd, relativeSchemeId) ||
472 !(FmPcdKgGetRequiredAction(p_FmHc->h_FmPcd, relativeSchemeId) & requiredAction))
475 (FmPcdKgGetNextEngine(p_FmHc->h_FmPcd, relativeSchemeId) == e_FM_PCD_PLCR))
477 if ((FmPcdKgIsDirectPlcr(p_FmHc->h_FmPcd, relativeSchemeId) == FALSE) ||
478 (FmPcdKgIsDistrOnPlcrProfile(p_FmHc->h_FmPcd, relativeSchemeId) == TRUE))
480 err = FmPcdPlcrCcGetSetParams(p_FmHc->h_FmPcd, FmPcdKgGetRelativeProfileId(p_FmHc->h_FmPcd, relativeSchemeId), requiredAction);
487 p_HcFrame = GetBuf(p_FmHc, &seqNum);
496 if ((err = EnQFrm(p_FmHc, &fmFd, seqNum)) != E_OK)
498 PutBuf(p_FmHc, p_HcFrame, seqNum);
504 ((FmPcdKgGetNextEngine(p_FmHc->h_FmPcd, relativeSchemeId) == e_FM_PCD_DONE) &&
505 (FmPcdKgGetDoneAction(p_FmHc->h_FmPcd, relativeSchemeId) == e_FM_PCD_ENQ_FRAME)))
513 (FmPcdKgGetNextEngine(p_FmHc->h_FmPcd, relativeSchemeId) == e_FM_PCD_CC))
538 err = EnQFrm(p_FmHc, &fmFd, seqNum);
540 PutBuf(p_FmHc, p_HcFrame, seqNum);
552 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
561 relativeSchemeId = FmPcdKgGetRelativeSchemeId(p_FmHc->h_FmPcd, physicalSchemeId);
569 p_HcFrame = GetBuf(p_FmHc, &seqNum);
583 err = EnQFrm(p_FmHc, &fmFd, seqNum);
586 PutBuf(p_FmHc, p_HcFrame, seqNum);
593 PutBuf(p_FmHc, p_HcFrame, seqNum);
599 PutBuf(p_FmHc, p_HcFrame, seqNum);
606 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
614 relativeSchemeId = FmPcdKgGetRelativeSchemeId(p_FmHc->h_FmPcd, physicalSchemeId);
619 p_HcFrame = GetBuf(p_FmHc, &seqNum);
632 err = EnQFrm(p_FmHc, &fmFd, seqNum);
634 PutBuf(p_FmHc, p_HcFrame, seqNum);
640 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
647 ASSERT_COND(p_FmHc);
649 p_HcFrame = GetBuf(p_FmHc, &seqNum);
666 if ((err = EnQFrm(p_FmHc, &fmFd, seqNum)) != E_OK)
668 PutBuf(p_FmHc, p_HcFrame, seqNum);
673 PutBuf(p_FmHc, p_HcFrame, seqNum);
679 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
688 p_ClsPlanSet->baseEntry = FmPcdKgGetClsPlanGrpBase(p_FmHc->h_FmPcd, grpId);
689 p_ClsPlanSet->numOfClsPlanEntries = FmPcdKgGetClsPlanGrpSize(p_FmHc->h_FmPcd, grpId);
692 if (FmHcPcdKgSetClsPlan(p_FmHc, p_ClsPlanSet) != E_OK)
699 FmPcdKgDestroyClsPlanGrp(p_FmHc->h_FmPcd, grpId);
706 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
714 p_HcFrame = GetBuf(p_FmHc, &seqNum);
724 err = EnQFrm(p_FmHc, &fmFd, seqNum);
726 PutBuf(p_FmHc, p_HcFrame, seqNum);
732 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
740 p_HcFrame = GetBuf(p_FmHc, &seqNum);
756 if ((err = EnQFrm(p_FmHc, &fmFd, seqNum)) != E_OK)
758 PutBuf(p_FmHc, p_HcFrame, seqNum);
764 PutBuf(p_FmHc, p_HcFrame, seqNum);
770 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
778 p_HcFrame = GetBuf(p_FmHc, &seqNum);
789 if ((err = EnQFrm(p_FmHc, &fmFd, seqNum)) != E_OK)
791 PutBuf(p_FmHc, p_HcFrame, seqNum);
798 PutBuf(p_FmHc, p_HcFrame, seqNum);
804 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
819 requiredActionTmp = FmPcdPlcrGetRequiredAction(p_FmHc->h_FmPcd, absoluteProfileId);
820 requiredActionFlag = FmPcdPlcrGetRequiredActionFlag(p_FmHc->h_FmPcd, absoluteProfileId);
826 p_HcFrame = GetBuf(p_FmHc, &seqNum);
838 if ((err = EnQFrm(p_FmHc, &fmFd, seqNum)) != E_OK)
840 PutBuf(p_FmHc, p_HcFrame, seqNum);
847 PutBuf(p_FmHc, p_HcFrame, seqNum);
862 if ((err = EnQFrm(p_FmHc, &fmFd, seqNum)) != E_OK)
864 PutBuf(p_FmHc, p_HcFrame, seqNum);
871 PutBuf(p_FmHc, p_HcFrame, seqNum);
885 if ((err = EnQFrm(p_FmHc, &fmFd, seqNum)) != E_OK)
887 PutBuf(p_FmHc, p_HcFrame, seqNum);
894 PutBuf(p_FmHc, p_HcFrame, seqNum);
908 if ((err = EnQFrm(p_FmHc, &fmFd, seqNum)) != E_OK)
910 PutBuf(p_FmHc, p_HcFrame, seqNum);
914 PutBuf(p_FmHc, p_HcFrame, seqNum);
923 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
930 p_HcFrame = GetBuf(p_FmHc, &seqNum);
945 err = EnQFrm(p_FmHc, &fmFd, seqNum);
947 PutBuf(p_FmHc, p_HcFrame, seqNum);
957 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
964 p_HcFrame = GetBuf(p_FmHc, &seqNum);
977 err = EnQFrm(p_FmHc, &fmFd, seqNum);
979 PutBuf(p_FmHc, p_HcFrame, seqNum);
990 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
998 p_HcFrame = GetBuf(p_FmHc, &seqNum);
1011 err = EnQFrm(p_FmHc, &fmFd, seqNum);
1013 PutBuf(p_FmHc, p_HcFrame, seqNum);
1023 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
1034 p_HcFrame = GetBuf(p_FmHc, &seqNum);
1048 err = EnQFrm(p_FmHc, &fmFd, seqNum);
1051 PutBuf(p_FmHc, p_HcFrame, seqNum);
1077 PutBuf(p_FmHc, p_HcFrame, seqNum);
1083 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
1089 ASSERT_COND(p_FmHc);
1091 p_HcFrame = GetBuf(p_FmHc, &seqNum);
1103 if ((err = EnQFrm(p_FmHc, &fmFd, seqNum)) != E_OK)
1105 PutBuf(p_FmHc, p_HcFrame, seqNum);
1119 err = EnQFrm(p_FmHc, &fmFd, seqNum);
1121 PutBuf(p_FmHc, p_HcFrame, seqNum);
1131 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
1137 ASSERT_COND(p_FmHc);
1139 p_HcFrame = GetBuf(p_FmHc, &seqNum);
1152 err = EnQFrm(p_FmHc, &fmFd, seqNum);
1154 PutBuf(p_FmHc, p_HcFrame, seqNum);
1164 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
1170 SANITY_CHECK_RETURN_ERROR(p_FmHc, E_INVALID_HANDLE);
1172 p_HcFrame = GetBuf(p_FmHc, &seqNum);
1185 err = EnQFrm(p_FmHc, &fmFd, seqNum);
1187 PutBuf(p_FmHc, p_HcFrame, seqNum);
1197 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
1203 ASSERT_COND(p_FmHc);
1205 p_HcFrame = GetBuf(p_FmHc, &seqNum);
1217 err = EnQFrm(p_FmHc, &fmFd, seqNum);
1219 PutBuf(p_FmHc, p_HcFrame, seqNum);
1229 t_FmHc *p_FmHc = (t_FmHc*)h_FmHc;
1230 return p_FmHc->h_HcPortDev;