/external/smack/src/org/jivesoftware/smack/ |
H A D | AccountManager.java | 47 private Connection connection; field in class:AccountManager 61 * @param connection a connection to a XMPP server. 63 public AccountManager(Connection connection) { argument 64 this.connection = connection; 228 reg.setTo(connection.getServiceName()); 234 PacketCollector collector = connection.createPacketCollector(filter); 235 connection.sendPacket(reg); 258 reg.setTo(connection [all...] |
H A D | PrivacyListManager.java | 49 private Connection connection;
field in class:PrivacyListManager 55 // Create a new PrivacyListManager on every established connection. In the init()
57 // instance when the connection is closed.
59 public void connectionCreated(Connection connection) {
60 new PrivacyListManager(connection);
69 * @param connection the XMPP connection.
71 private PrivacyListManager(Connection connection) {
argument 72 this.connection = connection;
164 getInstanceFor(Connection connection) argument [all...] |
H A D | SASLAuthentication.java | 37 * to the connection and establishing a session with the server.</p>
39 * <p>Once TLS has been negotiated (i.e. the connection has been secured) it is possible to
51 * the connection. If no resource is passed in {@link #authenticate(String, String, String)}
52 * then the server will assign a resource for the connection. In case a resource is passed
54 * the connection.</p>
69 private Connection connection;
field in class:SASLAuthentication 78 * the connection.
178 SASLAuthentication(Connection connection) {
argument 180 this.connection = connection;
[all...] |
/external/smack/src/org/jivesoftware/smackx/ |
H A D | OfflineMessageManager.java | 60 private Connection connection; field in class:OfflineMessageManager 64 public OfflineMessageManager(Connection connection) { argument 65 this.connection = connection; 80 DiscoverInfo info = ServiceDiscoveryManager.getInstanceFor(connection).discoverInfo(connection.getServiceName()); 85 * Returns the number of offline messages for the user of the connection. 87 * @return the number of offline messages for the user of the connection. 92 DiscoverInfo info = ServiceDiscoveryManager.getInstanceFor(connection).discoverInfo(null, 114 DiscoverItems items = ServiceDiscoveryManager.getInstanceFor(connection) [all...] |
H A D | MultipleRecipientManager.java | 54 * specified connection. If the server has support for JEP-33 then only one 59 * @param connection the connection to use to send the packet. 70 public static void send(Connection connection, Packet packet, List<String> to, List<String> cc, List<String> bcc) argument 72 send(connection, packet, to, cc, bcc, null, null, false); 77 * specified connection. If the server has support for JEP-33 then only one 82 * @param connection the connection to use to send the packet. 98 public static void send(Connection connection, Packet packet, List<String> to, List<String> cc, List<String> bcc, argument 100 String serviceAddress = getMultipleRecipienServiceAddress(connection); 130 reply(Connection connection, Message original, Message reply) argument 204 sendToIndividualRecipients(Connection connection, Packet packet, List<String> to, List<String> cc, List<String> bcc) argument 229 sendThroughService(Connection connection, Packet packet, List<String> to, List<String> cc, List<String> bcc, String replyTo, String replyRoom, boolean noReply, String serviceAddress) argument 283 getMultipleRecipienServiceAddress(Connection connection) argument [all...] |
/external/smack/src/org/jivesoftware/smackx/filetransfer/ |
H A D | FileTransferManager.java | 54 private Connection connection;
field in class:FileTransferManager 59 * @param connection
62 public FileTransferManager(Connection connection) {
argument 63 this.connection = connection;
65 .getInstanceFor(connection);
89 connection.addPacketListener(new PacketListener() {
145 return new OutgoingFileTransfer(connection.getUser(), userID,
180 connection.sendPacket(rejection);
|
/external/valgrind/main/gdbserver_tests/ |
H A D | mcclean_after_fork.stderrB.exp | 4 Remote connection closed
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
H A D | HttpEngine.java | 78 private Connection connection; field in class:HttpEngine 151 * @param connection the connection used for an intermediate response 153 * redirect. This engine assumes ownership of the connection and must 160 Connection connection, RouteSelector routeSelector, RetryableSink requestBodyOut, 165 this.connection = connection; 170 if (connection != null) { 171 connection.setOwner(this); 172 this.route = connection 159 HttpEngine(OkHttpClient client, Request request, boolean bufferRequestBody, Connection connection, RouteSelector routeSelector, RetryableSink requestBodyOut, Response priorResponse) argument [all...] |
/external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/ |
H A D | MockWebServerTest.java | 119 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); 120 connection.setRequestMethod("PUT"); 121 connection.setAllowUserInteraction(false); 122 connection.setRequestProperty("Expect", "100-continue"); 123 connection.setDoOutput(true); 124 connection.getOutputStream().write("hello".getBytes()); 125 assertEquals(HttpURLConnection.HTTP_OK, connection.getResponseCode()); 142 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); 143 connection.setRequestMethod("PUT"); 144 connection [all...] |
/external/okhttp/okhttp-apache/src/main/java/com/squareup/okhttp/apache/ |
H A D | OkApacheClient.java | 88 * this to customize the connection. 120 HttpURLConnection connection = openConnection(url); 121 connection.setRequestMethod(requestLine.getMethod()); 123 connection.addRequestProperty(header.getName(), header.getValue()); 130 connection.setDoOutput(true); 133 connection.addRequestProperty(type.getName(), type.getValue()); 137 connection.addRequestProperty(encoding.getName(), encoding.getValue()); 140 connection.setChunkedStreamingMode(0); 143 // to be transparently retried if there is a connection failure. 144 connection [all...] |
/external/smack/src/org/jivesoftware/smackx/bytestreams/socks5/ |
H A D | Socks5BytestreamManager.java | 88 * connection
93 public void connectionCreated(final Connection connection) {
95 manager = Socks5BytestreamManager.getBytestreamManager(connection);
98 connection.addConnectionListener(new AbstractConnectionListener() {
109 managers.put(connection, manager);
129 /* stores one Socks5BytestreamManager for each XMPP connection */
132 /* XMPP connection */
133 private final Connection connection;
field in class:Socks5BytestreamManager 177 * @param connection the XMPP connection o 181 getBytestreamManager(Connection connection) argument 199 Socks5BytestreamManager(Connection connection) argument [all...] |
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/mod_pywebsocket/ |
H A D | _stream_base.py | 35 # Note: request.connection.write/read are used in this module, even though 36 # mod_python document says that they should be used only in connection 49 """This exception will be raised when a connection is terminated 66 server-terminated connection or receive_message() is called on 67 client-terminated connection. 105 """Reads length bytes from connection. In case we catch any exception, 112 bytes = self._request.connection.read(length) 115 'Receiving %d byte failed. Peer (%r) closed connection' % 116 (length, (self._request.connection.remote_addr,))) 120 """Writes given bytes to connection [all...] |
/external/chromium_org/mojo/examples/apptest/ |
H A D | example_service_application.h | 24 virtual bool ConfigureIncomingConnection(ApplicationConnection* connection)
|
/external/chromium_org/mojo/public/cpp/application/ |
H A D | interface_factory.h | 24 virtual void Create(ApplicationConnection* connection,
|
/external/chromium_org/mojo/services/public/cpp/view_manager/lib/ |
H A D | view_manager_client_factory.cc | 23 ApplicationConnection* connection, 22 Create( ApplicationConnection* connection, InterfaceRequest<ViewManagerClient> request) argument
|
/external/chromium_org/mojo/services/view_manager/ |
H A D | view_manager_init_service_impl.cc | 16 ApplicationConnection* connection, 15 ViewManagerInitServiceImpl( ApplicationConnection* connection, ViewManagerInitServiceContext* context) argument
|
H A D | connection_manager.cc | 17 ViewManagerServiceImpl* connection, 21 connection_id_(connection->id()), 57 void ConnectionManager::AddConnection(ViewManagerServiceImpl* connection) { argument 58 DCHECK_EQ(0u, connection_map_.count(connection->id())); 59 connection_map_[connection->id()] = connection; 62 void ConnectionManager::RemoveConnection(ViewManagerServiceImpl* connection) { argument 63 connection_map_.erase(connection->id()); 64 connections_created_by_connect_.erase(connection); 70 i->second->OnViewManagerServiceImplDestroyed(connection 16 ScopedChange( ViewManagerServiceImpl* connection, ConnectionManager* connection_manager, bool is_delete_view) argument 84 ViewManagerServiceImpl* connection = GetConnection(kWindowManagerConnection); local 136 ViewManagerServiceImpl* connection = GetConnection(kWindowManagerConnection); local 225 ViewManagerServiceImpl* connection = local [all...] |
/external/chromium_org/mojo/shell/ |
H A D | network_application_loader.cc | 58 ApplicationConnection* connection) { 59 connection->AddService(this); 64 ApplicationConnection* connection, 66 BindToRequest(new NetworkServiceImpl(connection, context_.get()), &request); 57 ConfigureIncomingConnection( ApplicationConnection* connection) argument 63 Create( ApplicationConnection* connection, InterfaceRequest<NetworkService> request) argument
|
/external/chromium_org/sql/ |
H A D | transaction.h | 24 explicit Transaction(Connection* connection);
|
/external/chromium_org/third_party/WebKit/Source/devtools/front_end/ |
H A D | TestController.js | 48 InspectorBackend.connection().runAfterPendingDispatches(invokeMethod);
|
/external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/ |
H A D | _stream_base.py | 35 # Note: request.connection.write/read are used in this module, even though 36 # mod_python document says that they should be used only in connection 51 """This exception will be raised when a connection is terminated 68 server-terminated connection or receive_message() is called on 69 client-terminated connection. 107 """Reads length bytes from connection. In case we catch any exception, 115 read_bytes = self._request.connection.read(length) 118 'Receiving %d byte failed. Peer (%r) closed connection' % 119 (length, (self._request.connection.remote_addr,))) 136 """Writes given bytes to connection [all...] |
/external/chromium_org/remoting/webapp/unittests/ |
H A D | xmpp_connection_unittest.js | 15 var connection = null; variable 32 connection = new remoting.XmppConnection(onStateChange); 33 connection.setIncomingStanzaCallback(onStanza); 47 connection.connect( 58 QUnit.equal(connection.getError(), remoting.Error.NETWORK_FAILURE); 63 connection.connect( 80 connection.loginHandler_.onHandshakeDoneCallback_('test@example.com/123123',
|
/external/chromium_org/extensions/renderer/resources/ |
H A D | serial_custom_bindings.js | 9 * serial_service module. The functions that apply to a particular connection 41 }).then(function(connection) { 42 return $Function.apply(connection[methodName], connection, args); 60 result.connection.onData = function(data) { 64 result.connection.onError = function(error) {
|
/external/chromium_org/extensions/browser/api/serial/ |
H A D | serial_api.cc | 41 const char kErrorSerialConnectionNotFound[] = "Serial connection not found."; 194 SerialConnection* connection = GetSerialConnection(params_->connection_id); local 195 if (!connection) { 199 bool success = connection->Configure(params_->options); 217 SerialConnection* connection = GetSerialConnection(params_->connection_id); local 218 if (!connection) { 240 SerialConnection* connection = GetSerialConnection(params_->connection_id); local 241 if (!connection) { 247 if (!connection->Send( 276 SerialConnection* connection local 302 SerialConnection* connection = GetSerialConnection(params_->connection_id); local 333 SerialConnection* connection = GetSerialConnection(params_->connection_id); local 364 SerialConnection* connection = GetSerialConnection(connection_id); local 390 SerialConnection* connection = GetSerialConnection(params_->connection_id); local 419 SerialConnection* connection = GetSerialConnection(params_->connection_id); local [all...] |
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
H A D | test_mux.py | 65 """Mock class of mod_python connection for mux.""" 219 connection=_MockMuxConnection()) 401 request.connection.put_bytes(add_channel_request) 406 request.connection.put_bytes(flow_control) 412 request.connection.put_bytes(add_channel_request) 417 request.connection.put_bytes(flow_control) 419 request.connection.put_bytes( 421 request.connection.put_bytes( 423 request.connection.put_bytes( 425 request.connection [all...] |