| /dports/multimedia/pipewire/pipewire-0.3.43/src/modules/module-session-manager/client-endpoint/ |
| H A D | endpoint.h | 33 struct client_endpoint;
36 struct client_endpoint *client_ep;
45 struct client_endpoint *client_ep,
|
| H A D | endpoint-stream.h | 33 struct client_endpoint;
37 struct client_endpoint *client_ep;
48 struct client_endpoint *client_ep,
|
| H A D | client-endpoint.c | 46 static struct endpoint_stream *find_stream(struct client_endpoint *this, uint32_t id) in find_stream()
62 struct client_endpoint *this = object; in client_endpoint_update()
75 struct client_endpoint *this = object; in client_endpoint_stream_update()
140 struct client_endpoint *this = data; in client_endpoint_destroy()
170 struct client_endpoint *this; in create_object()
174 this = calloc(1, sizeof(struct client_endpoint)); in create_object()
|
| H A D | client-endpoint.h | 35 struct client_endpoint { struct
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/core/end2end/fixtures/ |
| H A D | http_proxy_fixture.cc | 85 grpc_endpoint* client_endpoint; member
129 gpr_log(GPR_DEBUG, "endpoints: %p %p", conn->client_endpoint, in proxy_connection_unref()
131 grpc_endpoint_destroy(conn->client_endpoint); in proxy_connection_unref()
182 grpc_endpoint_shutdown(conn->client_endpoint, GRPC_ERROR_REF(error)); in proxy_connection_failed()
212 grpc_endpoint_write(conn->client_endpoint, &conn->client_write_buffer, in on_client_write_done()
272 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_client_read_done()
324 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_write_response_done()
351 grpc_endpoint_write(conn->client_endpoint, &conn->client_write_buffer, in on_server_connect_done()
406 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_read_request_done()
474 conn->client_endpoint = endpoint; in on_accept()
[all …]
|
| /dports/devel/grpc134/grpc-1.34.1/test/core/end2end/fixtures/ |
| H A D | http_proxy_fixture.cc | 82 grpc_endpoint* client_endpoint; member
128 gpr_log(GPR_DEBUG, "endpoints: %p %p", conn->client_endpoint, in proxy_connection_unref()
130 grpc_endpoint_destroy(conn->client_endpoint); in proxy_connection_unref()
196 grpc_endpoint_shutdown(conn->client_endpoint, GRPC_ERROR_REF(error)); in proxy_connection_failed()
228 grpc_endpoint_write(conn->client_endpoint, &conn->client_write_buffer, in on_client_write_done_locked()
310 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_client_read_done_locked()
382 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_write_response_done_locked()
421 grpc_endpoint_write(conn->client_endpoint, &conn->client_write_buffer, in on_server_connect_done_locked()
486 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_read_request_done_locked()
563 conn->client_endpoint = endpoint; in on_accept()
[all …]
|
| /dports/devel/grpc/grpc-1.42.0/test/core/end2end/fixtures/ |
| H A D | http_proxy_fixture.cc | 83 grpc_endpoint* client_endpoint; member
129 gpr_log(GPR_DEBUG, "endpoints: %p %p", conn->client_endpoint, in proxy_connection_unref()
131 grpc_endpoint_destroy(conn->client_endpoint); in proxy_connection_unref()
197 grpc_endpoint_shutdown(conn->client_endpoint, GRPC_ERROR_REF(error)); in proxy_connection_failed()
229 grpc_endpoint_write(conn->client_endpoint, &conn->client_write_buffer, in on_client_write_done_locked()
311 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_client_read_done_locked()
383 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_write_response_done_locked()
422 grpc_endpoint_write(conn->client_endpoint, &conn->client_write_buffer, in on_server_connect_done_locked()
487 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_read_request_done_locked()
562 conn->client_endpoint = endpoint; in on_accept()
[all …]
|
| /dports/devel/grpc130/grpc-1.30.2/test/core/end2end/fixtures/ |
| H A D | http_proxy_fixture.cc | 85 grpc_endpoint* client_endpoint; member
131 gpr_log(GPR_DEBUG, "endpoints: %p %p", conn->client_endpoint, in proxy_connection_unref()
133 grpc_endpoint_destroy(conn->client_endpoint); in proxy_connection_unref()
199 grpc_endpoint_shutdown(conn->client_endpoint, GRPC_ERROR_REF(error)); in proxy_connection_failed()
231 grpc_endpoint_write(conn->client_endpoint, &conn->client_write_buffer, in on_client_write_done_locked()
313 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_client_read_done_locked()
385 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_write_response_done_locked()
424 grpc_endpoint_write(conn->client_endpoint, &conn->client_write_buffer, in on_server_connect_done_locked()
489 grpc_endpoint_read(conn->client_endpoint, &conn->client_read_buffer, in on_read_request_done_locked()
567 conn->client_endpoint = endpoint; in on_accept()
[all …]
|
| /dports/multimedia/pipewire/media-session-0.4.1/src/ |
| H A D | v4l2-endpoint.c | 68 struct pw_client_endpoint *client_endpoint; member
233 pw_client_endpoint_stream_update(endpoint->client_endpoint, in endpoint_add_stream()
249 pw_client_endpoint_stream_update(endpoint->client_endpoint, in destroy_stream()
285 pw_client_endpoint_update(endpoint->client_endpoint, in update_params()
340 pw_client_endpoint_update(endpoint->client_endpoint, in complete_endpoint()
365 endpoint->client_endpoint = NULL; in proxy_destroy()
439 endpoint->client_endpoint = (struct pw_client_endpoint *) proxy; in create_endpoint()
464 pw_client_endpoint_add_listener(endpoint->client_endpoint, in create_endpoint()
487 if (endpoint->client_endpoint) { in destroy_endpoint()
488 pw_proxy_destroy((struct pw_proxy*)endpoint->client_endpoint); in destroy_endpoint()
|
| H A D | bluez-endpoint.c | 68 struct pw_client_endpoint *client_endpoint; member
265 pw_client_endpoint_stream_update(endpoint->client_endpoint, in endpoint_add_stream()
281 pw_client_endpoint_stream_update(endpoint->client_endpoint, in destroy_stream()
317 pw_client_endpoint_update(endpoint->client_endpoint, in update_params()
375 pw_client_endpoint_update(endpoint->client_endpoint, in complete_endpoint()
409 endpoint->client_endpoint = NULL; in proxy_destroy()
494 endpoint->client_endpoint = (struct pw_client_endpoint *) proxy; in create_endpoint()
519 pw_client_endpoint_add_listener(endpoint->client_endpoint, in create_endpoint()
542 if (endpoint->client_endpoint) in destroy_endpoint()
543 pw_proxy_destroy((struct pw_proxy*)endpoint->client_endpoint); in destroy_endpoint()
|
| H A D | alsa-endpoint.c | 77 struct pw_client_endpoint *client_endpoint; member
277 pw_client_endpoint_stream_update(endpoint->client_endpoint, in endpoint_add_stream()
293 pw_client_endpoint_stream_update(endpoint->client_endpoint, in destroy_stream()
329 pw_client_endpoint_update(endpoint->client_endpoint, in update_params()
387 pw_client_endpoint_update(endpoint->client_endpoint, in complete_endpoint()
421 endpoint->client_endpoint = NULL; in proxy_destroy()
506 endpoint->client_endpoint = (struct pw_client_endpoint *) proxy; in create_endpoint()
531 pw_client_endpoint_add_listener(endpoint->client_endpoint, in create_endpoint()
554 if (endpoint->client_endpoint) in destroy_endpoint()
555 pw_proxy_destroy((struct pw_proxy*)endpoint->client_endpoint); in destroy_endpoint()
|
| H A D | stream-endpoint.c | 98 struct pw_client_endpoint *client_endpoint; member
277 pw_client_endpoint_stream_update(endpoint->client_endpoint, in endpoint_add_stream()
289 pw_client_endpoint_stream_update(endpoint->client_endpoint, in destroy_stream()
335 pw_client_endpoint_update(endpoint->client_endpoint, in complete_endpoint()
367 pw_client_endpoint_update(endpoint->client_endpoint, in update_params()
442 endpoint->client_endpoint = (struct pw_client_endpoint *) proxy; in create_endpoint()
466 pw_client_endpoint_add_listener(endpoint->client_endpoint, in create_endpoint()
486 pw_proxy_destroy((struct pw_proxy*)endpoint->client_endpoint); in destroy_endpoint()
|
| /dports/databases/percona57-pam-for-mysql/boost_1_59_0/libs/asio/test/ip/ |
| H A D | tcp.cpp | 810 ip::tcp::endpoint client_endpoint; in test() local
811 acceptor.accept(server_side_socket, client_endpoint); in test()
818 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
823 == client_endpoint.port()); in test()
836 acceptor.async_accept(server_side_socket, client_endpoint, &handle_accept); in test()
843 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
847 == client_endpoint.port()); in test()
|
| /dports/databases/mysqlwsrep57-server/boost_1_59_0/libs/asio/test/ip/ |
| H A D | tcp.cpp | 810 ip::tcp::endpoint client_endpoint; in test() local
811 acceptor.accept(server_side_socket, client_endpoint); in test()
818 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
823 == client_endpoint.port()); in test()
836 acceptor.async_accept(server_side_socket, client_endpoint, &handle_accept); in test()
843 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
847 == client_endpoint.port()); in test()
|
| /dports/databases/percona57-server/boost_1_59_0/libs/asio/test/ip/ |
| H A D | tcp.cpp | 810 ip::tcp::endpoint client_endpoint; in test() local
811 acceptor.accept(server_side_socket, client_endpoint); in test()
818 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
823 == client_endpoint.port()); in test()
836 acceptor.async_accept(server_side_socket, client_endpoint, &handle_accept); in test()
843 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
847 == client_endpoint.port()); in test()
|
| /dports/databases/xtrabackup/boost_1_59_0/libs/asio/test/ip/ |
| H A D | tcp.cpp | 810 ip::tcp::endpoint client_endpoint; in test() local
811 acceptor.accept(server_side_socket, client_endpoint); in test()
818 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
823 == client_endpoint.port()); in test()
836 acceptor.async_accept(server_side_socket, client_endpoint, &handle_accept); in test()
843 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
847 == client_endpoint.port()); in test()
|
| /dports/databases/percona57-client/boost_1_59_0/libs/asio/test/ip/ |
| H A D | tcp.cpp | 810 ip::tcp::endpoint client_endpoint; in test() local
811 acceptor.accept(server_side_socket, client_endpoint); in test()
818 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
823 == client_endpoint.port()); in test()
836 acceptor.async_accept(server_side_socket, client_endpoint, &handle_accept); in test()
843 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
847 == client_endpoint.port()); in test()
|
| /dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/modules/asio-standalone/asio/src/tests/unit/ip/ |
| H A D | tcp.cpp | 911 ip::tcp::endpoint client_endpoint; in test() local
912 acceptor.accept(server_side_socket, client_endpoint); in test()
916 ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
921 == client_endpoint.port()); in test()
934 acceptor.async_accept(server_side_socket, client_endpoint, &handle_accept); in test()
941 ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
945 == client_endpoint.port()); in test()
|
| /dports/emulators/mess/mame-mame0226/3rdparty/asio/src/tests/unit/ip/ |
| H A D | tcp.cpp | 1006 ip::tcp::endpoint client_endpoint; in test() local
1007 acceptor.accept(server_side_socket, client_endpoint); in test()
1011 ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
1016 == client_endpoint.port()); in test()
1029 acceptor.async_accept(server_side_socket, client_endpoint, &handle_accept); in test()
1036 ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
1040 == client_endpoint.port()); in test()
|
| /dports/emulators/mame/mame-mame0226/3rdparty/asio/src/tests/unit/ip/ |
| H A D | tcp.cpp | 1006 ip::tcp::endpoint client_endpoint; in test() local
1007 acceptor.accept(server_side_socket, client_endpoint); in test()
1011 ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
1016 == client_endpoint.port()); in test()
1029 acceptor.async_accept(server_side_socket, client_endpoint, &handle_accept); in test()
1036 ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
1040 == client_endpoint.port()); in test()
|
| /dports/net/asio/asio-1.16.0/src/tests/unit/ip/ |
| H A D | tcp.cpp | 982 ip::tcp::endpoint client_endpoint; in test() local
983 acceptor.accept(server_side_socket, client_endpoint); in test()
987 ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
992 == client_endpoint.port()); in test()
1005 acceptor.async_accept(server_side_socket, client_endpoint, &handle_accept); in test()
1012 ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
1016 == client_endpoint.port()); in test()
|
| /dports/www/py-google-cloud-storage/google-cloud-storage-1.43.0/tests/unit/ |
| H A D | test_batch.py | 546 client_endpoint = "http://localhost:9023"
548 connection = _Connection(http=http, api_endpoint=client_endpoint)
551 self.assertEqual(batch.API_BASE_URL, client_endpoint)
552 self.assertEqual(batch._client._connection.API_BASE_URL, client_endpoint)
|
| /dports/devel/py-botocore/botocore-1.21.61/tests/unit/ |
| H A D | test_protocols.py | 144 client_endpoint = service_description.get('clientEndpoint')
148 _assert_endpoints_equal(request, case['serialized'], client_endpoint)
|
| /dports/devel/boost-docs/boost_1_72_0/libs/asio/test/ip/ |
| H A D | tcp.cpp | 982 ip::tcp::endpoint client_endpoint; in test() local
983 acceptor.accept(server_side_socket, client_endpoint); in test()
987 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
992 == client_endpoint.port()); in test()
1005 acceptor.async_accept(server_side_socket, client_endpoint, &handle_accept); in test()
1012 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
1016 == client_endpoint.port()); in test()
|
| /dports/devel/boost-python-libs/boost_1_72_0/libs/asio/test/ip/ |
| H A D | tcp.cpp | 982 ip::tcp::endpoint client_endpoint; in test() local
983 acceptor.accept(server_side_socket, client_endpoint); in test()
987 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
992 == client_endpoint.port()); in test()
1005 acceptor.async_accept(server_side_socket, client_endpoint, &handle_accept); in test()
1012 BOOST_ASIO_CHECK(client_side_local_endpoint.port() == client_endpoint.port()); in test()
1016 == client_endpoint.port()); in test()
|