Home
last modified time | relevance | path

Searched refs:client (Results 1 – 25 of 4271) sorted by relevance

12345678910>>...171

/external/libvncserver/libvncclient/
Dvncviewer.c44 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 …]
Dtight.c53 (((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 …]
Dlisten.c49 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 …]
Drfbproto.c119 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 …]
Dultra.c35 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 …]
Dcursor.c32 ((((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 …]
Dzlib.c36 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 …]
Dzrle.c79 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 …]
Dtls_gnutls.c90 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 …]
Dtls_openssl.c176 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/
Dclient.c43 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 …]
Dentrygroup.c57 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 …]
Dbrowser.c88 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 …]
Dresolver.c41 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/
Dclient.c28 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/
Dsocket_unittest.cc197 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/
Drfbclient.h47 (*(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/
Ddbus-protocol.c118 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/
Dtpm_utils.py7 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/
DOkHttpClientTest.java61 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 …]
DURLConnectionTest.java107 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 …]
DDispatcherTest.java20 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/
Dencoder.py7 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/
DRealWebSocketTest.java46 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/
Dbackchannel.c12 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 …]

12345678910>>...171