MCPcopy Create free account

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

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

↓ 14 callersMethodsender
The sender link associated with the event, or ``None`` if none is associated with it. This is essentially an alias for ``link
python/proton/_events.py:567
↓ 14 callersFunctionunmarshal
Unmarshal from data into value pointed at by v. Returns v. NOTE: If you update this you also need to update getInterface()
go/pkg/amqp/unmarshal.go:291
↓ 14 callersMethodupdate
(transport: Transport, selectable: Selectable, now: float)
python/proton/_handlers.py:1304
↓ 13 callersMethod_test
(self, dtype, *values, **kwargs)
python/tests/proton_tests/codec.py:357
↓ 13 callersMethodadd_credit
cpp/src/receiver.cpp:61
↓ 13 callersMethoddecode
(self, data: bytes)
python/proton/_message.py:489
↓ 13 callersMethodget_cert_fingerprint
Get the fingerprint of the certificate. The certificate fingerprint (as displayed in the Fingerprints section when looking at a certi
python/proton/_transport.py:1030
↓ 13 callersMethodimpl
Returns the underlying message implementation.
ruby/lib/core/message.rb:110
↓ 13 callersMethodint
If the current node is an integer, returns its value. Otherwise, returns 0. @return [Integer] The integer value.
ruby/lib/codec/data.rb:370
↓ 13 callersFunctioniocp_log
c/src/proactor/win_iocp.cpp:538
↓ 13 callersMethodmk_funcall
(name: str, args: List[str])
c/tools/codec-generator/generate.py:32
↓ 13 callersFunctionpanicUnless
(ok bool, data *C.pn_data_t, v interface{})
go/pkg/amqp/unmarshal.go:83
↓ 13 callersFunctionpn_data_error
c/src/core/codec.c:416
↓ 13 callersFunctionpn_data_put_binary
c/src/core/codec.c:1801
↓ 13 callersFunctionpn_data_put_null
c/src/core/codec.c:1640
↓ 13 callersFunctionpn_equals
c/src/core/object/object.c:369
↓ 13 callersFunctionpn_error
c/src/core/error.c:42
↓ 13 callersFunctionpn_error_free
c/src/core/error.c:54
↓ 13 callersFunctionpn_event_raw_connection
c/src/proactor/raw_connection.c:847
↓ 13 callersFunctionpn_list_del
c/src/core/object/list.c:111
↓ 13 callersFunctionpn_proactor_set_timeout
c/src/proactor/epoll.c:2803
↓ 13 callersFunctionpn_raw_connection_write_buffers
c/src/proactor/raw_connection.c:347
↓ 13 callersFunctionpn_receiver
c/src/core/engine.c:1546
↓ 13 callersFunctionpn_record
c/src/core/object/record.c:63
↓ 13 callersFunctionpn_ssl_domain_free
c/src/ssl/openssl.c:609
↓ 13 callersFunctionpn_transport_set_max_frame
c/src/core/transport.c:2866
↓ 13 callersMethodread
c/tests/pn_test.cpp:137
↓ 13 callersFunctionssl_failed
unrecoverable SSL failure occured, notify transport and generate error code.
c/src/ssl/schannel.cpp:426
↓ 13 callersMethodtarget
cpp/src/sender.cpp:59
↓ 13 callersMethodto_s
@return [String] Convert to string
ruby/lib/core/url.rb:66
↓ 12 callersFunction_sslConnection
(domain, transport, connection)
python/tests/proton_tests/sasl.py:379
↓ 12 callersMethod_test
(self, name, default, values)
python/tests/proton_tests/message.py:40
↓ 12 callersMethodassertRaises
(self, exception, function, *args, **kwargs)
python/tests/proton_tests/url.py:102
↓ 12 callersMethodassertUrl
(self, u, scheme, username, password, host, port, path)
python/tests/proton_tests/url.py:32
↓ 12 callersMethodcleanup
(self)
python/tests/proton_tests/engine.py:95
↓ 12 callersMethodclosed
Called in handler goroutine when endpoint is remotely closed.
go/pkg/electron/endpoint.go:78
↓ 12 callersMethodgetResultType
tests/include/catch.hpp:8325
↓ 12 callersMethodlink_count
cpp/src/connection_driver_test.cpp:172
↓ 12 callersMethodlisten
(self, container)
python/tests/proton_tests/reactor.py:670
↓ 12 callersFunctionpmutex_finalize
c/src/proactor/epoll-internal.h:342
↓ 12 callersFunctionpn_buffer_size
c/src/core/buffer.c:74
↓ 12 callersFunctionpn_collector_free
c/src/core/event.c:118
↓ 12 callersFunctionpn_collector_next
c/src/core/event.c:212
↓ 12 callersFunctionpn_condition_set_name
c/src/core/engine.c:2345
↓ 12 callersFunctionpn_connection_driver_init
c/src/core/connection_driver.c:51
↓ 12 callersFunctionpn_connection_wake
c/src/proactor/epoll.c:1488
↓ 12 callersFunctionpn_data_put_map
c/src/core/codec.c:1608
↓ 12 callersFunctionpn_delivery_update
c/src/core/engine.c:2230
↓ 12 callersFunctionpn_ep_decref
c/src/core/engine.c:466
↓ 12 callersFunctionpn_framing_send_amqp
c/src/core/framing.c:143
↓ 12 callersFunctionpn_listener
c/src/proactor/epoll.c:1526
↓ 12 callersFunctionpn_map_put
c/src/core/object/map.c:248
↓ 12 callersFunctionpn_modified
c/src/core/engine.c:820
↓ 12 callersFunctionpn_proactor_free
c/src/proactor/epoll.c:2026
↓ 12 callersFunctionpn_proactor_get
c/src/proactor/epoll.c:2743
↓ 12 callersFunctionpn_reactor_update
c/src/reactor/reactor.c:212
↓ 12 callersFunctionpn_session_close
c/src/core/engine.c:281
↓ 12 callersFunctionpn_transport_close_tail
input stream has closed
c/src/core/transport.c:3000
↓ 12 callersFunctionpn_transport_get_max_frame
c/src/core/transport.c:2861
↓ 12 callersFunctionpni_mem_subdeallocate
c/src/core/memory.c:253
↓ 12 callersMethodrngSeed
tests/include/catch.hpp:10008
↓ 12 callersMethodschedule
(see WorkQueue#schedule)
ruby/lib/core/container.rb:249
↓ 12 callersMethodsender
Return a client sender and server receiver
go/pkg/electron/common_test.go:106
↓ 12 callersMethodsession
The session associated with the event, or ``None`` if none is associated with it.
python/proton/_events.py:551
↓ 12 callersMethodsession_head
Retrieve the first session from a given connection that matches the specified state mask. Examines the state of each session
python/proton/_endpoints.py:438
↓ 12 callersMethodset
cpp/src/scalar_base.cpp:50
↓ 12 callersMethodsleep
(t: float)
python/proton/_io.py:75
↓ 12 callersMethodtick
Process any pending transport timer events (like heartbeat generation). This method should be called after all pending input has bee
python/proton/_transport.py:257
↓ 12 callersMethodtransport
@return [Transport, nil] transport for this event
ruby/lib/core/event.rb:109
↓ 12 callersMethodupdate
(self, selectable: Selectable)
python/proton/_reactor.py:399
↓ 12 callersMethodvalue
cpp/src/map.cpp:137
↓ 12 callersMethodvirtual_host
cpp/src/connection.cpp:70
↓ 12 callersFunctionwakeup
Call wih lock held
c/src/proactor/win_iocp.cpp:1862
↓ 11 callersMethodDone
Done returns a channel that will close when the endpoint closes. After Done() has closed, Error() will return the reason for closing.
go/pkg/electron/endpoint.go:60
↓ 11 callersMethodInject
Inject a function into the engine goroutine. f() will be called in the same goroutine as event handlers, so it can safely use values belonging to eve
go/pkg/proton/engine.go:64
↓ 11 callersMethodOpen
Open an endpoint.
go/pkg/proton/wrappers.go:181
↓ 11 callersMethod__init__
(self, p)
python/tests/proton_tests/reactor.py:200
↓ 11 callersMethod_do_handshake
Attempt to connect client to server. Will throw a TransportException if the SSL handshake fails.
python/tests/proton_tests/ssl.py:84
↓ 11 callersFunctioncheck
cpp/src/message.cpp:119
↓ 11 callersFunctioncheckDecodeInterface
checkDecodeValue: want is the expected value, decode into a reflect.Value
go/pkg/amqp/interop_test.go:163
↓ 11 callersMethodexecute
tests/include/catch.hpp:13348
↓ 11 callersMethodextend
Add all elements of an iterable t to the end of the list
python/proton/_data.py:533
↓ 11 callersMethodget
c/tests/pn_test.hpp:57
↓ 11 callersFunctiongetReader
(t *testing.T, name string)
go/pkg/amqp/interop_test.go:39
↓ 11 callersFunctionhandle
c/tests/threaderciser.c:407
↓ 11 callersFunctioniocpdesc_fail
c/src/proactor/win_iocp.cpp:573
↓ 11 callersMethodname
tests/include/catch.hpp:10001
↓ 11 callersMethodobject
Gets the current node, based on how it was encoded. @return [Object] The current node.
ruby/lib/codec/data.rb:240
↓ 11 callersMethodpassword
cpp/src/url.cpp:244
↓ 11 callersFunctionpn_code
c/src/core/error.c:126
↓ 11 callersFunctionpn_condition
c/src/core/engine.c:231
↓ 11 callersFunctionpn_condition_format
c/src/core/engine.c:2392
↓ 11 callersFunctionpn_condition_set_description
c/src/core/engine.c:2366
↓ 11 callersFunctionpn_data_free
c/src/core/codec.c:406
↓ 11 callersFunctionpn_fixed_string
c/src/core/fixed_string.h:45
↓ 11 callersFunctionpn_hash
c/src/core/object/map.c:409
↓ 11 callersFunctionpn_link_set_drain
c/src/core/engine.c:2134
↓ 11 callersFunctionpn_message_is_inferred
c/src/core/message.c:447
↓ 11 callersFunctionpn_proactor_listen
c/src/proactor/epoll.c:1543
↓ 11 callersFunctionpn_session_state
c/src/core/engine.c:1196
← previousnext →401–500 of 8,826, ranked by callers