* */
| 491 | * |
| 492 | */ |
| 493 | int pv_get_mq_size(struct sip_msg *msg, pv_param_t *param, pv_value_t *res) |
| 494 | { |
| 495 | int mqs = -1; |
| 496 | |
| 497 | if (!param) |
| 498 | return pv_get_null(msg, param, res); |
| 499 | |
| 500 | if(pv_get_spec_name(msg, param, res)!=0 || (!(res->flags&PV_VAL_STR))) { |
| 501 | LM_ERR("invalid name\n"); |
| 502 | return -1; |
| 503 | } |
| 504 | |
| 505 | LM_DBG("Getting size of [%.*s]\n", res->rs.len, res->rs.s); |
| 506 | mqs = _mq_get_csize(&res->rs); |
| 507 | |
| 508 | if(mqs < 0) { |
| 509 | LM_ERR("mqueue not found: %.*s\n", res->rs.len, res->rs.s); |
| 510 | return -1; |
| 511 | } |
| 512 | |
| 513 | return pv_get_sintval(msg, param, res, mqs); |
| 514 | } |
| 515 | |
| 516 | /** |
| 517 | * Return head->csize for a given queue |
nothing calls this directly
no test coverage detected