78 	struct per_vhost_data__minimal *vhd =  in thread_spam()  local
83 	for (n = 0; n < (int)LWS_ARRAY_SIZE(vhd->pthread_spam); n++)  in thread_spam()
84 		if (pthread_equal(pthread_self(), vhd->pthread_spam[n]))  in thread_spam()
89 		if (!vhd->established)  in thread_spam()
92 		pthread_mutex_lock(&vhd->lock_ring); /* --------- ring lock { */  in thread_spam()
95 		n = (int)lws_ring_get_count_free_elements(vhd->ring);  in thread_spam()
109 		n = (int)lws_ring_insert(vhd->ring, &amsg, 1);  in thread_spam()
118 			lws_cancel_service(vhd->context);  in thread_spam()
121 		pthread_mutex_unlock(&vhd->lock_ring); /* } ring lock ------- */  in thread_spam()
126 	} while (!vhd->finished);  in thread_spam()
138 	struct per_vhost_data__minimal *vhd =  in sul_connect_attempt()  local
141 	vhd->i.context = vhd->context;  in sul_connect_attempt()
142 	vhd->i.port = 7681;  in sul_connect_attempt()
143 	vhd->i.address = "localhost";  in sul_connect_attempt()
144 	vhd->i.path = "/publisher";  in sul_connect_attempt()
145 	vhd->i.host = vhd->i.address;  in sul_connect_attempt()
146 	vhd->i.origin = vhd->i.address;  in sul_connect_attempt()
147 	vhd->i.ssl_connection = 0;  in sul_connect_attempt()
149 	vhd->i.protocol = "lws-minimal-broker";  in sul_connect_attempt()
150 	vhd->i.pwsi = &vhd->client_wsi;  in sul_connect_attempt()
152 	if (!lws_client_connect_via_info(&vhd->i))  in sul_connect_attempt()
153 		lws_sul_schedule(vhd->context, 0, &vhd->sul,  in sul_connect_attempt()
161 	struct per_vhost_data__minimal *vhd =  in callback_minimal_broker()  local
174 		vhd = lws_protocol_vh_priv_zalloc(lws_get_vhost(wsi),  in callback_minimal_broker()
177 		vhd->context = lws_get_context(wsi);  in callback_minimal_broker()
178 		vhd->protocol = lws_get_protocol(wsi);  in callback_minimal_broker()
179 		vhd->vhost = lws_get_vhost(wsi);  in callback_minimal_broker()
181 		vhd->ring = lws_ring_create(sizeof(struct msg), 8,  in callback_minimal_broker()
183 		if (!vhd->ring)  in callback_minimal_broker()
186 		pthread_mutex_init(&vhd->lock_ring, NULL);  in callback_minimal_broker()
190 		for (n = 0; n < (int)LWS_ARRAY_SIZE(vhd->pthread_spam); n++)  in callback_minimal_broker()
191 			if (pthread_create(&vhd->pthread_spam[n], NULL,  in callback_minimal_broker()
192 					   thread_spam, vhd)) {  in callback_minimal_broker()
198 		sul_connect_attempt(&vhd->sul);  in callback_minimal_broker()
203 		vhd->finished = 1;  in callback_minimal_broker()
204 		for (n = 0; n < (int)LWS_ARRAY_SIZE(vhd->pthread_spam); n++)  in callback_minimal_broker()
205 			pthread_join(vhd->pthread_spam[n], &retval);  in callback_minimal_broker()
207 		if (vhd->ring)  in callback_minimal_broker()
208 			lws_ring_destroy(vhd->ring);  in callback_minimal_broker()
210 		lws_sul_cancel(&vhd->sul);  in callback_minimal_broker()
211 		pthread_mutex_destroy(&vhd->lock_ring);  in callback_minimal_broker()
218 		vhd->client_wsi = NULL;  in callback_minimal_broker()
219 		lws_sul_schedule(vhd->context, 0, &vhd->sul,  in callback_minimal_broker()
227 		vhd->established = 1;  in callback_minimal_broker()
231 		pthread_mutex_lock(&vhd->lock_ring); /* --------- ring lock { */  in callback_minimal_broker()
232 		pmsg = lws_ring_get_element(vhd->ring, &vhd->tail);  in callback_minimal_broker()
240 			pthread_mutex_unlock(&vhd->lock_ring); /* } ring lock */  in callback_minimal_broker()
245 		lws_ring_consume_single_tail(vhd->ring, &vhd->tail, 1);  in callback_minimal_broker()
248 		if (lws_ring_get_element(vhd->ring, &vhd->tail))  in callback_minimal_broker()
253 		pthread_mutex_unlock(&vhd->lock_ring); /* } ring lock ------- */  in callback_minimal_broker()
257 		vhd->client_wsi = NULL;  in callback_minimal_broker()
258 		vhd->established = 0;  in callback_minimal_broker()
259 		lws_sul_schedule(vhd->context, 0, &vhd->sul,  in callback_minimal_broker()
272 		if (vhd && vhd->client_wsi && vhd->established)  in callback_minimal_broker()
273 			lws_callback_on_writable(vhd->client_wsi);  in callback_minimal_broker()