MCPcopy Create free account

hub / github.com/apache/qpid-proton / functions

Functions8,826 in github.com/apache/qpid-proton

↓ 5 callersFunctionpn_link_drained
c/src/core/engine.c:2071
↓ 5 callersFunctionpn_link_remote_properties
c/src/core/engine.c:2173
↓ 5 callersFunctionpn_link_set_rcv_settle_mode
c/src/core/engine.c:2031
↓ 5 callersFunctionpn_list_minpop
c/src/core/object/list.c:149
↓ 5 callersFunctionpn_listener_proactor
c/src/proactor/epoll.c:1871
↓ 5 callersFunctionpn_message_properties
c/src/core/message.c:1058
↓ 5 callersFunctionpn_message_send
c/src/core/message.c:1092
↓ 5 callersFunctionpn_message_set_inferred
c/src/core/message.c:453
↓ 5 callersFunctionpn_record_set_handler
c/src/reactor/reactor.c:248
↓ 5 callersFunctionpn_sasl_allowed_mechs
c/src/sasl/sasl.c:863
↓ 5 callersFunctionpn_sasl_set_allow_insecure_mechs
c/src/sasl/sasl.c:870
↓ 5 callersFunctionpn_selectable_on_finalize
c/src/reactor/selectable.c:165
↓ 5 callersFunctionpn_session_free
c/src/core/engine.c:287
↓ 5 callersFunctionpn_session_next
c/src/core/engine.c:875
↓ 5 callersFunctionpn_ssl_get_remote_subject
c/src/ssl/openssl.c:1554
↓ 5 callersFunctionpn_string_buffer
c/src/core/object/string.c:256
↓ 5 callersFunctionpn_terminus_filter
c/src/core/engine.c:1463
↓ 5 callersFunctionpn_terminus_properties
c/src/core/engine.c:1439
↓ 5 callersFunctionpn_tls
c/src/tls/openssl.c:1102
↓ 5 callersFunctionpn_tls_close_output
c/src/tls/openssl.c:2282
↓ 5 callersFunctionpn_tls_get_session_error
c/src/tls/openssl.c:416
↓ 5 callersFunctionpn_tls_give_encrypt_input_buffers
c/src/tls/openssl.c:1586
↓ 5 callersFunctionpn_tls_start
c/src/tls/openssl.c:1124
↓ 5 callersFunctionpn_tls_stop
c/src/tls/openssl.c:1150
↓ 5 callersFunctionpn_tracker_store
c/src/messenger/messenger.c:2032
↓ 5 callersFunctionpn_transport_attachments
c/src/core/transport.c:2799
↓ 5 callersFunctionpn_transport_get_remote_idle_timeout
c/src/core/transport.c:2893
↓ 5 callersFunctionpn_transport_process
c/src/core/transport.c:2983
↓ 5 callersFunctionpn_value_dump_nondescribed_value
c/src/core/value_dump.c:504
↓ 5 callersFunctionpni_emitter_writev32
c/src/core/emitters.h:154
↓ 5 callersFunctionpni_ep_get_connection
c/src/core/engine.c:61
↓ 5 callersFunctionpni_inspect_atom
c/src/core/codec.c:113
↓ 5 callersFunctionpni_iocp_begin_close
c/src/reactor/io/windows/iocp.c:1107
↓ 5 callersFunctionpni_iocp_drain_completions
c/src/reactor/io/windows/iocp.c:879
↓ 5 callersFunctionpni_iocpdesc_create
c/src/reactor/io/windows/iocp.c:774
↓ 5 callersFunctionpni_iocpdesc_map_del
c/src/reactor/io/windows/iocp.c:816
↓ 5 callersFunctionpni_matches
c/src/core/engine.c:843
↓ 5 callersFunctionpni_raw_connected
c/src/proactor/raw_connection.c:466
↓ 5 callersFunctionpni_raw_wclosed
Return whether closed for writing by application (name a little confusing!) NB Initial state is NOT closed for writing - app can write before connecti
c/src/proactor/raw_connection.c:163
↓ 5 callersFunctionpni_raw_wdrained
Return whether closed for application and all writes drained
c/src/proactor/raw_connection.c:179
↓ 5 callersFunctionpni_selectable_set_context
c/src/reactor/selectable.c:180
↓ 5 callersFunctionpni_sniff_header
* SSLv2 Client Hello format * http://www.mozilla.org/projects/security/pki/nss/ssl/draft02.html * * Bytes 0-1: RECORD-LENGTH * Byte 2: MSG-CLIE
c/src/core/autodetect.c:80
↓ 5 callersFunctionpni_switch_to_raw_multiple
c/src/core/util.h:129
↓ 5 callersFunctionpni_timer_set
Call without task lock or timer_manager lock. Calls for connection timers are generated in the proactor and serialized per connection. Calls for the p
c/src/proactor/epoll_timer.c:258
↓ 5 callersFunctionpni_track_common
c/src/core/memory.c:155
↓ 5 callersFunctionpni_transport
c/src/messenger/messenger.c:162
↓ 5 callersFunctionpni_value_dump
c/src/core/value_dump.c:584
↓ 5 callersFunctionpni_win32_error
c/src/proactor/win_iocp.cpp:564
↓ 5 callersFunctionpni_write_pipeline_return
c/src/proactor/win_iocp.cpp:488
↓ 5 callersFunctionpni_write_pipeline_return
c/src/reactor/io/windows/write_pipeline.c:296
↓ 5 callersMethodport
ruby/lib/core/url.rb:61
↓ 5 callersMethodport_int
cpp/src/url.cpp:256
↓ 5 callersFunctionproactor_add
c/src/proactor/epoll.c:2149
↓ 5 callersFunctionproactor_wake
Call wih lock held
c/src/proactor/win_iocp.cpp:1877
↓ 5 callersMethodpush_event
( self, obj: Union['Reactor', Task, 'Container', Selectable], etype: Event
python/proton/_reactor.py:402
↓ 5 callersMethodput_array
Puts an array value. Elements may be filled by entering the array node and putting the element values. The values must all be of the
python/proton/_data.py:863
↓ 5 callersMethodput_map
Puts a map value. Elements may be filled by entering the map node and putting alternating key value pairs. >>> data = Da
python/proton/_data.py:847
↓ 5 callersFunctionreap_check
c/src/proactor/win_iocp.cpp:1355
↓ 5 callersMethodreceiver
cpp/src/receiver.cpp:40
↓ 5 callersMethodreceiver
@return [Receiver, nil] receiver associated with this event
ruby/lib/core/event.rb:124
↓ 5 callersMethodrun
cpp/examples/service_bus.cpp:217
↓ 5 callersMethodrunning
Number of threads in {#run} @return [Bool] {#run} thread count
ruby/lib/core/container.rb:112
↓ 5 callersFunctionschedule_done
call with task lock held from xxx_process().
c/src/proactor/epoll.c:329
↓ 5 callersFunctionschedule_if_inactive
If inactive set need_inactive and return true if poller needs to be unblocked */
c/src/proactor/epoll.c:1425
↓ 5 callersFunctionsecs2millis
(secs: Union[float, int])
python/proton/_common.py:32
↓ 5 callersFunctionsequence_lte
c/src/core/transport.c:1545
↓ 5 callersFunctionset_error_condition
cpp/src/proton_bits.cpp:63
↓ 5 callersMethodsettle
@deprecated internal use only
ruby/lib/core/transfer.rb:96
↓ 5 callersMethodssl
cpp/src/transport.cpp:41
↓ 5 callersFunctionstart_ssl_shutdown
c/src/ssl/schannel.cpp:1457
↓ 5 callersMethodstate
@return [Integer] Remote state of the transfer, one of the values in {State}
ruby/lib/core/transfer.rb:58
↓ 5 callersFunctionstatistics_start
c/tools/msgr-common.c:106
↓ 5 callersMethodstop
(self)
python/tests/proton_tests/common.py:228
↓ 5 callersFunctionstop_timer
Either stops a timer before firing or returns after the callback has completed (in the threadpool thread). Never "in doubt".
c/src/proactor/win_iocp.cpp:2113
↓ 5 callersMethodstore_instance
@private Stores the given object for later retrieval. @param object [Object] The object. @param attachment_method [Symbol] The Proton attachment meth
ruby/lib/util/wrapper.rb:64
↓ 5 callersFunctiontask_finalize
c/src/proactor/epoll-internal.h:367
↓ 5 callersFunctiontask_init
c/src/proactor/epoll.c:224
↓ 5 callersMethodtestGarbage
(self, garbage=b"GARBAGE_")
python/tests/proton_tests/transport.py:76
↓ 5 callersMethodtestMultipleUnsettled
(self, count=1024, size=1024)
python/tests/proton_tests/engine.py:2027
↓ 5 callersFunctiontest_broker
()
python/tests/integration/test_PROTON_2121_blocking_connection_fd_leak.py:94
↓ 5 callersMethodtest_client_server
(self, client=['client.py'], server=['server.py'], sleep=0)
python/examples/test_examples.py:81
↓ 5 callersFunctiontranslateActiveException
tests/include/catch.hpp:12524
↓ 5 callersMethodtype
Returns the type of the current node. Returns `None` if there is no current node. :return: The current node type enumeration
python/proton/_data.py:782
↓ 5 callersFunctionuv_safe_close
c/src/proactor/libuv.c:440
↓ 5 callersFunctionverify
cpp/examples/flow_control.cpp:44
↓ 5 callersFunctionwake_if_inactive
Call whenever transitioning from "definitely active" to "maybe inactive"
c/src/proactor/win_iocp.cpp:2447
↓ 5 callersFunctionwin_credential_decref
Hack strategy for Proton object refcounting. Just hold the lock for incref. Use the next two functions for decref, one with, the other without the lo
c/src/ssl/schannel.cpp:155
↓ 5 callersFunctionwin_credential_delete
c/src/ssl/schannel.cpp:161
↓ 5 callersMethodwork_queue
cpp/src/work_queue.cpp:34
↓ 5 callersFunctionwrite_connect_conf
(obj)
python/tests/proton_tests/connect.py:29
↓ 4 callersMethodApplicationProperties
Properties set by the application to be carried with the message. Values must be simple types (not maps, lists or sequences)
go/pkg/amqp/message.go:122
↓ 4 callersMethodCPtr
CPtr returns the unsafe C pointer, equivalent to a C void*.
go/pkg/proton/wrappers.go:52
↓ 4 callersFunctionEndpointError
EndpointError returns the remote error if there is one, the local error if not nil if there is no error.
go/pkg/proton/wrappers.go:205
↓ 4 callersMethodFlow
(credit int)
go/pkg/proton/wrappers_gen.go:366
↓ 4 callersMethodFree
()
go/pkg/proton/wrappers.go:120
↓ 4 callersMethodIsReceiver
IsReceiver is true if this is the receiving end of the link.
go/pkg/electron/link.go:45
↓ 4 callersMethodLocalUninit
()
go/pkg/proton/wrappers.go:163
↓ 4 callersMethodNext
()
go/pkg/proton/wrappers.go:124
↓ 4 callersMethodReceiver
Receiver opens a new Receiver.
go/pkg/electron/session.go:34
↓ 4 callersMethodRemoteTarget
()
go/pkg/proton/wrappers_gen.go:318
← previousnext →1,101–1,200 of 8,826, ranked by callers