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
↓ 4 callers
Function
pn_url_get_host
c/src/extra/url.c:261
↓ 4 callers
Function
pn_url_get_port
c/src/extra/url.c:262
↓ 4 callers
Function
pn_url_parse
Parse a string URL as a pn_url_t. *@param[in] url A URL string. *@return The parsed pn_url_t or NULL if url is not a valid URL string. */
c/src/extra/url.c:205
↓ 4 callers
Function
pn_url_string
Internal use only, returns the pn_string_t. Public function is pn_url_str() */
c/src/extra/url.c:153
↓ 4 callers
Function
pn_wouldblock
c/src/reactor/io/posix/io.c:331
↓ 4 callers
Function
pni_class_decref
c/src/core/object/object.c:152
↓ 4 callers
Function
pni_connection_update
c/src/reactor/connection.c:95
↓ 4 callers
Function
pni_consumer_readf64
c/src/core/consumers.h:96
↓ 4 callers
Function
pni_data_id
c/src/core/codec.c:1259
↓ 4 callers
Function
pni_data_intern_node
c/src/core/codec.c:485
↓ 4 callers
Function
pni_emitter_writev8
c/src/core/emitters.h:146
↓ 4 callers
Function
pni_entry_bytes
c/src/messenger/store.c:245
↓ 4 callers
Function
pni_entry_set_delivery
c/src/messenger/store.c:269
↓ 4 callers
Function
pni_frame_get_type_value
c/src/core/value_dump.c:59
↓ 4 callers
Function
pni_iocpdesc_create
c/src/proactor/win_iocp.cpp:1212
↓ 4 callers
Function
pni_iocpdesc_start
c/src/reactor/io/windows/iocp.c:843
↓ 4 callers
Function
pni_parse
c/src/messenger/messenger.c:1596
↓ 4 callers
Function
pni_post_flow
c/src/core/transport.c:2073
↓ 4 callers
Function
pni_raw_can_read
c/src/proactor/raw_connection.c:670
↓ 4 callers
Function
pni_raw_can_write
c/src/proactor/raw_connection.c:674
↓ 4 callers
Function
pni_raw_read_close
c/src/proactor/raw_connection.c:741
↓ 4 callers
Function
pni_raw_write_close
c/src/proactor/raw_connection.c:755
↓ 4 callers
Function
pni_read16
c/src/core/util.h:171
↓ 4 callers
Function
pni_record_find
c/src/core/object/record.c:71
↓ 4 callers
Function
pni_record_init_reactor
c/src/reactor/reactor.c:260
↓ 4 callers
Function
pni_sasl_server_included_mech
c/src/sasl/sasl.c:432
↓ 4 callers
Function
pni_store_size
c/src/messenger/store.c:104
↓ 4 callers
Function
pni_strdup
Next three not exported from Proton core. Copied for now.
c/src/tls/openssl.c:532
↓ 4 callers
Function
pni_switch_to_raw_bytes
c/src/core/util.h:100
↓ 4 callers
Function
pni_terminus_free
c/src/core/engine.c:361
↓ 4 callers
Function
pni_terminus_init
c/src/core/engine.c:1201
↓ 4 callers
Function
pni_transport_collector
c/src/core/transport.c:927
↓ 4 callers
Function
pni_transport_unbind_handles
c/src/core/transport.c:727
↓ 4 callers
Function
pnx_sasl_get_allow_insecure_mechanisms
c/src/sasl/sasl.c:89
↓ 4 callers
Function
pnx_sasl_get_external_username
c/src/sasl/sasl.c:109
↓ 4 callers
Function
pnx_sasl_set_failed
c/src/sasl/sasl.c:175
↓ 4 callers
Function
pnx_sasl_set_selected_mechanism
c/src/sasl/sasl.c:150
↓ 4 callers
Function
pnx_sasl_set_succeeded
c/src/sasl/sasl.c:157
↓ 4 callers
Method
pop
Removes ``size`` bytes of output from the pending output queue following the transport's head pointer. Calls to this functio
python/proton/_transport.py:349
↓ 4 callers
Method
process
ruby/lib/core/container.rb:294
↓ 4 callers
Function
psocket_error
c/src/proactor/epoll_raw_connection.c:61
↓ 4 callers
Function
psocket_init
c/src/proactor/epoll.c:574
↓ 4 callers
Method
put_described
Puts a described value. A described node has two children, the descriptor and the value. These are specified by entering the node
python/proton/_data.py:894
↓ 4 callers
Function
py2bytes
(py)
python/cproton.py:207
↓ 4 callers
Method
queue
(address)
ruby/examples/broker.rb:157
↓ 4 callers
Function
random
tests/include/catch.hpp:4649
↓ 4 callers
Function
random_array
Generates a random array of a random type. Returns both the array and the type.
ruby/spec/spec_helper.rb:83
↓ 4 callers
Function
raw_buffer_to_pbuffer
c/src/tls/openssl.c:1568
↓ 4 callers
Function
rbuf_pool_get
A raw buffer "pool", in name only
c/experimental/raw_plus_tls2.c:88
↓ 4 callers
Function
rbuf_pool_return
c/experimental/raw_plus_tls2.c:95
↓ 4 callers
Function
reap_check
c/src/reactor/io/windows/iocp.c:941
↓ 4 callers
Method
receiver
Connect to url
cpp/examples/multithreaded_client_flow_control.cpp:165
↓ 4 callers
Method
receiver
Return a client receiver and server sender
go/pkg/electron/common_test.go:114
↓ 4 callers
Method
reconnected
cpp/src/connection.cpp:215
↓ 4 callers
Function
recoverUnmarshal
Call unmarshal(), convert panic to error value
go/pkg/amqp/unmarshal.go:275
↓ 4 callers
Method
remote_target
Returns a representation of the remotely defined target terminus. @return [Terminus] The terminus.
ruby/lib/core/link.rb:257
↓ 4 callers
Method
senders
cpp/src/session.cpp:114
↓ 4 callers
Method
setConfig
tests/include/catch.hpp:10324
↓ 4 callers
Function
setMessageProperties
Set all message properties
go/pkg/amqp/message_test.go:105
↓ 4 callers
Function
set_client_verify_mode
cpp/src/ssl_options.cpp:48
↓ 4 callers
Function
set_cred
cpp/src/ssl_options.cpp:35
↓ 4 callers
Function
set_error
c/src/proactor/epoll_raw_connection.c:401
↓ 4 callers
Method
settle
Settle any received messages. :param state: Update the delivery of all unsettled messages with the supplied state, then
python/proton/_utils.py:290
↓ 4 callers
Function
settle_delivery
cpp/src/delivery.cpp:36
↓ 4 callers
Function
shouldIndent
tests/include/catch.hpp:15486
↓ 4 callers
Method
singlePump
c/tests/tls_test.cpp:403
↓ 4 callers
Method
socket_hard_close
c/tests/raw_connection_proactor_test.cpp:205
↓ 4 callers
Method
socket_write_close
c/tests/raw_connection_proactor_test.cpp:194
↓ 4 callers
Method
ssl
Get the :class:`SSL` session associated with this transport. If not set, then a new session will be created using ``domain`` and
python/proton/_transport.py:473
↓ 4 callers
Function
start_reading
c/src/proactor/win_iocp.cpp:1153
↓ 4 callers
Function
start_ssl_shutdown
c/src/ssl/openssl.c:1124
↓ 4 callers
Function
statistics_msg_received
c/tools/msgr-common.c:113
↓ 4 callers
Function
statistics_report
c/tools/msgr-common.c:132
↓ 4 callers
Function
step
tests/include/catch.hpp:11536
↓ 4 callers
Method
stop
Stop the container. Close all listeners and abort all connections without doing AMQP protocol close. {#stop} returns immediately, calls to {#run} wi
ruby/lib/core/container.rb:227
↓ 4 callers
Method
subject
cpp/src/message.cpp:156
↓ 4 callers
Function
swap
cpp/src/map.cpp:79
↓ 4 callers
Function
task_listener
c/src/proactor/epoll.c:630
↓ 4 callers
Method
test_helloworld
(self, example="helloworld.py")
python/examples/test_examples.py:56
↓ 4 callers
Function
test_string
c/tests/object_test.cpp:590
↓ 4 callers
Function
type_name
cpp/src/type_id.cpp:28
↓ 4 callers
Method
ubyte
If the current node is an unsigned byte, returns its value. Otherwise, it returns 0. @return [Integer] The unsigned byte value.
ruby/lib/codec/data.rb:282
↓ 4 callers
Function
uninitialized
cpp/src/endpoint.cpp:35
↓ 4 callers
Method
update
@deprecated internal use only
ruby/lib/core/transfer.rb:88
↓ 4 callers
Method
uri
Convert +s+ to an amqp: or amqps: URI This does not give the same result as the standard URI parser in all cases. Short-cut strings like "host:port"
ruby/lib/core/uri.rb:65
↓ 4 callers
Function
usage
c/tests/threaderciser.c:492
↓ 4 callers
Method
user
@return [String] User name used for authentication (outgoing connection) or the authenticated user name (incoming connection)
ruby/lib/core/connection.rb:54
↓ 4 callers
Method
user_id
Returns the user id.
ruby/lib/core/message.rb:278
↓ 4 callers
Method
valueOr
tests/include/catch.hpp:4448
↓ 4 callers
Method
verbosity
tests/include/catch.hpp:10013
↓ 4 callers
Function
win_credential
c/src/ssl/schannel.cpp:140
↓ 4 callers
Method
write_next_wake
c/tests/raw_connection_proactor_test.cpp:238
↓ 3 callers
Method
Advance
()
go/pkg/proton/wrappers_gen.go:324
↓ 3 callers
Function
Approx
tests/include/catch.hpp:3754
↓ 3 callers
Function
Capacity
Capacity returns a LinkOption that sets the link capacity
go/pkg/electron/link.go:85
↓ 3 callers
Method
CloseHead
()
go/pkg/proton/wrappers_gen.go:891
↓ 3 callers
Method
CloseTail
()
go/pkg/proton/wrappers_gen.go:876
↓ 3 callers
Method
Connection
()
go/pkg/proton/engine.go:161
↓ 3 callers
Function
DecodeMessage
(data []byte)
go/pkg/amqp/message.go:370
↓ 3 callers
Method
Filter
Filter for the link
go/pkg/electron/link.go:57
← previous
next →
1,401–1,500 of 8,826, ranked by callers