| /external/libvncserver/libvncclient/ |
| D | vncviewer.c | 44 static void Dummy(rfbClient* client) { in Dummy() argument
46 static rfbBool DummyPoint(rfbClient* client, int x, int y) { in DummyPoint() argument
49 static void DummyRect(rfbClient* client, int x, int y, int w, int h) { in DummyRect() argument
53 static char* NoPassword(rfbClient* client) { in NoPassword() argument
62 static char* ReadPassword(rfbClient* client) { in ReadPassword() argument
66 return NoPassword(client); in ReadPassword()
91 static rfbBool MallocFrameBuffer(rfbClient* client) { in MallocFrameBuffer() argument
94 if(client->frameBuffer) in MallocFrameBuffer()
95 free(client->frameBuffer); in MallocFrameBuffer()
101 allocSize = (uint64_t)client->width * client->height * client->format.bitsPerPixel/8; in MallocFrameBuffer()
[all …]
|
| D | tight.c | 53 (((CARD##bpp)(r) & client->format.redMax) << client->format.redShift | \
54 ((CARD##bpp)(g) & client->format.greenMax) << client->format.greenShift | \
55 ((CARD##bpp)(b) & client->format.blueMax) << client->format.blueShift)
58 ((((CARD##bpp)(r) & 0xFF) * client->format.redMax + 127) / 255 \
59 << client->format.redShift | \
60 (((CARD##bpp)(g) & 0xFF) * client->format.greenMax + 127) / 255 \
61 << client->format.greenShift | \
62 (((CARD##bpp)(b) & 0xFF) * client->format.blueMax + 127) / 255 \
63 << client->format.blueShift)
66 (((uint32_t)(r) & 0xFF) << client->format.redShift | \
[all …]
|
| D | listen.c | 49 listenForIncomingConnections(rfbClient* client) in listenForIncomingConnections() argument
59 client->listenSpecified = TRUE; in listenForIncomingConnections()
61 listenSocket = ListenAtTcpPortAndAddress(client->listenPort, client->listenAddress); in listenForIncomingConnections()
67 client->programName,client->listenPort); in listenForIncomingConnections()
69 "a connection comes in.\n", client->programName); in listenForIncomingConnections()
73 if (client->listen6Port > 0) in listenForIncomingConnections()
75 listen6Socket = ListenAtTcpPortAndAddress(client->listen6Port, client->listen6Address); in listenForIncomingConnections()
81 client->programName,client->listenPort); in listenForIncomingConnections()
83 "a connection comes in.\n", client->programName); in listenForIncomingConnections()
106 client->sock = AcceptTcpConnection(client->listenSock); in listenForIncomingConnections()
[all …]
|
| D | rfbproto.c | 119 void rfbClientSetClientData(rfbClient* client, void* tag, void* data) in rfbClientSetClientData() argument
121 rfbClientData* clientData = client->clientData; in rfbClientSetClientData()
127 clientData->next = client->clientData; in rfbClientSetClientData()
128 client->clientData = clientData; in rfbClientSetClientData()
135 void* rfbClientGetClientData(rfbClient* client, void* tag) in rfbClientGetClientData() argument
137 rfbClientData* clientData = client->clientData; in rfbClientGetClientData()
150 static void FillRectangle(rfbClient* client, int x, int y, int w, int h, uint32_t colour) { in FillRectangle() argument
154 for(j=y*client->width;j<(y+h)*client->width;j+=client->width) \ in FillRectangle()
156 ((uint##BPP##_t*)client->frameBuffer)[j+i]=colour; in FillRectangle()
158 switch(client->format.bitsPerPixel) { in FillRectangle()
[all …]
|
| D | ultra.c | 35 HandleUltraBPP (rfbClient* client, int rx, int ry, int rw, int rh) in HandleUltraBPP() argument
42 if (!ReadFromRFBServer(client, (char *)&hdr, sz_rfbZlibHeader)) in HandleUltraBPP()
60 if ( client->raw_buffer_size < (int)uncompressedBytes) { in HandleUltraBPP()
61 if ( client->raw_buffer != NULL ) { in HandleUltraBPP()
62 free( client->raw_buffer ); in HandleUltraBPP()
64 client->raw_buffer_size = uncompressedBytes; in HandleUltraBPP()
66 if ((client->raw_buffer_size % 4)!=0) in HandleUltraBPP()
67 client->raw_buffer_size += (4-(client->raw_buffer_size % 4)); in HandleUltraBPP()
68 client->raw_buffer = (char*) malloc( client->raw_buffer_size ); in HandleUltraBPP()
72 if ( client->ultra_buffer_size < toRead ) { in HandleUltraBPP()
[all …]
|
| D | cursor.c | 32 ((((uint##bpp##_t)(r) & 0xFF) * client->format.redMax + 127) / 255 \
33 << client->format.redShift | \
34 (((uint##bpp##_t)(g) & 0xFF) * client->format.greenMax + 127) / 255 \
35 << client->format.greenShift | \
36 (((uint##bpp##_t)(b) & 0xFF) * client->format.blueMax + 127) / 255 \
37 << client->format.blueShift)
46 rfbBool HandleCursorShape(rfbClient* client,int xhot, int yhot, int width, int height, uint32_t enc) in HandleCursorShape() argument
56 bytesPerPixel = client->format.bitsPerPixel / 8; in HandleCursorShape()
64 if(client->rcSource) in HandleCursorShape()
65 free(client->rcSource); in HandleCursorShape()
[all …]
|
| D | zlib.c | 36 HandleZlibBPP (rfbClient* client, int rx, int ry, int rw, int rh) in HandleZlibBPP() argument
49 if ( client->raw_buffer_size < (( rw * rh ) * ( BPP / 8 ))) { in HandleZlibBPP()
51 if ( client->raw_buffer != NULL ) { in HandleZlibBPP()
53 free( client->raw_buffer ); in HandleZlibBPP()
57 client->raw_buffer_size = (( rw * rh ) * ( BPP / 8 )); in HandleZlibBPP()
58 client->raw_buffer = (char*) malloc( client->raw_buffer_size ); in HandleZlibBPP()
62 if (!ReadFromRFBServer(client, (char *)&hdr, sz_rfbZlibHeader)) in HandleZlibBPP()
68 client->decompStream.next_in = ( Bytef * )client->buffer; in HandleZlibBPP()
69 client->decompStream.avail_in = 0; in HandleZlibBPP()
70 client->decompStream.next_out = ( Bytef * )client->raw_buffer; in HandleZlibBPP()
[all …]
|
| D | zrle.c | 79 static int HandleZRLETile(rfbClient* client,
84 HandleZRLE (rfbClient* client, int rx, int ry, int rw, int rh) in HandleZRLE() argument
98 if ( client->raw_buffer_size < min_buffer_size) { in HandleZRLE()
100 if ( client->raw_buffer != NULL ) { in HandleZRLE()
102 free( client->raw_buffer ); in HandleZRLE()
106 client->raw_buffer_size = min_buffer_size; in HandleZRLE()
107 client->raw_buffer = (char*) malloc( client->raw_buffer_size ); in HandleZRLE()
111 if (!ReadFromRFBServer(client, (char *)&header, sz_rfbZRLEHeader)) in HandleZRLE()
117 client->decompStream.next_in = ( Bytef * )client->buffer; in HandleZRLE()
118 client->decompStream.avail_in = 0; in HandleZRLE()
[all …]
|
| D | tls_gnutls.c | 90 rfbClient *client = (rfbClient*)transport; in PushTLS() local
95 ret = write(client->sock, data, len); in PushTLS()
112 rfbClient *client = (rfbClient*)transport; in PullTLS() local
117 ret = read(client->sock, data, len); in PullTLS()
131 InitializeTLSSession(rfbClient* client, rfbBool anonTLS) in InitializeTLSSession() argument
136 if (client->tlsSession) return TRUE; in InitializeTLSSession()
138 if ((ret = gnutls_init((gnutls_session_t*)&client->tlsSession, GNUTLS_CLIENT)) < 0) in InitializeTLSSession()
144 if ((ret = gnutls_priority_set_direct((gnutls_session_t)client->tlsSession, in InitializeTLSSession()
150 gnutls_transport_set_ptr((gnutls_session_t)client->tlsSession, (gnutls_transport_ptr_t)client); in InitializeTLSSession()
151 gnutls_transport_set_push_function((gnutls_session_t)client->tlsSession, PushTLS); in InitializeTLSSession()
[all …]
|
| D | tls_openssl.c | 176 rfbClient *client; in ssl_verify() local
188 client = SSL_CTX_get_app_data (ssl->ctx); in ssl_verify()
261 open_ssl_connection (rfbClient *client, int sockfd, rfbBool anonTLS) in open_ssl_connection() argument
276 SSL_CTX_set_app_data (ssl_ctx, client); in open_ssl_connection()
302 InitializeTLSSession(rfbClient* client, rfbBool anonTLS) in InitializeTLSSession() argument
304 if (client->tlsSession) return TRUE; in InitializeTLSSession()
306 client->tlsSession = open_ssl_connection (client, client->sock, anonTLS); in InitializeTLSSession()
308 if (!client->tlsSession) in InitializeTLSSession()
317 SetTLSAnonCredential(rfbClient* client) in SetTLSAnonCredential() argument
324 HandshakeTLS(rfbClient* client) in HandshakeTLS() argument
[all …]
|
| /external/fio/ |
| D | client.c | 28 static void handle_du(struct fio_client *client, struct fio_net_cmd *cmd);
29 static void handle_ts(struct fio_client *client, struct fio_net_cmd *cmd);
30 static void handle_gs(struct fio_client *client, struct fio_net_cmd *cmd);
31 static void handle_probe(struct fio_client *client, struct fio_net_cmd *cmd);
32 static void handle_text(struct fio_client *client, struct fio_net_cmd *cmd);
33 static void handle_stop(struct fio_client *client, struct fio_net_cmd *cmd);
34 static void handle_start(struct fio_client *client, struct fio_net_cmd *cmd);
77 static void fio_client_add_hash(struct fio_client *client) in fio_client_add_hash() argument
79 int bucket = hash_long(client->fd, FIO_CLIENT_HASH_BITS); in fio_client_add_hash()
82 flist_add(&client->hash_list, &client_hash[bucket]); in fio_client_add_hash()
[all …]
|
| /external/webrtc/webrtc/base/ |
| D | socket_unittest.cc | 197 scoped_ptr<AsyncSocket> client(ss_->CreateAsyncSocket(loopback.family(), in ConnectInternal() local
199 sink.Monitor(client.get()); in ConnectInternal()
200 EXPECT_EQ(AsyncSocket::CS_CLOSED, client->GetState()); in ConnectInternal()
201 EXPECT_PRED1(IsUnspecOrEmptyIP, client->GetLocalAddress().ipaddr()); in ConnectInternal()
217 EXPECT_EQ(0, client->Connect(server->GetLocalAddress())); in ConnectInternal()
218 EXPECT_FALSE(client->GetLocalAddress().IsNil()); in ConnectInternal()
219 EXPECT_NE(server->GetLocalAddress(), client->GetLocalAddress()); in ConnectInternal()
222 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client->GetState()); in ConnectInternal()
223 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_OPEN)); in ConnectInternal()
224 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE)); in ConnectInternal()
[all …]
|
| /external/libvncserver/rfb/ |
| D | rfbclient.h | 47 (*(char *)&client->endianTest ? ((((s) & 0xff) << 8) | (((s) >> 8) & 0xff)) : (s))
50 (*(char *)&client->endianTest ? ((((l) & 0xff000000) >> 24) | \
56 (*(char *)&client->endianTest ? ((((l) & 0xff00000000000000ULL) >> 56) | \
154 typedef void (*HandleTextChatProc)(struct _rfbClient* client, int value, char *text);
164 typedef void (*HandleXvpMsgProc)(struct _rfbClient* client, uint8_t version, uint8_t opcode);
165 typedef void (*HandleKeyboardLedStateProc)(struct _rfbClient* client, int value, int pad);
166 typedef rfbBool (*HandleCursorPosProc)(struct _rfbClient* client, int x, int y);
167 typedef void (*SoftCursorLockAreaProc)(struct _rfbClient* client, int x, int y, int w, int h);
168 typedef void (*SoftCursorUnlockScreenProc)(struct _rfbClient* client);
169 typedef void (*GotFrameBufferUpdateProc)(struct _rfbClient* client, int x, int y, int w, int h);
[all …]
|
| /external/autotest/client/common_lib/cros/ |
| D | cr50_utils.py | 10 from autotest_lib.client.common_lib import error
134 def GetSavedVersion(client): argument
136 result = client.run(GET_CR50_VERSION).stdout.strip()
140 def UsbUpdater(client, args): argument
152 result = client.run("status trunksd")
154 client.run("stop trunksd")
163 result = client.run("usb_updater %s" % ' '.join(args),
176 def GetVersionFromUpdater(client, args): argument
178 result = UsbUpdater(client, args).stdout.strip()
182 def GetFwVersion(client): argument
[all …]
|
| D | tpm_utils.py | 7 from autotest_lib.client.common_lib import error
25 def TPMStatus(client): argument
30 out = client.run('cryptohome --action=tpm_status').stdout.strip()
47 def IsTPMAvailable(client): argument
52 status = TPMStatus(client)
56 def ClearTPMServer(client, out_dir): argument
62 if IsTPMAvailable(client):
66 client.run('stop ui')
68 password = TPMStatus(client)['Password']
71 client.get_file(_PASSWD_FILE, out_dir)
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | OkHttpClientTest.java | 61 OkHttpClient client = new OkHttpClient(); in timeoutDefaults() local
62 assertEquals(10_000, client.getConnectTimeout()); in timeoutDefaults()
63 assertEquals(10_000, client.getReadTimeout()); in timeoutDefaults()
64 assertEquals(10_000, client.getWriteTimeout()); in timeoutDefaults()
68 OkHttpClient client = new OkHttpClient(); in timeoutValidRange() local
70 client.setConnectTimeout(1, TimeUnit.NANOSECONDS); in timeoutValidRange()
74 client.setWriteTimeout(1, TimeUnit.NANOSECONDS); in timeoutValidRange()
78 client.setReadTimeout(1, TimeUnit.NANOSECONDS); in timeoutValidRange()
82 client.setConnectTimeout(365, TimeUnit.DAYS); in timeoutValidRange()
86 client.setWriteTimeout(365, TimeUnit.DAYS); in timeoutValidRange()
[all …]
|
| D | URLConnectionTest.java | 109 private OkUrlFactory client; field in URLConnectionTest
115 client = new OkUrlFactory(new OkHttpClient()); in setUp()
135 connection = client.open(server.getUrl("/")); in requestHeaders()
194 connection = client.open(server.getUrl("/")); in getRequestPropertyReturnsLastValue()
207 connection = client.open(server.getUrl("/")); in responseHeaders()
237 connection = client.open(server.getUrl("/")); in serverSendsInvalidResponseHeaders()
248 connection = client.open(server.getUrl("/")); in serverSendsInvalidCodeTooLarge()
259 connection = client.open(server.getUrl("/")); in serverSendsInvalidCodeNotANumber()
270 connection = client.open(server.getUrl("/")); in serverSendsUnnecessaryWhitespace()
282 connection = client.open(url); in connectRetriesUntilConnectedOrFailed()
[all …]
|
| D | DispatcherTest.java | 20 OkHttpClient client = new OkHttpClient().setDispatcher(dispatcher); field in DispatcherTest
44 client.newCall(newRequest("http://a/1")).enqueue(callback); in enqueuedJobsRunImmediately()
50 client.newCall(newRequest("http://a/1")).enqueue(callback); in maxRequestsEnforced()
51 client.newCall(newRequest("http://a/2")).enqueue(callback); in maxRequestsEnforced()
52 client.newCall(newRequest("http://b/1")).enqueue(callback); in maxRequestsEnforced()
53 client.newCall(newRequest("http://b/2")).enqueue(callback); in maxRequestsEnforced()
59 client.newCall(newRequest("http://a/1")).enqueue(callback); in maxPerHostEnforced()
60 client.newCall(newRequest("http://a/2")).enqueue(callback); in maxPerHostEnforced()
61 client.newCall(newRequest("http://a/3")).enqueue(callback); in maxPerHostEnforced()
67 client.newCall(newRequest("http://a/1")).enqueue(callback); in increasingMaxRequestsPromotesJobsImmediately()
[all …]
|
| /external/python/cpython2/Lib/test/ |
| D | test_ftplib.py | 420 self.client = ftplib.FTP(timeout=10)
421 self.client.connect(self.server.host, self.server.port)
424 self.client.close()
428 self.assertEqual(self.client.getwelcome(), '220 welcome')
431 self.assertEqual(self.client.sanitize('foo'), repr('foo'))
432 self.assertEqual(self.client.sanitize('pass 12345'), repr('pass *****'))
433 self.assertEqual(self.client.sanitize('PASS 12345'), repr('PASS *****'))
436 self.assertRaises(ftplib.error_temp, self.client.sendcmd, 'echo 400')
437 self.assertRaises(ftplib.error_temp, self.client.sendcmd, 'echo 499')
438 self.assertRaises(ftplib.error_perm, self.client.sendcmd, 'echo 500')
[all …]
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/ |
| D | RealWebSocketTest.java | 51 private RealWebSocket client; field in RealWebSocketTest
67 client = new RealWebSocket(true, server2client.source(), client2Server.sink(), random, in setUp()
98 client.sendMessage(null); in nullMessageThrows()
106 client.sendMessage(RequestBody.create(TEXT, "Hello!")); in textMessage()
112 client.sendMessage(RequestBody.create(BINARY, "Hello!")); in binaryMessage()
119 client.sendMessage(RequestBody.create(null, "Hey!")); in missingContentTypeThrows()
129 client.sendMessage(RequestBody.create(MediaType.parse("text/plain"), "Hey!")); in unknownContentTypeThrows()
150 client.sendMessage(message); in streamingMessage()
163 client.sendPing(new Buffer().writeUtf8("Pong?")); in streamingMessageCanInterleavePing()
169 client.sendMessage(message); in streamingMessageCanInterleavePing()
[all …]
|
| /external/autotest/server/brillo/feedback/ |
| D | closed_loop_audio_client.py | 12 from autotest_lib.client.common_lib import error
13 from autotest_lib.client.common_lib.feedback import client
48 class Client(client.Client):
101 if query_id == client.QUERY_AUDIO_PLAYBACK_SILENT:
103 elif query_id == client.QUERY_AUDIO_PLAYBACK_AUDIBLE:
105 elif query_id == client.QUERY_AUDIO_RECORDING:
111 class _PlaybackAudioQuery(client.OutputQuery):
114 def __init__(self, client): argument
120 self.client = client
135 if not host_utils.wait_for_process(self.client.host,
[all …]
|
| /external/libvncserver/client_examples/ |
| D | backchannel.c | 12 static void HandleRect(rfbClient* client, int x, int y, int w, int h) { in HandleRect() argument
29 static void sendMessage(rfbClient* client, char* text) in sendMessage() argument
36 if(!WriteToRFBServer(client, (char*)&msg, sizeof(msg)) || in sendMessage()
37 !WriteToRFBServer(client, text, length)) { in sendMessage()
42 static rfbBool handleBackChannelMessage(rfbClient* client, in handleBackChannelMessage() argument
51 rfbClientSetClientData(client, sendMessage, sendMessage); in handleBackChannelMessage()
53 if(!ReadFromRFBServer(client, ((char*)&msg)+1, sizeof(msg)-1)) in handleBackChannelMessage()
57 if(!ReadFromRFBServer(client, text, msg.size)) { in handleBackChannelMessage()
80 rfbClient* client = rfbGetClient(8,3,4); in main() local
82 client->GotFrameBufferUpdate = HandleRect; in main()
[all …]
|
| D | ppmtest.c | 12 static void PrintRect(rfbClient* client, int x, int y, int w, int h) { in PrintRect() argument
16 static void SaveFramebufferAsPPM(rfbClient* client, int x, int y, int w, int h) { in SaveFramebufferAsPPM() argument
20 rfbPixelFormat* pf=&client->format; in SaveFramebufferAsPPM()
22 int row_stride=client->width*bpp; in SaveFramebufferAsPPM()
43 fprintf(f,"P6\n# %s\n%d %d\n255\n",client->desktopName,client->width,client->height); in SaveFramebufferAsPPM()
44 for(j=0;j<client->height*row_stride;j+=row_stride) in SaveFramebufferAsPPM()
45 for(i=0;i<client->width*bpp;i+=bpp) { in SaveFramebufferAsPPM()
46 unsigned char* p=client->frameBuffer+j+i; in SaveFramebufferAsPPM()
64 rfbClient* client = rfbGetClient(8,3,4); in main() local
68 client->GotFrameBufferUpdate = PrintRect; in main()
[all …]
|
| /external/oauth/core/src/main/java/net/oauth/client/httpclient4/ |
| D | HttpClient4.java | 17 package net.oauth.client.httpclient4;
23 import net.oauth.client.ExcerptInputStream;
27 import org.apache.http.client.HttpClient;
28 import org.apache.http.client.methods.HttpDelete;
29 import org.apache.http.client.methods.HttpEntityEnclosingRequestBase;
30 import org.apache.http.client.methods.HttpGet;
31 import org.apache.http.client.methods.HttpPost;
32 import org.apache.http.client.methods.HttpPut;
33 import org.apache.http.client.methods.HttpRequestBase;
34 import org.apache.http.client.params.ClientPNames;
[all …]
|
| /external/autotest/client/bin/self-test/tests/ |
| D | 111-barrier-unordered-20x-out | 81 barrier: 127.0.0.1#P1 checking client present: 127.0.0.1#P10
82 barrier: 127.0.0.1#P1 checking client present: 127.0.0.1#P11
83 barrier: 127.0.0.1#P1 checking client present: 127.0.0.1#P12
84 barrier: 127.0.0.1#P1 checking client present: 127.0.0.1#P13
85 barrier: 127.0.0.1#P1 checking client present: 127.0.0.1#P14
86 barrier: 127.0.0.1#P1 checking client present: 127.0.0.1#P15
87 barrier: 127.0.0.1#P1 checking client present: 127.0.0.1#P16
88 barrier: 127.0.0.1#P1 checking client present: 127.0.0.1#P17
89 barrier: 127.0.0.1#P1 checking client present: 127.0.0.1#P18
90 barrier: 127.0.0.1#P1 checking client present: 127.0.0.1#P19
[all …]
|