discovery.h

/* discovery.h -- discovery protocol
 *
 * Roger B. Dannenberg
 * April 2020
 */
 
#ifndef DISCOVERY_H
#define DISCOVERY_H
 
#define O2_DY_INFO 50
#define O2_DY_HUB 51
#define O2_DY_REPLY 52
#define O2_DY_CALLBACK 53
#define O2_DY_CONNECT 54
 
// we need to successfully allocate one port from the list. This number is
// how many ports to search.
#define PORT_MAX  16
 
extern SOCKET o2_discovery_socket;
extern Fds_info *o2_udp_server;
 
#ifndef O2_NO_HUB
extern char o2_hub_addr[O2_MAX_PROCNAME_LEN]; // @public:internal:port of hub
        // if any, otherwise empty string. Non-empty turns off broadcasting.
#endif
 
O2err o2_discovery_initialize(void);
void o2_discovery_init_phase2();
 
O2err o2_discovery_finish(void);
 
#ifndef O2_NO_O2DISCOVERY
void o2_discovery_send_handler(o2_msg_data_ptr msg, const char *types,
                    O2arg_ptr *argv, int argc, const void *user_data);
 
void o2_send_discovery_at(O2time when);
#endif
 
O2err o2_send_services(Proxy_info *proc);
 
void o2_discovery_handler(o2_msg_data_ptr msg, const char *types,
               O2arg_ptr *argv, int argc, const void *user_data);
 
void o2_discovery_init_handler(o2_msg_data_ptr msg, const char *types,
                    O2arg_ptr *argv, int argc, const void *user_data);
 
 
void o2_hub_handler(o2_msg_data_ptr msg, const char *types,
         O2arg_ptr *argv, int argc, const void *user_data);
 
void o2_services_handler(o2_msg_data_ptr msg, const char *types,
              O2arg_ptr *argv, int argc, const void *user_data);
 
// call this if you have a (padded) O2string for name:
O2err o2_discovered_a_remote_process_name(const char *name, int version,
        const char *internal_ip, int tcp_port, int udp_port, int dy);
 
// call this if you have just individual address components OR if
// dy is O2_CALLBACK:
O2err o2_discovered_a_remote_process(int version, const char *public_ip,
        const char *internal_ip, int tcp_port, int udp_port, int dy);
 
O2message_ptr o2_make_dy_msg(Proc_info *proc, bool tcp_flag, bool swap_flag,
                             int dy_flag);
 
#endif /* DISCOVERY_H */