MCPcopy Create free account

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

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

⨍ Functions 8,826◇ Types & classes 1,881
↓ 6 callersFunctionlistening_port
c/tests/pn_test_proactor.cpp:37
↓ 6 callersFunctionmillis2secs
(millis: int)
python/proton/_common.py:36
↓ 6 callersFunctionnotify
Notify the leader thread that there is something to do outside of uv_run() */
c/src/proactor/libuv.c:262
↓ 6 callersFunctionobj2dat
(obj, dimpl)
python/proton/_data.py:1649
↓ 6 callersFunctionpconnection_is_final
Call with lock held and closing == true (i.e. pn_connection_driver_finished() == true), no pending timer. Return true when all possible outstanding ep
c/src/proactor/epoll.c:832
↓ 6 callersFunctionpconnection_rclosed
Shortcuts */
c/src/proactor/epoll.c:962
↓ 6 callersMethodpending
Get the number of pending output bytes following the transport's head pointer. :return: The number of pending output bytes.
python/proton/_transport.py:316
↓ 6 callersFunctionpn_buffer_trim
c/src/core/buffer.c:194
↓ 6 callersFunctionpn_class_equals
c/src/core/object/object.c:252
↓ 6 callersFunctionpn_collector_pop
c/src/core/event.c:204
↓ 6 callersFunctionpn_collector_release
c/src/core/event.c:125
↓ 6 callersFunctionpn_condition_info
c/src/core/engine.c:2402
↓ 6 callersFunctionpn_condition_init
c/src/core/engine.c:223
↓ 6 callersFunctionpn_condition_tini
c/src/core/engine.c:237
↓ 6 callersFunctionpn_connection_driver_write_closed
c/src/core/connection_driver.c:127
↓ 6 callersFunctionpn_connection_set_context
c/src/core/engine.c:211
↓ 6 callersFunctionpn_data_encode
c/src/core/codec.c:1573
↓ 6 callersFunctionpn_data_get_byte
c/src/core/codec.c:1922
↓ 6 callersFunctionpn_data_get_int
c/src/core/codec.c:1962
↓ 6 callersFunctionpn_data_get_short
c/src/core/codec.c:1942
↓ 6 callersFunctionpn_data_get_ubyte
c/src/core/codec.c:1912
↓ 6 callersFunctionpn_data_get_ushort
c/src/core/codec.c:1932
↓ 6 callersFunctionpn_data_put_bool
c/src/core/codec.c:1648
↓ 6 callersFunctionpn_data_put_long
c/src/core/codec.c:1729
↓ 6 callersFunctionpn_data_put_uint
c/src/core/codec.c:1693
↓ 6 callersFunctionpn_data_put_ulong
c/src/core/codec.c:1720
↓ 6 callersFunctionpn_delivery_abort
c/src/core/engine.c:2270
↓ 6 callersFunctionpn_delivery_current
c/src/core/engine.c:1793
↓ 6 callersFunctionpn_error_report
c/src/messenger/messenger.c:214
↓ 6 callersFunctionpn_link_name
c/src/core/engine.c:1556
↓ 6 callersFunctionpn_listener_accept2
c/src/proactor/epoll.c:1891
↓ 6 callersFunctionpn_listener_condition
c/src/proactor/epoll.c:1875
↓ 6 callersFunctionpn_listener_free
c/src/proactor/epoll.c:1644
↓ 6 callersFunctionpn_message_encode2
c/src/core/message.c:1072
↓ 6 callersFunctionpn_message_get_address
c/src/core/message.c:580
↓ 6 callersFunctionpn_message_set_id
c/src/core/message.c:550
↓ 6 callersFunctionpn_messenger_flow
Run the credit scheduler, grant flow as needed. Return True if credit allocation for any link has changed.
c/src/messenger/messenger.c:863
↓ 6 callersFunctionpn_messenger_incoming
c/src/messenger/messenger.c:2345
↓ 6 callersFunctionpn_proactor_disconnect
c/src/proactor/epoll.c:2860
↓ 6 callersFunctionpn_proactor_now_64
c/src/proactor/win_iocp.cpp:3436
↓ 6 callersFunctionpn_raw_connection
Empty stubs for raw connection code
c/src/proactor/libuv.c:1388
↓ 6 callersFunctionpn_raw_connection_set_context
c/src/proactor/raw_connection.c:837
↓ 6 callersFunctionpn_record_get_handler
c/src/reactor/reactor.c:241
↓ 6 callersFunctionpn_selectable_set_deadline
c/src/reactor/selectable.c:135
↓ 6 callersFunctionpn_session_set_incoming_window_and_lwm
c/src/core/engine.c:1145
↓ 6 callersFunctionpn_set_error_layer
c/src/core/transport.c:262
↓ 6 callersFunctionpn_ssl_domain_set_trusted_ca_db
c/src/ssl/openssl.c:833
↓ 6 callersFunctionpn_stringn
c/src/core/object/string.c:109
↓ 6 callersFunctionpn_terminus_set_dynamic
c/src/core/engine.c:1432
↓ 6 callersFunctionpn_terminus_set_timeout
c/src/core/engine.c:1420
↓ 6 callersFunctionpn_tls_config
c/src/tls/openssl.c:892
↓ 6 callersFunctionpn_transport_tail
c/src/core/transport.c:2952
↓ 6 callersFunctionpni_add_tpwork
c/src/core/engine.c:782
↓ 6 callersFunctionpni_channel_state
c/src/core/transport.c:494
↓ 6 callersFunctionpni_check_sasl_result
c/src/sasl/cyrus_sasl.c:112
↓ 6 callersFunctionpni_class_free
c/src/core/object/object.c:168
↓ 6 callersFunctionpni_conn_modified
c/src/messenger/messenger.c:229
↓ 6 callersFunctionpni_delivery_map_clear
c/src/core/transport.c:128
↓ 6 callersFunctionpni_emit
c/src/sasl/sasl.c:377
↓ 6 callersFunctionpni_logger_log
c/src/core/logger.c:264
↓ 6 callersFunctionpni_mem_allocate
c/src/core/memory.c:224
↓ 6 callersFunctionpni_proactor_set_cond
c/src/proactor/proactor-internal.c:74
↓ 6 callersFunctionpni_raw_rclosed
Closed for reading by application
c/src/proactor/raw_connection.c:121
↓ 6 callersFunctionpni_selectable_set_index
c/src/reactor/selectable.c:192
↓ 6 callersFunctionpni_store_entry
c/src/messenger/store.c:343
↓ 6 callersMethodprint_error
Logs an error message related to an error condition at an endpoint. :param endpoint: The endpoint to be tested :param endpoi
python/proton/_handlers.py:387
↓ 6 callersMethodpush_event
( self, context: 'Selectable', etype: 'EventType', )
python/proton/_selectable.py:76
↓ 6 callersFunctionputData
==== put message to pn_message_t
go/pkg/amqp/message.go:505
↓ 6 callersMethodput_list
Puts a list value. Elements may be filled by entering the list node and putting element values. >>> data = Data()
python/proton/_data.py:830
↓ 6 callersFunctionread
cpp/src/interop_test.cpp:45
↓ 6 callersFunctionrecode
c/tests/message_test.cpp:41
↓ 6 callersMethodreply_to_group_id
Returns the reply-to group id.
ruby/lib/core/message.rb:479
↓ 6 callersFunctionrewind_sc_inbuf
c/src/ssl/schannel.cpp:1481
↓ 6 callersFunctionroom
c/src/tls/openssl.c:1473
↓ 6 callersFunctionroundTrip
(m Message)
go/pkg/amqp/message_test.go:30
↓ 6 callersFunctionset_iocp_error_status
c/src/proactor/win_iocp.cpp:547
↓ 6 callersMethodshowDurations
tests/include/catch.hpp:10005
↓ 6 callersMethodtarget
Returns the locally defined target terminus. @return [Terminus] The terminus.
ruby/lib/core/link.rb:241
↓ 6 callersMethodtoString
tests/include/catch.hpp:7895
↓ 6 callersMethoduint
If the current node is an unsigned int, returns its value. Otherwise, returns 0. @return [Integer] The unsigned integer value.
ruby/lib/codec/data.rb:352
↓ 6 callersMethodulong
If the current node is an unsigned long, returns its value. Otherwise, returns 0. @return [Integer] The unsigned long value.
ruby/lib/codec/data.rb:406
↓ 6 callersMethodushort
If the current node is an unsigned short, returns its value. Otherwise, it returns 0. @return [Integer] The unsigned short value.
ruby/lib/codec/data.rb:316
↓ 6 callersFunctionvalidate
cpp/src/connect_config.cpp:68
↓ 6 callersMethodwhat
tests/include/catch.hpp:10974
↓ 6 callersFunctionwrite_flush
Never call with any locks held.
c/src/proactor/epoll.c:1092
↓ 5 callersMethodContainer
Container for the connection.
go/pkg/electron/connection.go:79
↓ 5 callersMethodContains
tests/include/catch.hpp:4974
↓ 5 callersMethodCopy
Copy the contents of another message to this one.
go/pkg/amqp/message.go:169
↓ 5 callersMethodCredit
Not part of Link interface but use by Sender and Receiver.
go/pkg/electron/link.go:287
↓ 5 callersMethodIncoming
Incoming returns a channel for incoming endpoints opened by the remote peer. See the Incoming interface for more detail. Note: this channel will firs
go/pkg/electron/connection.go:102
↓ 5 callersMethodInjectWait
InjectWait is like Inject but does not return till f() has completed. If f() cannot be injected it returns the error from Inject(), otherwise it retur
go/pkg/proton/engine.go:69
↓ 5 callersFunctionPnError
(e *C.pn_error_t)
go/pkg/proton/error.go:61
↓ 5 callersMethodRemoteSource
()
go/pkg/proton/wrappers_gen.go:315
↓ 5 callersMethodSendAsync
SendAsync puts a message in the send buffer and returns immediately. An Outcome with Value = value will be sent to the ack channel when the remote re
go/pkg/electron/sender.go:73
↓ 5 callersMethodSender
Sender opens a new sender.
go/pkg/electron/session.go:31
↓ 5 callersMethodSetError
Set a Go error into a condition, converting to an amqp.Error using amqp.MakeError
go/pkg/proton/wrappers.go:382
↓ 5 callersMethodSettle
()
go/pkg/proton/wrappers_gen.go:445
↓ 5 callersMethodSettleAs
SettleAs is equivalent to d.Update(disposition); d.Settle()
go/pkg/proton/wrappers.go:222
↓ 5 callersFunctionTarget
Target returns a LinkOption that sets address that messages are going to.
go/pkg/electron/link.go:73
↓ 5 callersMethod__init__
(self, reactor: 'Container', deadline: float, handler: Handler)
python/proton/_reactor.py:82
← previousnext →901–1,000 of 8,826, ranked by callers