| /external/apache-http/src/org/apache/http/impl/conn/ |
| AbstractPooledConnAdapter.java | 2 * $HeadURL: http://svn.apache.org/repos/asf/httpcomponents/httpclient/trunk/module-client/src/main/java/org/apache/http/impl/conn/AbstractPooledConnAdapter.java $
31 package org.apache.http.impl.conn;
39 import org.apache.http.conn.routing.HttpRoute;
40 import org.apache.http.conn.ClientConnectionManager;
41 import org.apache.http.conn.OperatedClientConnection;
47 * {@link org.apache.http.conn.ManagedClientConnection managed}
161 OperatedClientConnection conn = getWrappedConnection(); local
162 if (conn != null) {
163 conn.close();
172 OperatedClientConnection conn = getWrappedConnection() local
[all...] |
| /external/curl/lib/ |
| connect.h | 30 CURLcode Curl_is_connected(struct connectdata *conn,
34 CURLcode Curl_connecthost(struct connectdata *conn,
59 bool Curl_connalive(struct connectdata *conn);
76 void Curl_updateconninfo(struct connectdata *conn, curl_socket_t sockfd);
77 void Curl_persistconninfo(struct connectdata *conn);
78 int Curl_closesocket(struct connectdata *conn, curl_socket_t sock);
100 * Create a socket based on info from 'conn' and 'ai'.
106 CURLcode Curl_socket(struct connectdata *conn,
111 void Curl_tcpnodelay(struct connectdata *conn, curl_socket_t sockfd);
129 void Curl_conncontrol(struct connectdata *conn,
[all...] |
| ssh-libssh.c | 99 static CURLcode myssh_connect(struct connectdata *conn, bool *done);
100 static CURLcode myssh_multi_statemach(struct connectdata *conn,
102 static CURLcode myssh_do_it(struct connectdata *conn, bool *done);
104 static CURLcode scp_done(struct connectdata *conn,
106 static CURLcode scp_doing(struct connectdata *conn, bool *dophase_done);
107 static CURLcode scp_disconnect(struct connectdata *conn,
110 static CURLcode sftp_done(struct connectdata *conn,
112 static CURLcode sftp_doing(struct connectdata *conn,
114 static CURLcode sftp_disconnect(struct connectdata *conn, bool dead);
116 CURLcode sftp_perform(struct connectdata *conn,
[all...] |
| curl_sasl.c | 78 * conn [in] - The connection data.
81 void Curl_sasl_cleanup(struct connectdata *conn, unsigned int authused)
86 Curl_auth_gssapi_cleanup(&conn->krb5);
93 Curl_auth_ntlm_cleanup(&conn->ntlm);
99 (void)conn;
195 static void state(struct SASL *sasl, struct connectdata *conn,
222 infof(conn->data, "SASL %p state change from %s to %s\n",
225 (void) conn;
236 bool Curl_sasl_can_authenticate(struct SASL *sasl, struct connectdata *conn)
239 if(conn->bits.user_passwd
[all...] |
| rtsp.c | 61 static CURLcode rtsp_do(struct connectdata *conn, bool *done);
62 static CURLcode rtsp_done(struct connectdata *conn, CURLcode, bool premature);
63 static CURLcode rtsp_connect(struct connectdata *conn, bool *done);
64 static CURLcode rtsp_disconnect(struct connectdata *conn, bool dead);
66 static int rtsp_getsock_do(struct connectdata *conn,
78 struct connectdata *conn,
82 static CURLcode rtsp_setup_connection(struct connectdata *conn);
91 static int rtsp_getsock_do(struct connectdata *conn,
97 socks[0] = conn->sock[FIRSTSOCKET];
102 CURLcode rtp_client_write(struct connectdata *conn, char *ptr, size_t len)
[all...] |
| asyn-ares.c | 175 void Curl_resolver_cancel(struct connectdata *conn)
177 if(conn->data && conn->data->state.resolver)
178 ares_cancel((ares_channel)conn->data->state.resolver);
179 destroy_async_data(&conn->async);
213 int Curl_resolver_getsock(struct connectdata *conn,
222 int max = ares_getsock((ares_channel)conn->data->state.resolver,
228 timeout = ares_timeout((ares_channel)conn->data->state.resolver, &maxtime,
233 Curl_expire(conn->data, milli, EXPIRE_ASYNC_NAME);
248 static int waitperform(struct connectdata *conn, int timeout_ms
462 struct connectdata *conn = (struct connectdata *)arg; local
[all...] |
| conncache.h | 57 struct connectbundle *Curl_conncache_find_bundle(struct connectdata *conn,
59 void Curl_conncache_unlock(struct connectdata *conn);
62 size_t Curl_conncache_bundle_size(struct connectdata *conn);
64 bool Curl_conncache_return_conn(struct connectdata *conn);
66 struct connectdata *conn);
67 void Curl_conncache_remove_conn(struct connectdata *conn,
72 int (*func)(struct connectdata *conn,
|
| gopher.c | 45 static CURLcode gopher_do(struct connectdata *conn, bool *done);
74 static CURLcode gopher_do(struct connectdata *conn, bool *done)
77 struct Curl_easy *data = conn->data;
78 curl_socket_t sockfd = conn->sock[FIRSTSOCKET];
120 result = Curl_write(conn, sockfd, sel, k, &amount);
122 result = Curl_client_write(conn, CLIENTWRITE_HEADER, sel, amount);
154 result = Curl_sendf(sockfd, conn, "\r\n");
159 result = Curl_client_write(conn, CLIENTWRITE_HEADER, (char *)"\r\n", 2);
163 Curl_setup_transfer(conn, FIRSTSOCKET, -1, FALSE, bytecount,
|
| openldap.c | 79 static CURLcode ldap_setup_connection(struct connectdata *conn);
80 static CURLcode ldap_do(struct connectdata *conn, bool *done);
81 static CURLcode ldap_done(struct connectdata *conn, CURLcode, bool);
82 static CURLcode ldap_connect(struct connectdata *conn, bool *done);
83 static CURLcode ldap_connecting(struct connectdata *conn, bool *done);
84 static CURLcode ldap_disconnect(struct connectdata *conn, bool dead);
170 static CURLcode ldap_setup_connection(struct connectdata *conn)
174 struct Curl_easy *data = conn->data;
187 failf(conn->data, "LDAP local: %s", msg);
197 conn->proto.generic = li
694 struct connectdata *conn = sbiod->sbiod_pvt; local
703 struct connectdata *conn = sbiod->sbiod_pvt; local
718 struct connectdata *conn = sbiod->sbiod_pvt; local
[all...] |
| sendf.c | 134 bool Curl_recv_has_postponed_data(struct connectdata *conn, int sockindex)
136 struct postponed_data * const psnd = &(conn->postponed[sockindex]);
141 static void pre_receive_plain(struct connectdata *conn, int num)
143 const curl_socket_t sockfd = conn->sock[num];
144 struct postponed_data * const psnd = &(conn->postponed[num]);
151 if((conn->handler->protocol&PROTO_FAMILY_HTTP) != 0 &&
152 conn->recv[num] == Curl_recv_plain &&
160 psnd->allocated_size = 2 * conn->data->set.buffer_size;
183 static ssize_t get_pre_recved(struct connectdata *conn, int num, char *buf,
186 struct postponed_data * const psnd = &(conn->postponed[num])
[all...] |
| pingpong.c | 49 struct connectdata *conn = pp->conn; local
50 struct Curl_easy *data = conn->data;
69 Curl_timediff(Curl_now(), conn->now); /* spent time */
83 struct connectdata *conn = pp->conn; local
84 curl_socket_t sock = conn->sock[FIRSTSOCKET];
88 struct Curl_easy *data = conn->data;
104 if(Curl_ssl_data_pending(conn, FIRSTSOCKET))
109 else if(!pp->sendleft && Curl_ssl_data_pending(conn, FIRSTSOCKET)
142 struct connectdata *conn = pp->conn; local
170 struct connectdata *conn = pp->conn; local
283 struct connectdata *conn = pp->conn; local
467 struct connectdata *conn = pp->conn; local
486 struct connectdata *conn = pp->conn; local
[all...] |
| /external/wpa_supplicant_8/src/crypto/ |
| tls.h | 233 * Returns: Connection context data, conn for other function calls
240 * @conn: Connection context data from tls_connection_init()
244 void tls_connection_deinit(void *tls_ctx, struct tls_connection *conn);
249 * @conn: Connection context data from tls_connection_init()
252 int tls_connection_established(void *tls_ctx, struct tls_connection *conn);
257 * @conn: Connection context data from tls_connection_init()
261 * connection can be started by using the same conn without having to call
265 int tls_connection_shutdown(void *tls_ctx, struct tls_connection *conn);
276 * @conn: Connection context data from tls_connection_init()
287 tls_connection_set_params(void *tls_ctx, struct tls_connection *conn,
[all...] |
| /libcore/luni/src/test/java/libcore/java/sql/ |
| OldSQLTest.java | 28 static Connection conn; field in class:OldSQLTest
48 conn = DriverManager.getConnection("jdbc:sqlite:/" + dbFile.getPath());
49 assertNotNull("Connection created ", conn);
55 if (! conn.isClosed()) {
56 st = conn.createStatement();
63 conn.close();
79 st = conn.createStatement();
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Demo/sockets/ |
| echosvr.py | 23 conn, (remotehost, remoteport) = s.accept()
26 data = conn.recv(BUFSIZE)
29 conn.send(data)
|
| /external/adhd/cras/src/server/ |
| cras_bt_profile.h | 28 int (*new_connection)(DBusConnection *conn,
40 * conn - The dbus connection.
43 int cras_bt_add_profile(DBusConnection *conn,
64 * conn - The dbus connection.
68 int cras_bt_register_profiles(DBusConnection *conn);
|
| cras_a2dp_endpoint.h | 13 int cras_a2dp_endpoint_create(DBusConnection *conn);
|
| /external/apache-http/src/org/apache/http/client/params/ |
| AllClientPNames.java | 38 import org.apache.http.conn.params.ConnManagerPNames;
39 import org.apache.http.conn.params.ConnConnectionPNames;
40 import org.apache.http.conn.params.ConnRoutePNames;
|
| /external/python/cpython2/Demo/sockets/ |
| echosvr.py | 23 conn, (remotehost, remoteport) = s.accept()
26 data = conn.recv(BUFSIZE)
29 conn.send(data)
|
| /external/curl/docs/examples/ |
| hiperfifo.c | 166 ConnInfo *conn; local
175 curl_easy_getinfo(easy, CURLINFO_PRIVATE, &conn);
177 fprintf(MSG_OUT, "DONE: %s => (%d) %s\n", eff_url, res, conn->error);
179 free(conn->url);
181 free(conn);
303 ConnInfo *conn = (ConnInfo*) data; local
305 (void)conn;
314 ConnInfo *conn = (ConnInfo *)p; local
318 fprintf(MSG_OUT, "Progress: %s (%g/%g)\n", conn->url, dlnow, dltotal);
326 ConnInfo *conn; local
[all...] |
| /external/apache-http/src/org/apache/http/conn/ |
| ClientConnectionRequest.java | 2 * $HeadURL: http://svn.apache.org/repos/asf/httpcomponents/httpclient/trunk/module-client/src/main/java/org/apache/http/conn/ClientConnectionRequest.java $
32 package org.apache.http.conn;
|
| /external/apache-http/src/org/apache/http/conn/routing/ |
| HttpRouteDirector.java | 2 * $HeadURL: http://svn.apache.org/repos/asf/httpcomponents/httpclient/trunk/module-client/src/main/java/org/apache/http/conn/routing/HttpRouteDirector.java $
32 package org.apache.http.conn.routing;
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| RefQueueHandler.java | 2 * $HeadURL: http://svn.apache.org/repos/asf/httpcomponents/httpclient/trunk/module-client/src/main/java/org/apache/http/impl/conn/tsccm/RefQueueHandler.java $
31 package org.apache.http.impl.conn.tsccm;
|
| /external/curl/lib/vtls/ |
| vtls.h | 50 int (*shutdown)(struct connectdata *conn, int sockindex);
51 bool (*data_pending)(const struct connectdata *conn,
59 CURLcode (*connect)(struct connectdata *conn, int sockindex);
60 CURLcode (*connect_nonblocking)(struct connectdata *conn, int sockindex,
63 void (*close_one)(struct connectdata *conn, int sockindex);
85 int Curl_none_shutdown(struct connectdata *conn, int sockindex);
86 int Curl_none_check_cxn(struct connectdata *conn);
91 bool Curl_none_data_pending(const struct connectdata *conn, int connindex);
130 #define SSL_IS_PROXY() (CURLPROXY_HTTPS == conn->http_proxy.proxytype && \
131 ssl_connection_complete != conn->proxy_ssl[conn->sock[SECONDARYSOCKET] ==
[all...] |
| /external/libxkbcommon/xkbcommon/src/x11/ |
| util.c | 27 xkb_x11_setup_xkb_extension(xcb_connection_t *conn,
46 xcb_get_extension_data(conn, &xcb_xkb_id);
64 xcb_xkb_use_extension(conn, major_xkb_version, minor_xkb_version);
66 xcb_xkb_use_extension_reply(conn, cookie, &error);
108 xkb_x11_get_core_keyboard_device_id(xcb_connection_t *conn)
112 xcb_xkb_get_device_info(conn, XCB_XKB_ID_USE_CORE_KBD,
115 xcb_xkb_get_device_info_reply(conn, cookie, NULL);
126 get_atom_name(xcb_connection_t *conn, xcb_atom_t atom, char **out)
138 cookie = xcb_get_atom_name(conn, atom);
139 reply = xcb_get_atom_name_reply(conn, cookie, NULL)
[all...] |
| /external/syslinux/core/fs/pxe/ |
| core.c | 30 priv->conn = netconn_new(NETCONN_UDP);
31 if (!priv->conn)
34 priv->conn->recv_timeout = 15; /* A 15 ms recv timeout... */
35 err = netconn_bind(priv->conn, NULL, 0);
53 if (priv->conn) {
54 netconn_delete(priv->conn);
55 priv->conn = NULL;
74 netconn_connect(priv->conn, &addr, port);
85 netconn_disconnect(priv->conn);
106 err = netconn_recv(priv->conn, &nbuf)
137 struct netconn *conn = socket->net.lwip.conn; local
178 struct netconn *conn = socket->net.lwip.conn; local
[all...] |
