forked from analogdevicesinc/libiio
-
Notifications
You must be signed in to change notification settings - Fork 0
/
iiod-responder.h
181 lines (144 loc) · 5.04 KB
/
iiod-responder.h
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
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
/* SPDX-License-Identifier: LGPL-2.1-or-later */
/*
* libiio - Library for interfacing industrial I/O (IIO) devices
*
* Copyright (C) 2021 Analog Devices, Inc.
* Author: Paul Cercueil <[email protected]>
*/
#ifndef __IIOD_RESPONDER_H__
#define __IIOD_RESPONDER_H__
#include <stddef.h>
#include <stdint.h>
#if (defined(_WIN32) || defined(__MBED__))
#ifndef _SSIZE_T_DEFINED
typedef ptrdiff_t ssize_t;
#define _SSIZE_T_DEFINED
#endif
#else
#include <sys/types.h>
#endif
struct iiod_command_data;
struct iiod_responder;
struct iiod_io;
enum iiod_opcode {
IIOD_OP_RESPONSE,
IIOD_OP_PRINT,
IIOD_OP_TIMEOUT,
IIOD_OP_READ_ATTR,
IIOD_OP_READ_DBG_ATTR,
IIOD_OP_READ_BUF_ATTR,
IIOD_OP_READ_CHN_ATTR,
IIOD_OP_WRITE_ATTR,
IIOD_OP_WRITE_DBG_ATTR,
IIOD_OP_WRITE_BUF_ATTR,
IIOD_OP_WRITE_CHN_ATTR,
IIOD_OP_GETTRIG,
IIOD_OP_SETTRIG,
IIOD_OP_CREATE_BUFFER,
IIOD_OP_FREE_BUFFER,
IIOD_OP_ENABLE_BUFFER,
IIOD_OP_DISABLE_BUFFER,
IIOD_OP_CREATE_BLOCK,
IIOD_OP_FREE_BLOCK,
IIOD_OP_TRANSFER_BLOCK,
IIOD_OP_ENQUEUE_BLOCK_CYCLIC,
IIOD_OP_RETRY_DEQUEUE_BLOCK,
IIOD_OP_CREATE_EVSTREAM,
IIOD_OP_FREE_EVSTREAM,
IIOD_OP_READ_EVENT,
IIOD_NB_OPCODES,
};
struct iiod_command {
uint16_t client_id;
uint8_t op;
uint8_t dev;
int32_t code;
};
struct iiod_buf {
void *ptr;
size_t size;
};
struct iiod_responder_ops {
int (*cmd)(const struct iiod_command *cmd,
struct iiod_command_data *data, void *d);
ssize_t (*read)(void *d, const struct iiod_buf *buf, size_t nb);
ssize_t (*write)(void *d, const struct iiod_buf *buf, size_t nb);
ssize_t (*discard)(void *d, size_t bytes);
};
/* Create / Destroy IIOD Responder. */
struct iiod_responder *
iiod_responder_create(const struct iiod_responder_ops *ops, void *d);
void iiod_responder_destroy(struct iiod_responder *responder);
/* Set the timeout for I/O operations (default is 0 == infinite) */
void iiod_responder_set_timeout(struct iiod_responder *priv,
unsigned int timeout_ms);
void iiod_io_set_timeout(struct iiod_io *io, unsigned int timeout_ms);
/* Read the current value of the micro-second counter */
uint64_t iiod_responder_read_counter_us(void);
/* Stop the iiod_responder. */
void iiod_responder_stop(struct iiod_responder *responder);
/* Wait until the iiod_responder stops. */
void iiod_responder_wait_done(struct iiod_responder *responder);
/* Create a iiod_io instance, to be used for I/O. */
struct iiod_io *
iiod_responder_create_io(struct iiod_responder *responder, uint16_t id);
struct iiod_io *
iiod_responder_get_default_io(struct iiod_responder *responder);
/* Create a iiod_io suitable for responding to the given command.
* Initialized with the reference counter set to 1. */
struct iiod_io *
iiod_command_create_io(const struct iiod_command *cmd,
struct iiod_command_data *data);
struct iiod_io *
iiod_command_get_default_io(struct iiod_command_data *data);
/* Remove queued asynchronous requests for commands or responses. */
void iiod_io_cancel(struct iiod_io *io);
/* Increase the internal reference counter */
void iiod_io_ref(struct iiod_io *io);
/* Decrease the internal reference counter. If zero, the iiod_io instance is freed. */
void iiod_io_unref(struct iiod_io *io);
/* Read the command's additional data, if any. */
int iiod_command_data_read(struct iiod_command_data *data,
const struct iiod_buf *buf);
/* Send command or response to the remote */
int iiod_io_send_command(struct iiod_io *io,
const struct iiod_command *cmd,
const struct iiod_buf *buf, size_t nb);
int iiod_io_send_response(struct iiod_io *io, int32_t code,
const struct iiod_buf *buf, size_t nb);
/* Send command, then read the response. */
int iiod_io_exec_command(struct iiod_io *io,
const struct iiod_command *cmd,
const struct iiod_buf *cmd_buf,
const struct iiod_buf *buf);
/* Simplified version of iiod_io_exec_command.
* Send a simple command then read the response code. */
static inline int
iiod_io_exec_simple_command(struct iiod_io *io,
const struct iiod_command *cmd)
{
return iiod_io_exec_command(io, cmd, NULL, NULL);
}
/* Asynchronous variants of the functions above */
int iiod_io_send_command_async(struct iiod_io *io,
const struct iiod_command *cmd,
const struct iiod_buf *buf, size_t nb);
int iiod_io_send_response_async(struct iiod_io *io, int32_t code,
const struct iiod_buf *buf, size_t nb);
/* Wait for an async. command or response to be done sending */
int iiod_io_wait_for_command_done(struct iiod_io *io);
_Bool iiod_io_command_is_done(struct iiod_io *io);
/* Simplified version of iiod_io_send_response, to just send a code. */
static inline int
iiod_io_send_response_code(struct iiod_io *io, int32_t code)
{
return iiod_io_send_response(io, code, NULL, 0);
}
/* Asynchronous variant of iiod_io_get_response */
int iiod_io_get_response_async(struct iiod_io *io,
const struct iiod_buf *buf, size_t nb);
/* Wait for iiod_io_get_response_async to be done. */
int32_t iiod_io_wait_for_response(struct iiod_io *io);
_Bool iiod_io_has_response(struct iiod_io *io);
void iiod_io_cancel_response(struct iiod_io *io);
#endif /* __IIOD_RESPONDER_H__ */