dmlc--dgl
3e69692233
* WIP: rpc components * client & server * move network package to rpc * fix include * fix compile * c api * wip: test * add basic tests * missing file * [RPC] Zero copy serializer (#1517) * zerocopy serialization * add test for HeteroGraph * fix lint * remove unnecessary codes * add comment * lint * lint * disable pylint for now * add include for win * windows guard * lint * lint * skip test on windows * refactor * add comment * fix * comment * 1111 * fix * Update Jenkinsfile * [RPC] Implementation of RPC infra (#1544) * update * update * update * update * update * update * update * update * update * update * update * update * update * update * remove client.cc and server.cc * fix lint * update * update * fix linr * update * fix lint * update * update * update * update * update * update * update test * update * update test * update * update * update * update * update * update * update * update * update * update * update * update comment * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * fix lint * fix lint * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update Co-authored-by: Minjie Wang <wmjlyjemaine@gmail.com> Co-authored-by: Jinjing Zhou <VoVAllen@users.noreply.github.com>
52 行
1.6 KiB
C++
52 行
1.6 KiB
C++
/*!
|
|
* Copyright (c) 2017 by Contributors
|
|
* \file dgl/runtime/serializer.h
|
|
* \brief Serializer extension to support DGL data types
|
|
* Include this file to enable serialization of DLDataType, DLContext
|
|
*/
|
|
#ifndef DGL_RUNTIME_SERIALIZER_H_
|
|
#define DGL_RUNTIME_SERIALIZER_H_
|
|
|
|
#include <dmlc/io.h>
|
|
#include <dmlc/serializer.h>
|
|
#include "c_runtime_api.h"
|
|
#include "smart_ptr_serializer.h"
|
|
|
|
namespace dmlc {
|
|
namespace serializer {
|
|
|
|
template <>
|
|
struct Handler<DLDataType> {
|
|
inline static void Write(Stream *strm, const DLDataType &dtype) {
|
|
Handler<uint8_t>::Write(strm, dtype.code);
|
|
Handler<uint8_t>::Write(strm, dtype.bits);
|
|
Handler<uint16_t>::Write(strm, dtype.lanes);
|
|
}
|
|
inline static bool Read(Stream *strm, DLDataType *dtype) {
|
|
if (!Handler<uint8_t>::Read(strm, &(dtype->code))) return false;
|
|
if (!Handler<uint8_t>::Read(strm, &(dtype->bits))) return false;
|
|
if (!Handler<uint16_t>::Read(strm, &(dtype->lanes))) return false;
|
|
return true;
|
|
}
|
|
};
|
|
|
|
template <>
|
|
struct Handler<DLContext> {
|
|
inline static void Write(Stream *strm, const DLContext &ctx) {
|
|
int32_t device_type = static_cast<int32_t>(ctx.device_type);
|
|
Handler<int32_t>::Write(strm, device_type);
|
|
Handler<int32_t>::Write(strm, ctx.device_id);
|
|
}
|
|
inline static bool Read(Stream *strm, DLContext *ctx) {
|
|
int32_t device_type = 0;
|
|
if (!Handler<int32_t>::Read(strm, &(device_type))) return false;
|
|
ctx->device_type = static_cast<DLDeviceType>(device_type);
|
|
if (!Handler<int32_t>::Read(strm, &(ctx->device_id))) return false;
|
|
return true;
|
|
}
|
|
};
|
|
|
|
} // namespace serializer
|
|
} // namespace dmlc
|
|
#endif // DGL_RUNTIME_SERIALIZER_H_
|