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
|
/*
* Copyright (c) Meta Platforms, Inc. and affiliates.
*
* This source code is licensed under the MIT license found in the
* LICENSE file in the root directory of this source tree.
*/
// -*- c++ -*-
#include "io_c.h"
#include <faiss/impl/io.h>
#include "../macros_impl.h"
using faiss::IOReader;
using faiss::IOWriter;
struct CustomIOReader : IOReader {
size_t (*func)(void* ptr, size_t size, size_t nitems) = nullptr;
CustomIOReader(size_t (*func_in)(void* ptr, size_t size, size_t nitems));
size_t operator()(void* ptr, size_t size, size_t nitems) override;
};
CustomIOReader::CustomIOReader(
size_t (*func_in)(void* ptr, size_t size, size_t nitems))
: func(func_in) {}
size_t CustomIOReader::operator()(void* ptr, size_t size, size_t nitems) {
return func(ptr, size, nitems);
}
int faiss_CustomIOReader_new(
FaissCustomIOReader** p_out,
size_t (*func_in)(void* ptr, size_t size, size_t nitems)) {
try {
*p_out = reinterpret_cast<FaissCustomIOReader*>(
new CustomIOReader(func_in));
}
CATCH_AND_HANDLE
}
void faiss_CustomIOReader_free(FaissCustomIOReader* obj) {
delete reinterpret_cast<CustomIOReader*>(obj);
}
struct CustomIOWriter : IOWriter {
size_t (*func)(const void* ptr, size_t size, size_t nitems) = nullptr;
CustomIOWriter(
size_t (*func_in)(const void* ptr, size_t size, size_t nitems));
size_t operator()(const void* ptr, size_t size, size_t nitems) override;
};
CustomIOWriter::CustomIOWriter(
size_t (*func_in)(const void* ptr, size_t size, size_t nitems))
: func(func_in) {}
size_t CustomIOWriter::operator()(const void* ptr, size_t size, size_t nitems) {
return func(ptr, size, nitems);
}
int faiss_CustomIOWriter_new(
FaissCustomIOWriter** p_out,
size_t (*func_in)(const void* ptr, size_t size, size_t nitems)) {
try {
*p_out = reinterpret_cast<FaissCustomIOWriter*>(
new CustomIOWriter(func_in));
}
CATCH_AND_HANDLE
}
void faiss_CustomIOWriter_free(FaissCustomIOWriter* obj) {
delete reinterpret_cast<CustomIOWriter*>(obj);
}
|