/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/avahi/avahi-client/ |
D | client.c | 43 static int init_server(AvahiClient *client, int *ret_error); 45 int avahi_client_set_errno (AvahiClient *client, int error) { in avahi_client_set_errno() argument 46 assert(client); in avahi_client_set_errno() 48 return client->error = error; in avahi_client_set_errno() 51 int avahi_client_set_dbus_error(AvahiClient *client, DBusError *error) { in avahi_client_set_dbus_error() argument 52 assert(client); in avahi_client_set_dbus_error() 55 return avahi_client_set_errno(client, avahi_error_dbus_to_number(error->name)); in avahi_client_set_dbus_error() 58 static void client_set_state(AvahiClient *client, AvahiClientState state) { in client_set_state() argument 59 assert(client); in client_set_state() 61 if (client->state == state) in client_set_state() [all …]
|
D | entrygroup.c | 57 AvahiClient *client; in retrieve_state() local 62 client = group->client; in retrieve_state() 65 r = avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY); in retrieve_state() 69 if (!(reply = dbus_connection_send_with_reply_and_block(client->bus, message, -1, &error)) || in retrieve_state() 71 r = avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR); in retrieve_state() 77 r = avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR); in retrieve_state() 88 r = avahi_client_set_dbus_error(client, &error); in retrieve_state() 101 AvahiEntryGroup* avahi_entry_group_new (AvahiClient *client, AvahiEntryGroupCallback callback, void… in avahi_entry_group_new() argument 108 assert(client); in avahi_entry_group_new() 112 if (!avahi_client_is_connected(client)) { in avahi_entry_group_new() [all …]
|
D | browser.c | 88 db->client->poll_api->timeout_free(db->defer_timeout); in defer_timeout_callback() 105 AvahiClient *client, in avahi_domain_browser_new() argument 121 assert(client); in avahi_domain_browser_new() 126 if (!avahi_client_is_connected(client)) { in avahi_domain_browser_new() 127 avahi_client_set_errno(client, AVAHI_ERR_BAD_STATE); in avahi_domain_browser_new() 135 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY); in avahi_domain_browser_new() 140 db->client = client; in avahi_domain_browser_new() 149 AVAHI_LLIST_PREPEND(AvahiDomainBrowser, domain_browsers, client->domain_browsers, db); in avahi_domain_browser_new() 151 if (!(client->flags & AVAHI_CLIENT_IGNORE_USER_CONFIG)) { in avahi_domain_browser_new() 159 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY); in avahi_domain_browser_new() [all …]
|
D | resolver.c | 41 DBusHandlerResult avahi_service_resolver_event (AvahiClient *client, AvahiResolverEvent event, DBus… in avahi_service_resolver_event() argument 47 assert(client); in avahi_service_resolver_event() 55 for (r = client->service_resolvers; r; r = r->service_resolvers_next) in avahi_service_resolver_event() 164 avahi_client_set_errno(r->client, avahi_error_dbus_to_number(etxt)); in avahi_service_resolver_event() 180 AvahiClient *client, in avahi_service_resolver_new() argument 198 assert(client); in avahi_service_resolver_new() 209 if (!avahi_client_is_connected(client)) { in avahi_service_resolver_new() 210 avahi_client_set_errno(client, AVAHI_ERR_BAD_STATE); in avahi_service_resolver_new() 215 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY); in avahi_service_resolver_new() 219 r->client = client; in avahi_service_resolver_new() [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); 72 static void fio_client_add_hash(struct fio_client *client) in fio_client_add_hash() argument 74 int bucket = hash_long(client->fd, FIO_CLIENT_HASH_BITS); in fio_client_add_hash() 77 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/avahi/avahi-daemon/ |
D | dbus-protocol.c | 118 Client *client; in client_get() local 123 for (client = server->clients; client; client = client->clients_next) in client_get() 124 if (!strcmp(name, client->name)) in client_get() 125 return client; in client_get() 134 client = avahi_new(Client, 1); in client_get() 135 client->id = server->current_id++; in client_get() 136 client->name = avahi_strdup(name); in client_get() 137 client->current_id = 0; in client_get() 138 client->n_objects = 0; in client_get() 140 AVAHI_LLIST_HEAD_INIT(EntryGroupInfo, client->entry_groups); in client_get() [all …]
|
/external/autotest/client/common_lib/cros/ |
D | tpm_utils.py | 7 from autotest_lib.client.common_lib import error 8 from autotest_lib.client.cros import cros_ui 26 def TPMStatus(client): argument 31 out = client.run('cryptohome --action=tpm_status').stdout.strip() 48 def IsTPMAvailable(client): argument 53 status = TPMStatus(client) 57 def ClearTPMServer(client, out_dir): argument 63 if IsTPMAvailable(client): 67 client.run('stop ui') 69 password = TPMStatus(client)['Password'] [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 | 107 private OkUrlFactory client; field in URLConnectionTest 113 client = new OkUrlFactory(new OkHttpClient()); in setUp() 133 connection = client.open(server.getUrl("/")); in requestHeaders() 192 connection = client.open(server.getUrl("/")); in getRequestPropertyReturnsLastValue() 205 connection = client.open(server.getUrl("/")); in responseHeaders() 234 connection = client.open(server.getUrl("/")); in serverSendsInvalidResponseHeaders() 245 connection = client.open(server.getUrl("/")); in serverSendsInvalidCodeTooLarge() 256 connection = client.open(server.getUrl("/")); in serverSendsInvalidCodeNotANumber() 267 connection = client.open(server.getUrl("/")); in serverSendsUnnecessaryWhitespace() 279 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/chromium-trace/catapult/third_party/gsutil/third_party/pyasn1/pyasn1/codec/cer/ |
D | encoder.py | 7 def encodeValue(self, encodeFun, client, defMode, maxChunkSize): argument 8 if client == 0: 15 def encodeValue(self, encodeFun, client, defMode, maxChunkSize): argument 17 self, encodeFun, client, defMode, 1000 21 def encodeValue(self, encodeFun, client, defMode, maxChunkSize): argument 23 self, encodeFun, client, defMode, 1000 32 def encodeValue(self, encodeFun, client, defMode, maxChunkSize): argument 33 if isinstance(client, univ.SequenceAndSetBase): 34 client.setDefaultComponents() 35 client.verifySizeSpec() [all …]
|
/external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/ |
D | RealWebSocketTest.java | 46 private RealWebSocket client; field in RealWebSocketTest 61 client = new RealWebSocket(true, server2client, client2Server, random, clientExecutor, in setUp() 83 client.sendMessage(TEXT, new Buffer().writeUtf8("Hello!")); in textMessage() 89 client.sendMessage(BINARY, new Buffer().writeUtf8("Hello!")); in binaryMessage() 95 BufferedSink sink = client.newMessageSink(TEXT); in streamingMessage() 104 BufferedSink sink = client.newMessageSink(TEXT); in streamingMessageCanInterleavePing() 106 client.sendPing(new Buffer().writeUtf8("Pong?")); in streamingMessageCanInterleavePing() 112 client.readMessage(); in streamingMessageCanInterleavePing() 117 client.sendPing(new Buffer().writeUtf8("Hello!")); in pingWritesPong() 120 client.readMessage(); // Read the pong. in pingWritesPong() [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 …]
|