Start Doing C-API for predict.

Author: reyoung

paddle/CMakeLists.txt

@@ -8,7 +8,7 @@ add_subdirectory(gserver)
 add_subdirectory(pserver)
 add_subdirectory(trainer)
 add_subdirectory(scripts)
-
+add_subdirectory(capi)
 configure_file(${CMAKE_CURRENT_SOURCE_DIR}/setup.py.in
     ${CMAKE_CURRENT_SOURCE_DIR}/setup.py)
 

paddle/capi/Arguments.cpp

@@ -0,0 +1,49 @@
+#include "PaddleCAPI.h"
+#include "PaddleCAPIPrivate.h"
+
+#define cast(v) paddle::capi::cast<paddle::capi::CArguments>(v)
+
+extern "C" {
+int PDArgsCreateNone(PD_Arguments* args) {
+  auto ptr = new paddle::capi::CArguments();
+  *args = ptr;
+  return PD_NO_ERROR;
+}
+
+int PDArgsDestroy(PD_Arguments args) {
+  if (args == nullptr) return PD_NULLPTR;
+  delete cast(args);
+  return PD_NO_ERROR;
+}
+
+int PDArgsGetSize(PD_Arguments args, uint64_t* size) {
+  if (args == nullptr || size == nullptr) return PD_NULLPTR;
+  *size = cast(args)->args.size();
+  return PD_NO_ERROR;
+}
+
+int PDArgsResize(PD_Arguments args, uint64_t size) {
+  if (args == nullptr) return PD_NULLPTR;
+  cast(args)->args.resize(size);
+  return PD_NO_ERROR;
+}
+
+int PDArgsSetValue(PD_Arguments args, uint64_t ID, PD_Matrix mat) {
+  if (args == nullptr || mat == nullptr) return PD_NULLPTR;
+  auto m = paddle::capi::cast<paddle::capi::CMatrix>(mat);
+  if (m->mat == nullptr) return PD_NULLPTR;
+  auto a = cast(args);
+  if (ID >= a->args.size()) return PD_OUT_OF_RANGE;
+  a->args[ID].value = m->mat;
+  return PD_NO_ERROR;
+}
+
+int PDArgsGetValue(PD_Arguments args, uint64_t ID, PD_Matrix mat) {
+  if (args == nullptr || mat == nullptr) return PD_NULLPTR;
+  auto m = paddle::capi::cast<paddle::capi::CMatrix>(mat);
+  auto a = cast(args);
+  if (ID >= a->args.size()) return PD_OUT_OF_RANGE;
+  m->mat = a->args[ID].value;
+  return PD_NO_ERROR;
+}
+}

paddle/capi/CMakeLists.txt

@@ -0,0 +1,47 @@
+if (WITH_DOUBLE)
+  set(PADDLE_FLOAT_TYPE double)
+else ()
+  set(PADDLE_FLOAT_TYPE float)
+endif()
+
+configure_file(config.h.in config.h @ONLY)
+
+set(CAPI_HEADER
+   PaddleCAPI.h)
+set(CAPI_PRIVATE_HEADER
+   PaddleCAPIPrivate.h)
+file(GLOB CAPI_SOURCES *.cpp)
+
+add_library(paddle_capi SHARED ${CAPI_SOURCES})
+
+target_include_directories(paddle_capi PUBLIC ${CMAKE_CURRENT_BINARY_DIR})
+add_dependencies(paddle_capi gen_proto_cpp)
+
+target_link_libraries(paddle_capi
+  paddle_gserver
+  paddle_function
+  paddle_pserver
+  paddle_trainer_lib
+  paddle_network
+  paddle_math
+  paddle_utils
+  paddle_parameter
+  paddle_proto
+  paddle_cuda
+  ${PROTOBUF_LIBRARY}
+  ${LIBGLOG_LIBRARY}
+  ${GFLAGS_LIBRARIES}
+  ${CMAKE_THREAD_LIBS_INIT}
+  ${CBLAS_LIBS}
+  ${ZLIB_LIBRARIES}
+  ${INTERAL_LIBS}
+  ${CMAKE_DL_LIBS})
+
+
+set(PADDLE_CAPI_INC_PATH
+  ${CMAKE_CURRENT_BINARY_DIR}
+  ${CMAKE_CURRENT_SOURCE_DIR})
+
+if (WITH_TESTING)
+  add_subdirectory(tests)
+endif()

paddle/capi/Matrix.cpp

@@ -0,0 +1,61 @@
+#include "PaddleCAPI.h"
+#include "PaddleCAPIPrivate.h"
+#include "hl_cuda.h"
+
+#define cast(v) paddle::capi::cast<paddle::capi::CMatrix>(v)
+extern "C" {
+int PDMatCreate(PD_Matrix* mat, uint64_t height, uint64_t width, bool useGpu) {
+  auto ptr = new paddle::capi::CMatrix();
+  ptr->mat = paddle::Matrix::create(height, width, false, useGpu);
+  *mat = ptr;
+  return PD_NO_ERROR;
+}
+
+int PDMatCreateNone(PD_Matrix* mat) {
+  auto ptr = new paddle::capi::CMatrix();
+  *mat = ptr;
+  return PD_NO_ERROR;
+}
+
+int PDMatDestroy(PD_Matrix mat) {
+  if (mat == nullptr) return PD_NULLPTR;
+  auto ptr = cast(mat);
+  delete ptr;
+  return PD_NO_ERROR;
+}
+
+int PDMatCopyToRow(PD_Matrix mat, uint64_t rowID, pd_real* rowArray) {
+  if (mat == nullptr) return PD_NULLPTR;
+  auto ptr = cast(mat);
+  if (ptr->mat == nullptr) return PD_NULLPTR;
+  if (rowID >= ptr->mat->getHeight()) return PD_OUT_OF_RANGE;
+  paddle::real* buf = ptr->mat->getRowBuf(rowID);
+  size_t width = ptr->mat->getWidth();
+#ifndef PADDLE_ONLY_CPU
+  hl_memcpy(buf, rowArray, sizeof(paddle::real) * width);
+#else
+  std::copy(rowArray, rowArray + width, buf);
+#endif
+  return PD_NO_ERROR;
+}
+
+int PDMatGetRow(PD_Matrix mat, uint64_t rowID, pd_real** rawRowBuffer) {
+  if (mat == nullptr) return PD_NULLPTR;
+  auto ptr = cast(mat);
+  if (ptr->mat == nullptr) return PD_NULLPTR;
+  if (rowID >= ptr->mat->getHeight()) return PD_OUT_OF_RANGE;
+  *rawRowBuffer = ptr->mat->getRowBuf(rowID);
+  return PD_NO_ERROR;
+}
+
+int PDMatGetShape(PD_Matrix mat, uint64_t* height, uint64_t* width) {
+  if (mat == nullptr) return PD_NULLPTR;
+  if (height != nullptr) {
+    *height = cast(mat)->mat->getHeight();
+  }
+  if (width != nullptr) {
+    *width = cast(mat)->mat->getWidth();
+  }
+  return PD_NO_ERROR;
+}
+}

paddle/capi/PaddleCAPI.h

@@ -0,0 +1,54 @@
+#ifndef __PADDLE_PADDLE_CAPI_PADDLECAPI_H_INCLUDED__
+#define __PADDLE_PADDLE_CAPI_PADDLECAPI_H_INCLUDED__
+#include <stdbool.h>
+#include <stdint.h>
+#include "config.h"
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+#define PD_NO_ERROR 0
+#define PD_NULLPTR 1
+#define PD_OUT_OF_RANGE 2
+#define PD_UNDEFINED_ERROR -1
+
+typedef void* PD_Vector;
+
+int PDVecCreate(PD_Vector* vec, uint64_t size, bool useGpu);
+
+int PDVecDestroy(PD_Vector vec);
+
+int PDVecIsSparse(PD_Vector vec, bool* isSparse);
+
+typedef void* PD_Matrix;
+
+int PDMatCreate(PD_Matrix* mat, uint64_t height, uint64_t width, bool useGpu);
+
+int PDMatDestroy(PD_Matrix mat);
+
+int PDMatCopyToRow(PD_Matrix mat, uint64_t rowID, pd_real* rowArray);
+
+int PDMatGetRow(PD_Matrix mat, uint64_t rowID, pd_real** rawRowBuffer);
+
+int PDMatCreateNone(PD_Matrix* mat);
+
+int PDMatGetShape(PD_Matrix mat, uint64_t* height, uint64_t* width);
+
+typedef void* PD_Arguments;
+
+int PDArgsCreateNone(PD_Arguments* args);
+
+int PDArgsDestroy(PD_Arguments args);
+
+int PDArgsGetSize(PD_Arguments args, uint64_t* size);
+
+int PDArgsResize(PD_Arguments args, uint64_t size);
+
+int PDArgsSetValue(PD_Arguments args, uint64_t ID, PD_Matrix mat);
+
+int PDArgsGetValue(PD_Arguments args, uint64_t ID, PD_Matrix mat);
+
+#ifdef __cplusplus
+}
+#endif
+#endif

paddle/capi/PaddleCAPIPrivate.h

@@ -0,0 +1,27 @@
+#include "PaddleCAPI.h"
+#include "paddle/math/Matrix.h"
+#include "paddle/math/Vector.h"
+#include "paddle/parameter/Argument.h"
+#pragma once
+
+namespace paddle {
+namespace capi {
+
+struct CVector {
+  VectorPtr vec;
+};
+
+struct CMatrix {
+  MatrixPtr mat;
+};
+
+struct CArguments {
+  std::vector<paddle::Argument> args;
+};
+
+template <typename T>
+inline T* cast(void* ptr) {
+  return reinterpret_cast<T*>(ptr);
+}
+}
+}

paddle/capi/Vector.cpp

@@ -0,0 +1,26 @@
+#include "PaddleCAPI.h"
+#include "PaddleCAPIPrivate.h"
+
+#define cast(v) paddle::capi::cast<paddle::capi::CVector>(v)
+extern "C" {
+int PDVecCreate(PD_Vector* vec, uint64_t size, bool useGpu) {
+  auto ptr = new paddle::capi::CVector();
+  ptr->vec = paddle::Vector::create(size, useGpu);
+  *vec = ptr;
+  return PD_NO_ERROR;
+}
+int PDVecDestroy(PD_Vector vec) {
+  auto v = cast(vec);
+  v->vec.reset();
+  delete v;
+  return PD_NO_ERROR;
+}
+
+int PDVecIsSparse(PD_Vector vec, bool* isSparse) {
+  if (isSparse == nullptr || vec == nullptr) {
+    return PD_NULLPTR;
+  }
+  *isSparse = cast(vec)->vec->isSparse();
+  return PD_NO_ERROR;
+}
+}

paddle/capi/config.h.in

@@ -0,0 +1,6 @@
+#ifndef __PADDLE_PADDLE_CAPI_CONFIG_H_INCLUDED__
+#define __PADDLE_PADDLE_CAPI_CONFIG_H_INCLUDED__
+
+typedef @PADDLE_FLOAT_TYPE@ pd_real;
+
+#endif

paddle/capi/tests/CMakeLists.txt

@@ -0,0 +1,15 @@
+function(add_capi_unittest TARGET_NAME)
+  add_executable(
+    ${TARGET_NAME}
+    ${ARGN})
+  target_link_libraries(
+    ${TARGET_NAME}
+    paddle_capi
+    paddle_test_main
+    ${GTEST_LIBRARIES})
+  target_include_directories(${TARGET_NAME} PUBLIC ${PADDLE_CAPI_INC_PATH})
+  add_test(NAME ${TARGET_NAME} COMMAND ${TARGET_NAME})
+endfunction()
+
+add_capi_unittest(capi_test_mats test_Vector.cpp
+  test_Matrix.cpp test_Arguments.cpp)

paddle/capi/tests/test_Arguments.cpp

@@ -0,0 +1,54 @@
+#include "PaddleCAPI.h"
+#include "gtest/gtest.h"
+#include "paddle/utils/ThreadLocal.h"
+
+static std::vector<pd_real> randomBuffer(size_t bufSize) {
+  auto& eng = paddle::ThreadLocalRandomEngine::get();
+  std::uniform_real_distribution<pd_real> dist(-1.0, 1.0);
+  std::vector<pd_real> retv;
+  retv.reserve(bufSize);
+  for (size_t i = 0; i < bufSize; ++i) {
+    retv.push_back(dist(eng));
+  }
+  return retv;
+}
+
+TEST(CAPIArguments, create) {
+  PD_Arguments args;
+  ASSERT_EQ(PD_NO_ERROR, PDArgsCreateNone(&args));
+  uint64_t size;
+  ASSERT_EQ(PD_NO_ERROR, PDArgsGetSize(args, &size));
+  ASSERT_EQ(0UL, size);
+  ASSERT_EQ(PD_NO_ERROR, PDArgsDestroy(args));
+}
+
+TEST(CAPIArguments, value) {
+  PD_Arguments args;
+  ASSERT_EQ(PD_NO_ERROR, PDArgsCreateNone(&args));
+  ASSERT_EQ(PD_NO_ERROR, PDArgsResize(args, 1));
+
+  PD_Matrix mat;
+  ASSERT_EQ(PD_NO_ERROR, PDMatCreate(&mat, 128, 64, false));
+  for (size_t i = 0; i < 128; ++i) {
+    std::vector<pd_real> sampleBuf = randomBuffer(64);
+    PDMatCopyToRow(mat, i, sampleBuf.data());
+  }
+  ASSERT_EQ(PD_NO_ERROR, PDArgsSetValue(args, 0, mat));
+
+  PD_Matrix val;
+  ASSERT_EQ(PD_NO_ERROR, PDMatCreateNone(&val));
+
+  ASSERT_EQ(PD_NO_ERROR, PDArgsGetValue(args, 0, val));
+
+  for (size_t i = 0; i < 128; ++i) {
+    pd_real* row1;
+    pd_real* row2;
+
+    ASSERT_EQ(PD_NO_ERROR, PDMatGetRow(mat, i, &row1));
+    ASSERT_EQ(PD_NO_ERROR, PDMatGetRow(val, i, &row2));
+    ASSERT_EQ(row1, row2);
+  }
+  ASSERT_EQ(PD_NO_ERROR, PDMatDestroy(val));
+  ASSERT_EQ(PD_NO_ERROR, PDMatDestroy(mat));
+  ASSERT_EQ(PD_NO_ERROR, PDArgsDestroy(args));
+}