mirror of
https://github.com/overte-org/overte.git
synced 2025-07-29 10:51:31 +02:00
40 lines
1.3 KiB
C++
40 lines
1.3 KiB
C++
//
|
|
// MessagesMixer.h
|
|
// assignment-client/src/messages
|
|
//
|
|
// Created by Brad hefta-Gaub on 11/16/2015.
|
|
// Copyright 2015 High Fidelity, Inc.
|
|
//
|
|
// The avatar mixer receives head, hand and positional data from all connected
|
|
// nodes, and broadcasts that data back to them, every BROADCAST_INTERVAL ms.
|
|
//
|
|
// Distributed under the Apache License, Version 2.0.
|
|
// See the accompanying file LICENSE or http://www.apache.org/licenses/LICENSE-2.0.html
|
|
//
|
|
|
|
#ifndef hifi_MessagesMixer_h
|
|
#define hifi_MessagesMixer_h
|
|
|
|
#include <ThreadedAssignment.h>
|
|
|
|
/// Handles assignments of type MessagesMixer - distribution of avatar data to various clients
|
|
class MessagesMixer : public ThreadedAssignment {
|
|
Q_OBJECT
|
|
public:
|
|
MessagesMixer(ReceivedMessage& message);
|
|
|
|
public slots:
|
|
void run() override;
|
|
void nodeKilled(SharedNodePointer killedNode);
|
|
void sendStatsPacket() override;
|
|
|
|
private slots:
|
|
void handleMessages(QSharedPointer<ReceivedMessage> message, SharedNodePointer senderNode);
|
|
void handleMessagesSubscribe(QSharedPointer<ReceivedMessage> message, SharedNodePointer senderNode);
|
|
void handleMessagesUnsubscribe(QSharedPointer<ReceivedMessage> message, SharedNodePointer senderNode);
|
|
|
|
private:
|
|
QHash<QString,QSet<QUuid>> _channelSubscribers;
|
|
};
|
|
|
|
#endif // hifi_MessagesMixer_h
|