fleet_message_node_sync   xtlang


Defined in:  https://github.com/digego/extempore/tree/v0.8.9/libs/external/fleet.xtm

Implementation

(bind-func fleet_message_node_sync
  (let ((buf:i8* (zalloc FLEET_NANOMSG_CLIENT_BUFLEN)))
    (lambda (msg:i8* sock:i32)
      (let ((sz_msg (+ (strlen msg) 1))
            (bytes (nn_send sock msg sz_msg 0)))
        (nn_sock_set_timeout sock 1000)
        (if (= bytes (convert sz_msg)) ;; should also check (< bytes (convert sz_msg))
            (let ((rbytes (nn_recv sock buf FLEET_NANOMSG_CLIENT_BUFLEN 0)))
              (if (> rbytes 0)
                  (begin (printf "%s\n" buf)
                         void)))
            (nn_println_strerror "error in request"))))))


Back to Index

Similar Entries

  • Pm_Event_Message    xtlang
  • Pm_Message    xtlang
  • Pm_Message_Channel    xtlang
  • Pm_Message_Data1    xtlang
  • Pm_Message_Data2    xtlang
  • Pm_Message_Status    xtlang
  • Pm_Message_Type    xtlang
  • ai_build_node    xtlang
  • ai_find_matching_node    xtlang
  • async    xtlang
  • async    xtlang
  • async_done    xtlang
  • async_kill    xtlang
  • clock-runsync    scheme
  • clock:sync-adjust    scheme
  • find_node    xtlang
  • fleet-connect    scheme
  • fleet-eval    scheme
  • fleet-killemall    scheme
  • fleet_connect_to_nodes    xtlang
  • fleet_delete_unit    xtlang
  • fleet_get_api    xtlang
  • fleet_get_ip_list    xtlang
  • fleet_get_machines    xtlang
  • fleet_get_state    xtlang
  • fleet_get_state    xtlang
  • fleet_get_units    xtlang
  • fleet_message_all_nodes_sync    xtlang
  • fleet_print_machines    xtlang
  • fleet_print_state    xtlang
  • fleet_print_state    xtlang
  • fleet_print_unit    xtlang
  • fleet_print_unit_state    xtlang
  • fleet_print_units    xtlang
  • fleet_response_error_p    xtlang
  • fleet_set_unit_state    xtlang
  • fleet_set_unit_state    xtlang
  • fleet_submit_extempore_service    xtlang
  • godot_node_path_destroy    xtlang
  • godot_node_path_new    xtlang
  • godot_variant_new_node_path    xtlang
  • ipc:sync-receive    scheme
  • node_reply_function    xtlang
  • node_reply_loop    xtlang
  • node_reply_loop_stop    xtlang
  • node_reply_socket_init    xtlang
  • on_process_message_received    xtlang
  • rtmidi_process_message    xtlang
  • send_process_message    xtlang
  • suppress-compiler-messages    scheme
  • sync-server-receive    scheme
  • sys_file_datasync    xtlang
  • sys_file_datasync    xtlang
  • sys_file_sync    xtlang
  • topclock-sync    scheme
  • toplap-clock-sync    scheme