Function run_message_test

tests/test_webrtc.cpp:91–162

}

static bool run_message_test(const char *label, internal_socket_t *left, internal_socket_t *right)
{
	internal_callbacks_t events;
	
	memset(&events, 0, sizeof(events));
	
	events.on_data = on_data;
	
	internal_set_callbacks(left, &events );
	internal_set_callbacks(right, &events );
	
	const char* binary_message;
	int received_message_count = 0;
	int expected_message_count = 2;
	
	std::vector<std::string> msg_queue;
	
	printf("[%s] starting\n", label);
	
//    g_signal_connect(left, "on-data", G_CALLBACK(on_data), msg_queue);
//    g_signal_connect(right, "on-data", G_CALLBACK(on_data), msg_queue);
//    g_signal_connect(left, "on-binary-data", G_CALLBACK(on_binary_data), msg_queue);
//    g_signal_connect(right, "on-binary-data", G_CALLBACK(on_binary_data), msg_queue);
	
	internal_set_data( left, &msg_queue );
	internal_set_data( right, &msg_queue );
	
	printf("[%s] sending messages\n", label);
	
	binary_message = "binary: left->right";
	internal_write_socket(left, binary_message, strlen(binary_message));
	binary_message = "binary: right->left";
	internal_write_socket(right, binary_message, strlen(binary_message));
	
	printf("[%s] expecting messages\n", label);
	
	int timeout = 5000;
	for (received_message_count = 0; received_message_count < expected_message_count; ) {
		wait(&timeout);
	
		// detect time has run out...
		if( timeout <= 0 )
		{
			printf("[%s] *** timeout while waiting for message\n", label);
			break;
		}
		
		for( auto it = msg_queue.begin(); it != msg_queue.end(); ) {
			const char* received_message = it->c_str();
			
			printf("[%s] received message: %s\n", label, received_message);
			
			received_message_count++;
			
			msg_queue.erase(it);
			
			it = msg_queue.begin();
		}