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