1
Fork 0
mirror of https://github.com/RGBCube/serenity synced 2025-07-25 18:37:35 +00:00

LibIPC+LibGfx: Templatize IPC encoding as well as decoding

Now most classes dictate how they are serialized and deserialized when
transmitted across LibIPC sockets. This also makes the IPC compiler
a bit simpler. :^)
This commit is contained in:
Andreas Kling 2020-05-12 18:05:43 +02:00
parent cba4880301
commit 3775983dfe
10 changed files with 83 additions and 45 deletions

View file

@ -311,26 +311,7 @@ int main(int argc, char** argv)
initial_value = "false"; initial_value = "false";
out() << " " << parameter.type << " " << parameter.name << " = " << initial_value << ";"; out() << " " << parameter.type << " " << parameter.name << " = " << initial_value << ";";
if (parameter.type == "Vector<Gfx::Rect>") { if (parameter.type.starts_with("Optional<")) {
out() << " u64 " << parameter.name << "_size = 0;";
out() << " stream >> " << parameter.name << "_size;";
out() << " for (size_t i = 0; i < " << parameter.name << "_size; ++i) {";
out() << " Gfx::Rect rect;";
out() << " if (!decoder.decode(rect))";
out() << " return nullptr;";
out() << " " << parameter.name << ".append(move(rect));";
out() << " }";
} else if (parameter.type == "Vector<i32>") {
out() << " u64 " << parameter.name << "_size = 0;";
out() << " stream >> " << parameter.name << "_size;";
out() << " for (size_t i = 0; i < " << parameter.name << "_size; ++i) {";
out() << " i32 value;";
out() << " stream >> value;";
out() << " if (stream.handle_read_failure())";
out() << " return nullptr;";
out() << " " << parameter.name << ".append(value);";
out() << " }";
} else if (parameter.type.starts_with("Optional<")) {
out() << " bool has_value = false;"; out() << " bool has_value = false;";
out() << " stream >> has_value;"; out() << " stream >> has_value;";
out() << " if (has_value) {"; out() << " if (has_value) {";
@ -364,30 +345,6 @@ int main(int argc, char** argv)
for (auto& parameter : parameters) { for (auto& parameter : parameters) {
if (parameter.type == "Gfx::Color") { if (parameter.type == "Gfx::Color") {
out() << " stream << m_" << parameter.name << ".value();"; out() << " stream << m_" << parameter.name << ".value();";
} else if (parameter.type == "Gfx::Size") {
out() << " stream << m_" << parameter.name << ".width();";
out() << " stream << m_" << parameter.name << ".height();";
} else if (parameter.type == "Gfx::Point") {
out() << " stream << m_" << parameter.name << ".x();";
out() << " stream << m_" << parameter.name << ".y();";
} else if (parameter.type == "Gfx::Rect") {
out() << " stream << m_" << parameter.name << ".x();";
out() << " stream << m_" << parameter.name << ".y();";
out() << " stream << m_" << parameter.name << ".width();";
out() << " stream << m_" << parameter.name << ".height();";
} else if (parameter.type == "Vector<Gfx::Rect>") {
out() << " stream << (u64)m_" << parameter.name << ".size();";
out() << " for (auto& rect : m_" << parameter.name << ") {";
out() << " stream << rect.x();";
out() << " stream << rect.y();";
out() << " stream << rect.width();";
out() << " stream << rect.height();";
out() << " }";
} else if (parameter.type == "Vector<i32>") {
out() << " stream << (u64)m_" << parameter.name << ".size();";
out() << " for (auto value : m_" << parameter.name << ") {";
out() << " stream << value;";
out() << " }";
} else if (parameter.type == "Gfx::ShareableBitmap") { } else if (parameter.type == "Gfx::ShareableBitmap") {
out() << " stream << m_" << parameter.name << ".shbuf_id();"; out() << " stream << m_" << parameter.name << ".shbuf_id();";
out() << " stream << m_" << parameter.name << ".width();"; out() << " stream << m_" << parameter.name << ".width();";

View file

@ -28,6 +28,7 @@
#include <AK/String.h> #include <AK/String.h>
#include <LibGfx/Point.h> #include <LibGfx/Point.h>
#include <LibIPC/Decoder.h> #include <LibIPC/Decoder.h>
#include <LibIPC/Encoder.h>
namespace Gfx { namespace Gfx {
@ -45,6 +46,12 @@ const LogStream& operator<<(const LogStream& stream, const Point& value)
namespace IPC { namespace IPC {
bool encode(Encoder& encoder, const Gfx::Point& point)
{
encoder << point.x() << point.y();
return true;
}
bool decode(Decoder& decoder, Gfx::Point& point) bool decode(Decoder& decoder, Gfx::Point& point)
{ {
int x = 0; int x = 0;

View file

@ -179,5 +179,6 @@ const LogStream& operator<<(const LogStream&, const Point&);
} }
namespace IPC { namespace IPC {
bool encode(Encoder&, const Gfx::Point&);
bool decode(Decoder&, Gfx::Point&); bool decode(Decoder&, Gfx::Point&);
} }

View file

@ -29,6 +29,7 @@
#include <AK/Vector.h> #include <AK/Vector.h>
#include <LibGfx/Rect.h> #include <LibGfx/Rect.h>
#include <LibIPC/Decoder.h> #include <LibIPC/Decoder.h>
#include <LibIPC/Encoder.h>
namespace Gfx { namespace Gfx {
@ -146,6 +147,12 @@ const LogStream& operator<<(const LogStream& stream, const Rect& value)
namespace IPC { namespace IPC {
bool encode(Encoder& encoder, const Gfx::Rect& rect)
{
encoder << rect.location() << rect.size();
return true;
}
bool decode(Decoder& decoder, Gfx::Rect& rect) bool decode(Decoder& decoder, Gfx::Rect& rect)
{ {
Gfx::Point point; Gfx::Point point;

View file

@ -339,4 +339,5 @@ const LogStream& operator<<(const LogStream&, const Rect&);
namespace IPC { namespace IPC {
bool decode(Decoder&, Gfx::Rect&); bool decode(Decoder&, Gfx::Rect&);
bool encode(Encoder&, const Gfx::Rect&);
} }

View file

@ -28,6 +28,7 @@
#include <AK/String.h> #include <AK/String.h>
#include <LibGfx/Size.h> #include <LibGfx/Size.h>
#include <LibIPC/Decoder.h> #include <LibIPC/Decoder.h>
#include <LibIPC/Encoder.h>
namespace Gfx { namespace Gfx {
@ -45,6 +46,12 @@ const LogStream& operator<<(const LogStream& stream, const Size& value)
namespace IPC { namespace IPC {
bool encode(Encoder& encoder, const Gfx::Size& size)
{
encoder << size.width() << size.height();
return true;
}
bool decode(Decoder& decoder, Gfx::Size& size) bool decode(Decoder& decoder, Gfx::Size& size)
{ {
int width = 0; int width = 0;

View file

@ -114,5 +114,6 @@ const LogStream& operator<<(const LogStream&, const Size&);
} }
namespace IPC { namespace IPC {
bool encode(Encoder&, const Gfx::Size&);
bool decode(Decoder&, Gfx::Size&); bool decode(Decoder&, Gfx::Size&);
} }

View file

@ -136,4 +136,13 @@ bool Decoder::decode(Dictionary& dictionary)
return true; return true;
} }
void dongle() {
ByteBuffer buffer;
BufferStream stream(buffer);
Decoder d(stream);
Vector<String> x;
d.decode(x);
}
} }

View file

@ -26,15 +26,19 @@
#pragma once #pragma once
#include <AK/BufferStream.h>
#include <AK/Forward.h> #include <AK/Forward.h>
#include <AK/NumericLimits.h>
#include <AK/String.h>
#include <LibIPC/Forward.h> #include <LibIPC/Forward.h>
#include <LibIPC/Message.h> #include <LibIPC/Message.h>
namespace IPC { namespace IPC {
template<typename T> template<typename T>
bool decode(BufferStream&, T&) inline bool decode(Decoder&, T&)
{ {
ASSERT_NOT_REACHED();
return false; return false;
} }
@ -64,6 +68,21 @@ public:
return IPC::decode(*this, value); return IPC::decode(*this, value);
} }
template<typename T>
bool decode(Vector<T>& vector)
{
u64 size;
if (!decode(size) || size > NumericLimits<i32>::max())
return false;
for (size_t i = 0; i < size; ++i) {
T value;
if (!decode(value))
return false;
vector.append(move(value));
}
return true;
}
private: private:
BufferStream& m_stream; BufferStream& m_stream;
}; };

View file

@ -31,6 +31,13 @@
namespace IPC { namespace IPC {
template<typename T>
bool encode(BufferStream&, T&)
{
ASSERT_NOT_REACHED();
return false;
}
class Encoder { class Encoder {
public: public:
explicit Encoder(MessageBuffer& buffer) explicit Encoder(MessageBuffer& buffer)
@ -53,6 +60,28 @@ public:
Encoder& operator<<(const String&); Encoder& operator<<(const String&);
Encoder& operator<<(const Dictionary&); Encoder& operator<<(const Dictionary&);
template<typename T>
Encoder& operator<<(const Vector<T>& vector)
{
*this << (u64)vector.size();
for (auto& value : vector)
*this << value;
return *this;
}
template<typename T>
Encoder& operator<<(const T& value)
{
encode(value);
return *this;
}
template<typename T>
void encode(const T& value)
{
IPC::encode(*this, value);
}
private: private:
MessageBuffer& m_buffer; MessageBuffer& m_buffer;
}; };