mellanox/mlx4/resource_tracker.c

74 	u64		        res_id;
235 static void *res_tracker_lookup(struct rb_root *root, u64 res_id)
243 		if (res_id < res->res_id)
245 		else if (res_id > res->res_id)
263 		if (res->res_id < this->res_id)
265 		else if (res->res_id > this->res_id)
882 static void *find_res(struct mlx4_dev *dev, u64 res_id,
888 				  res_id);
891 static int _get_res(struct mlx4_dev *dev, int slave, u64 res_id,
899 	r = find_res(dev, res_id, type);
908 			  func_name, slave, res_id, mlx4_resource_type_to_str(type),
931 #define get_res(dev, slave, res_id, type, res) \
932 	_get_res((dev), (slave), (res_id), (type), (res), __func__)
936 				    u64 res_id, int *slave)
941 	int id = res_id;
957 static void put_res(struct mlx4_dev *dev, int slave, u64 res_id,
963 	r = find_res(dev, res_id, type);
1015 			qpc->pri_path.counter_index  = counter->com.res_id;
1058 	ret->com.res_id = id;
1076 	ret->com.res_id = id;
1092 	ret->com.res_id = id;
1107 	ret->com.res_id = id;
1121 	ret->com.res_id = id;
1136 	ret->com.res_id = id;
1151 	ret->com.res_id = id;
1166 	ret->com.res_id = id;
1180 	ret->com.res_id = id;
1254 			counters_arr[i] = (int)tmp->res_id;
1523 				 __func__, r->com.res_id);
1531 			mlx4_dbg(dev, "failed RES_QP, 0x%llx\n", r->com.res_id);
1541 					  r->com.res_id);
2747 	int res_start = mtt->com.res_id;
2823 		put_res(dev, slave, mtt->com.res_id, RES_MTT);
2831 		put_res(dev, slave, mtt->com.res_id, RES_MTT);
3101 	int res_id = (slave << 10) | eqn;
3108 	err = add_res_range(dev, slave, res_id, 1, RES_EQ, 0);
3111 	err = eq_res_start_move_to(dev, slave, res_id, RES_EQ_HW, &eq);
3129 	put_res(dev, slave, mtt->com.res_id, RES_MTT);
3130 	res_end_move(dev, slave, RES_EQ, res_id);
3134 	put_res(dev, slave, mtt->com.res_id, RES_MTT);
3136 	res_abort_move(dev, slave, RES_EQ, res_id);
3138 	rem_res_range(dev, slave, res_id, 1, RES_EQ, 0);
3296 		put_res(dev, slave, rmtt->com.res_id, RES_MTT);
3308 	int res_id = eqn | (slave << 10);
3312 	err = eq_res_start_move_to(dev, slave, res_id, RES_EQ_RESERVED, &eq);
3316 	err = get_res(dev, slave, eq->mtt->com.res_id, RES_MTT, NULL);
3325 	put_res(dev, slave, eq->mtt->com.res_id, RES_MTT);
3326 	res_end_move(dev, slave, RES_EQ, res_id);
3327 	rem_res_range(dev, slave, res_id, 1, RES_EQ, 0);
3332 	put_res(dev, slave, eq->mtt->com.res_id, RES_MTT);
3334 	res_abort_move(dev, slave, RES_EQ, res_id);
3346 	int res_id;
3365 	res_id = (slave << 10) | event_eq->eqn;
3366 	err = get_res(dev, slave, res_id, RES_EQ, &req);
3394 	put_res(dev, slave, res_id, RES_EQ);
3400 	put_res(dev, slave, res_id, RES_EQ);
3414 	int res_id = eqn | (slave << 10);
3418 	err = get_res(dev, slave, res_id, RES_EQ, &eq);
3430 	put_res(dev, slave, res_id, RES_EQ);
3461 	put_res(dev, slave, mtt->com.res_id, RES_MTT);
3466 	put_res(dev, slave, mtt->com.res_id, RES_MTT);
3534 	err = get_res(dev, slave, cq->mtt->com.res_id, RES_MTT, &orig_mtt);
3554 	put_res(dev, slave, orig_mtt->com.res_id, RES_MTT);
3557 	put_res(dev, slave, mtt->com.res_id, RES_MTT);
3561 	put_res(dev, slave, mtt->com.res_id, RES_MTT);
3563 	put_res(dev, slave, orig_mtt->com.res_id, RES_MTT);
3643 	put_res(dev, slave, mtt->com.res_id, RES_MTT);
3648 	put_res(dev, slave, mtt->com.res_id, RES_MTT);
4489 	err = rem_res_range(dev, fs_rule->com.owner, fs_rule->com.res_id, 1, RES_FS_RULE, 0);
4495 	mlx4_cmd(dev, fs_rule->com.res_id, 0, 0, MLX4_QP_FLOW_STEERING_DETACH,
4625 							  r->res_id);
4682 			qpn = qp->com.res_id;
4755 			srqn = srq->com.res_id;
4820 			cqn = cq->com.res_id;
4882 			mptn = mpt->com.res_id;
4949 			base = mtt->com.res_id;
5085 			base = fs_rule->com.res_id;
5137 			eqn = eq->com.res_id;
5201 				counters_arr[i++] = counter->com.res_id;
5238 			xrcdn = xrcd->com.res_id;