blob: 85af58e64c5ff919c24788713eb7bfd9f47e4730 (
plain)
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
|
/*
* %CopyrightBegin%
*
* Copyright Ericsson AB 2001-2023. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
* %CopyrightEnd%
*/
/*
* Purpose: Connect to any node at any host. (EI version)
*/
/* FIXME far to many includes here... */
/* some send() functions use buffer on heap for "small" messages */
/* messages larger than this require call to malloc() */
#ifndef _EI_CONNECT_H
#define _EI_CONNECT_H
#include <stdlib.h>
#include <sys/types.h>
#include <fcntl.h>
#ifdef __WIN32__
#include <winsock2.h>
#include <windows.h>
#include <winbase.h>
#else /* some unix */
#include <unistd.h>
#include <sys/types.h>
#include <sys/times.h>
#include <time.h>
#if HAVE_SYS_TIME_H
# include <sys/time.h>
#endif
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <sys/utsname.h> /* for gen_challenge (NEED FIX?) */
#endif
/* FIXME remove duplicate definitions */
#define DEFBUF_SIZ 100
/* rpc_from() uses a buffer this size */
#ifndef MAX_RECEIVE_BUF
# define MAX_RECEIVE_BUF 32*1024
#endif
/* Distribution capability flags */
typedef EI_ULONGLONG DistFlags;
#define DFLAG_PUBLISHED 1
#define DFLAG_ATOM_CACHE 2
#define DFLAG_EXTENDED_REFERENCES 4
#define DFLAG_DIST_MONITOR 8
#define DFLAG_FUN_TAGS 0x10
#define DFLAG_NEW_FUN_TAGS 0x80
#define DFLAG_EXTENDED_PIDS_PORTS 0x100
#define DFLAG_EXPORT_PTR_TAG 0x200
#define DFLAG_BIT_BINARIES 0x400
#define DFLAG_NEW_FLOATS 0x800
#define DFLAG_SMALL_ATOM_TAGS 0x4000
#define DFLAG_UTF8_ATOMS 0x10000
#define DFLAG_MAP_TAG 0x20000
#define DFLAG_BIG_CREATION 0x40000
#define DFLAG_HANDSHAKE_23 0x1000000
#define DFLAG_UNLINK_ID 0x2000000
#define DFLAG_MANDATORY_25_DIGEST 0x4000000
#define DFLAG_RESERVED 0xf8000000
#define DFLAG_NAME_ME (((DistFlags)0x2) << 32)
#define DFLAG_V4_NC (((DistFlags)0x4) << 32)
/* Control message tags not exposed to user... */
#define ERL_UNLINK_ID 35
#define ERL_UNLINK_ID_ACK 36
/* Mandatory flags for distribution in OTP 25. */
#define DFLAG_DIST_MANDATORY_25 (DFLAG_EXTENDED_REFERENCES \
| DFLAG_FUN_TAGS \
| DFLAG_EXTENDED_PIDS_PORTS \
| DFLAG_UTF8_ATOMS \
| DFLAG_NEW_FUN_TAGS \
| DFLAG_BIG_CREATION \
| DFLAG_NEW_FLOATS \
| DFLAG_MAP_TAG \
| DFLAG_EXPORT_PTR_TAG \
| DFLAG_BIT_BINARIES \
| DFLAG_HANDSHAKE_23)
/* New mandatory flags for distribution in OTP 26. */
#define DFLAG_DIST_MANDATORY_26 (DFLAG_V4_NC \
| DFLAG_UNLINK_ID)
/* Mandatory flags for distribution. */
/*
* Mandatory flags for distribution. Keep them in sync with
* erts/emulator/beam/dist.h.
*/
#define DFLAG_DIST_MANDATORY (DFLAG_DIST_MANDATORY_25 \
| DFLAG_DIST_MANDATORY_26)
ei_cnode *ei_fd_to_cnode(int fd);
int ei_distversion(int fd);
const char* ei_getfdcookie(int fd);
const char *ei_thiscookie(const ei_cnode* ec);
int ei_do_receive_msg(int fd, int staticbuffer_p,
erlang_msg* msg, ei_x_buff* x, unsigned ms);
#endif /* _EI_CONNECT_H */
|
