msgsend.h

//
//  msgsend.h - send messages
//
//  Roger B. Dannenberg
//  April 2020
 
#ifndef MSGSEND_H
#define MSGSEND_H
 
// if MSG_NOSIGNAL is an option for send(), then use it;
// otherwise, give it a legal innocuous value as a flag:
#ifndef MSG_NOSIGNAL
#define MSG_NOSIGNAL 0
#endif
 
class Pending_msgs_queue {
    O2message_ptr head;
    O2message_ptr tail;
public:
    Pending_msgs_queue();
    void enqueue(O2message_ptr msg);
    O2message_ptr dequeue();
    bool empty();
};
 
extern Pending_msgs_queue o2_pending_local;
extern Pending_msgs_queue o2_pending_anywhere;
 
 
void o2_drop_msg_data(const char *warn, o2_msg_data_ptr data);
 
void o2_prepare_to_deliver(O2message_ptr msg);
 
extern int o2_do_not_reenter; // counter to allow nesting
 
void o2_deliver_pending(void);
 
// free any remaining messages after O2 has been shut down
void o2_free_pending_msgs(void);
 
void o2_msg_deliver(O2node *service, Services_entry *services);
 
 
void o2_send_to_taps(O2message_ptr msg, Services_entry *ss);
 
 
O2err o2_msg_send_now();
 
void o2_call_handler(Handler_entry *handler, o2_msg_data_ptr msg,
                     const char *types);
 
O2node *o2_msg_service(o2_msg_data_ptr msg, Services_entry **services);
 
// int o2_send_message(Fds_info *proc, int blocking);
 
void o2_send_local(O2node *service, Services_entry *ss);
 
// void o2_queue_message(O2message_ptr msg, Fds_info *proc);
 
#endif /* o2_send_h */