005.c File Reference

Go to the source code of this file.

Functions
	GNUNET_mq_send (mq, env)

Variables
struct GNUNET_MQ_Envelope *	env = GNUNET_MQ_msg_extra (msg, payload_size, GNUNET_MY_MESSAGE_TYPE)
struct GNUNET_MessageHeader *	msg

Function Documentation

GNUNET_mq_send()

GNUNET_mq_send	(	mq	,
		env
	)

Variable Documentation

env

env = GNUNET_MQ_msg_extra (msg, payload_size, GNUNET_MY_MESSAGE_TYPE)

Definition at line 1 of file 005.c.

Referenced by addr_cb(), adv_transmit(), announce_reconnect(), attr_iter_cb(), attr_iter_finished(), attr_store_cont(), broadcast_status(), cadet_mq_send_impl(), cadet_mq_send_now(), callback_found_message(), change_service(), clean_up_channel(), client_response_handler(), client_send_response(), conclude_autoconfig_request(), consume_result_cb(), core_mq_send_impl(), core_send_connect_info(), cores_send_disconnect_info(), create_loc_uri(), create_update_message(), cred_iter_cb(), cred_iter_finished(), cred_store_cont(), destroy_direction(), DHTU_gnunet_init(), DHTU_ip_init(), dir_ready_cb(), discard_buffer(), dns_pre_request_handler(), do_connect(), do_send(), expand_dollar(), finish_cmc_handling_with_continue(), finish_handling_raw_message(), forward_reply(), forward_tunnel_message(), GCC_destroy_without_tunnel(), GCC_transmit(), GCCH_handle_channel_plaintext_data(), GCCH_handle_local_data(), GCP_send(), GCP_send_ooo(), GCT_send(), get_action(), get_all_peers_iterator(), get_all_tunnels_iterator(), GNUNET_ARM_request_service_list(), GNUNET_CADET_channel_create(), GNUNET_CADET_channel_destroy(), GNUNET_CADET_close_port(), GNUNET_CADET_drop_message(), GNUNET_CADET_receive_done(), GNUNET_DATASTORE_disconnect(), GNUNET_DATASTORE_get_for_replication(), GNUNET_DATASTORE_get_key(), GNUNET_DATASTORE_get_zero_anonymity(), GNUNET_DATASTORE_put(), GNUNET_DATASTORE_release_reserve(), GNUNET_DATASTORE_remove(), GNUNET_DATASTORE_reserve(), GNUNET_DHT_get_stop(), GNUNET_DHT_hello_get(), GNUNET_DHT_hello_offer(), GNUNET_DHT_monitor_stop(), GNUNET_DHT_put(), GNUNET_DNS_request_answer(), GNUNET_DNS_request_drop(), GNUNET_DNS_request_forward(), GNUNET_FS_get_indexed_files(), GNUNET_FS_indexing_send_list(), GNUNET_HELLO_builder_to_env_(), GNUNET_HELLO_parser_to_env(), GNUNET_IDENTITY_create(), GNUNET_IDENTITY_delete(), GNUNET_IDENTITY_ego_lookup(), GNUNET_IDENTITY_ego_lookup_by_suffix(), GNUNET_IDENTITY_rename(), GNUNET_MESSENGER_connect(), GNUNET_MESSENGER_disconnect(), GNUNET_MESSENGER_get_message(), GNUNET_MQ_dll_insert_head(), GNUNET_MQ_dll_insert_tail(), GNUNET_MQ_dll_remove(), GNUNET_MQ_env_copy(), GNUNET_MQ_env_get_msg(), GNUNET_MQ_env_get_options(), GNUNET_MQ_env_next(), GNUNET_MQ_env_set_options(), GNUNET_MQ_send_copy(), GNUNET_MQ_unsent_head(), GNUNET_NAMECACHE_block_cache(), GNUNET_NAMECACHE_lookup_block(), GNUNET_NAMESTORE_record_set_edit_begin(), GNUNET_NAMESTORE_record_set_edit_cancel(), GNUNET_NAMESTORE_records_store(), GNUNET_NAMESTORE_zone_iteration_start(), GNUNET_NAMESTORE_zone_iteration_start2(), GNUNET_NAMESTORE_zone_iteration_stop(), GNUNET_NAMESTORE_zone_iterator_next(), GNUNET_NAMESTORE_zone_monitor_next(), GNUNET_NAMESTORE_zone_to_name(), GNUNET_NAT_add_global_address(), GNUNET_NAT_AUTO_autoconfig_start(), GNUNET_NAT_request_reversal(), GNUNET_NAT_stun_handle_packet(), GNUNET_notification_context_broadcast(), GNUNET_PEERSTORE_monitor_next(), GNUNET_RECLAIM_get_attributes_next(), GNUNET_RECLAIM_get_attributes_start(), GNUNET_RECLAIM_get_attributes_stop(), GNUNET_RECLAIM_get_credentials_next(), GNUNET_RECLAIM_get_credentials_start(), GNUNET_RECLAIM_get_credentials_stop(), GNUNET_RECLAIM_ticket_iteration_next(), GNUNET_RECLAIM_ticket_iteration_start(), GNUNET_RECLAIM_ticket_iteration_stop(), GNUNET_REVOCATION_query(), GNUNET_REVOCATION_revoke(), GNUNET_SCALARPRODUCT_accept_computation(), GNUNET_SCALARPRODUCT_start_computation(), gnunet_send(), GNUNET_TRANSPORT_communicator_burst_finished(), GNUNET_TRANSPORT_communicator_notify(), GNUNET_TRANSPORT_communicator_receive(), GNUNET_TRANSPORT_TESTING_send(), GNUNET_TRANSPORT_TESTING_transport_communicator_open_queue(), GNUNET_TRANSPORT_TESTING_transport_communicator_send(), GSC_bind(), GSC_CLIENTS_deliver_message(), GSC_CLIENTS_notify_client_about_neighbour(), GSC_CLIENTS_solicit_request(), GSC_handle_remote_channel_destroy(), GSC_KX_encrypt_and_transmit(), GSC_KX_handle_client_monitor_peers(), GSC_send_to_client(), GSF_block_peer_migration_(), GSF_peer_transmit_(), GSF_pending_request_get_message_(), handle_backchannel_encapsulation(), handle_block_cache(), handle_cadet_audio_message(), handle_cadet_hangup_message(), handle_cadet_pickup_message(), handle_cadet_resume_message(), handle_cadet_ring_message(), handle_cadet_suspend_message(), handle_channel_created(), handle_client_init(), handle_client_loc_sign(), handle_client_pickup_message(), handle_client_unindex(), handle_communicator_backchannel(), handle_create_queue(), handle_data(), handle_datastore_reply(), handle_dht_local_hello_get(), handle_disconnect(), handle_edit_record_set(), handle_edit_record_set_cancel(), handle_get(), handle_get_peers(), handle_incoming_msg(), handle_info_tunnels(), handle_list(), handle_lookup_block(), handle_lookup_block_it(), handle_lookup_by_suffix_message(), handle_lookup_message(), handle_p2p_reply(), handle_ping(), handle_query_message(), handle_record_lookup(), handle_revoke_message(), handle_room_close(), handle_room_entry(), handle_room_open(), handle_room_sync(), handle_search_result(), handle_send_msg(), handle_show_path(), handle_start(), handle_start_message(), handle_test(), handle_zone_to_name(), handle_zone_to_name_it(), hash_for_index_cb(), hash_for_index_val(), hello_iter(), icmp_from_helper(), iterate_next_member_ids(), iterate_proc(), iterate_send_room_message(), iteration_done_client_continue(), libgnunet_plugin_datacache_heap_init(), libgnunet_plugin_datacache_postgres_init(), libgnunet_plugin_datacache_sqlite_init(), libgnunet_plugin_datacache_template_init(), libgnunet_plugin_datastore_heap_init(), libgnunet_plugin_datastore_postgres_init(), libgnunet_plugin_datastore_sqlite_init(), libgnunet_plugin_datastore_template_init(), make_queue_entry(), monitor_iterate_cb(), monitor_sync(), mq_send_impl(), notify_change(), notify_client(), notify_clients_stun_change(), notify_monitor(), notify_srv_handle_message(), open_port_cb(), pack_message(), path_info_iterator(), process_dns_result(), process_requests(), put_action(), queue_send_msg(), read_stdio(), reconnect(), reconnect_arm(), reconnect_arm_monitor(), records_lookup(), response_action(), retry_entry(), return_agpl(), reversal_callback(), revoke_result_cb(), route_message(), route_packet(), run(), schedule_action(), schedule_next_hello(), schedule_transmit_search_request(), search_reconnect(), send_ack(), send_ack_to_client(), send_add_address(), send_add_queue(), send_broken(), send_broken_without_mqm(), send_client_reply(), send_close_room(), send_create(), send_create_ack(), send_del_address(), send_del_queue(), send_delete_response(), send_echo(), send_end_msg(), send_enter_room(), send_get(), send_get_known_results(), send_intermediate_response(), send_key(), send_kx(), send_kx_auth(), send_lookup_response(), send_lookup_response_with_filter(), send_message_to_room(), send_monitor_start(), send_open_room(), send_packet_to_cadet_channel(), send_ping(), send_reply(), send_request(), send_request_to_client(), send_result_code(), send_simple_cb(), send_simple_single(), send_start_monitor(), send_store_response(), send_sync_room(), send_ticket_result(), send_to_channel(), send_tunnel_envelope(), send_tunnel_message(), send_update_queue(), signal_index_ok(), signal_result(), start_burst(), store_pi(), store_record_continuation(), suggest_to_connect(), tcp_from_helper(), test_nat_punched(), ticket_iter_cb(), transmit(), transmit_get(), transmit_item(), transmit_pending(), transmit_set(), transmit_status(), transmit_task_cb(), transmit_watch(), udp_from_helper(), unindex_finish(), watch_notifier(), and zone_iteration_done_client_continue().

msg

GNUNET_memcpy&[1] msg

Definition at line 2 of file 005.c.

Referenced by addr_cb(), broadcast_status(), bus_call(), cadet_mq_send_impl(), callback_download(), change_service(), check_add_address(), check_alice_client_message(), check_alice_client_message_multipart(), check_alices_cryptodata_message(), check_attribute_result(), check_bob_client_message(), check_bob_client_message_multipart(), check_bobs_cryptodata_message(), check_bobs_cryptodata_multipart(), check_cadet_audio_message(), check_client_audio_message(), check_client_keygen(), check_client_redirect_to_ip(), check_client_result(), check_client_seed(), check_communicator_available(), check_connection_create(), check_consume_ticket_result(), check_core_message(), check_create_message(), check_credential_result(), check_delete_message(), check_edit_record_set_response(), check_hello(), check_helper_init(), check_incoming_msg(), check_index_start_failed(), check_local_data(), check_lookup_result(), check_monitor_get_resp(), check_monitor_notify(), check_monitor_put(), check_peer_pull_reply(), check_record_result(), check_recv_message(), check_rename_message(), check_request(), check_response(), check_room_entry(), check_room_initial_key(), check_room_open(), check_send_message(), check_set(), check_stream_input(), check_ticket_result(), check_union_p2p_ibf(), check_union_p2p_inquiry(), check_union_p2p_strata_estimator(), check_view_update(), check_zone_to_name_response(), client_request_complete_alice(), connection_client_send_impl(), continue_after_remove(), core_mq_send_impl(), cs_full_domain_hash(), curl_task_download(), decode_and_send(), decode_class(), decode_method(), decrypt_conclude(), demultiplex_with_cmc(), do_send(), do_unknown(), ds_put_cont(), enc_notify_cb(), execute_add(), execute_mutation(), execute_remove(), fail_intersection_operation(), fail_union_operation(), finish_reserve(), flush_bulk(), forward_dv_learn(), fragment_message(), GCC_handle_encrypted(), GCC_handle_kx(), GCC_handle_kx_auth(), GCCH_handle_channel_plaintext_data(), GCP_check_monotime_sig(), GCT_handle_encrypted(), GCT_handle_kx(), GCT_handle_kx_auth(), GCT_send_channel_destroy(), GDS_NEIGHBOURS_broadcast(), GDS_u_send(), get_all_peers_iterator(), get_all_tunnels_iterator(), GNUNET_ARM_request_service_list(), GNUNET_CADET_channel_create(), GNUNET_CADET_channel_destroy(), GNUNET_CADET_close_port(), GNUNET_CADET_receive_done(), GNUNET_copy_message(), GNUNET_CRYPTO_cs_calc_blinded_c(), GNUNET_CRYPTO_cs_verify(), GNUNET_FS_get_indexed_files(), GNUNET_FS_uri_parse(), gnunet_gst_bus_call(), GNUNET_HELLO_builder_to_dht_hello_msg(), GNUNET_HELLO_builder_to_env_(), GNUNET_HELLO_dht_msg_to_block(), GNUNET_HELLO_get_expiration_time_from_msg(), GNUNET_HELLO_parser_from_msg(), GNUNET_HELLO_parser_to_env(), GNUNET_HELPER_send(), GNUNET_JSON_pack_blinded_message(), GNUNET_JSON_spec_blinded_message(), GNUNET_MESSENGER_connect(), GNUNET_MESSENGER_disconnect(), GNUNET_MESSENGER_get_message(), GNUNET_NAMECACHE_block_cache(), GNUNET_NAMECACHE_lookup_block(), GNUNET_NAMESTORE_record_set_edit_begin(), GNUNET_NAMESTORE_record_set_edit_cancel(), GNUNET_NAMESTORE_records_store(), GNUNET_NAMESTORE_zone_iteration_start(), GNUNET_NAMESTORE_zone_iteration_start2(), GNUNET_NAMESTORE_zone_iteration_stop(), GNUNET_NAMESTORE_zone_iterator_next(), GNUNET_NAMESTORE_zone_to_name(), GNUNET_notification_context_broadcast(), GNUNET_PEERSTORE_hello_add(), GNUNET_RECLAIM_get_attributes_next(), GNUNET_RECLAIM_get_attributes_start(), GNUNET_RECLAIM_get_attributes_stop(), GNUNET_RECLAIM_get_credentials_next(), GNUNET_RECLAIM_get_credentials_start(), GNUNET_RECLAIM_get_credentials_stop(), GNUNET_RECLAIM_ticket_iteration_next(), GNUNET_RECLAIM_ticket_iteration_start(), GNUNET_RECLAIM_ticket_iteration_stop(), GNUNET_RECLAIM_ticket_revoke(), GNUNET_RPS_seed_ids(), GNUNET_RPS_stream_request(), GNUNET_RPS_sub_start(), GNUNET_RPS_sub_stop(), GNUNET_RPS_view_request(), GNUNET_SCALARPRODUCT_accept_computation(), GNUNET_SCALARPRODUCT_start_computation(), GNUNET_SECRETSHARING_create_session(), GNUNET_SECRETSHARING_decrypt(), gnunet_send(), GNUNET_SET_accept(), GNUNET_SET_add_element(), GNUNET_SET_prepare(), GNUNET_SET_remove_element(), GNUNET_SETI_accept(), GNUNET_SETI_add_element(), GNUNET_SETI_prepare(), GNUNET_SETU_accept(), GNUNET_SETU_add_element(), GNUNET_SETU_prepare(), GNUNET_TRANSPORT_communicator_receive(), GNUNET_TRANSPORT_TESTING_transport_communicator_open_queue(), GNUNET_TRANSPORT_TESTING_transport_communicator_send(), GSC_CLIENTS_deliver_message(), GSC_KX_handle_client_monitor_peers(), GSC_SESSIONS_broadcast_typemap(), GSC_SESSIONS_confirm_typemap(), GSC_SESSIONS_set_typemap(), GSC_SESSIONS_transmit(), GSC_TYPEMAP_get_from_message(), handle_add_address(), handle_add_queue_message(), handle_alice_client_message(), handle_alice_client_message_multipart(), handle_alices_computation_request(), handle_alices_cryptodata_message(), handle_attribute_result(), handle_block_cache_response(), handle_bob_client_message(), handle_bob_client_message_multipart(), handle_bobs_cryptodata_message(), handle_bobs_cryptodata_multipart(), handle_cadet_audio_message(), handle_cadet_resume_message(), handle_cadet_ring_message(), handle_call_hangup(), handle_call_picked_up(), handle_call_resume(), handle_call_suspend(), handle_channel_created(), handle_channel_destroy(), handle_client_accept(), handle_client_audio_message(), handle_client_call_message(), handle_client_cancel(), handle_client_copy_lazy_connect(), handle_client_create_set(), handle_client_decrypt(), handle_client_evaluate(), handle_client_hangup_message(), handle_client_insert(), handle_client_keygen(), handle_client_listen(), handle_client_loc_sign(), handle_client_mutation(), handle_client_pickup_message(), handle_client_redirect_to_ip(), handle_client_redirect_to_service(), handle_client_register_message(), handle_client_reject(), handle_client_result(), handle_client_resume_message(), handle_client_seed(), handle_client_set_add(), handle_client_start_sub(), handle_client_stop_sub(), handle_client_stream_cancel(), handle_client_stream_request(), handle_client_suspend_message(), handle_client_unindex(), handle_client_view_cancel(), handle_client_view_request(), handle_communicator_available(), handle_communicator_backchannel(), handle_confirm(), handle_connection_broken(), handle_connection_create(), handle_connection_create_ack(), handle_connection_destroy(), handle_consume_ticket_result(), handle_copy_lazy(), handle_core_message(), handle_credential_result(), handle_data(), handle_decrypted(), handle_dht_local_hello_offer(), handle_dht_local_monitor(), handle_dht_local_monitor_stop(), handle_disconnect(), handle_dns_request(), handle_dns_response(), handle_edit_record_set_response(), handle_fragment_box(), handle_generic_response(), handle_get(), handle_get_key(), handle_get_message(), handle_get_peers_end(), handle_get_tunnels_end(), handle_get_zero_anonymity(), handle_hello(), handle_helper_init(), handle_icmp_back(), handle_icmp_remote(), handle_icmp_service(), handle_incoming_msg(), handle_index_start_failed(), handle_intersection_p2p_bf(), handle_intersection_p2p_element_info(), handle_iter_element(), handle_iterate_end(), handle_iterate_result(), handle_list(), handle_local_ack(), handle_local_data(), handle_lookup_block_response(), handle_lookup_result(), handle_member_id(), handle_miss_message(), handle_monitor_get(), handle_monitor_get_resp(), handle_monitor_put(), handle_new_element(), handle_peer_check(), handle_peer_pull_reply(), handle_peer_pull_request(), handle_peer_push(), handle_plaintext_data(), handle_record_result(), handle_record_result_end(), handle_recv_message(), handle_release_reserve(), handle_request(), handle_reserve(), handle_response(), handle_result(), handle_revoke_ticket_result(), handle_room_close(), handle_room_entry(), handle_room_open(), handle_room_sync(), handle_send_message(), handle_set(), handle_show_path(), handle_store_result(), handle_stream_input(), handle_success_response(), handle_suggest(), handle_suggest_cancel(), handle_sync(), handle_tcp_back(), handle_test(), handle_ticket_result(), handle_tunnel_encrypted(), handle_tunnel_kx(), handle_tunnel_kx_auth(), handle_udp_back(), handle_udp_remote(), handle_udp_service(), handle_union_p2p_ibf(), handle_union_p2p_inquiry(), handle_union_p2p_request_full(), handle_union_p2p_send_full(), handle_union_p2p_strata_estimator(), handle_update_queue_message(), handle_view_update(), handle_zone_to_name_response(), hash_for_index_val(), hello_iter(), initialize_handle_via_key(), intersection_evaluate(), ip_send(), iterate_next_member_ids(), kb_put_cont(), lf(), list_callback(), listen_connect(), load_debug(), monitor_notify_all(), mq_send(), mq_send_d(), mq_send_impl(), mq_send_kx(), mqm_execute(), notify_client(), notify_clients_stun_change(), notify_srv_handle_message(), open_port_cb(), output_message(), prepare_client_end_notification(), print_hex(), process_cont(), process_helper_msgs(), process_record_messages(), process_requests(), process_result_message(), put_cb(), put_continuation(), read_stdio(), reconnect(), reconnect_arm_monitor(), records_lookup(), recv_message(), recv_message_info(), reliability_box_message(), remove_cont(), remove_continuation(), return_agpl(), route_message(), save(), select_read_cb(), select_write_cb(), send_alices_cryptodata_message(), send_bloomfilter(), send_channel_data_ack(), send_client_element(), send_close_room(), send_echo(), send_element_count(), send_end_msg(), send_enter_room(), send_get_known_results(), send_ibf(), send_keepalive(), send_kx(), send_kx_auth(), send_message_to_room(), send_msg_with_kx(), send_open_ack(), send_open_room(), send_reply(), send_srv_handle_message(), send_start_messages(), send_sync_room(), service_mq_send(), set_monotime_sig(), signal_index_ok(), signal_result(), sks_publish_cont(), sqlite_plugin_put(), srv_status(), state_changed_cb(), stdin_receiver(), stop_callback(), store_pi(), store_record_continuation(), stream_start_response(), stun_attr2str(), stun_msg2str(), t_h_encrypt(), task_download(), term_callback(), test_nat_punched(), transmit_bobs_cryptodata_message(), transmit_bobs_cryptodata_message_multipart(), transmit_client_response(), transmit_content(), transmit_status(), ublock_put_cont(), and union_evaluate().