MCPcopy Create free account
hub / github.com/OpenStarbound/OpenStarbound / broadcast

Method broadcast

source/game/StarChatProcessor.cpp:125–142  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

123}
124
125void ChatProcessor::broadcast(ConnectionId sourceConnectionId, String const& text, JsonObject data) {
126 RecursiveMutexLocker locker(m_mutex);
127
128 ChatReceivedMessage message = {
129 {MessageContext::Broadcast},
130 sourceConnectionId,
131 connectionNick(sourceConnectionId),
132 text
133 };
134
135 message.data = std::move(data);
136
137 if (handleCommand(message))
138 return;
139
140 for (auto& pair : m_clients)
141 pair.second.pendingMessages.append(message);
142}
143
144void ChatProcessor::message(ConnectionId sourceConnectionId, MessageContext::Mode mode, String const& channelName, String const& text, JsonObject data) {
145 RecursiveMutexLocker locker(m_mutex);

Callers 2

~WorldClientMethod · 0.45
processChatMethod · 0.45

Calls 1

appendMethod · 0.45

Tested by

no test coverage detected