|
version 1.15.2.6, 2013/07/16 12:47:25
|
version 1.20, 2013/09/05 00:43:04
|
|
Line 62 SUCH DAMAGE.
|
Line 62 SUCH DAMAGE.
|
| #include <aitsched.h> |
#include <aitsched.h> |
| |
|
| |
|
| #define RPC_VERSION 6 | #define RPC_VERSION 7 |
| #define RPC_DEFPORT 2611 |
#define RPC_DEFPORT 2611 |
| |
|
| /* RPC call request flags */ |
/* RPC call request flags */ |
|
Line 127 typedef struct {
|
Line 127 typedef struct {
|
| struct tagRPCCall { |
struct tagRPCCall { |
| rpc_sess_t call_session; |
rpc_sess_t call_session; |
| |
|
| uint16_t call_seq; | uint32_t call_len; |
| uint16_t call_len; | |
| uint16_t call_crc; |
uint16_t call_crc; |
| |
|
| union { |
union { |
|
Line 145 struct tagRPCCall {
|
Line 144 struct tagRPCCall {
|
| uint16_t call_argc; |
uint16_t call_argc; |
| ait_val_t call_argv[0]; |
ait_val_t call_argv[0]; |
| } __packed; /* size == 20 bytes */ |
} __packed; /* size == 20 bytes */ |
| #define RPC_CHK_NOREPLY(x) ((x)->call_req.flags & RPC_NOREPLY) | #define RPC_CHK_NOREPLY(x) (ntohl((u_long) (x)->call_req.flags) & RPC_NOREPLY) |
| | #define RPC_SET_ERRNO(x, _v) ((x)->call_rep.eno = htonl((_v))) |
| |
|
| /* Network BLOB packet - Header */ |
/* Network BLOB packet - Header */ |
| |
|
|
Line 256 typedef int (*rpc_callback_t)(rpc_cli_t *, struct tagR
|
Line 256 typedef int (*rpc_callback_t)(rpc_cli_t *, struct tagR
|
| int rpc_GetErrno(); |
int rpc_GetErrno(); |
| // rpc_GetError() Get error text of last operation |
// rpc_GetError() Get error text of last operation |
| const char *rpc_GetError(); |
const char *rpc_GetError(); |
| |
// rpc_SetErr() Set error to variables for internal use!!! |
| |
void rpc_SetErr(int eno, char *estr, ...); |
| |
|
| |
|
| |
|
| |
/* |
| |
* rpc_Read() - RPC read operation |
| |
* |
| |
* @sock = socket |
| |
* @type = type of socket |
| |
* @flags = receive flags |
| |
* @sa = check client address, if you use udp protocol |
| |
* @buf = buffer |
| |
* @blen = buffer length |
| |
* return: -1 error or >-1 readed bytes into buffer |
| |
*/ |
| |
ssize_t rpc_Read(int sock, int type, int flags, sockaddr_t * __restrict sa, |
| |
unsigned char * __restrict buf, size_t blen); |
| |
/* |
| |
* rpc_Write() - RPC write operation |
| |
* |
| |
* @sock = socket |
| |
* @type = type of socket |
| |
* @flags = send flags |
| |
* @sa = send to client address, if you use udp protocol |
| |
* @buf = buffer |
| |
* @blen = buffer length |
| |
* return: -1 error or >-1 written bytes into buffer |
| |
*/ |
| |
ssize_t rpc_Write(int sock, int type, int flags, sockaddr_t * __restrict sa, |
| |
unsigned char * __restrict buf, size_t blen); |
| |
|
| /* |
/* |
| * rpc_chkPktSession() - Check RPC session |
* rpc_chkPktSession() - Check RPC session |