Lines Matching refs:priv
32 /* this is the transport priv instantiated at abs->ati */
70 lws_unit_test_packet_dispose(abs_unit_test_priv_t *priv,
74 assert(priv->disposition == LPE_CONTINUE);
79 lws_strncpy(priv->note, note, sizeof(priv->note));
81 priv->disposition = disp;
83 lws_seq_queue_event(priv->seq, UTSEQ_MSG_DISPOSITION_KNOWN,
94 process_expect(abs_unit_test_priv_t *priv)
96 assert(priv->disposition == LPE_CONTINUE);
98 while (priv->expect->flags & LWS_AUT_EXPECT_RX &&
99 priv->disposition == LPE_CONTINUE) {
100 int f = priv->expect->flags & LWS_AUT_EXPECT_LOCAL_CLOSE, s;
102 if (priv->expect->pre)
103 priv->expect->pre(priv->abs);
106 lwsl_hexdump_debug(priv->expect->buffer, priv->expect->len);
107 s = priv->abs->ap->rx(priv->abs->api, priv->expect->buffer,
108 priv->expect->len);
114 return lws_unit_test_packet_dispose(priv, LPE_FAILED,
118 if (priv->expect->flags & LWS_AUT_EXPECT_TEST_END) {
119 lws_unit_test_packet_dispose(priv, LPE_SUCCEEDED, NULL);
123 priv->expect++;
134 abs_unit_test_priv_t *priv = (abs_unit_test_priv_t *)s->ai->ati;
155 if (priv->abs)
156 lws_abs_destroy_instance(&priv->abs);
164 if (!priv->timeout)
169 if (now <= priv->timeout)
172 if (priv->expect->flags & LWS_AUT_EXPECT_SHOULD_TIMEOUT) {
175 lws_unit_test_packet_dispose(priv,
183 if (priv->abs->ap->heartbeat)
184 priv->abs->ap->heartbeat(priv->abs->api);
190 priv->abs->ap->name,
191 priv->current_test->name,
192 priv->disposition == LPE_SUCCEEDED ? "OK" : "FAIL");
198 if (priv->result_cb)
199 priv->result_cb(priv->result_cb_arg, priv->disposition);
206 if (priv->abs->ap->accept)
207 priv->abs->ap->accept(priv->abs->api);
209 priv->established = 1;
214 if (priv->disposition)
217 if (process_expect(priv) != LPE_CONTINUE) {
228 priv->abs->ap->writeable(priv->abs->api, 1024);
233 if (!(priv->expect->flags & LWS_AUT_EXPECT_LOCAL_CLOSE)) {
236 lws_unit_test_packet_dispose(priv,
243 if (priv->abs && priv->abs->ap->closed)
244 priv->abs->ap->closed(priv->abs->api);
252 if (!(priv->expect->flags & LWS_AUT_EXPECT_SHOULD_TIMEOUT)) {
255 lws_unit_test_packet_dispose(priv,
264 priv->expect++;
265 if (!priv->expect->buffer) {
283 abs_unit_test_priv_t *priv = (abs_unit_test_priv_t *)ati;
287 lws_seq_queue_event(priv->seq, UTSEQ_MSG_CLOSING, NULL, NULL);
295 abs_unit_test_priv_t *priv = (abs_unit_test_priv_t *)ati;
297 assert(priv->disposition == LPE_CONTINUE);
301 if (priv->expect->pre)
302 priv->expect->pre(priv->abs);
304 if (!(priv->expect->flags & LWS_AUT_EXPECT_TX)) {
307 lws_unit_test_packet_dispose(priv, LPE_FAILED, "unexpected tx");
312 if (len != priv->expect->len) {
314 __func__, len, priv->expect->len);
315 lws_unit_test_packet_dispose(priv, LPE_FAILED,
321 if (memcmp(buf, priv->expect->buffer, len)) {
323 lwsl_hexdump_debug(priv->expect->buffer, len);
325 lws_unit_test_packet_dispose(priv, LPE_FAILED,
331 if (priv->expect->flags & LWS_AUT_EXPECT_TEST_END) {
332 lws_unit_test_packet_dispose(priv, LPE_SUCCEEDED, NULL);
337 priv->expect++;
339 lws_seq_queue_event(priv->seq, UTSEQ_MSG_POST_TX_KICK, NULL, NULL);
348 abs_unit_test_priv_t *priv = (abs_unit_test_priv_t *)abs->ati;
351 if (priv->established) {
365 priv->current_test = (lws_unit_test_t *)tm->u.value;
370 priv->result_cb = (lws_unit_test_packet_test_cb)tm->u.value;
372 priv->result_cb = NULL;
378 priv->result_cb_arg = tm->u.value;
380 priv->expect = priv->current_test->expect_array;
381 priv->disposition = LPE_CONTINUE;
382 priv->note[0] = '\0';
384 lws_seq_timeout_us(priv->seq, priv->current_test->max_secs *
388 priv->current_test->name);
390 lws_seq_queue_event(priv->seq, UTSEQ_MSG_CONNECTING, NULL, NULL);
399 abs_unit_test_priv_t *priv = (abs_unit_test_priv_t *)ati;
401 if (!priv->established)
409 lws_seq_queue_event(priv->seq, UTSEQ_MSG_WRITEABLE, NULL, NULL);
421 abs_unit_test_priv_t *priv;
444 priv = ai->ati;
446 memset(priv, 0, sizeof(*priv));
448 /* the sequencer priv just points to the lws_abs_t */
450 priv->abs = ai;
451 priv->seq = seq;
470 abs_unit_test_priv_t *priv = (abs_unit_test_priv_t *)ati;
476 priv->timeout = now + secs;
478 priv->timeout = 0;
486 abs_unit_test_priv_t *priv = (abs_unit_test_priv_t *)ati;
488 if (!priv || (!priv->established && !priv->connecting))