ray-rs-sys 0.0.0

Low-level bindings to the for the C-ABI Ray CoreWorker (shared library) harness
Documentation 
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

#ifndef _Included_rustlang_worker
#define _Included_rustlang_worker
#include <stdbool.h>
#include <stdint.h>
#include <stddef.h>

#ifdef __cplusplus
extern "C" {
#endif
#ifndef RAY_NATIVE_PROLOGUE_H
#define RAY_NATIVE_PROLOGUE_H
typedef unsigned long long RayInt64;
typedef RayInt64 RayInt;
typedef struct RaySlice {
  // Shouldn't this be `char *data`?
  // Actually no, we want this to be some arbitrary type
  // (either a DataBuffer or a DataValue)
  void *data;
  RayInt64 len;
  RayInt64 cap;
} RaySlice;
#endif

typedef struct DataBuffer {
  // TODO: replace with standard uint64_t here...
  size_t size;
  uint8_t *p;
} DataBuffer;

typedef struct DataValue {
  struct DataBuffer *data;
  struct DataBuffer *meta;
} DataValue;

// TODO: Write detailed description of methods
typedef void (*c_worker_ExecuteCallback)(RayInt task_type, RaySlice ray_function_info,
                                         RaySlice args, RaySlice return_values);

int c_worker_RegisterExecutionCallback(c_worker_ExecuteCallback callback);

// Why not char instead of void ptr?
DataValue *c_worker_AllocateDataValue(uint8_t *data_ptr, size_t data_size, uint8_t *meta_ptr, size_t meta_size);

void c_worker_InitConfig(int workerMode, int language, int num_workers,
                                    char *code_search_path, char *head_args,
                                    int argc, char** argv);

void c_worker_Initialize();

void c_worker_Run();

void c_worker_Log(char* msg);

void c_worker_AddLocalRef(char* id);

void c_worker_RemoveLocalRef(char* id);

// int c_worker_GetNextJobID(void *p);
//
// int c_worker_CreateActor(char *type_name, char **result);
//
// // todo calloptions
// int c_worker_SubmitActorTask(void *actor_id, char *method_name,
//                               DataValue **input_values, int num_input_value,
//                               int num_returns, void **object_ids);
//
int c_worker_SubmitTask(char *method_name, bool *input_is_ref,
                                   DataValue **input_values, char **input_refs,
                                   int num_input_value,
                                   int num_returns, char **object_ids);

int c_worker_Get(char **object_ids, int object_ids_size, int timeout, DataValue **objects);

int c_worker_Put(char **object_ids, int timeout, DataValue **objects, int objects_size);

void c_worker_Shutdown();

#ifdef __cplusplus
}
#endif
#endif