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
↓ 213 callers
Function
assert_equal
cpp/src/test_bits.hpp:43
↓ 189 callers
Function
pn_free
c/src/core/object/object.c:310
↓ 185 callers
Method
open
Opens the link. In more detail, this moves the local state of the link to the :const:`LOCAL_ACTIVE` state and triggers an at
python/proton/_endpoints.py:749
↓ 184 callers
Method
pump
(self, buffer_size=OUTPUT_SIZE)
python/tests/proton_tests/engine.py:98
↓ 168 callers
Function
pn_fixed_string_addf
c/src/core/fixed_string.h:74
↓ 152 callers
Method
Error
Error returns nil if the endpoint is open, otherwise returns an error. Error() == Closed means the endpoint was closed without error.
go/pkg/electron/endpoint.go:53
↓ 149 callers
Method
size
cpp/src/map.cpp:182
↓ 147 callers
Function
pn_decref
c/src/core/object/object.c:279
↓ 134 callers
Method
size
tests/include/catch.hpp:651
↓ 133 callers
Method
empty
cpp/src/url.cpp:251
↓ 131 callers
Function
print
Print a value, for example purposes. Normal code can use operator<<
cpp/examples/encode_decode.cpp:243
↓ 130 callers
Method
close
(s: socket.socket)
python/proton/_io.py:41
↓ 127 callers
Function
pn_event_type
c/src/core/event.c:290
↓ 126 callers
Function
pn_event_connection
c/src/core/engine.c:2440
↓ 121 callers
Function
pn_refcount
c/src/core/object/object.c:303
↓ 115 callers
Method
append
Add a single value v to the end of the list
python/proton/_data.py:529
↓ 115 callers
Function
str
cpp/src/test_bits.hpp:103
↓ 113 callers
Method
join
()
ruby/tests/test_tools.rb:171
↓ 113 callers
Function
pn_string
c/src/core/object/string.c:101
↓ 109 callers
Function
unlock
c/src/proactor/epoll-internal.h:344
↓ 103 callers
Function
pn_string_get
c/src/core/object/string.c:119
↓ 100 callers
Method
run
Run the container: wait for IO activity, dispatch events to handlers. Multi-threaading* : More than one thread can call {#run} concurrently, the cont
ruby/lib/core/container.rb:191
↓ 92 callers
Method
connection
cpp/src/link.cpp:78
↓ 91 callers
Function
get
cpp/src/connect_config.cpp:74
↓ 89 callers
Function
lock
c/src/proactor/epoll-internal.h:343
↓ 89 callers
Function
pn_list_size
c/src/core/object/list.c:35
↓ 85 callers
Method
what
cpp/src/error_condition.cpp:78
↓ 82 callers
Function
Equals
tests/include/catch.hpp:3749
↓ 80 callers
Method
body
cpp/src/message.cpp:236
↓ 79 callers
Method
client
cpp/examples/client.cpp:47
↓ 79 callers
Method
empty
named queries
tests/include/catch.hpp:648
↓ 78 callers
Method
connection
Returns the parent connection. @return [Connection] The connection.
ruby/lib/core/link.rb:273
↓ 77 callers
Function
check
cpp/src/decoder.cpp:52
↓ 76 callers
Function
pn_list_get
c/src/core/object/list.c:41
↓ 70 callers
Method
assertEqual
(self, a, b)
python/tests/proton_tests/url.py:26
↓ 70 callers
Method
next
Advances the current node to its next sibling and returns its type. If there is no next sibling the current node remains unch
python/proton/_data.py:716
↓ 69 callers
Method
collect
(self, collector: 'Collector')
python/proton/_endpoints.py:215
↓ 69 callers
Method
expect
(self, *types)
python/tests/proton_tests/engine.py:2419
↓ 69 callers
Function
pn_class_new
c/src/core/object/object.c:176
↓ 68 callers
Method
end
tests/include/catch.hpp:8639
↓ 65 callers
Method
bind
Assign a connection to the transport. :param connection: Connection to which to bind. :raise: :exc:`TransportException` if t
python/proton/_transport.py:218
↓ 65 callers
Function
pn_connection_close
c/src/core/engine.c:126
↓ 63 callers
Function
Differ
if reflect.DeepEqual(want, got) { return nil } else { return error("want != got" })
go/pkg/internal/test/test.go:71
↓ 63 callers
Method
get
(self)
python/examples/client_http.py:80
↓ 63 callers
Function
pn_link_credit
c/src/core/engine.c:1976
↓ 61 callers
Method
handler
c/tests/pn_test.cpp:93
↓ 61 callers
Function
make
cpp/src/scalar_test.hpp:158
↓ 61 callers
Function
pn_event_link
c/src/core/engine.c:2475
↓ 60 callers
Function
range
tests/include/catch.hpp:4700
↓ 59 callers
Function
pn_bytes
c/tests/pn_test.cpp:73
↓ 58 callers
Method
c_str
tests/include/catch.hpp:13919
↓ 58 callers
Function
pn_list_add
c/src/core/object/list.c:68
↓ 58 callers
Function
pni_raw_event_next
c/src/proactor/raw_connection.c:732
↓ 57 callers
Method
begin
tests/include/catch.hpp:8638
↓ 55 callers
Function
stringify
tests/include/catch.hpp:1644
↓ 54 callers
Method
open
Open the {Sender} link @overload open_sender(address) @param address [String] address of the target to send to @overload open_sender(opts) @option op
ruby/lib/core/sender.rb:42
↓ 54 callers
Function
pn_bytes_free
c/src/core/util.h:65
↓ 54 callers
Function
pni_raw_validate
c/src/proactor/raw_connection.c:212
↓ 54 callers
Function
random_string
Generates a random string of the specified length
ruby/spec/spec_helper.rb:59
↓ 53 callers
Method
get
cpp/src/map.cpp:155
↓ 52 callers
Method
advance
Advance the current delivery of this link to the next delivery. For sending links this operation is used to finish sending message
python/proton/_endpoints.py:876
↓ 52 callers
Function
pn_error_format
c/src/core/error.c:93
↓ 52 callers
Method
send
(self)
python/examples/db_send.py:70
↓ 52 callers
Method
set_peer_authentication
This method controls how the peer's certificate is validated, if at all. By default, servers do not attempt to verify their peers (P
python/proton/_transport.py:787
↓ 51 callers
Method
close
Close the local end of the link. The remote end may or may not be closed. @param error [Condition] Optional error condition to send with the close.
ruby/lib/core/link.rb:56
↓ 50 callers
Method
begin
cpp/include/proton/endpoint.hpp:93
↓ 50 callers
Method
mk_indent
(indent: int)
c/tools/codec-generator/generate.py:28
↓ 49 callers
Method
wait
wait for and call the accept function, call in proton goroutine.
go/pkg/electron/endpoint.go:158
↓ 48 callers
Method
end
cpp/include/proton/endpoint.hpp:94
↓ 46 callers
Function
pni_emitter_writef8
c/src/core/emitters.h:97
↓ 45 callers
Function
pn_collector_put_object
c/src/core/event.c:181
↓ 45 callers
Method
server
cpp/examples/server.cpp:41
↓ 45 callers
Function
ssl_log
c/src/ssl/openssl.c:171
↓ 45 callers
Function
unwrap
cpp/src/proton_bits.hpp:154
↓ 44 callers
Method
credit
cpp/src/link.cpp:51
↓ 44 callers
Method
run
c/tests/pn_test.cpp:124
↓ 44 callers
Method
set_credentials
(self, cert_file, key_file, password)
python/proton/_reactor.py:1137
↓ 43 callers
Function
pn_connection_open
c/src/core/engine.c:120
↓ 42 callers
Function
pn_condition_is_set
c/src/core/engine.c:2320
↓ 41 callers
Method
_pump
(self, ssl_client, ssl_server, buffer_size=1024)
python/tests/proton_tests/ssl.py:81
↓ 41 callers
Method
delivery
The delivery associated with the event, or ``None`` if none is associated with it.
python/proton/_events.py:594
↓ 41 callers
Function
make_wrapper
cpp/src/proton_bits.hpp:148
↓ 41 callers
Function
pn_hash_put
c/src/core/object/map.c:422
↓ 41 callers
Method
pop
Get the next available incoming message. If the message is unsettled, its delivery object is moved onto the unsettled queue, and can
python/proton/_utils.py:185
↓ 40 callers
Method
address
cpp/src/source.cpp:49
↓ 40 callers
Method
flow
Increases the credit issued to the remote sender by the specified number of messages. :param n: The credit to be issued to the remot
python/proton/_endpoints.py:1200
↓ 40 callers
Function
pn_data_enter
c/src/core/codec.c:1443
↓ 40 callers
Function
pn_do_error
c/src/core/transport.c:954
↓ 40 callers
Function
pn_error_text
c/src/core/error.c:109
↓ 40 callers
Function
pn_incref
c/src/core/object/object.c:270
↓ 40 callers
Function
pn_link_flow
c/src/core/engine.c:2113
↓ 40 callers
Function
pn_session_open
c/src/core/engine.c:275
↓ 40 callers
Method
properties
cpp/src/link.cpp:86
↓ 40 callers
Function
simple_type_test
cpp/src/codec_test.cpp:29
↓ 40 callers
Function
value
cpp/include/proton/value.hpp:77
↓ 39 callers
Function
pn_hash_get
c/src/core/object/map.c:427
↓ 39 callers
Function
pn_link_open
c/src/core/engine.c:338
↓ 39 callers
Function
pn_message_body
c/src/core/message.c:1065
↓ 38 callers
Function
check_url
c/tests/url_test.cpp:33
↓ 38 callers
Method
close
(self)
python/examples/db_common.py:39
next →
1–100 of 8,826, ranked by callers