Function test_cachedb_api

cachedb/test/test_cachedb.c:595–657

}

static void test_cachedb_api(const char *cachedb_name, const char *group1,
								const char *group2)
{
	str key = str_init("foo"),
	    val = str_init("bar");
	str cdb_str, cdb_gr1, str_gr1, str_gr2 = {0,0};
	cachedb_engine *cde;
	cachedb_con *con1 = NULL, *con2 = NULL;

	init_str(&cdb_str, cachedb_name);

	if (group1) {
		cdb_gr1.len = strlen(cachedb_name) + strlen(group1) + 1;
		cdb_gr1.s = pkg_malloc(cdb_gr1.len);
		snprintf(cdb_gr1.s, cdb_gr1.len+1, "%s:%s", cachedb_name, group1);

		init_str(&str_gr1, group1);
		init_str(&str_gr2, group2);
	} else
		init_str(&cdb_gr1, cachedb_name);

	/* high-level cachedb API (called by script, MI) */

	/* TODO: write tests for signed integers (may be broken in current Mongo) */

	ok(cachedb_store(&cdb_gr1, &key, &val, 0) == 1, "store key");

	memset(&val, 0, sizeof val);
	ok(cachedb_fetch(&cdb_gr1, &key, &val) == 1, "fetch key");
	cmp_mem(val.s, "bar", 3, "check fetched value");

	ok(cachedb_remove(&cdb_gr1, &key) == 1, "remove key");

	ok(cachedb_fetch(&cdb_gr1, &key, &val) == -2, "fetch non-existing key");

	/* low-level cachedb API (called by core and modules) */

	cde = lookup_cachedb(&cdb_str);
	if (!ok(cde != NULL, "have cachedb engine"))
		return;

	if (group1) {
		con1 = cachedb_get_connection(cde, &str_gr1);
		if (!ok(con1 != NULL, "engine has con"))
				return;

		con2 = cachedb_get_connection(cde, &str_gr2);
		if (!ok(con2 != NULL, "engine has con"))
				return;
	} else {
		con1 = cachedb_get_connection(cde, NULL);
		if (!ok(con1 != NULL, "engine has con"))
				return;
	}

	if (CACHEDB_CAPABILITY(&cde->cdb_func, CACHEDB_CAP_COL_ORIENTED))
		ok(test_column_ops(&cde->cdb_func, con1, con2, cachedb_name),
			"column-oriented tests");