| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
| reduction.py | 65 def send_handle(conn, handle, destination_pid):
71 conn.send(new_handle)
75 def recv_handle(conn):
76 return conn.recv()
79 def send_handle(conn, handle, destination_pid):
80 _multiprocessing.sendfd(conn.fileno(), handle)
82 def recv_handle(conn):
83 return _multiprocessing.recvfd(conn.fileno())
124 conn = _listener.accept()
125 handle_wanted, destination_pid = conn.recv(
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
| reduction.py | 65 def send_handle(conn, handle, destination_pid):
71 conn.send(new_handle)
75 def recv_handle(conn):
76 return conn.recv()
79 def send_handle(conn, handle, destination_pid):
80 _multiprocessing.sendfd(conn.fileno(), handle)
82 def recv_handle(conn):
83 return _multiprocessing.recvfd(conn.fileno())
124 conn = _listener.accept()
125 handle_wanted, destination_pid = conn.recv(
[all...] |
| /external/javasqlite/src/main/java/SQLite/JDBC2z/ |
| JDBCStatement.java | 8 protected JDBCConnection conn; field in class:JDBCStatement
14 public JDBCStatement(JDBCConnection conn) {
15 this.conn = conn;
70 conn.timeout = 5000;
72 conn.timeout = seconds * 1000;
78 return conn.timeout / 1000; // android-changed: should return seconds
93 if (conn == null || conn.db == null) {
97 boolean starttrans = !conn.autocommit && !conn.intrans
[all...] |
| /external/chromium_org/third_party/mongoose/ |
| mongoose.c | 484 static void *call_user(struct mg_connection *conn, enum mg_event event) {
485 conn->request_info.user_data = conn->ctx->user_data;
486 return conn->ctx->user_callback == NULL ? NULL :
487 conn->ctx->user_callback(event, conn, &conn->request_info);
514 static void cry(struct mg_connection *conn, const char *fmt, ...) {
527 conn->request_info.log_message = buf;
528 if (call_user(conn, MG_EVENT_LOG) == NULL)
2283 struct mg_connection *conn; member in struct:de
2774 struct mg_connection *conn; member in struct:cgi_env_block
3278 struct mg_connection *conn = (struct mg_connection *) data; local
3995 struct mg_connection *conn; local
[all...] |
| chrome-mongoose-modifications.diff | 66 @@ -3768,15 +3781,8 @@ static void reset_per_request_attributes(struct mg_connection *conn) {
91 @@ -3812,1 +3812,1 @@ static void close_connection(struct mg_connection *conn) {
94 static void discard_current_request_from_buffer(struct mg_connection *conn) {
98 - buffered = conn->buf + conn->request_len;
99 buffered_len = conn->data_len - conn->request_len;
102 @@ -3867,7 +3865,7 @@ static void handle_proxy_request(struct mg_connection *conn) {
104 conn->peer->client.is_ssl = is_ssl;
109 mg_printf(conn->peer, "%s %s HTTP/%s\r\n", ri->request_method, ri->uri + len
[all...] |
| /external/openssh/ |
| sftp-client.c | 85 get_handle(struct sftp_conn *conn, u_int expected_id, u_int *len,
99 send_msg(struct sftp_conn *conn, Buffer *m)
114 if (atomiciov6(writev, conn->fd_out, iov, 2,
115 conn->limit_kbps > 0 ? sftpio : NULL, &conn->bwlimit_out) !=
123 get_msg(struct sftp_conn *conn, Buffer *m)
128 if (atomicio6(read, conn->fd_in, buffer_ptr(m), 4,
129 conn->limit_kbps > 0 ? sftpio : NULL, &conn->bwlimit_in) != 4) {
141 if (atomicio6(read, conn->fd_in, buffer_ptr(m), msg_len
[all...] |
| /external/qemu/proxy/ |
| proxy_http_connector.c | 50 connection_init( Connection* conn )
52 HttpService* service = (HttpService*) conn->root->service;
53 ProxyConnection* root = conn->root;
64 conn->state = STATE_SEND_HEADER;
69 conn->state = STATE_CONNECTING;
86 Connection* conn = (Connection*)root; local
88 switch (conn->state) {
110 Connection* conn = (Connection*)root; local
116 switch (conn->state)
120 conn->state = STATE_SEND_HEADER
179 Connection* conn; local
[all...] |
| proxy_int.h | 56 typedef void (*ProxyConnectionFreeFunc) ( ProxyConnection* conn );
59 typedef void (*ProxyConnectionSelectFunc) ( ProxyConnection* conn,
63 typedef void (*ProxyConnectionPollFunc) ( ProxyConnection* conn,
96 proxy_connection_init( ProxyConnection* conn,
105 proxy_connection_done( ProxyConnection* conn );
112 proxy_connection_free( ProxyConnection* conn,
124 * starting from offset conn->str_pos in the buffer
130 * on exit, conn->str_sent contains the number of bytes
131 * that were really sent. conn->str_pos will be incremented
132 * by conn->str_sent as well
[all...] |
| /external/ppp/pppd/plugins/rp-pppoe/ |
| plugin.c | 84 static PPPoEConnection *conn = NULL; variable
98 conn = malloc(sizeof(PPPoEConnection));
99 if (!conn) {
102 memset(conn, 0, sizeof(PPPoEConnection));
104 SET_STRING(conn->acName, acName);
107 SET_STRING(conn->serviceName, pppd_pppoe_service);
109 SET_STRING(conn->ifName, devnam);
110 conn->discoverySocket = -1;
111 conn->sessionSocket = -1;
112 conn->useHostUniq = 1
[all...] |
| /external/wpa_supplicant_8/src/crypto/ |
| tls_schannel.c | 118 struct tls_connection *conn; local
120 conn = os_zalloc(sizeof(*conn));
121 if (conn == NULL)
123 conn->start = 1;
125 return conn;
129 void tls_connection_deinit(void *ssl_ctx, struct tls_connection *conn)
131 if (conn == NULL)
134 os_free(conn);
138 int tls_connection_established(void *ssl_ctx, struct tls_connection *conn)
[all...] |
| tls_openssl.c | 558 struct tls_connection *conn = SSL_get_app_data((SSL *) ssl); local
567 conn->read_alerts++;
569 conn->write_alerts++;
571 if (conn->context->event_cb != NULL) {
573 struct tls_context *context = conn->context;
863 static int tls_engine_init(struct tls_connection *conn, const char *engine_id,
888 conn->engine = ENGINE_by_id(engine_id);
889 if (!conn->engine) {
894 if (ENGINE_init(conn->engine) != 1) {
903 if (ENGINE_ctrl_cmd_string(conn->engine, "PIN", pin, 0) == 0)
987 struct tls_connection *conn; local
1268 struct tls_connection *conn; local
2809 struct tls_connection *conn = arg; local
3139 struct tls_connection *conn = arg; local
3165 struct tls_connection *conn = arg; local
3192 struct tls_connection *conn = arg; local
3217 struct tls_connection *conn = arg; local
[all...] |
| tls.h | 202 * Returns: Connection context data, conn for other function calls
209 * @conn: Connection context data from tls_connection_init()
213 void tls_connection_deinit(void *tls_ctx, struct tls_connection *conn);
218 * @conn: Connection context data from tls_connection_init()
221 int tls_connection_established(void *tls_ctx, struct tls_connection *conn);
226 * @conn: Connection context data from tls_connection_init()
230 * connection can be started by using the same conn without having to call
234 int tls_connection_shutdown(void *tls_ctx, struct tls_connection *conn);
244 * @conn: Connection context data from tls_connection_init()
253 tls_connection_set_params(void *tls_ctx, struct tls_connection *conn,
[all...] |
| /external/ganymed-ssh2/examples/ |
| PublicKeyAuthentication.java | 29 Connection conn = new Connection(hostname); local
33 conn.connect();
37 boolean isAuthenticated = conn.authenticateWithPublicKey(username, keyfile, keyfilePass);
44 Session sess = conn.openSession();
68 conn.close();
|
| BasicWithHTTPProxy.java | 30 Connection conn = new Connection(hostname); local
34 conn.setProxyData(new HTTPProxyData(proxyHost, proxyPort));
37 // conn.setProxyData(new HTTPProxyData(proxyHost, proxyPort, "username", "secret"));
41 conn.connect();
49 boolean isAuthenticated = conn.authenticateWithPassword(username, password);
56 Session sess = conn.openSession();
89 conn.close();
|
| Basic.java | 26 Connection conn = new Connection(hostname); local
30 conn.connect();
38 boolean isAuthenticated = conn.authenticateWithPassword(username, password);
45 Session sess = conn.openSession();
78 conn.close();
|
| /external/wpa_supplicant_8/src/tls/ |
| tlsv1_server_i.h | 61 void tlsv1_server_alert(struct tlsv1_server *conn, u8 level, u8 description);
62 int tlsv1_server_derive_keys(struct tlsv1_server *conn,
65 u8 * tlsv1_server_handshake_write(struct tlsv1_server *conn, size_t *out_len);
66 u8 * tlsv1_server_send_alert(struct tlsv1_server *conn, u8 level,
68 int tlsv1_server_process_handshake(struct tlsv1_server *conn, u8 ct,
|
| /external/chromium_org/native_client_sdk/src/build_tools/tests/ |
| test_server.py | 23 self.conn = parent_conn
28 self.conn.send(False)
46 def _HTTPServerProcess(conn, serve_dir):
52 conn: A connection to the parent process. The child process sends
62 conn.send(httpd.server_address[1]) # the chosen port number
67 if conn.poll():
68 running = conn.recv()
69 conn.close()
|
| /cts/tests/tests/app/src/android/app/cts/ |
| ServiceTest.java | 179 TestConnection conn = new TestConnection(true, false); local
185 mContext.bindService(service, conn, 0);
197 mContext.unbindService(conn);
208 mContext.unbindService(conn);
210 conn = new TestConnection(true, true);
214 conn.setMonitor(true);
216 mContext.bindService(service, conn, 0);
223 mContext.unbindService(conn);
229 conn.setMonitor(false);
234 mContext.unbindService(conn);
278 TestConnection conn = new TestConnection(false, true); local
298 TestConnection conn = new TestConnection(false, false); local
453 EmptyConnection conn = new EmptyConnection(); local
[all...] |
| /frameworks/base/core/tests/coretests/src/android/app/activity/ |
| ServiceTest.java | 233 TestConnection conn = new TestConnection(true, false); local
239 getContext().bindService(service, conn, 0);
253 getContext().unbindService(conn);
266 getContext().unbindService(conn);
268 conn = new TestConnection(true, true);
272 conn.setMonitor(true);
274 getContext().bindService(service, conn, 0);
283 getContext().unbindService(conn);
291 conn.setMonitor(false);
296 getContext().unbindService(conn);
340 TestConnection conn = new TestConnection(false, true); local
364 TestConnection conn = new TestConnection(false, false); local
458 EmptyConnection conn = new EmptyConnection(); local
[all...] |
| /external/chromium_org/third_party/jstemplate/ |
| compile.py | 33 conn = httplib.HTTPConnection('closure-compiler.appspot.com')
34 conn.request('POST', '/compile', params, headers)
35 response = conn.getresponse()
39 conn.close()
|
| /external/iproute2/etc/iproute2/ |
| rt_protos | 28 248 gated/conn
|
| /external/smack/asmack-master/lib/ |
| httpclient-4.1.3.jar | |
| /external/chromium_org/third_party/mesa/src/src/gallium/auxiliary/vl/ |
| vl_winsys_dri.c | 54 xcb_connection_t *conn; member in struct:vl_dri_screen
103 free(xcb_dri2_swap_buffers_reply(scrn->conn, scrn->swap_cookie, NULL));
105 wait_sbc_reply = xcb_dri2_wait_sbc_reply(scrn->conn, scrn->wait_cookie, NULL);
112 return xcb_dri2_get_buffers_reply(scrn->conn, scrn->buffers_cookie, NULL);
133 scrn->swap_cookie = xcb_dri2_swap_buffers_unchecked(scrn->conn, scrn->drawable, msc_hi, msc_lo, 0, 0, 0, 0);
134 scrn->wait_cookie = xcb_dri2_wait_sbc_unchecked(scrn->conn, scrn->drawable, 0, 0);
135 scrn->buffers_cookie = xcb_dri2_get_buffers_unchecked(scrn->conn, scrn->drawable, 1, 1, attachments);
147 destroy_cookie = xcb_dri2_destroy_drawable_checked(scrn->conn, scrn->drawable);
149 free(xcb_request_check(scrn->conn, destroy_cookie));
164 xcb_dri2_create_drawable(scrn->conn, drawable)
[all...] |
| /external/mesa3d/src/gallium/auxiliary/vl/ |
| vl_winsys_dri.c | 54 xcb_connection_t *conn; member in struct:vl_dri_screen
103 free(xcb_dri2_swap_buffers_reply(scrn->conn, scrn->swap_cookie, NULL));
105 wait_sbc_reply = xcb_dri2_wait_sbc_reply(scrn->conn, scrn->wait_cookie, NULL);
112 return xcb_dri2_get_buffers_reply(scrn->conn, scrn->buffers_cookie, NULL);
133 scrn->swap_cookie = xcb_dri2_swap_buffers_unchecked(scrn->conn, scrn->drawable, msc_hi, msc_lo, 0, 0, 0, 0);
134 scrn->wait_cookie = xcb_dri2_wait_sbc_unchecked(scrn->conn, scrn->drawable, 0, 0);
135 scrn->buffers_cookie = xcb_dri2_get_buffers_unchecked(scrn->conn, scrn->drawable, 1, 1, attachments);
147 destroy_cookie = xcb_dri2_destroy_drawable_checked(scrn->conn, scrn->drawable);
149 free(xcb_request_check(scrn->conn, destroy_cookie));
164 xcb_dri2_create_drawable(scrn->conn, drawable)
[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();
|
