Lines Matching refs:bus
79 static SkMessageBus<Message, IDType, AllowCopyableMessage>* bus; \
80 once([] { bus = new SkMessageBus<Message, IDType, AllowCopyableMessage>(); }); \
81 return bus; \
90 auto* bus = SkMessageBus<Message, IDType, AllowCopyableMessage>::Get();
91 SkAutoMutexExclusive lock(bus->fInboxesMutex);
92 bus->fInboxes.push_back(this);
98 auto* bus = SkMessageBus<Message, IDType, AllowCopyableMessage>::Get();
99 SkAutoMutexExclusive lock(bus->fInboxesMutex);
101 for (int i = 0; i < bus->fInboxes.count(); i++) {
102 if (this == bus->fInboxes[i]) {
103 bus->fInboxes.removeShuffle(i);
130 auto* bus = SkMessageBus<Message, IDType, AllowCopyableMessage>::Get();
131 SkAutoMutexExclusive lock(bus->fInboxesMutex);
132 for (int i = 0; i < bus->fInboxes.count(); i++) {
133 if (SkShouldPostMessageToBus(m, bus->fInboxes[i]->fUniqueID)) {
135 bus->fInboxes[i]->receive(m);
140 bus->fInboxes[i]->receive(std::move(m));