| /dports/www/p5-AnyEvent-WebSocket-Client/AnyEvent-WebSocket-Client-0.44/t/ |
| H A D | anyevent_websocket_connection__destroy_in_callbacks.t | 21 my $a_conn;
23 $a_conn_weak = $a_conn;
41 my ($a_conn, $cv_finish) = @_;
42 $a_conn->on(finish => sub {
45 $a_conn->on(finish => sub {
58 my ($a_conn, $cv_finish) = @_;
59 $a_conn->on(next_message => sub {
64 $a_conn->on(next_message => sub {
78 my ($a_conn, $cv_finish) = @_;
79 $a_conn->on(each_message => sub {
[all …]
|
| H A D | anyevent_websocket_connection__counter_shutdown.t | 19 my ($a_conn, $b_handle) = create_connection_and_handle;
24 $a_conn->on(finish => sub {
31 $code->($a_conn, $b_handle);
37 test_case "on_eof of a_conn", sub {
38 my ($a_conn, $b_handle) = @_;
42 test_case "on_error of a_conn", sub {
43 my ($a_conn, $b_handle) = @_;
45 # force connection error on a_conn
46 $a_conn->handle->push_shutdown;
47 $a_conn->send("foo");
[all …]
|
| H A D | anyevent_websocket_connection.t | 173 $a_conn->send("Hello");
183 my ($a_conn, $b_handle) = create_connection_and_handle;
284 $a_conn->on(finish => sub {
287 $a_conn->close();
288 $a_conn->send("hoge");
308 $a_conn->on(finish => sub { $cv_finish->send });
349 $a_conn->on(finish => sub {
352 $a_conn->on(each_message => sub {
379 # $a_conn chance to receive data.
397 $a_conn->on(finish => sub {
[all …]
|
| /dports/sysutils/rsyslog8/rsyslog-8.2112.0/contrib/omrabbitmq/ |
| H A D | omrabbitmq.c | 272 amqp_channel_open(a_conn, 1); in amqp_authenticate()
317 amqp_channel_open(a_conn, 1); in amqp_authenticate()
347 amqp_socket_t *sockfd = (a_conn) ? amqp_tcp_socket_new(a_conn) : NULL; in tryConnection()
363 return a_conn; in tryConnection()
405 self->a_conn = new_conn; in manage_connection()
499 if (self->a_conn != NULL) in run_connection_routine()
505 self->a_conn = NULL; in run_connection_routine()
665 if (self->a_conn != NULL) in run_connection_routine()
672 self->a_conn = NULL; in run_connection_routine()
722 if (self->a_conn) in closeAMQPConnection()
[all …]
|
| /dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/p2p/base/ |
| H A D | p2ptransportchannel.cc | 144 bool ShouldSwitch(cricket::Connection* a_conn, cricket::Connection* b_conn) { in ShouldSwitch() argument
145 if (a_conn == b_conn) in ShouldSwitch()
148 if (!a_conn || !b_conn) // don't think the latter should happen in ShouldSwitch()
151 int prefs_cmp = CompareConnections(a_conn, b_conn); in ShouldSwitch()
157 return b_conn->rtt() <= a_conn->rtt() + kMinImprovement; in ShouldSwitch()
|
| /dports/misc/amanda-server/amanda-3.3.9/ndmp-src/ |
| H A D | ndml_conn.c | 853 ndmconn_readit (void *a_conn, char *buf, int len) in ndmconn_readit() argument
855 struct ndmconn *conn = (struct ndmconn *)a_conn; in ndmconn_readit()
905 ndmconn_writeit (void *a_conn, char *buf, int len) in ndmconn_writeit() argument
907 struct ndmconn *conn = (struct ndmconn *)a_conn; in ndmconn_writeit()
|
| /dports/misc/amanda-client/amanda-3.3.9/ndmp-src/ |
| H A D | ndml_conn.c | 853 ndmconn_readit (void *a_conn, char *buf, int len) in ndmconn_readit() argument
855 struct ndmconn *conn = (struct ndmconn *)a_conn; in ndmconn_readit()
905 ndmconn_writeit (void *a_conn, char *buf, int len) in ndmconn_writeit() argument
907 struct ndmconn *conn = (struct ndmconn *)a_conn; in ndmconn_writeit()
|
| /dports/sysutils/bareos-traymonitor/bareos-Release-20.0.3/core/src/ndmp/ |
| H A D | ndml_conn.c | 808 int ndmconn_readit(void* a_conn, char* buf, int len) in ndmconn_readit() argument
810 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_readit()
854 int ndmconn_writeit(void* a_conn, char* buf, int len) in ndmconn_writeit() argument
856 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_writeit()
|
| /dports/sysutils/bareos18-client/bareos-Release-18.2.12/core/src/ndmp/ |
| H A D | ndml_conn.c | 866 ndmconn_readit (void *a_conn, char *buf, int len) in ndmconn_readit() argument
868 struct ndmconn *conn = (struct ndmconn *)a_conn; in ndmconn_readit()
918 ndmconn_writeit (void *a_conn, char *buf, int len) in ndmconn_writeit() argument
920 struct ndmconn *conn = (struct ndmconn *)a_conn; in ndmconn_writeit()
|
| /dports/sysutils/bareos19-traymonitor/bareos-Release-19.2.11/core/src/ndmp/ |
| H A D | ndml_conn.c | 808 int ndmconn_readit(void* a_conn, char* buf, int len) in ndmconn_readit() argument
810 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_readit()
854 int ndmconn_writeit(void* a_conn, char* buf, int len) in ndmconn_writeit() argument
856 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_writeit()
|
| /dports/sysutils/bareos19-server/bareos-Release-19.2.11/core/src/ndmp/ |
| H A D | ndml_conn.c | 808 int ndmconn_readit(void* a_conn, char* buf, int len) in ndmconn_readit() argument
810 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_readit()
854 int ndmconn_writeit(void* a_conn, char* buf, int len) in ndmconn_writeit() argument
856 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_writeit()
|
| /dports/sysutils/bareos19-client/bareos-Release-19.2.11/core/src/ndmp/ |
| H A D | ndml_conn.c | 808 int ndmconn_readit(void* a_conn, char* buf, int len) in ndmconn_readit() argument
810 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_readit()
854 int ndmconn_writeit(void* a_conn, char* buf, int len) in ndmconn_writeit() argument
856 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_writeit()
|
| /dports/sysutils/bareos-client/bareos-Release-20.0.3/core/src/ndmp/ |
| H A D | ndml_conn.c | 808 int ndmconn_readit(void* a_conn, char* buf, int len) in ndmconn_readit() argument
810 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_readit()
854 int ndmconn_writeit(void* a_conn, char* buf, int len) in ndmconn_writeit() argument
856 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_writeit()
|
| /dports/sysutils/bareos18-traymonitor/bareos-Release-18.2.12/core/src/ndmp/ |
| H A D | ndml_conn.c | 866 ndmconn_readit (void *a_conn, char *buf, int len) in ndmconn_readit() argument
868 struct ndmconn *conn = (struct ndmconn *)a_conn; in ndmconn_readit()
918 ndmconn_writeit (void *a_conn, char *buf, int len) in ndmconn_writeit() argument
920 struct ndmconn *conn = (struct ndmconn *)a_conn; in ndmconn_writeit()
|
| /dports/sysutils/bareos-server/bareos-Release-20.0.3/core/src/ndmp/ |
| H A D | ndml_conn.c | 808 int ndmconn_readit(void* a_conn, char* buf, int len) in ndmconn_readit() argument
810 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_readit()
854 int ndmconn_writeit(void* a_conn, char* buf, int len) in ndmconn_writeit() argument
856 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_writeit()
|
| /dports/sysutils/bareos18-server/bareos-Release-18.2.12/core/src/ndmp/ |
| H A D | ndml_conn.c | 866 ndmconn_readit (void *a_conn, char *buf, int len) in ndmconn_readit() argument
868 struct ndmconn *conn = (struct ndmconn *)a_conn; in ndmconn_readit()
918 ndmconn_writeit (void *a_conn, char *buf, int len) in ndmconn_writeit() argument
920 struct ndmconn *conn = (struct ndmconn *)a_conn; in ndmconn_writeit()
|
| /dports/www/bareos-webui/bareos-Release-20.0.3/core/src/ndmp/ |
| H A D | ndml_conn.c | 808 int ndmconn_readit(void* a_conn, char* buf, int len) in ndmconn_readit() argument
810 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_readit()
854 int ndmconn_writeit(void* a_conn, char* buf, int len) in ndmconn_writeit() argument
856 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_writeit()
|
| /dports/www/bareos18-webui/bareos-Release-18.2.12/core/src/ndmp/ |
| H A D | ndml_conn.c | 866 ndmconn_readit (void *a_conn, char *buf, int len) in ndmconn_readit() argument
868 struct ndmconn *conn = (struct ndmconn *)a_conn; in ndmconn_readit()
918 ndmconn_writeit (void *a_conn, char *buf, int len) in ndmconn_writeit() argument
920 struct ndmconn *conn = (struct ndmconn *)a_conn; in ndmconn_writeit()
|
| /dports/www/bareos19-webui/bareos-Release-19.2.11/core/src/ndmp/ |
| H A D | ndml_conn.c | 808 int ndmconn_readit(void* a_conn, char* buf, int len) in ndmconn_readit() argument
810 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_readit()
854 int ndmconn_writeit(void* a_conn, char* buf, int len) in ndmconn_writeit() argument
856 struct ndmconn* conn = (struct ndmconn*)a_conn; in ndmconn_writeit()
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/media/webrtc/trunk/webrtc/p2p/base/ |
| H A D | p2ptransportchannel.cc | 124 bool ShouldSwitch(cricket::Connection* a_conn, cricket::Connection* b_conn) { in ShouldSwitch() argument
125 if (a_conn == b_conn) in ShouldSwitch()
128 if (!a_conn || !b_conn) // don't think the latter should happen in ShouldSwitch()
131 int prefs_cmp = CompareConnections(a_conn, b_conn); in ShouldSwitch()
137 return b_conn->rtt() <= a_conn->rtt() + kMinImprovement; in ShouldSwitch()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/usb/phy/ |
| H A D | phy-mv-usb.h | 80 u8 a_conn; member
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/usb/phy/ |
| H A D | phy-mv-usb.h | 80 u8 a_conn; member
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/usb/phy/ |
| H A D | phy-mv-usb.h | 80 u8 a_conn; member
|
| /dports/devel/upp/upp/uppsrc/PostgreSQL/ |
| H A D | PostgreSQL.cpp | 101 PostgreSQLConnection(PostgreSQLSession& a_session, PGconn *a_conn);
717 PostgreSQLConnection::PostgreSQLConnection(PostgreSQLSession& a_session, PGconn *a_conn) in PostgreSQLConnection() argument
718 : session(a_session), conn(a_conn) in PostgreSQLConnection()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/usb/common/ |
| H A D | usb-otg-fsm.c | 363 if (fsm->a_conn) in otg_statemachine()
375 else if (!fsm->b_bus_req || !fsm->a_conn || fsm->test_device) in otg_statemachine()
|