• file
• revisions
• annotate
• diff
• comparison
• raw

gfx/skia/trunk/src/core/SkMessageBus.h@129ffea94266 (annotated)

gfx/skia/trunk/src/core/SkMessageBus.h

Sat, 03 Jan 2015 20:18:00 +0100

author

Michael Schloh von Bennewitz <michael@schloh.com>

date

Sat, 03 Jan 2015 20:18:00 +0100

branch

TOR_BUG_3246

changeset 7

129ffea94266

permissions

-rw-r--r--

Conditionally enable double key logic according to:
private browsing mode or privacy.thirdparty.isolate preference and
implement in GetCookieStringCommon and FindCookie where it counts...
With some reservations of how to convince FindCookie users to test
condition and pass a nullptr when disabling double key logic.

michael@0	1	/*
michael@0	2	* Copyright 2013 Google Inc.
michael@0	3	*
michael@0	4	* Use of this source code is governed by a BSD-style license that can be
michael@0	5	* found in the LICENSE file.
michael@0	6	*/
michael@0	7
michael@0	8	#ifndef SkMessageBus_DEFINED
michael@0	9	#define SkMessageBus_DEFINED
michael@0	10
michael@0	11	#include "SkOnce.h"
michael@0	12	#include "SkTDArray.h"
michael@0	13	#include "SkThread.h"
michael@0	14	#include "SkTypes.h"
michael@0	15
michael@0	16	template <typename Message>
michael@0	17	class SkMessageBus : SkNoncopyable {
michael@0	18	public:
michael@0	19	// Post a message to be received by all Inboxes for this Message type. Threadsafe.
michael@0	20	static void Post(const Message& m);
michael@0	21
michael@0	22	class Inbox {
michael@0	23	public:
michael@0	24	Inbox();
michael@0	25	~Inbox();
michael@0	26
michael@0	27	// Overwrite out with all the messages we've received since the last call. Threadsafe.
michael@0	28	void poll(SkTDArray<Message>* out);
michael@0	29
michael@0	30	private:
michael@0	31	SkTDArray<Message> fMessages;
michael@0	32	SkMutex fMessagesMutex;
michael@0	33
michael@0	34	friend class SkMessageBus;
michael@0	35	void receive(const Message& m); // SkMessageBus is a friend only to call this.
michael@0	36	};
michael@0	37
michael@0	38	private:
michael@0	39	SkMessageBus();
michael@0	40	static SkMessageBus* Get();
michael@0	41	static void New(SkMessageBus**);
michael@0	42
michael@0	43	SkTDArray<Inbox*> fInboxes;
michael@0	44	SkMutex fInboxesMutex;
michael@0	45	};
michael@0	46
michael@0	47	// This must go in a single .cpp file, not some .h, or we risk creating more than one global
michael@0	48	// SkMessageBus per type when using shared libraries.
michael@0	49	#define DECLARE_SKMESSAGEBUS_MESSAGE(Message) \
michael@0	50	template <> \
michael@0	51	SkMessageBus<Message>* SkMessageBus<Message>::Get() { \
michael@0	52	static SkMessageBus<Message>* bus = NULL; \
michael@0	53	SK_DECLARE_STATIC_ONCE(once); \
michael@0	54	SkOnce(&once, &New, &bus); \
michael@0	55	SkASSERT(bus != NULL); \
michael@0	56	return bus; \
michael@0	57	}
michael@0	58
michael@0	59	// ----------------------- Implementation of SkMessageBus::Inbox -----------------------
michael@0	60
michael@0	61	template<typename Message>
michael@0	62	SkMessageBus<Message>::Inbox::Inbox() {
michael@0	63	// Register ourselves with the corresponding message bus.
michael@0	64	SkMessageBus<Message>* bus = SkMessageBus<Message>::Get();
michael@0	65	SkAutoMutexAcquire lock(bus->fInboxesMutex);
michael@0	66	bus->fInboxes.push(this);
michael@0	67	}
michael@0	68
michael@0	69	template<typename Message>
michael@0	70	SkMessageBus<Message>::Inbox::~Inbox() {
michael@0	71	// Remove ourselves from the corresponding message bus.
michael@0	72	SkMessageBus<Message>* bus = SkMessageBus<Message>::Get();
michael@0	73	SkAutoMutexAcquire lock(bus->fInboxesMutex);
michael@0	74	// This is a cheaper fInboxes.remove(fInboxes.find(this)) when order doesn't matter.
michael@0	75	for (int i = 0; i < bus->fInboxes.count(); i++) {
michael@0	76	if (this == bus->fInboxes[i]) {
michael@0	77	bus->fInboxes.removeShuffle(i);
michael@0	78	break;
michael@0	79	}
michael@0	80	}
michael@0	81	}
michael@0	82
michael@0	83	template<typename Message>
michael@0	84	void SkMessageBus<Message>::Inbox::receive(const Message& m) {
michael@0	85	SkAutoMutexAcquire lock(fMessagesMutex);
michael@0	86	fMessages.push(m);
michael@0	87	}
michael@0	88
michael@0	89	template<typename Message>
michael@0	90	void SkMessageBus<Message>::Inbox::poll(SkTDArray<Message>* messages) {
michael@0	91	SkASSERT(NULL != messages);
michael@0	92	messages->reset();
michael@0	93	SkAutoMutexAcquire lock(fMessagesMutex);
michael@0	94	messages->swap(fMessages);
michael@0	95	}
michael@0	96
michael@0	97	// ----------------------- Implementation of SkMessageBus -----------------------
michael@0	98
michael@0	99	template <typename Message>
michael@0	100	SkMessageBus<Message>::SkMessageBus() {}
michael@0	101
michael@0	102	template <typename Message>
michael@0	103	/*static*/ void SkMessageBus<Message>::New(SkMessageBus<Message>** bus) {
michael@0	104	*bus = new SkMessageBus<Message>();
michael@0	105	}
michael@0	106
michael@0	107	template <typename Message>
michael@0	108	/*static*/ void SkMessageBus<Message>::Post(const Message& m) {
michael@0	109	SkMessageBus<Message>* bus = SkMessageBus<Message>::Get();
michael@0	110	SkAutoMutexAcquire lock(bus->fInboxesMutex);
michael@0	111	for (int i = 0; i < bus->fInboxes.count(); i++) {
michael@0	112	bus->fInboxes[i]->receive(m);
michael@0	113	}
michael@0	114	}
michael@0	115
michael@0	116	#endif // SkMessageBus_DEFINED