Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/qpid-proton
/ functions
Functions
8,826 in github.com/apache/qpid-proton
⨍
Functions
8,826
◇
Types & classes
1,881
↓ 5 callers
Function
pn_link_drained
c/src/core/engine.c:2071
↓ 5 callers
Function
pn_link_remote_properties
c/src/core/engine.c:2173
↓ 5 callers
Function
pn_link_set_rcv_settle_mode
c/src/core/engine.c:2031
↓ 5 callers
Function
pn_list_minpop
c/src/core/object/list.c:149
↓ 5 callers
Function
pn_listener_proactor
c/src/proactor/epoll.c:1871
↓ 5 callers
Function
pn_message_properties
c/src/core/message.c:1058
↓ 5 callers
Function
pn_message_send
c/src/core/message.c:1092
↓ 5 callers
Function
pn_message_set_inferred
c/src/core/message.c:453
↓ 5 callers
Function
pn_record_set_handler
c/src/reactor/reactor.c:248
↓ 5 callers
Function
pn_sasl_allowed_mechs
c/src/sasl/sasl.c:863
↓ 5 callers
Function
pn_sasl_set_allow_insecure_mechs
c/src/sasl/sasl.c:870
↓ 5 callers
Function
pn_selectable_on_finalize
c/src/reactor/selectable.c:165
↓ 5 callers
Function
pn_session_free
c/src/core/engine.c:287
↓ 5 callers
Function
pn_session_next
c/src/core/engine.c:875
↓ 5 callers
Function
pn_ssl_get_remote_subject
c/src/ssl/openssl.c:1554
↓ 5 callers
Function
pn_string_buffer
c/src/core/object/string.c:256
↓ 5 callers
Function
pn_terminus_filter
c/src/core/engine.c:1463
↓ 5 callers
Function
pn_terminus_properties
c/src/core/engine.c:1439
↓ 5 callers
Function
pn_tls
c/src/tls/openssl.c:1102
↓ 5 callers
Function
pn_tls_close_output
c/src/tls/openssl.c:2282
↓ 5 callers
Function
pn_tls_get_session_error
c/src/tls/openssl.c:416
↓ 5 callers
Function
pn_tls_give_encrypt_input_buffers
c/src/tls/openssl.c:1586
↓ 5 callers
Function
pn_tls_start
c/src/tls/openssl.c:1124
↓ 5 callers
Function
pn_tls_stop
c/src/tls/openssl.c:1150
↓ 5 callers
Function
pn_tracker_store
c/src/messenger/messenger.c:2032
↓ 5 callers
Function
pn_transport_attachments
c/src/core/transport.c:2799
↓ 5 callers
Function
pn_transport_get_remote_idle_timeout
c/src/core/transport.c:2893
↓ 5 callers
Function
pn_transport_process
c/src/core/transport.c:2983
↓ 5 callers
Function
pn_value_dump_nondescribed_value
c/src/core/value_dump.c:504
↓ 5 callers
Function
pni_emitter_writev32
c/src/core/emitters.h:154
↓ 5 callers
Function
pni_ep_get_connection
c/src/core/engine.c:61
↓ 5 callers
Function
pni_inspect_atom
c/src/core/codec.c:113
↓ 5 callers
Function
pni_iocp_begin_close
c/src/reactor/io/windows/iocp.c:1107
↓ 5 callers
Function
pni_iocp_drain_completions
c/src/reactor/io/windows/iocp.c:879
↓ 5 callers
Function
pni_iocpdesc_create
c/src/reactor/io/windows/iocp.c:774
↓ 5 callers
Function
pni_iocpdesc_map_del
c/src/reactor/io/windows/iocp.c:816
↓ 5 callers
Function
pni_matches
c/src/core/engine.c:843
↓ 5 callers
Function
pni_raw_connected
c/src/proactor/raw_connection.c:466
↓ 5 callers
Function
pni_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 callers
Function
pni_raw_wdrained
Return whether closed for application and all writes drained
c/src/proactor/raw_connection.c:179
↓ 5 callers
Function
pni_selectable_set_context
c/src/reactor/selectable.c:180
↓ 5 callers
Function
pni_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 callers
Function
pni_switch_to_raw_multiple
c/src/core/util.h:129
↓ 5 callers
Function
pni_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 callers
Function
pni_track_common
c/src/core/memory.c:155
↓ 5 callers
Function
pni_transport
c/src/messenger/messenger.c:162
↓ 5 callers
Function
pni_value_dump
c/src/core/value_dump.c:584
↓ 5 callers
Function
pni_win32_error
c/src/proactor/win_iocp.cpp:564
↓ 5 callers
Function
pni_write_pipeline_return
c/src/proactor/win_iocp.cpp:488
↓ 5 callers
Function
pni_write_pipeline_return
c/src/reactor/io/windows/write_pipeline.c:296
↓ 5 callers
Method
port
ruby/lib/core/url.rb:61
↓ 5 callers
Method
port_int
cpp/src/url.cpp:256
↓ 5 callers
Function
proactor_add
c/src/proactor/epoll.c:2149
↓ 5 callers
Function
proactor_wake
Call wih lock held
c/src/proactor/win_iocp.cpp:1877
↓ 5 callers
Method
push_event
( self, obj: Union['Reactor', Task, 'Container', Selectable], etype: Event
python/proton/_reactor.py:402
↓ 5 callers
Method
put_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 callers
Method
put_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 callers
Function
reap_check
c/src/proactor/win_iocp.cpp:1355
↓ 5 callers
Method
receiver
cpp/src/receiver.cpp:40
↓ 5 callers
Method
receiver
@return [Receiver, nil] receiver associated with this event
ruby/lib/core/event.rb:124
↓ 5 callers
Method
run
cpp/examples/service_bus.cpp:217
↓ 5 callers
Method
running
Number of threads in {#run} @return [Bool] {#run} thread count
ruby/lib/core/container.rb:112
↓ 5 callers
Function
schedule_done
call with task lock held from xxx_process().
c/src/proactor/epoll.c:329
↓ 5 callers
Function
schedule_if_inactive
If inactive set need_inactive and return true if poller needs to be unblocked */
c/src/proactor/epoll.c:1425
↓ 5 callers
Function
secs2millis
(secs: Union[float, int])
python/proton/_common.py:32
↓ 5 callers
Function
sequence_lte
c/src/core/transport.c:1545
↓ 5 callers
Function
set_error_condition
cpp/src/proton_bits.cpp:63
↓ 5 callers
Method
settle
@deprecated internal use only
ruby/lib/core/transfer.rb:96
↓ 5 callers
Method
ssl
cpp/src/transport.cpp:41
↓ 5 callers
Function
start_ssl_shutdown
c/src/ssl/schannel.cpp:1457
↓ 5 callers
Method
state
@return [Integer] Remote state of the transfer, one of the values in {State}
ruby/lib/core/transfer.rb:58
↓ 5 callers
Function
statistics_start
c/tools/msgr-common.c:106
↓ 5 callers
Method
stop
(self)
python/tests/proton_tests/common.py:228
↓ 5 callers
Function
stop_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 callers
Method
store_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 callers
Function
task_finalize
c/src/proactor/epoll-internal.h:367
↓ 5 callers
Function
task_init
c/src/proactor/epoll.c:224
↓ 5 callers
Method
testGarbage
(self, garbage=b"GARBAGE_")
python/tests/proton_tests/transport.py:76
↓ 5 callers
Method
testMultipleUnsettled
(self, count=1024, size=1024)
python/tests/proton_tests/engine.py:2027
↓ 5 callers
Function
test_broker
()
python/tests/integration/test_PROTON_2121_blocking_connection_fd_leak.py:94
↓ 5 callers
Method
test_client_server
(self, client=['client.py'], server=['server.py'], sleep=0)
python/examples/test_examples.py:81
↓ 5 callers
Function
translateActiveException
tests/include/catch.hpp:12524
↓ 5 callers
Method
type
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 callers
Function
uv_safe_close
c/src/proactor/libuv.c:440
↓ 5 callers
Function
verify
cpp/examples/flow_control.cpp:44
↓ 5 callers
Function
wake_if_inactive
Call whenever transitioning from "definitely active" to "maybe inactive"
c/src/proactor/win_iocp.cpp:2447
↓ 5 callers
Function
win_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 callers
Function
win_credential_delete
c/src/ssl/schannel.cpp:161
↓ 5 callers
Method
work_queue
cpp/src/work_queue.cpp:34
↓ 5 callers
Function
write_connect_conf
(obj)
python/tests/proton_tests/connect.py:29
↓ 4 callers
Method
ApplicationProperties
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 callers
Method
CPtr
CPtr returns the unsafe C pointer, equivalent to a C void*.
go/pkg/proton/wrappers.go:52
↓ 4 callers
Function
EndpointError
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 callers
Method
Flow
(credit int)
go/pkg/proton/wrappers_gen.go:366
↓ 4 callers
Method
Free
()
go/pkg/proton/wrappers.go:120
↓ 4 callers
Method
IsReceiver
IsReceiver is true if this is the receiving end of the link.
go/pkg/electron/link.go:45
↓ 4 callers
Method
LocalUninit
()
go/pkg/proton/wrappers.go:163
↓ 4 callers
Method
Next
()
go/pkg/proton/wrappers.go:124
↓ 4 callers
Method
Receiver
Receiver opens a new Receiver.
go/pkg/electron/session.go:34
↓ 4 callers
Method
RemoteTarget
()
go/pkg/proton/wrappers_gen.go:318
← previous
next →
1,101–1,200 of 8,826, ranked by callers