Commit e274a910 authored by Claes Sjofors's avatar Claes Sjofors

QCom, when queue qouta was exceeded, message wasn't freed from pool (refs #62)

parent 75efc0df
...@@ -664,6 +664,7 @@ qcom_Put ( ...@@ -664,6 +664,7 @@ qcom_Put (
qdb_sNode *np = NULL; qdb_sNode *np = NULL;
qdb_sQue *qp = NULL; qdb_sQue *qp = NULL;
pwr_dStatus (sts, status, QCOM__SUCCESS); pwr_dStatus (sts, status, QCOM__SUCCESS);
pwr_tStatus lsts;
pwr_Assert(pp != NULL); pwr_Assert(pp != NULL);
...@@ -694,7 +695,9 @@ qcom_Put ( ...@@ -694,7 +695,9 @@ qcom_Put (
} }
qdb_Put(sts, bp, qp); qdb_Put(sts, bp, qp);
if (ODD(*sts)) qdb->ap->put_count++; if ( *sts == QDB__QUOTAEXCEEDED)
qdb_Free(&lsts, bp);
else if (ODD(*sts)) qdb->ap->put_count++;
} qdb_ScopeUnlock; } qdb_ScopeUnlock;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment