| /frameworks/base/tools/preload2/src/com/android/preload/classdataretrieval/hprof/ |
| Hprof.java | 19 import com.android.ddmlib.Client;
48 public static File doHprof(Client client, int timeout) {
49 GetHprof gh = new GetHprof(client, timeout);
119 private Client client; field in class:Hprof.GetHprof
121 public GetHprof(Client client, long timeout) {
122 this.client = client;
[all...] |
| /frameworks/native/libs/vr/libbufferhub/include/private/dvr/ |
| buffer_hub_client.h | 6 #include <pdx/client.h>
19 class BufferHubClient : public pdx::Client {
27 using pdx::Client::Close;
28 using pdx::Client::GetChannel;
29 using pdx::Client::InvokeRemoteMethod;
30 using pdx::Client::IsConnected;
31 using pdx::Client::event_fd;
34 class BufferHubBuffer : public pdx::Client {
85 using Client::event_fd;
115 // A state mask which is unique to a buffer hub client among all its sibling
[all...] |
| /prebuilts/go/darwin-x86/src/net/smtp/ |
| smtp.go | 29 // A Client represents a client connection to an SMTP server.
30 type Client struct {
31 // Text is the textproto.Conn used by the Client. It is exported to allow for
37 // whether the Client is using TLS
49 // Dial returns a new Client connected to an SMTP server at addr.
51 func Dial(addr string) (*Client, error) {
60 // NewClient returns a new Client using an existing connection and host as a
62 func NewClient(conn net.Conn, host string) (*Client, error) {
69 c := &Client{Text: text, conn: conn, serverName: host, localName: "localhost"
[all...] |
| /prebuilts/go/linux-x86/src/net/smtp/ |
| smtp.go | 29 // A Client represents a client connection to an SMTP server.
30 type Client struct {
31 // Text is the textproto.Conn used by the Client. It is exported to allow for
37 // whether the Client is using TLS
49 // Dial returns a new Client connected to an SMTP server at addr.
51 func Dial(addr string) (*Client, error) {
60 // NewClient returns a new Client using an existing connection and host as a
62 func NewClient(conn net.Conn, host string) (*Client, error) {
69 c := &Client{Text: text, conn: conn, serverName: host, localName: "localhost"
[all...] |
| /frameworks/data-binding/compilerCommon/src/main/java/android/databinding/tool/util/ |
| L.java | 32 private static final Client sSystemClient = new Client() {
43 private static Client sClient = sSystemClient;
45 public static void setClient(Client systemClient) {
136 public interface Client {
|
| /frameworks/av/media/libmediaplayerservice/ |
| MediaPlayerService.cpp | 294 ALOGV("Create new media recorder client from pid %d", pid);
298 void MediaPlayerService::removeMediaRecorderClient(const wp<MediaRecorderClient>& client)
301 mMediaRecorderClients.remove(client);
302 ALOGV("Delete media recorder client");
313 sp<IMediaPlayer> MediaPlayerService::create(const sp<IMediaPlayerClient>& client,
319 sp<Client> c = new Client(
320 this, pid, connId, client, audioSessionId,
323 ALOGV("Create new client(%d) from pid %d, uid %d, ", connId, pid,
326 wp<Client> w = c
[all...] |
| /external/autotest/site_utils/lxc/container_pool/ |
| client.py | 20 # Extra timeout to use on the client side; limits network communication time.
23 class Client(object):
26 The Client class enables clients to communicate with a running container
33 client = Client(pool_address, timeout)
34 print(client.get_status())
35 client.close()
40 with Client.connect(pool_address, timeout) as client:
41 print(client.get_status()
[all...] |
| unittest_client.py | 12 """Creates an AsyncListener client for testing purposes.
24 """Factory class for making client connections with a timeout.
42 """Instantiates a connection.Client."""
43 self._client = connection.Client(self._address)
47 """Attempts to create a connection.Client with a timeout.
54 @return: A connection.Client connected using the address that was
72 'Test client failed to connect after %s seconds', i)
74 raise socket.timeout('Test client timed out waiting for connection.')
|
| /prebuilts/jdk/jdk8/darwin-x86/sample/nio/chatserver/ |
| Client.java | 50 * Client represents a remote connection to the chat server.
54 * messages are buffered in the {@code Client}.
59 class Client {
68 public Client(AsynchronousSocketChannel channel, ClientReader reader) {
140 * Send a message from a specific client
141 * @param client the message is sent from
144 public void writeMessageFrom(Client client, String message) {
146 writeStringMessage(client.getUserName() + ": " + message);
|
| ClientReader.java | 45 * Handles a cycle of reading / writing on the {@code Client}.
62 * read on the client. Handles closed channels and errors while reading.
63 * If the client is still connected a new round of actions are called.
65 public void run(final Client client) {
66 callback.beforeRead(client);
67 client.read(new CompletionHandler<Integer, ByteBuffer>() {
72 client.close();
73 System.out.println("Closing connection to " + client);
74 chatServer.removeClient(client);
[all...] |
| /prebuilts/jdk/jdk8/linux-x86/sample/nio/chatserver/ |
| Client.java | 50 * Client represents a remote connection to the chat server.
54 * messages are buffered in the {@code Client}.
59 class Client {
68 public Client(AsynchronousSocketChannel channel, ClientReader reader) {
140 * Send a message from a specific client
141 * @param client the message is sent from
144 public void writeMessageFrom(Client client, String message) {
146 writeStringMessage(client.getUserName() + ": " + message);
|
| ClientReader.java | 45 * Handles a cycle of reading / writing on the {@code Client}.
62 * read on the client. Handles closed channels and errors while reading.
63 * If the client is still connected a new round of actions are called.
65 public void run(final Client client) {
66 callback.beforeRead(client);
67 client.read(new CompletionHandler<Integer, ByteBuffer>() {
72 client.close();
73 System.out.println("Closing connection to " + client);
74 chatServer.removeClient(client);
[all...] |
| /prebuilts/go/darwin-x86/src/net/rpc/ |
| client.go | 37 // Client represents an RPC Client.
39 // with a single Client, and a Client may be used by
41 type Client struct {
55 // reading of RPC responses for the client side of an RPC session.
56 // The client calls WriteRequest to write a request to the connection
58 // to read responses. The client calls Close when finished with the
71 func (client *Client) send(call *Call)
[all...] |
| /prebuilts/go/linux-x86/src/net/rpc/ |
| client.go | 37 // Client represents an RPC Client.
39 // with a single Client, and a Client may be used by
41 type Client struct {
55 // reading of RPC responses for the client side of an RPC session.
56 // The client calls WriteRequest to write a request to the connection
58 // to read responses. The client calls Close when finished with the
71 func (client *Client) send(call *Call)
[all...] |
| /external/libmojo/mojo/common/ |
| data_pipe_drainer.cc | 16 DataPipeDrainer::DataPipeDrainer(Client* client,
18 : client_(client),
|
| /external/pdfium/xfa/fxfa/parser/ |
| cxfa_execute.cpp | 19 (void*)XFA_AttributeEnum::Client},
|
| /external/tensorflow/tensorflow/compiler/xla/tools/ |
| show_signature.cc | 32 #include "tensorflow/compiler/xla/client/client.h"
33 #include "tensorflow/compiler/xla/client/client_library.h"
34 #include "tensorflow/compiler/xla/client/computation.h"
35 #include "tensorflow/compiler/xla/client/local_client.h"
50 Client* client = ClientLibrary::LocalClientOrDie(); local
55 Computation computation = client->LoadSnapshot(module).ConsumeValueOrDie();
57 client->GetComputationShape(computation).ConsumeValueOrDie();
|
| /frameworks/native/libs/vr/libdisplay/include/private/dvr/ |
| display_manager_client.h | 7 #include <pdx/client.h>
27 using Client::event_fd;
|
| /external/boringssl/src/tool/ |
| tool.cc | 46 { "client", Client },
53 { "s_client", Client },
|
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| RenegotiationTest.java | 54 * This tests that server-initiated cipher renegotiation works properly with a Conscrypt client.
70 Client newClient(int port) {
71 return new Client(false, port);
76 Client newClient(int port) {
77 return new Client(true, port);
81 abstract Client newClient(int port);
92 private Client client; field in class:RenegotiationTest
100 client = socketType.newClient(server.port());
101 client.start()
[all...] |
| /external/pdfium/xfa/fxfa/ |
| cxfa_ffsignature.cpp | 100 return FWL_WidgetHit::Client;
107 return FWL_WidgetHit::Client;
|
| /external/clang/lib/Frontend/Rewrite/ |
| FixItRewriter.cpp | 1 //===--- FixItRewriter.cpp - Fix-It Rewriter Diagnostic Client --*- C++ -*-===//
10 // This is a diagnostic client adaptor that performs rewrites as
12 // then forwards any diagnostics to the adapted diagnostic client.
40 Client = Diags.getClient();
45 Diags.setClient(Client, Owner.release() != nullptr);
119 return Client ? Client->IncludeInDiagnosticCounts() : true;
131 Client->HandleDiagnostic(DiagLevel, Info);
192 /// \brief Emit a diagnostic via the adapted diagnostic client.
195 // clear out any current diagnostic, and let the downstream client
[all...] |
| /frameworks/base/tools/preload2/src/com/android/preload/ui/ |
| SwingUI.java | 19 import com.android.ddmlib.Client;
46 private JList<Client> clientList;
62 public void prepare(ListModel<Client> clientListModel, TableModel dataTableModel,
64 getContentPane().add(new JScrollPane(clientList = new JList<Client>(clientListModel)),
93 public Client getSelectedClient() {
286 ClientData cd = ((Client) value).getClientData();
|
| /device/google/contexthub/contexthubhal/test/ |
| main.cpp | 67 class Client : IClient {
73 explicit Client(const context_hub_t *hub, CHub *parent) {
77 ~Client() = default;
114 mHubs[item->hub_id] = std::unique_ptr<Client>(new Client(item, this));
131 Client *cli = getClientById(hubId);
151 Client *getClientById(size_t id) { return mHubs.count(id) ? mHubs[id].get() : nullptr; }
156 std::map <size_t, std::unique_ptr<Client> > mHubs;
164 Client *getClientByIndex(size_t idx) {
172 CHub::Client *mClient
[all...] |
| /prebuilts/go/darwin-x86/src/net/http/httptest/ |
| server_test.go | 143 // Tests that the Server.Client method works and returns an http.Client that can hit
150 client := ts.Client()
151 res, err := client.Get(ts.URL)
165 // Tests that the Server.Client.Transport interface is implemented
171 client := ts.Client()
172 if _, ok := client.Transport.(*http.Transport); !ok {
173 t.Errorf("got %T, want *http.Transport", client.Transport
[all...] |
