12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022 |
- // SPDX-License-Identifier: BSD-3-Clause OR GPL-2.0
- /* Copyright (c) 2018 Mellanox Technologies. All rights reserved */
- #define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
- #include <linux/kernel.h>
- #include <linux/module.h>
- #include <linux/slab.h>
- #include <linux/random.h>
- #include <linux/objagg.h>
- struct tokey {
- unsigned int id;
- };
- #define NUM_KEYS 32
- static int key_id_index(unsigned int key_id)
- {
- if (key_id >= NUM_KEYS) {
- WARN_ON(1);
- return 0;
- }
- return key_id;
- }
- #define BUF_LEN 128
- struct world {
- unsigned int root_count;
- unsigned int delta_count;
- char next_root_buf[BUF_LEN];
- struct objagg_obj *objagg_objs[NUM_KEYS];
- unsigned int key_refs[NUM_KEYS];
- };
- struct root {
- struct tokey key;
- char buf[BUF_LEN];
- };
- struct delta {
- unsigned int key_id_diff;
- };
- static struct objagg_obj *world_obj_get(struct world *world,
- struct objagg *objagg,
- unsigned int key_id)
- {
- struct objagg_obj *objagg_obj;
- struct tokey key;
- int err;
- key.id = key_id;
- objagg_obj = objagg_obj_get(objagg, &key);
- if (IS_ERR(objagg_obj)) {
- pr_err("Key %u: Failed to get object.\n", key_id);
- return objagg_obj;
- }
- if (!world->key_refs[key_id_index(key_id)]) {
- world->objagg_objs[key_id_index(key_id)] = objagg_obj;
- } else if (world->objagg_objs[key_id_index(key_id)] != objagg_obj) {
- pr_err("Key %u: God another object for the same key.\n",
- key_id);
- err = -EINVAL;
- goto err_key_id_check;
- }
- world->key_refs[key_id_index(key_id)]++;
- return objagg_obj;
- err_key_id_check:
- objagg_obj_put(objagg, objagg_obj);
- return ERR_PTR(err);
- }
- static void world_obj_put(struct world *world, struct objagg *objagg,
- unsigned int key_id)
- {
- struct objagg_obj *objagg_obj;
- if (!world->key_refs[key_id_index(key_id)])
- return;
- objagg_obj = world->objagg_objs[key_id_index(key_id)];
- objagg_obj_put(objagg, objagg_obj);
- world->key_refs[key_id_index(key_id)]--;
- }
- #define MAX_KEY_ID_DIFF 5
- static bool delta_check(void *priv, const void *parent_obj, const void *obj)
- {
- const struct tokey *parent_key = parent_obj;
- const struct tokey *key = obj;
- int diff = key->id - parent_key->id;
- return diff >= 0 && diff <= MAX_KEY_ID_DIFF;
- }
- static void *delta_create(void *priv, void *parent_obj, void *obj)
- {
- struct tokey *parent_key = parent_obj;
- struct world *world = priv;
- struct tokey *key = obj;
- int diff = key->id - parent_key->id;
- struct delta *delta;
- if (!delta_check(priv, parent_obj, obj))
- return ERR_PTR(-EINVAL);
- delta = kzalloc(sizeof(*delta), GFP_KERNEL);
- if (!delta)
- return ERR_PTR(-ENOMEM);
- delta->key_id_diff = diff;
- world->delta_count++;
- return delta;
- }
- static void delta_destroy(void *priv, void *delta_priv)
- {
- struct delta *delta = delta_priv;
- struct world *world = priv;
- world->delta_count--;
- kfree(delta);
- }
- static void *root_create(void *priv, void *obj, unsigned int id)
- {
- struct world *world = priv;
- struct tokey *key = obj;
- struct root *root;
- root = kzalloc(sizeof(*root), GFP_KERNEL);
- if (!root)
- return ERR_PTR(-ENOMEM);
- memcpy(&root->key, key, sizeof(root->key));
- memcpy(root->buf, world->next_root_buf, sizeof(root->buf));
- world->root_count++;
- return root;
- }
- static void root_destroy(void *priv, void *root_priv)
- {
- struct root *root = root_priv;
- struct world *world = priv;
- world->root_count--;
- kfree(root);
- }
- static int test_nodelta_obj_get(struct world *world, struct objagg *objagg,
- unsigned int key_id, bool should_create_root)
- {
- unsigned int orig_root_count = world->root_count;
- struct objagg_obj *objagg_obj;
- const struct root *root;
- int err;
- if (should_create_root)
- prandom_bytes(world->next_root_buf,
- sizeof(world->next_root_buf));
- objagg_obj = world_obj_get(world, objagg, key_id);
- if (IS_ERR(objagg_obj)) {
- pr_err("Key %u: Failed to get object.\n", key_id);
- return PTR_ERR(objagg_obj);
- }
- if (should_create_root) {
- if (world->root_count != orig_root_count + 1) {
- pr_err("Key %u: Root was not created\n", key_id);
- err = -EINVAL;
- goto err_check_root_count;
- }
- } else {
- if (world->root_count != orig_root_count) {
- pr_err("Key %u: Root was incorrectly created\n",
- key_id);
- err = -EINVAL;
- goto err_check_root_count;
- }
- }
- root = objagg_obj_root_priv(objagg_obj);
- if (root->key.id != key_id) {
- pr_err("Key %u: Root has unexpected key id\n", key_id);
- err = -EINVAL;
- goto err_check_key_id;
- }
- if (should_create_root &&
- memcmp(world->next_root_buf, root->buf, sizeof(root->buf))) {
- pr_err("Key %u: Buffer does not match the expected content\n",
- key_id);
- err = -EINVAL;
- goto err_check_buf;
- }
- return 0;
- err_check_buf:
- err_check_key_id:
- err_check_root_count:
- objagg_obj_put(objagg, objagg_obj);
- return err;
- }
- static int test_nodelta_obj_put(struct world *world, struct objagg *objagg,
- unsigned int key_id, bool should_destroy_root)
- {
- unsigned int orig_root_count = world->root_count;
- world_obj_put(world, objagg, key_id);
- if (should_destroy_root) {
- if (world->root_count != orig_root_count - 1) {
- pr_err("Key %u: Root was not destroyed\n", key_id);
- return -EINVAL;
- }
- } else {
- if (world->root_count != orig_root_count) {
- pr_err("Key %u: Root was incorrectly destroyed\n",
- key_id);
- return -EINVAL;
- }
- }
- return 0;
- }
- static int check_stats_zero(struct objagg *objagg)
- {
- const struct objagg_stats *stats;
- int err = 0;
- stats = objagg_stats_get(objagg);
- if (IS_ERR(stats))
- return PTR_ERR(stats);
- if (stats->stats_info_count != 0) {
- pr_err("Stats: Object count is not zero while it should be\n");
- err = -EINVAL;
- }
- objagg_stats_put(stats);
- return err;
- }
- static int check_stats_nodelta(struct objagg *objagg)
- {
- const struct objagg_stats *stats;
- int i;
- int err;
- stats = objagg_stats_get(objagg);
- if (IS_ERR(stats))
- return PTR_ERR(stats);
- if (stats->stats_info_count != NUM_KEYS) {
- pr_err("Stats: Unexpected object count (%u expected, %u returned)\n",
- NUM_KEYS, stats->stats_info_count);
- err = -EINVAL;
- goto stats_put;
- }
- for (i = 0; i < stats->stats_info_count; i++) {
- if (stats->stats_info[i].stats.user_count != 2) {
- pr_err("Stats: incorrect user count\n");
- err = -EINVAL;
- goto stats_put;
- }
- if (stats->stats_info[i].stats.delta_user_count != 2) {
- pr_err("Stats: incorrect delta user count\n");
- err = -EINVAL;
- goto stats_put;
- }
- }
- err = 0;
- stats_put:
- objagg_stats_put(stats);
- return err;
- }
- static bool delta_check_dummy(void *priv, const void *parent_obj,
- const void *obj)
- {
- return false;
- }
- static void *delta_create_dummy(void *priv, void *parent_obj, void *obj)
- {
- return ERR_PTR(-EOPNOTSUPP);
- }
- static void delta_destroy_dummy(void *priv, void *delta_priv)
- {
- }
- static const struct objagg_ops nodelta_ops = {
- .obj_size = sizeof(struct tokey),
- .delta_check = delta_check_dummy,
- .delta_create = delta_create_dummy,
- .delta_destroy = delta_destroy_dummy,
- .root_create = root_create,
- .root_destroy = root_destroy,
- };
- static int test_nodelta(void)
- {
- struct world world = {};
- struct objagg *objagg;
- int i;
- int err;
- objagg = objagg_create(&nodelta_ops, NULL, &world);
- if (IS_ERR(objagg))
- return PTR_ERR(objagg);
- err = check_stats_zero(objagg);
- if (err)
- goto err_stats_first_zero;
- /* First round of gets, the root objects should be created */
- for (i = 0; i < NUM_KEYS; i++) {
- err = test_nodelta_obj_get(&world, objagg, i, true);
- if (err)
- goto err_obj_first_get;
- }
- /* Do the second round of gets, all roots are already created,
- * make sure that no new root is created
- */
- for (i = 0; i < NUM_KEYS; i++) {
- err = test_nodelta_obj_get(&world, objagg, i, false);
- if (err)
- goto err_obj_second_get;
- }
- err = check_stats_nodelta(objagg);
- if (err)
- goto err_stats_nodelta;
- for (i = NUM_KEYS - 1; i >= 0; i--) {
- err = test_nodelta_obj_put(&world, objagg, i, false);
- if (err)
- goto err_obj_first_put;
- }
- for (i = NUM_KEYS - 1; i >= 0; i--) {
- err = test_nodelta_obj_put(&world, objagg, i, true);
- if (err)
- goto err_obj_second_put;
- }
- err = check_stats_zero(objagg);
- if (err)
- goto err_stats_second_zero;
- objagg_destroy(objagg);
- return 0;
- err_stats_nodelta:
- err_obj_first_put:
- err_obj_second_get:
- for (i--; i >= 0; i--)
- world_obj_put(&world, objagg, i);
- i = NUM_KEYS;
- err_obj_first_get:
- err_obj_second_put:
- for (i--; i >= 0; i--)
- world_obj_put(&world, objagg, i);
- err_stats_first_zero:
- err_stats_second_zero:
- objagg_destroy(objagg);
- return err;
- }
- static const struct objagg_ops delta_ops = {
- .obj_size = sizeof(struct tokey),
- .delta_check = delta_check,
- .delta_create = delta_create,
- .delta_destroy = delta_destroy,
- .root_create = root_create,
- .root_destroy = root_destroy,
- };
- enum action {
- ACTION_GET,
- ACTION_PUT,
- };
- enum expect_delta {
- EXPECT_DELTA_SAME,
- EXPECT_DELTA_INC,
- EXPECT_DELTA_DEC,
- };
- enum expect_root {
- EXPECT_ROOT_SAME,
- EXPECT_ROOT_INC,
- EXPECT_ROOT_DEC,
- };
- struct expect_stats_info {
- struct objagg_obj_stats stats;
- bool is_root;
- unsigned int key_id;
- };
- struct expect_stats {
- unsigned int info_count;
- struct expect_stats_info info[NUM_KEYS];
- };
- struct action_item {
- unsigned int key_id;
- enum action action;
- enum expect_delta expect_delta;
- enum expect_root expect_root;
- struct expect_stats expect_stats;
- };
- #define EXPECT_STATS(count, ...) \
- { \
- .info_count = count, \
- .info = { __VA_ARGS__ } \
- }
- #define ROOT(key_id, user_count, delta_user_count) \
- {{user_count, delta_user_count}, true, key_id}
- #define DELTA(key_id, user_count) \
- {{user_count, user_count}, false, key_id}
- static const struct action_item action_items[] = {
- {
- 1, ACTION_GET, EXPECT_DELTA_SAME, EXPECT_ROOT_INC,
- EXPECT_STATS(1, ROOT(1, 1, 1)),
- }, /* r: 1 d: */
- {
- 7, ACTION_GET, EXPECT_DELTA_SAME, EXPECT_ROOT_INC,
- EXPECT_STATS(2, ROOT(1, 1, 1), ROOT(7, 1, 1)),
- }, /* r: 1, 7 d: */
- {
- 3, ACTION_GET, EXPECT_DELTA_INC, EXPECT_ROOT_SAME,
- EXPECT_STATS(3, ROOT(1, 1, 2), ROOT(7, 1, 1),
- DELTA(3, 1)),
- }, /* r: 1, 7 d: 3^1 */
- {
- 5, ACTION_GET, EXPECT_DELTA_INC, EXPECT_ROOT_SAME,
- EXPECT_STATS(4, ROOT(1, 1, 3), ROOT(7, 1, 1),
- DELTA(3, 1), DELTA(5, 1)),
- }, /* r: 1, 7 d: 3^1, 5^1 */
- {
- 3, ACTION_GET, EXPECT_DELTA_SAME, EXPECT_ROOT_SAME,
- EXPECT_STATS(4, ROOT(1, 1, 4), ROOT(7, 1, 1),
- DELTA(3, 2), DELTA(5, 1)),
- }, /* r: 1, 7 d: 3^1, 3^1, 5^1 */
- {
- 1, ACTION_GET, EXPECT_DELTA_SAME, EXPECT_ROOT_SAME,
- EXPECT_STATS(4, ROOT(1, 2, 5), ROOT(7, 1, 1),
- DELTA(3, 2), DELTA(5, 1)),
- }, /* r: 1, 1, 7 d: 3^1, 3^1, 5^1 */
- {
- 30, ACTION_GET, EXPECT_DELTA_SAME, EXPECT_ROOT_INC,
- EXPECT_STATS(5, ROOT(1, 2, 5), ROOT(7, 1, 1), ROOT(30, 1, 1),
- DELTA(3, 2), DELTA(5, 1)),
- }, /* r: 1, 1, 7, 30 d: 3^1, 3^1, 5^1 */
- {
- 8, ACTION_GET, EXPECT_DELTA_INC, EXPECT_ROOT_SAME,
- EXPECT_STATS(6, ROOT(1, 2, 5), ROOT(7, 1, 2), ROOT(30, 1, 1),
- DELTA(3, 2), DELTA(5, 1), DELTA(8, 1)),
- }, /* r: 1, 1, 7, 30 d: 3^1, 3^1, 5^1, 8^7 */
- {
- 8, ACTION_GET, EXPECT_DELTA_SAME, EXPECT_ROOT_SAME,
- EXPECT_STATS(6, ROOT(1, 2, 5), ROOT(7, 1, 3), ROOT(30, 1, 1),
- DELTA(3, 2), DELTA(8, 2), DELTA(5, 1)),
- }, /* r: 1, 1, 7, 30 d: 3^1, 3^1, 5^1, 8^7, 8^7 */
- {
- 3, ACTION_PUT, EXPECT_DELTA_SAME, EXPECT_ROOT_SAME,
- EXPECT_STATS(6, ROOT(1, 2, 4), ROOT(7, 1, 3), ROOT(30, 1, 1),
- DELTA(8, 2), DELTA(3, 1), DELTA(5, 1)),
- }, /* r: 1, 1, 7, 30 d: 3^1, 5^1, 8^7, 8^7 */
- {
- 3, ACTION_PUT, EXPECT_DELTA_DEC, EXPECT_ROOT_SAME,
- EXPECT_STATS(5, ROOT(1, 2, 3), ROOT(7, 1, 3), ROOT(30, 1, 1),
- DELTA(8, 2), DELTA(5, 1)),
- }, /* r: 1, 1, 7, 30 d: 5^1, 8^7, 8^7 */
- {
- 1, ACTION_PUT, EXPECT_DELTA_SAME, EXPECT_ROOT_SAME,
- EXPECT_STATS(5, ROOT(7, 1, 3), ROOT(1, 1, 2), ROOT(30, 1, 1),
- DELTA(8, 2), DELTA(5, 1)),
- }, /* r: 1, 7, 30 d: 5^1, 8^7, 8^7 */
- {
- 1, ACTION_PUT, EXPECT_DELTA_SAME, EXPECT_ROOT_SAME,
- EXPECT_STATS(5, ROOT(7, 1, 3), ROOT(30, 1, 1), ROOT(1, 0, 1),
- DELTA(8, 2), DELTA(5, 1)),
- }, /* r: 7, 30 d: 5^1, 8^7, 8^7 */
- {
- 5, ACTION_PUT, EXPECT_DELTA_DEC, EXPECT_ROOT_DEC,
- EXPECT_STATS(3, ROOT(7, 1, 3), ROOT(30, 1, 1),
- DELTA(8, 2)),
- }, /* r: 7, 30 d: 8^7, 8^7 */
- {
- 5, ACTION_GET, EXPECT_DELTA_SAME, EXPECT_ROOT_INC,
- EXPECT_STATS(4, ROOT(7, 1, 3), ROOT(30, 1, 1), ROOT(5, 1, 1),
- DELTA(8, 2)),
- }, /* r: 7, 30, 5 d: 8^7, 8^7 */
- {
- 6, ACTION_GET, EXPECT_DELTA_INC, EXPECT_ROOT_SAME,
- EXPECT_STATS(5, ROOT(7, 1, 3), ROOT(5, 1, 2), ROOT(30, 1, 1),
- DELTA(8, 2), DELTA(6, 1)),
- }, /* r: 7, 30, 5 d: 8^7, 8^7, 6^5 */
- {
- 8, ACTION_GET, EXPECT_DELTA_SAME, EXPECT_ROOT_SAME,
- EXPECT_STATS(5, ROOT(7, 1, 4), ROOT(5, 1, 2), ROOT(30, 1, 1),
- DELTA(8, 3), DELTA(6, 1)),
- }, /* r: 7, 30, 5 d: 8^7, 8^7, 8^7, 6^5 */
- {
- 8, ACTION_PUT, EXPECT_DELTA_SAME, EXPECT_ROOT_SAME,
- EXPECT_STATS(5, ROOT(7, 1, 3), ROOT(5, 1, 2), ROOT(30, 1, 1),
- DELTA(8, 2), DELTA(6, 1)),
- }, /* r: 7, 30, 5 d: 8^7, 8^7, 6^5 */
- {
- 8, ACTION_PUT, EXPECT_DELTA_SAME, EXPECT_ROOT_SAME,
- EXPECT_STATS(5, ROOT(7, 1, 2), ROOT(5, 1, 2), ROOT(30, 1, 1),
- DELTA(8, 1), DELTA(6, 1)),
- }, /* r: 7, 30, 5 d: 8^7, 6^5 */
- {
- 8, ACTION_PUT, EXPECT_DELTA_DEC, EXPECT_ROOT_SAME,
- EXPECT_STATS(4, ROOT(5, 1, 2), ROOT(7, 1, 1), ROOT(30, 1, 1),
- DELTA(6, 1)),
- }, /* r: 7, 30, 5 d: 6^5 */
- {
- 8, ACTION_GET, EXPECT_DELTA_INC, EXPECT_ROOT_SAME,
- EXPECT_STATS(5, ROOT(5, 1, 3), ROOT(7, 1, 1), ROOT(30, 1, 1),
- DELTA(6, 1), DELTA(8, 1)),
- }, /* r: 7, 30, 5 d: 6^5, 8^5 */
- {
- 7, ACTION_PUT, EXPECT_DELTA_SAME, EXPECT_ROOT_DEC,
- EXPECT_STATS(4, ROOT(5, 1, 3), ROOT(30, 1, 1),
- DELTA(6, 1), DELTA(8, 1)),
- }, /* r: 30, 5 d: 6^5, 8^5 */
- {
- 30, ACTION_PUT, EXPECT_DELTA_SAME, EXPECT_ROOT_DEC,
- EXPECT_STATS(3, ROOT(5, 1, 3),
- DELTA(6, 1), DELTA(8, 1)),
- }, /* r: 5 d: 6^5, 8^5 */
- {
- 5, ACTION_PUT, EXPECT_DELTA_SAME, EXPECT_ROOT_SAME,
- EXPECT_STATS(3, ROOT(5, 0, 2),
- DELTA(6, 1), DELTA(8, 1)),
- }, /* r: d: 6^5, 8^5 */
- {
- 6, ACTION_PUT, EXPECT_DELTA_DEC, EXPECT_ROOT_SAME,
- EXPECT_STATS(2, ROOT(5, 0, 1),
- DELTA(8, 1)),
- }, /* r: d: 6^5 */
- {
- 8, ACTION_PUT, EXPECT_DELTA_DEC, EXPECT_ROOT_DEC,
- EXPECT_STATS(0, ),
- }, /* r: d: */
- };
- static int check_expect(struct world *world,
- const struct action_item *action_item,
- unsigned int orig_delta_count,
- unsigned int orig_root_count)
- {
- unsigned int key_id = action_item->key_id;
- switch (action_item->expect_delta) {
- case EXPECT_DELTA_SAME:
- if (orig_delta_count != world->delta_count) {
- pr_err("Key %u: Delta count changed while expected to remain the same.\n",
- key_id);
- return -EINVAL;
- }
- break;
- case EXPECT_DELTA_INC:
- if (WARN_ON(action_item->action == ACTION_PUT))
- return -EINVAL;
- if (orig_delta_count + 1 != world->delta_count) {
- pr_err("Key %u: Delta count was not incremented.\n",
- key_id);
- return -EINVAL;
- }
- break;
- case EXPECT_DELTA_DEC:
- if (WARN_ON(action_item->action == ACTION_GET))
- return -EINVAL;
- if (orig_delta_count - 1 != world->delta_count) {
- pr_err("Key %u: Delta count was not decremented.\n",
- key_id);
- return -EINVAL;
- }
- break;
- }
- switch (action_item->expect_root) {
- case EXPECT_ROOT_SAME:
- if (orig_root_count != world->root_count) {
- pr_err("Key %u: Root count changed while expected to remain the same.\n",
- key_id);
- return -EINVAL;
- }
- break;
- case EXPECT_ROOT_INC:
- if (WARN_ON(action_item->action == ACTION_PUT))
- return -EINVAL;
- if (orig_root_count + 1 != world->root_count) {
- pr_err("Key %u: Root count was not incremented.\n",
- key_id);
- return -EINVAL;
- }
- break;
- case EXPECT_ROOT_DEC:
- if (WARN_ON(action_item->action == ACTION_GET))
- return -EINVAL;
- if (orig_root_count - 1 != world->root_count) {
- pr_err("Key %u: Root count was not decremented.\n",
- key_id);
- return -EINVAL;
- }
- }
- return 0;
- }
- static unsigned int obj_to_key_id(struct objagg_obj *objagg_obj)
- {
- const struct tokey *root_key;
- const struct delta *delta;
- unsigned int key_id;
- root_key = objagg_obj_root_priv(objagg_obj);
- key_id = root_key->id;
- delta = objagg_obj_delta_priv(objagg_obj);
- if (delta)
- key_id += delta->key_id_diff;
- return key_id;
- }
- static int
- check_expect_stats_nums(const struct objagg_obj_stats_info *stats_info,
- const struct expect_stats_info *expect_stats_info,
- const char **errmsg)
- {
- if (stats_info->is_root != expect_stats_info->is_root) {
- if (errmsg)
- *errmsg = "Incorrect root/delta indication";
- return -EINVAL;
- }
- if (stats_info->stats.user_count !=
- expect_stats_info->stats.user_count) {
- if (errmsg)
- *errmsg = "Incorrect user count";
- return -EINVAL;
- }
- if (stats_info->stats.delta_user_count !=
- expect_stats_info->stats.delta_user_count) {
- if (errmsg)
- *errmsg = "Incorrect delta user count";
- return -EINVAL;
- }
- return 0;
- }
- static int
- check_expect_stats_key_id(const struct objagg_obj_stats_info *stats_info,
- const struct expect_stats_info *expect_stats_info,
- const char **errmsg)
- {
- if (obj_to_key_id(stats_info->objagg_obj) !=
- expect_stats_info->key_id) {
- if (errmsg)
- *errmsg = "incorrect key id";
- return -EINVAL;
- }
- return 0;
- }
- static int check_expect_stats_neigh(const struct objagg_stats *stats,
- const struct expect_stats *expect_stats,
- int pos)
- {
- int i;
- int err;
- for (i = pos - 1; i >= 0; i--) {
- err = check_expect_stats_nums(&stats->stats_info[i],
- &expect_stats->info[pos], NULL);
- if (err)
- break;
- err = check_expect_stats_key_id(&stats->stats_info[i],
- &expect_stats->info[pos], NULL);
- if (!err)
- return 0;
- }
- for (i = pos + 1; i < stats->stats_info_count; i++) {
- err = check_expect_stats_nums(&stats->stats_info[i],
- &expect_stats->info[pos], NULL);
- if (err)
- break;
- err = check_expect_stats_key_id(&stats->stats_info[i],
- &expect_stats->info[pos], NULL);
- if (!err)
- return 0;
- }
- return -EINVAL;
- }
- static int __check_expect_stats(const struct objagg_stats *stats,
- const struct expect_stats *expect_stats,
- const char **errmsg)
- {
- int i;
- int err;
- if (stats->stats_info_count != expect_stats->info_count) {
- *errmsg = "Unexpected object count";
- return -EINVAL;
- }
- for (i = 0; i < stats->stats_info_count; i++) {
- err = check_expect_stats_nums(&stats->stats_info[i],
- &expect_stats->info[i], errmsg);
- if (err)
- return err;
- err = check_expect_stats_key_id(&stats->stats_info[i],
- &expect_stats->info[i], errmsg);
- if (err) {
- /* It is possible that one of the neighbor stats with
- * same numbers have the correct key id, so check it
- */
- err = check_expect_stats_neigh(stats, expect_stats, i);
- if (err)
- return err;
- }
- }
- return 0;
- }
- static int check_expect_stats(struct objagg *objagg,
- const struct expect_stats *expect_stats,
- const char **errmsg)
- {
- const struct objagg_stats *stats;
- int err;
- stats = objagg_stats_get(objagg);
- if (IS_ERR(stats)) {
- *errmsg = "objagg_stats_get() failed.";
- return PTR_ERR(stats);
- }
- err = __check_expect_stats(stats, expect_stats, errmsg);
- objagg_stats_put(stats);
- return err;
- }
- static int test_delta_action_item(struct world *world,
- struct objagg *objagg,
- const struct action_item *action_item,
- bool inverse)
- {
- unsigned int orig_delta_count = world->delta_count;
- unsigned int orig_root_count = world->root_count;
- unsigned int key_id = action_item->key_id;
- enum action action = action_item->action;
- struct objagg_obj *objagg_obj;
- const char *errmsg;
- int err;
- if (inverse)
- action = action == ACTION_GET ? ACTION_PUT : ACTION_GET;
- switch (action) {
- case ACTION_GET:
- objagg_obj = world_obj_get(world, objagg, key_id);
- if (IS_ERR(objagg_obj))
- return PTR_ERR(objagg_obj);
- break;
- case ACTION_PUT:
- world_obj_put(world, objagg, key_id);
- break;
- }
- if (inverse)
- return 0;
- err = check_expect(world, action_item,
- orig_delta_count, orig_root_count);
- if (err)
- goto errout;
- err = check_expect_stats(objagg, &action_item->expect_stats, &errmsg);
- if (err) {
- pr_err("Key %u: Stats: %s\n", action_item->key_id, errmsg);
- goto errout;
- }
- return 0;
- errout:
- /* This can only happen when action is not inversed.
- * So in case of an error, cleanup by doing inverse action.
- */
- test_delta_action_item(world, objagg, action_item, true);
- return err;
- }
- static int test_delta(void)
- {
- struct world world = {};
- struct objagg *objagg;
- int i;
- int err;
- objagg = objagg_create(&delta_ops, NULL, &world);
- if (IS_ERR(objagg))
- return PTR_ERR(objagg);
- for (i = 0; i < ARRAY_SIZE(action_items); i++) {
- err = test_delta_action_item(&world, objagg,
- &action_items[i], false);
- if (err)
- goto err_do_action_item;
- }
- objagg_destroy(objagg);
- return 0;
- err_do_action_item:
- for (i--; i >= 0; i--)
- test_delta_action_item(&world, objagg, &action_items[i], true);
- objagg_destroy(objagg);
- return err;
- }
- struct hints_case {
- const unsigned int *key_ids;
- size_t key_ids_count;
- struct expect_stats expect_stats;
- struct expect_stats expect_stats_hints;
- };
- static const unsigned int hints_case_key_ids[] = {
- 1, 7, 3, 5, 3, 1, 30, 8, 8, 5, 6, 8,
- };
- static const struct hints_case hints_case = {
- .key_ids = hints_case_key_ids,
- .key_ids_count = ARRAY_SIZE(hints_case_key_ids),
- .expect_stats =
- EXPECT_STATS(7, ROOT(1, 2, 7), ROOT(7, 1, 4), ROOT(30, 1, 1),
- DELTA(8, 3), DELTA(3, 2),
- DELTA(5, 2), DELTA(6, 1)),
- .expect_stats_hints =
- EXPECT_STATS(7, ROOT(3, 2, 9), ROOT(1, 2, 2), ROOT(30, 1, 1),
- DELTA(8, 3), DELTA(5, 2),
- DELTA(6, 1), DELTA(7, 1)),
- };
- static void __pr_debug_stats(const struct objagg_stats *stats)
- {
- int i;
- for (i = 0; i < stats->stats_info_count; i++)
- pr_debug("Stat index %d key %u: u %d, d %d, %s\n", i,
- obj_to_key_id(stats->stats_info[i].objagg_obj),
- stats->stats_info[i].stats.user_count,
- stats->stats_info[i].stats.delta_user_count,
- stats->stats_info[i].is_root ? "root" : "noroot");
- }
- static void pr_debug_stats(struct objagg *objagg)
- {
- const struct objagg_stats *stats;
- stats = objagg_stats_get(objagg);
- if (IS_ERR(stats))
- return;
- __pr_debug_stats(stats);
- objagg_stats_put(stats);
- }
- static void pr_debug_hints_stats(struct objagg_hints *objagg_hints)
- {
- const struct objagg_stats *stats;
- stats = objagg_hints_stats_get(objagg_hints);
- if (IS_ERR(stats))
- return;
- __pr_debug_stats(stats);
- objagg_stats_put(stats);
- }
- static int check_expect_hints_stats(struct objagg_hints *objagg_hints,
- const struct expect_stats *expect_stats,
- const char **errmsg)
- {
- const struct objagg_stats *stats;
- int err;
- stats = objagg_hints_stats_get(objagg_hints);
- if (IS_ERR(stats))
- return PTR_ERR(stats);
- err = __check_expect_stats(stats, expect_stats, errmsg);
- objagg_stats_put(stats);
- return err;
- }
- static int test_hints_case(const struct hints_case *hints_case)
- {
- struct objagg_obj *objagg_obj;
- struct objagg_hints *hints;
- struct world world2 = {};
- struct world world = {};
- struct objagg *objagg2;
- struct objagg *objagg;
- const char *errmsg;
- int i;
- int err;
- objagg = objagg_create(&delta_ops, NULL, &world);
- if (IS_ERR(objagg))
- return PTR_ERR(objagg);
- for (i = 0; i < hints_case->key_ids_count; i++) {
- objagg_obj = world_obj_get(&world, objagg,
- hints_case->key_ids[i]);
- if (IS_ERR(objagg_obj)) {
- err = PTR_ERR(objagg_obj);
- goto err_world_obj_get;
- }
- }
- pr_debug_stats(objagg);
- err = check_expect_stats(objagg, &hints_case->expect_stats, &errmsg);
- if (err) {
- pr_err("Stats: %s\n", errmsg);
- goto err_check_expect_stats;
- }
- hints = objagg_hints_get(objagg, OBJAGG_OPT_ALGO_SIMPLE_GREEDY);
- if (IS_ERR(hints)) {
- err = PTR_ERR(hints);
- goto err_hints_get;
- }
- pr_debug_hints_stats(hints);
- err = check_expect_hints_stats(hints, &hints_case->expect_stats_hints,
- &errmsg);
- if (err) {
- pr_err("Hints stats: %s\n", errmsg);
- goto err_check_expect_hints_stats;
- }
- objagg2 = objagg_create(&delta_ops, hints, &world2);
- if (IS_ERR(objagg2))
- return PTR_ERR(objagg2);
- for (i = 0; i < hints_case->key_ids_count; i++) {
- objagg_obj = world_obj_get(&world2, objagg2,
- hints_case->key_ids[i]);
- if (IS_ERR(objagg_obj)) {
- err = PTR_ERR(objagg_obj);
- goto err_world2_obj_get;
- }
- }
- pr_debug_stats(objagg2);
- err = check_expect_stats(objagg2, &hints_case->expect_stats_hints,
- &errmsg);
- if (err) {
- pr_err("Stats2: %s\n", errmsg);
- goto err_check_expect_stats2;
- }
- err = 0;
- err_check_expect_stats2:
- err_world2_obj_get:
- for (i--; i >= 0; i--)
- world_obj_put(&world2, objagg, hints_case->key_ids[i]);
- i = hints_case->key_ids_count;
- objagg_destroy(objagg2);
- err_check_expect_hints_stats:
- objagg_hints_put(hints);
- err_hints_get:
- err_check_expect_stats:
- err_world_obj_get:
- for (i--; i >= 0; i--)
- world_obj_put(&world, objagg, hints_case->key_ids[i]);
- objagg_destroy(objagg);
- return err;
- }
- static int test_hints(void)
- {
- return test_hints_case(&hints_case);
- }
- static int __init test_objagg_init(void)
- {
- int err;
- err = test_nodelta();
- if (err)
- return err;
- err = test_delta();
- if (err)
- return err;
- return test_hints();
- }
- static void __exit test_objagg_exit(void)
- {
- }
- module_init(test_objagg_init);
- module_exit(test_objagg_exit);
- MODULE_LICENSE("Dual BSD/GPL");
- MODULE_AUTHOR("Jiri Pirko <jiri@mellanox.com>");
- MODULE_DESCRIPTION("Test module for objagg");
|