swoole_process原始碼分析之查詢佇列狀態
阿新 • • 發佈:2018-12-13
swoole_process提供的statQueue用於統計佇列狀態,其返回一個數組,裡面包括了訊息總個數和總的位元組數。
array swoole_process->statQueue();
下面我們看看其實現。
static PHP_METHOD(swoole_process, statQueue) { swWorker *process = swoole_get_object(getThis()); if (!process->queue) { swoole_php_fatal_error(E_WARNING, "no queue, can't get stats of the queue."); RETURN_FALSE; } int queue_num = -1; int queue_bytes = -1; if (swMsgQueue_stat(process->queue, &queue_num, &queue_bytes) == 0) { array_init(return_value); sw_add_assoc_long_ex(return_value, ZEND_STRS("queue_num"), queue_num); sw_add_assoc_long_ex(return_value, ZEND_STRS("queue_bytes"), queue_bytes); } else { RETURN_FALSE; } }
int swMsgQueue_stat(swMsgQueue *q, int *queue_num, int *queue_bytes) { struct msqid_ds __stat; if (msgctl(q->msg_id, IPC_STAT, &__stat) == 0) { *queue_num = __stat.msg_qnum; *queue_bytes = __stat.msg_cbytes; return 0; } else { return -1; } }