/external/smack/src/org/jivesoftware/smack/ |
H A D | ReconnectionManager.java | 23 * Handles the automatic reconnection process. Every time a connection is dropped without
38 // Holds the connection to the server
39 private Connection connection;
field in class:ReconnectionManager 47 // Create a new PrivacyListManager on every established connection. In the init()
49 // instance when the connection is closed.
51 public void connectionCreated(Connection connection) {
52 connection.addConnectionListener(new ReconnectionManager(connection));
57 private ReconnectionManager(Connection connection) {
argument 58 this.connection [all...] |
H A D | PacketReader.java | 49 private XMPPConnection connection; field in class:PacketReader 55 protected PacketReader(final XMPPConnection connection) { argument 56 this.connection = connection; 62 * first connection and when reconnecting due to an abruptly disconnection. 73 readerThread.setName("Smack Packet Reader (" + connection.connectionCounterValue + ")"); 82 "Smack Listener Processor (" + connection.connectionCounterValue + ")"); 92 * Starts the packet reader thread and returns once a connection to the server 93 * has been established. A connection will be attempted for a maximum of five 94 * seconds. An XMPPException will be thrown if the connection fail [all...] |
H A D | PacketWriter.java | 45 private XMPPConnection connection; field in class:PacketWriter 50 * Creates a new packet writer with the specified connection. 52 * @param connection the connection. 54 protected PacketWriter(XMPPConnection connection) { argument 56 this.connection = connection; 61 * Initializes the writer in order to be used. It is called at the first connection and also 62 * is invoked if the connection is disconnected by an error. 65 this.writer = connection [all...] |
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/testdata/handlers/sub/ |
H A D | no_wsh_at_the_end.py | 40 request.connection.write(
|
H A D | plain_wsh.py | 36 request.connection.write('sub/plain_wsh.py is called for %s, %s' %
|
H A D | wrong_handshake_sig_wsh.py | 40 request.connection.write(
|
H A D | wrong_transfer_sig_wsh.py | 40 request.connection.write(
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
H A D | ConnectionPool.java | 45 * connection alive in the pool before closing it. Default is 5 minutes. 120 // See whether we should continue checking the connection pool. 148 Connection connection = i.previous(); 149 if (!connection.isAlive() || connection.isExpired(keepAliveDurationNs)) { 151 expiredConnections.add(connection); 153 } else if (connection.isIdle()) { 160 Connection connection = i.previous(); 161 if (connection.isIdle()) { 162 expiredConnections.add(connection); 273 recycle(Connection connection) argument 309 share(Connection connection) argument [all...] |
/external/chromium_org/mojo/examples/apptest/ |
H A D | example_service_application.cc | 18 ApplicationConnection* connection) { 19 connection->AddService(&example_service_factory_); 17 ConfigureIncomingConnection( ApplicationConnection* connection) argument
|
/external/chromium_org/mojo/public/cpp/application/ |
H A D | application_delegate.h | 28 // Override this method to configure what services a connection supports when 30 // return false to reject the connection entirely. 31 virtual bool ConfigureIncomingConnection(ApplicationConnection* connection); 33 // Override this method to configure what services a connection supports when 35 // return false to reject the connection entirely. 36 virtual bool ConfigureOutgoingConnection(ApplicationConnection* connection);
|
/external/chromium_org/net/data/websocket/ |
H A D | close-with-split-packet_wsh.py | 23 request.connection.write(packet[:1]) 24 request.connection.write(packet[1:]) 25 raise handshake.AbortedByUserException('Abort the connection')
|
/external/chromium_org/net/quic/ |
H A D | quic_client_session_base.cc | 12 QuicConnection* connection, 14 : QuicSession(connection, config) {} 11 QuicClientSessionBase( QuicConnection* connection, const QuicConfig& config) argument
|
/external/chromium_org/content/public/android/java/src/org/chromium/content/browser/ |
H A D | BindingManagerImpl.java | 35 * bindings of the connection. The reference to ChildProcessConnection is cleared when the 36 * connection goes away, but ManagedConnection itself is kept (until overwritten by a new entry 56 final ChildProcessConnection connection = mConnection; 57 if (connection == null || !connection.isInitialBindingBound()) return; 62 if (connection.isInitialBindingBound()) { 63 connection.removeInitialBinding(); 71 ChildProcessConnection connection = mConnection; 72 if (connection == null) return; 74 connection 114 ManagedConnection(ChildProcessConnection connection) argument 210 addNewConnection(int pid, ChildProcessConnection connection) argument [all...] |
/external/chromium_org/mojo/shell/ |
H A D | view_manager_loader.cc | 42 ApplicationConnection* connection) { 43 context_.ConfigureIncomingConnection(connection); 44 connection->AddService(this); 49 ApplicationConnection* connection, 51 BindToRequest(new ViewManagerInitServiceImpl(connection, &context_), 41 ConfigureIncomingConnection( ApplicationConnection* connection) argument 48 Create( ApplicationConnection* connection, InterfaceRequest<ViewManagerInitService> request) argument
|
/external/smack/src/org/jivesoftware/smackx/ |
H A D | XHTMLManager.java | 43 // Enable the XHTML support on every established connection 47 public void connectionCreated(Connection connection) { 48 XHTMLManager.setServiceEnabled(connection, true); 96 * Enables or disables the XHTML support on a given connection.<p> 101 * @param connection the connection where the service will be enabled or disabled 104 public synchronized static void setServiceEnabled(Connection connection, boolean enabled) { argument 105 if (isServiceEnabled(connection) == enabled) 109 ServiceDiscoveryManager.getInstanceFor(connection).addFeature(namespace); 112 ServiceDiscoveryManager.getInstanceFor(connection) 122 isServiceEnabled(Connection connection) argument 133 isServiceEnabled(Connection connection, String userID) argument [all...] |
H A D | GatewayManager.java | 41 private Connection connection; field in class:GatewayManager 51 * @param connection 54 private GatewayManager(Connection connection) throws XMPPException{ argument 55 this.connection = connection; 56 this.roster = connection.getRoster(); 57 sdManager = ServiceDiscoveryManager.getInstanceFor(connection); 65 DiscoverItems items = sdManager.discoverItems(connection.getHost()); 87 gateways.put(itemJID, new Gateway(connection,itemJID)); 88 if(itemJID.contains(connection 124 getInstanceFor(Connection connection) argument [all...] |
/external/smack/src/org/jivesoftware/smackx/carbons/ |
H A D | CarbonManager.java | 53 public void connectionCreated(Connection connection) { 54 new CarbonManager(connection); 59 private Connection connection; field in class:CarbonManager 62 private CarbonManager(Connection connection) { argument 63 ServiceDiscoveryManager sdm = ServiceDiscoveryManager.getInstanceFor(connection); 65 this.connection = connection; 66 instances.put(connection, this); 70 * Obtain the CarbonManager responsible for a connection. 72 * @param connection th 76 getInstanceFor(Connection connection) argument [all...] |
/external/chromium_org/mojo/services/view_manager/ |
H A D | view_manager_init_service_context.cc | 25 ViewManagerInitServiceImpl* connection) { 26 DCHECK(std::find(connections_.begin(), connections_.end(), connection) == 28 connections_.push_back(connection); 32 ViewManagerInitServiceImpl* connection) { 35 std::find(connections_.begin(), connections_.end(), connection); 48 ApplicationConnection* connection) { 51 connection, 66 // Prevent the connection from modifying the connection list during manual 24 AddConnection( ViewManagerInitServiceImpl* connection) argument 31 RemoveConnection( ViewManagerInitServiceImpl* connection) argument 47 ConfigureIncomingConnection( ApplicationConnection* connection) argument
|
/external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/guide/ |
H A D | PostExample.java | 22 HttpURLConnection connection = client.open(url); 27 connection.setRequestMethod("POST"); 28 out = connection.getOutputStream(); 33 if (connection.getResponseCode() != HttpURLConnection.HTTP_OK) { 35 + connection.getResponseCode() + " " + connection.getResponseMessage()); 37 in = connection.getInputStream();
|
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/ |
H A D | SpdyConnectionTest.java | 75 SpdyConnection connection = connection(peer, SPDY3); 76 SpdyStream stream = connection.newStream(headerEntries("b", "banana"), true, true); 82 assertEquals(0, connection.openStreamCount()); 102 SpdyConnection connection = connection(peer, SPDY3); 103 SpdyStream stream = connection.newStream(headerEntries("a", "android"), false, false); 104 assertEquals(1, connection.openStreamCount()); 106 assertEquals(0, connection.openStreamCount()); 118 SpdyConnection connection 1556 private SpdyConnection connection(MockSpdyPeer peer, Variant variant) throws IOException { method in class:SpdyConnectionTest [all...] |
/external/chromium_org/mojo/examples/surfaces_app/ |
H A D | child_app.cc | 28 ApplicationConnection* connection) OVERRIDE { 29 connection->AddService(this); 34 virtual void Create(ApplicationConnection* connection,
|
/external/chromium_org/mojo/services/clipboard/ |
H A D | main.cc | 27 mojo::ApplicationConnection* connection) OVERRIDE { 28 connection->AddService(this); 34 mojo::ApplicationConnection* connection,
|
/external/chromium_org/mojo/services/test_service/ |
H A D | test_service_application.h | 27 virtual bool ConfigureIncomingConnection(ApplicationConnection* connection) 31 virtual void Create(ApplicationConnection* connection, 35 virtual void Create(ApplicationConnection* connection,
|
/external/smack/src/org/jivesoftware/smackx/workgroup/agent/ |
H A D | Agent.java | 39 private Connection connection;
field in class:Agent 42 public static Collection<String> getWorkgroups(String serviceJID, String agentJID, Connection connection) throws XMPPException {
argument 45 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID()));
47 connection.sendPacket(request);
65 Agent(Connection connection, String workgroupJID) {
argument 66 this.connection = connection;
76 return connection.getUser();
89 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(agentInfo.getPacketID()));
91 connection [all...] |
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/example/ |
H A D | origin_check_wsh.py | 40 request.connection.write('origin_check_wsh.py is called for %s, %s' %
|