1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
// Copyright (C) 2021 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR GPL-3.0-only WITH Qt-GPL-exception-1.0
#include "message.h"
#include <QtNetwork/qlocalsocket.h>
QT_BEGIN_NAMESPACE
Message::Type Message::type() const { return Message::Type::Invalid; }
UniformsMessage::~UniformsMessage()
{
}
bool UniformsMessage::read(QDataStream &stream)
{
stream >> uniforms;
return (stream.status() == QDataStream::Ok);
}
bool UniformsMessage::write(QDataStream &stream) const
{
if (uniforms.size() > 0)
stream << id.toByteArray() << uniforms;
return (stream.status() == QDataStream::Ok);
}
FilenamesMessage::~FilenamesMessage()
{
}
bool FilenamesMessage::read(QDataStream &stream)
{
stream >> vertFilename >> fragFilename;
return (stream.status() == QDataStream::Ok);
}
bool FilenamesMessage::write(QDataStream &stream) const
{
stream << vertFilename << fragFilename;
return (stream.status() == QDataStream::Ok);
}
Message::~Message()
{
}
Message::MessagePtr Message::getMessage(QIODevice &device)
{
if (device.isOpen()) {
if (device.isReadable()) {
QByteArray id;
QDataStream stream(&device);
stream >> id;
if (UniformsMessage::id == id) {
UniformsMessage uniforms;
if (uniforms.read(stream))
return std::make_shared<UniformsMessage>(uniforms);
} else if (id == FilenamesMessage::id) {
FilenamesMessage filenames;
if (filenames.read(stream))
return std::make_shared<FilenamesMessage>(filenames);
} else {
qDebug("Unknown message!");
}
} else {
qDebug("Device not writeable!");
}
} else {
qDebug("Device not open!");
}
return Message::MessagePtr();
}
bool Message::postMessage(QIODevice &device, const Message &message)
{
bool ok = false;
if (device.isOpen()) {
if (device.isWritable()) {
QDataStream stream(&device);
stream << message;
ok = (stream.status() == QDataStream::Ok);
} else {
qDebug("Device not writeable!");
}
} else {
qDebug("Device not open!");
}
return ok;
}
QT_END_NAMESPACE
|
