Differential D2917 Diff 9554 source/blender/windowmanager/message_bus/intern/wm_message_bus.c

Changeset View

Standalone View

source/blender/windowmanager/message_bus/intern/wm_message_bus.c

This file was added.

				/*
				* *** BEGIN GPL LICENSE BLOCK ***
				*
				* This program is free software; you can redistribute it and/or
				* modify it under the terms of the GNU General Public License
				* as published by the Free Software Foundation; either version 2
				* of the License, or (at your option) any later version.
				*
				* This program is distributed in the hope that it will be useful,
				* but WITHOUT ANY WARRANTY; without even the implied warranty of
				* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
				* GNU General Public License for more details.
				*
				* You should have received a copy of the GNU General Public License
				* along with this program; if not, write to the Free Software Foundation,
				* Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
				*
				* *** END GPL LICENSE BLOCK ***
				*/

				/** \file blender/windowmanager/intern/wm_message_bus.c
				* \ingroup wm
				*/

				#define WM_MESSAGE_BUS_INTERN

				#include <string.h>

				#include "BLI_utildefines.h"
				#include "BLI_listbase.h"

				#include "BLI_ghash.h"

				#include "WM_types.h"

				#include "MEM_guardedalloc.h"

				#include "message_bus/wm_message_bus.h"

				static wmMsgTypeInfo wm_msg_types[WM_MSG_TYPE_NUM] = {NULL};

				typedef void (wmMsgTypeInitFn)(wmMsgTypeInfo );

				static wmMsgTypeInitFn wm_msg_init_fn[WM_MSG_TYPE_NUM] = {
				WM_msgtypeinfo_init_rna,
				WM_msgtypeinfo_init_static,
				};

				void WM_msgbus_types_init(void)
				{
				for (uint i = 0; i < WM_MSG_TYPE_NUM; i++) {
				wm_msg_init_fn[i](&wm_msg_types[i]);
				}
				}

				struct wmMsgBus *WM_msgbus_create(void)
				{
				struct wmMsgBus mbus = MEM_callocN(sizeof(mbus), __func__);
				const uint gset_reserve = 512;
				for (uint i = 0; i < WM_MSG_TYPE_NUM; i++) {
				wmMsgTypeInfo *info = &wm_msg_types[i];
				mbus->messages_gset[i] = BLI_gset_new_ex(info->gset.hash_fn, info->gset.cmp_fn, __func__, gset_reserve);
				}
				return mbus;
				}

				void WM_msgbus_destroy(struct wmMsgBus *mbus)
				{
				for (uint i = 0; i < WM_MSG_TYPE_NUM; i++) {
				wmMsgTypeInfo *info = &wm_msg_types[i];
				BLI_gset_free(mbus->messages_gset[i], info->gset.key_free_fn);
				}
				MEM_freeN(mbus);
				}

				void WM_msgbus_clear_by_owner(struct wmMsgBus mbus, void owner)
				{
				wmMsgSubscribeKey key, key_next;
				for (key = mbus->messages.first; key; key = key_next) {
				key_next = key->next;

				wmMsgSubscribeValueLink *msg_lnk_next;
				for (wmMsgSubscribeValueLink *msg_lnk = key->values.first; msg_lnk; msg_lnk = msg_lnk_next) {
				msg_lnk_next = msg_lnk->next;
				if (msg_lnk->params.owner == owner) {
				BLI_remlink(&key->values, msg_lnk);
				MEM_freeN(msg_lnk);
				}
				}

				if (BLI_listbase_is_empty(&key->values)) {
				wmMsgTypeInfo *info = &wm_msg_types[key->msg->type];
				BLI_remlink(&mbus->messages, key);
				bool ok = BLI_gset_remove(mbus->messages_gset[key->msg->type], key, info->gset.key_free_fn);
				BLI_assert(ok);
				}
				mont29Unsubmitted Not Done Inline Actions That’s gonna make gcc grumpy in non-debug builds I bet ;) mont29: That’s gonna make gcc grumpy in non-debug builds I bet ;)
				}
				}

				void WM_msgbus_handle(struct wmMsgBus mbus, struct bContext C)
				{
				for (wmMsgSubscribeKey *key = mbus->messages.first; key; key = key->next) {
				for (wmMsgSubscribeValueLink *msg_lnk = key->values.first; msg_lnk; msg_lnk = msg_lnk->next) {
				if (msg_lnk->params.tag) {
				msg_lnk->params.notify(C, key, &msg_lnk->params);
				msg_lnk->params.tag = false;
				}
				}
				}
				}

				/**
				* \param msg_key_test: Needs following wmMsgSubscribeKey fields filled in:
				* - msg.params
				* - msg.head.type
				* - msg.head.id
				* .. other values should be zeroed.
				*/
				void WN_msg_subscribe_with_key(
				struct wmMsgBus *mbus,
				const wmMsgSubscribeKey *msg_key_test,
				const wmMsgSubscribeValue *msg_val_params)
				{
				const uint type = msg_key_test->msg->type;
				const wmMsgTypeInfo *info = &wm_msg_types[type];
				wmMsgSubscribeKey *key;

				BLI_assert(msg_key_test->msg->id != NULL);

				void **r_key;
				if (!BLI_gset_ensure_p_ex(mbus->messages_gset[type], msg_key_test, &r_key)) {
				key = *r_key = MEM_mallocN(info->msg_key_size, __func__);
				memcpy(key, msg_key_test, info->msg_key_size);
				BLI_addtail(&mbus->messages, key);
				}
				else {
				key = *r_key;
				for (wmMsgSubscribeValueLink *msg_lnk = key->values.first; msg_lnk; msg_lnk = msg_lnk->next) {
				if ((msg_lnk->params.notify == msg_val_params->notify) &&
				(msg_lnk->params.owner == msg_val_params->owner) &&
				(msg_lnk->params.user_data == msg_val_params->user_data))
				{
				return;
				}
				}
				}

				wmMsgSubscribeValueLink *msg_lnk = MEM_mallocN(sizeof(wmMsgSubscribeValueLink), __func__);
				msg_lnk->params = *msg_val_params;
				BLI_addtail(&key->values, msg_lnk);
				}

				void WM_msg_publish_with_key(struct wmMsgBus UNUSED(mbus), wmMsgSubscribeKey msg_key)
				{
				for (wmMsgSubscribeValueLink *msg_lnk = msg_key->values.first; msg_lnk; msg_lnk = msg_lnk->next) {
				if (false) { /* make an option? */
				msg_lnk->params.notify(NULL, msg_key, &msg_lnk->params);
				}
				else {
				msg_lnk->params.tag = true;
				}
				}
				}