Lines Matching refs:pss
104 struct pss {
200 struct pss *pss = (struct pss *)user;
231 pss->state++;
240 if (++pss->state == STATE_TEST_FINISH) {
256 switch (pss->state) {
265 pss->state++;
273 pss->pub_param.topic = pss->state == STATE_PUBLISH_QOS0 ?
275 pss->pub_param.topic_len = (uint16_t)strlen(pss->pub_param.topic);
276 pss->pub_param.qos =
277 pss->state == STATE_PUBLISH_QOS0 ? QOS0 : QOS1;
278 pss->pub_param.payload_len = TEST_STRING_LEN;
284 if (chunk > TEST_STRING_LEN - pss->pos)
285 chunk = TEST_STRING_LEN - pss->pos;
288 (int)chunk, (int)pss->pos);
290 if (lws_mqtt_client_send_publish(wsi, &pss->pub_param,
291 test_string + pss->pos, (uint32_t)chunk,
292 (pss->pos + chunk == TEST_STRING_LEN))) {
297 pss->pos += chunk;
299 if (pss->pos == TEST_STRING_LEN) {
301 pss->pos = 0;
302 pss->state++;
309 pss->state++;
322 lwsl_user("%s: item %d: MQTT_ACK (state %d)\n", __func__, (int)(item - &items[0]), pss->state);
329 pss->state++;
330 if (pss->state != STATE_TEST_FINISH) {
342 if (++pss->retries == 3) {
346 pss->state--;
347 pss->pos = 0;
378 .per_session_data_size = sizeof(struct pss)