Searched refs:connection (Results 26 - 50 of 701) sorted by relevance

1234567891011>>

/external/smack/src/org/jivesoftware/smack/
H A DReconnectionManager.java23 * 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 DPacketReader.java49 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 DPacketWriter.java45 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 Dno_wsh_at_the_end.py40 request.connection.write(
H A Dplain_wsh.py36 request.connection.write('sub/plain_wsh.py is called for %s, %s' %
H A Dwrong_handshake_sig_wsh.py40 request.connection.write(
H A Dwrong_transfer_sig_wsh.py40 request.connection.write(
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
H A DConnectionPool.java45 * 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 Dexample_service_application.cc18 ApplicationConnection* connection) {
19 connection->AddService(&example_service_factory_);
17 ConfigureIncomingConnection( ApplicationConnection* connection) argument
/external/chromium_org/mojo/public/cpp/application/
H A Dapplication_delegate.h28 // 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 Dclose-with-split-packet_wsh.py23 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 Dquic_client_session_base.cc12 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 DBindingManagerImpl.java35 * 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 Dview_manager_loader.cc42 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 DXHTMLManager.java43 // 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 DGatewayManager.java41 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 DCarbonManager.java53 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 Dview_manager_init_service_context.cc25 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 DPostExample.java22 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 DSpdyConnectionTest.java75 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 Dchild_app.cc28 ApplicationConnection* connection) OVERRIDE {
29 connection->AddService(this);
34 virtual void Create(ApplicationConnection* connection,
/external/chromium_org/mojo/services/clipboard/
H A Dmain.cc27 mojo::ApplicationConnection* connection) OVERRIDE {
28 connection->AddService(this);
34 mojo::ApplicationConnection* connection,
/external/chromium_org/mojo/services/test_service/
H A Dtest_service_application.h27 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 DAgent.java39 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 Dorigin_check_wsh.py40 request.connection.write('origin_check_wsh.py is called for %s, %s' %

Completed in 2483 milliseconds

1234567891011>>