Home
last modified time | relevance | path

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

12345

/AliOS-Things-master/components/ble_mesh/bt_mesh/core/src/
A Dproxy.c161 memset(client->filter, 0, sizeof(client->filter)); in filter_set()
165 memset(client->filter, 0, sizeof(client->filter)); in filter_set()
467 proxy_cfg(client); in proxy_complete_pdu()
473 bt_mesh_pb_gatt_recv(client->conn, &client->buf); in proxy_complete_pdu()
492 if (!client) { in proxy_recv()
604 if (!client) { in proxy_connected()
611 memset(client->filter, 0, sizeof(client->filter)); in proxy_connected()
756 if (!client->conn || client->filter_type != PROV) { in bt_mesh_proxy_prov_disable()
863 … if (client->conn && (client->filter_type == WHITELIST || client->filter_type == BLACKLIST)) { in bt_mesh_proxy_gatt_disconnect()
950 if (!client->conn) { in bt_mesh_proxy_relay()
[all …]
/AliOS-Things-master/components/http/src/
A Dhttp_method_api.c19 ret = httpclient_conn(client, url); in httpclient_common()
22 ret = httpclient_send(client, url, method, client_data); in httpclient_common()
25 ret = httpclient_recv(client, client_data); in httpclient_common()
33 httpclient_clse(client); in httpclient_common()
40 int ret = httpclient_common(client, url, HTTP_GET, client_data); in httpclient_get()
43 ret = httpclient_common(client, client_data->redirect_url, HTTP_GET, client_data); in httpclient_get()
56 int ret = httpclient_common(client, url, HTTP_HEAD, client_data); in httpclient_head()
59 ret = httpclient_common(client, client_data->redirect_url, HTTP_HEAD, client_data); in httpclient_head()
72 int ret = httpclient_common(client, url, HTTP_POST, client_data); in httpclient_post()
88 int ret = httpclient_common(client, url, HTTP_PUT, client_data); in httpclient_put()
[all …]
A Dhttp_client.c153 client->header = header ; in httpclient_set_custom_header()
161 client->auth_user = user; in httpclient_basic_auth()
253 if (client->auth_user) { in httpclient_send_header()
258 if (client->header) { in httpclient_send_header()
259 httpclient_get_info(client, send_buf, &len, (char *)client->header, strlen(client->header)); in httpclient_send_header()
389 if (client->is_http) { in httpclient_recv_data()
620 if ( (client->response_code < 200) || (client->response_code >= 400) ) { in httpclient_response_parse()
774 client->socket = -1; in httpclient_conn()
775 if (client->is_http) { in httpclient_conn()
879 if (client->is_http) { in httpclient_clse()
[all …]
A Dhttp_aos_wrapper.c81 close(client->socket); in http_tcp_conn_wrapper()
92 close(client->socket); in http_tcp_close_wrapper()
93 client->socket = -1; in http_tcp_close_wrapper()
124 int sockfd = client->socket; in http_tcp_recv_wrapper()
249 if (!client->ssl) { in http_ssl_conn_wrapper()
256 if (client->server_cert) in http_ssl_conn_wrapper()
289 if (client->client_cert && client->client_pk) { in http_ssl_conn_wrapper()
411 client->ssl = NULL; in http_ssl_close_wrapper()
412 client->client_cert = NULL; in http_ssl_close_wrapper()
414 client->client_pk = NULL; in http_ssl_close_wrapper()
[all …]
/AliOS-Things-master/components/linkkit/infra/
A Dinfra_httpc.c117 ret = client->net.write(&client->net, send_buf, in _utils_fill_tx_buffer()
158 if (client->header) { in _http_send_header()
159 _utils_fill_tx_buffer(client, send_buf, &len, (char *)client->header, in _http_send_header()
183 ret = client->net.write(&client->net, send_buf, len, 5000); in _http_send_header()
199 ret = client->net.write(&client->net, (char *)client_data->post_buf, in _http_send_userdata()
225 ret = client->net.read(&client->net, buf, max_len, iotx_time_left(&timer)); in _http_recv()
473 rc = client->net.connect(&client->net); in httpclient_connect()
475 client->net.disconnect(&client->net); in httpclient_connect()
560 client->net.disconnect(&client->net); in httpclient_close()
562 client->net.handle = 0; in httpclient_close()
[all …]
/AliOS-Things-master/components/mqtt/
A DREADME.md81 |client |MQTT client上下文|
91 |client |MQTT client上下文|
100 |client |MQTT client上下文|
110 |client |MQTT client上下文|
120 |client |MQTT client上下文|
125 DLLExport int MQTTDisconnect(MQTTClient* client);
129 |client |MQTT client上下文|
133 DLLExport int MQTTYield(MQTTClient* client, int time);
137 |client |MQTT client上下文|
142 DLLExport int MQTTIsConnected(MQTTClient* client);
[all …]
/AliOS-Things-master/components/ucloud_ai/src/model/aliyun-openapi/test/core/
A Dstsclient_ut.cc36 EXPECT_CALL(client, makeRequest(_, _, _)); in TEST()
49 mockStsClient client(credentials, configuration); in TEST() local
51 EXPECT_CALL(client, makeRequest(_, _, _)); in TEST()
67 EXPECT_CALL(client, makeRequest(_, _, _)); in TEST()
82 EXPECT_CALL(client, makeRequest(_, _, _)); in TEST()
95 EXPECT_CALL(client, makeRequest(_, _, _)); in TEST()
106 void cb(const StsClient *client, in cb() argument
130 EXPECT_CALL(client, makeRequest(_, _, _)); in TEST()
148 EXPECT_CALL(client, makeRequest(_, _, _)); in TEST()
168 EXPECT_CALL(client, makeRequest(_, _, _)); in TEST()
[all …]
A Dtimeout_ut.cc38 CommonClient client("key", "secret", configuration); in TEST() local
42 auto out = client.commonResponse(request); in TEST()
49 CommonClient client("key", "secret", configuration); in TEST() local
53 auto out = client.commonResponse(request); in TEST()
63 CommonClient client("key", "secret", configuration); in TEST() local
68 auto out = client.commonResponse(request); in TEST()
82 auto out = client.commonResponse(request); in TEST()
96 auto out = client.commonResponse(request); in TEST()
110 auto out = client.commonResponse(request); in TEST()
126 auto out = client.commonResponse(request); in TEST()
[all …]
A Dcurlhttpclient_ut.cc27 CurlHttpClient client; in TEST() local
46 CurlHttpClient client; in TEST() local
63 CurlHttpClient client; in TEST() local
86 CurlHttpClient client; in TEST() local
103 CurlHttpClient client; in TEST() local
121 CurlHttpClient client; in TEST() local
139 CurlHttpClient client; in TEST() local
157 CurlHttpClient client; in TEST() local
171 CurlHttpClient client; in TEST() local
187 CurlHttpClient client; in TEST() local
[all …]
A Dlocationclient_ut.cc37 mockLocationClient client("key", "secret", configuration); in TEST() local
40 EXPECT_CALL(client, makeRequest(_, _, _)); in TEST()
42 LocationClient::DescribeEndpointsOutcome out = client.describeEndpoints(req); in TEST()
75 mockLocationClient client(credentials, configuration); in TEST() local
78 EXPECT_CALL(client, makeRequest(_, _, _)); in TEST()
80 LocationClient::DescribeEndpointsOutcome out = client.describeEndpoints(req); in TEST()
113 EXPECT_CALL(client, makeRequest(_, _, _)); in TEST()
143 mockLocationClient client("key", "secret", configuration); in TEST() local
146 EXPECT_CALL(client, makeRequest(_, _, _)); in TEST()
173 void cb(const LocationClient *client, in cb() argument
[all …]
A Dcommonclient_ut.cc93 TestCommonClient* client = new TestCommonClient(credentials, cfg); in TEST() local
94 HttpRequest r = client->buildHttpRequest("cn-hangzhou", cr, HttpRequest::Method::Post); in TEST()
117 HttpRequest rr = client->buildRoaHttpRequest("cn-shanghai", cr, HttpRequest::Method::Get); in TEST()
140 rr = client->buildRoaHttpRequest("cn-shanghai", cr, HttpRequest::Method::Get); in TEST()
146 EXPECT_TRUE(client->serviceName() == "Common"); in TEST()
150 rrr = client->buildRpcHttpRequest("cn-hangzhou", cr, HttpRequest::Method::Post); in TEST()
156 client->asyncExecute(rf); in TEST()
172 TestCommonClient* client = new TestCommonClient(credentials, cfg); in TEST() local
182 CommonClient client("key", "secret", configuration); in TEST() local
188 auto out = client.commonResponse(req); in TEST()
[all …]
A Drpcserviceclient_ut.cc57 …mockRpcServiceClient client("ecs", std::make_shared<SimpleCredentialsProvider>(credentials), confi… in TEST() local
67 HttpRequest http_req = client.buildHttpRequest(endpoint, req, HttpRequest::Method::Get); in TEST()
86 http_req = client.buildHttpRequest(endpoint, req, HttpRequest::Method::Get); in TEST()
110 …mockRpcServiceClient client(servicename, std::make_shared<SimpleCredentialsProvider>(credentials),… in TEST() local
111 EXPECT_CALL(client, AttemptRequest(_, _, _)); in TEST()
113 …RpcServiceClient::JsonOutcome out = client.makeRequest(endpoint, rpc_req, HttpRequest::Method::Get… in TEST()
143 …mockRpcServiceClient client(servicename, std::make_shared<SimpleCredentialsProvider>(credentials),… in TEST() local
144 EXPECT_CALL(client, AttemptRequest(_, _, _)); in TEST()
146 …RpcServiceClient::JsonOutcome out = client.makeRequest(endpoint, rpc_req, HttpRequest::Method::Get… in TEST()
/AliOS-Things-master/components/http/
A DREADME.md140 |client |HTTP client上下文，包含配置参数，如服务端口号、服务端证书等|
151 |client |HTTP client上下文，包含配置参数，如服务端口号、服务端证书等|
162 |client |HTTP client上下文，包含配置参数，如服务端口号、服务端证书等|
173 |client |HTTP client上下文，包含配置参数，如服务端口号、服务端证书等|
184 |client |HTTP client上下文，包含配置参数，如服务端口号、服务端证书等|
195 |client |HTTP client上下文，包含配置参数，如服务端口号、服务端证书等|
207 |client |HTTP client上下文，包含配置参数，如服务端口号、服务端证书等|
212 void httpclient_clse(httpclient_t *client)
217 |client |HTTP client上下文，包含配置参数，如服务端口号、服务端证书等|
226 |client |HTTP client上下文，包含配置参数，如服务端口号、服务端证书等|
[all …]
/AliOS-Things-master/components/linkkit/mqtt/
A Dmqtt_wrapper.h9 int wrapper_mqtt_connect(void *client);
10 int wrapper_mqtt_yield(void *client, int timeout_ms);
11 int wrapper_mqtt_check_state(void *client);
12 int wrapper_mqtt_subscribe(void *client, const char *topicFilter,
17 void *client, const char *topic_filter, iotx_mqtt_qos_t qos,
20 int wrapper_mqtt_unsubscribe(void *client, const char *topicFilter);
21 int wrapper_mqtt_publish(void *client, const char *topicName,
24 int wrapper_mqtt_nwk_event_handler(void *client, iotx_mqtt_nwk_event_t event,
A Dmqtt_api.c455 void *client; in IOT_MQTT_Destroy() local
457 client = *phandler; in IOT_MQTT_Destroy()
460 client = g_mqtt_client; in IOT_MQTT_Destroy()
463 if (client == NULL) { in IOT_MQTT_Destroy()
468 wrapper_mqtt_release(&client); in IOT_MQTT_Destroy()
497 void *client = handle ? handle : g_mqtt_client; in IOT_MQTT_Subscribe() local
521 void *client = handle ? handle : g_mqtt_client; in IOT_MQTT_Subscribe_Sync() local
545 void *client = handle ? handle : g_mqtt_client; in IOT_MQTT_Unsubscribe() local
558 void *client = handle ? handle : g_mqtt_client; in IOT_MQTT_Publish() local
574 void *client = handle ? handle : g_mqtt_client; in IOT_MQTT_Publish_Simple() local
[all …]
/AliOS-Things-master/components/ota/ota_agent/download/
A Dota_download_http.c70 client->server_cert = ca_cert; in ota_httpc_settings_init()
95 httpclient_clse(client); in ota_httpc_settings_destory()
134 if (client == NULL || client_data == NULL) { in ota_httpc_recv_data()
208 httpclient_t client = { 0 }; in ota_download_image_header() local
266 client.header = tmp_header; in ota_download_image_header()
268 ret = httpclient_conn(&client, new_url); in ota_download_image_header()
332 ota_httpc_settings_destory(&client); in ota_download_image_header()
369 httpclient_t client = {0}; in ota_download_start() local
400 memset(&client, 0 , sizeof(client)); in ota_download_start()
415 client.header = tmp_header; in ota_download_start()
[all …]
A Dota_download_file2fs_http.c17 int ota_httpc_request_send(httpclient_t *client, char *url, httpclient_data_t *client_data);
18 int ota_httpc_recv_data(httpclient_t *client, httpclient_data_t *client_data);
19 int ota_httpc_settings_init(httpclient_t *client, httpclient_data_t *client_data);
20 void ota_httpc_settings_destory(httpclient_t *client);
47 httpclient_t client = {0}; in ota_download_store_fs_start() local
85 ret = ota_httpc_settings_init(&client, &client_data); in ota_download_store_fs_start()
99 client.header = tmp_header; in ota_download_store_fs_start()
100 ret = httpclient_conn(&client, new_url); in ota_download_store_fs_start()
105 ret = ota_httpc_request_send(&client, new_url, &client_data); in ota_download_store_fs_start()
113 ret = ota_httpc_recv_data(&client, &client_data); in ota_download_store_fs_start()
[all …]
/AliOS-Things-master/components/http/include/
A Dhttpclient.h96 HTTPC_RESULT httpclient_get(httpclient_t *client, const char *url, httpclient_data_t *client_data);
105 HTTPC_RESULT httpclient_head(httpclient_t *client, const char *url, httpclient_data_t *client_data);
114 HTTPC_RESULT httpclient_post(httpclient_t *client, const char *url, httpclient_data_t *client_data);
123 HTTPC_RESULT httpclient_put(httpclient_t *client, const char *url, httpclient_data_t *client_data);
132 HTTPC_RESULT httpclient_delete(httpclient_t *client, const char *url, httpclient_data_t *client_dat…
165 HTTPC_RESULT httpclient_conn(httpclient_t *client, const char *url);
175 HTTPC_RESULT httpclient_send(httpclient_t *client, const char *url, int method, httpclient_data_t *…
183 HTTPC_RESULT httpclient_recv(httpclient_t *client, httpclient_data_t *client_data);
190 void httpclient_clse(httpclient_t *client);
198 void httpclient_set_custom_header(httpclient_t *client, char *header);
[all …]
/AliOS-Things-master/components/mqtt/MQTTClient-C/
A DMQTTClient.h145 DLLExport void MQTTClientInit(MQTTClient* client, Network* network, unsigned int command_timeout_ms,
153 DLLExport int MQTTConnectWithResults(MQTTClient* client, MQTTPacket_connectData* options,
161 DLLExport int MQTTConnect(MQTTClient* client, MQTTPacket_connectData* options);
169 DLLExport int MQTTPublish(MQTTClient* client, const char*, MQTTMessage*);
185 DLLExport int MQTTSubscribe(MQTTClient* client, const char* topicFilter, enum QoS, messageHandler);
194 DLLExport int MQTTSubscribeWithResults(MQTTClient* client, const char* topicFilter, enum QoS, messa…
201 DLLExport int MQTTUnsubscribe(MQTTClient* client, const char* topicFilter);
207 DLLExport int MQTTDisconnect(MQTTClient* client);
214 DLLExport int MQTTYield(MQTTClient* client, int time);
220 DLLExport int MQTTIsConnected(MQTTClient* client);
[all …]
/AliOS-Things-master/components/http/internal/
A Dhttp_wrappers.h29 int http_tcp_conn_wrapper(httpclient_t *client, const char *host);
30 int http_tcp_close_wrapper(httpclient_t *client);
31 int http_tcp_send_wrapper(httpclient_t *client, const char *data, int length);
32 int http_tcp_recv_wrapper(httpclient_t *client, char *buf, int buflen, int timeout_ms, int *p_read_…
35 int http_ssl_conn_wrapper(httpclient_t *client, const char *host);
36 int http_ssl_close_wrapper(httpclient_t *client);
37 int http_ssl_send_wrapper(httpclient_t *client, const char *data, size_t length);
38 int http_ssl_recv_wrapper(httpclient_t *client, char *buf, int buflen, int timeout_ms, int *p_read_…
/AliOS-Things-master/components/SDL2/src/audio/jack/
A DSDL_jackaudio.c261 if (this->hidden->client) { in JACK_CloseDevice()
262 JACK_jack_deactivate(this->hidden->client); in JACK_CloseDevice()
273 JACK_jack_client_close(this->hidden->client); in JACK_CloseDevice()
296 jack_client_t *client = NULL; in JACK_OpenDevice() local
310 this->hidden->client = client; in JACK_OpenDevice()
311 if (client == NULL) { in JACK_OpenDevice()
344 this->spec.freq = JACK_jack_get_sample_rate(client); in JACK_OpenDevice()
346 this->spec.samples = JACK_jack_get_buffer_size(client); in JACK_OpenDevice()
381 if (JACK_jack_activate(client) != 0) { in JACK_OpenDevice()
418 if (client == NULL) { in JACK_Init()
[all …]
/AliOS-Things-master/components/ucloud_ai/src/model/aliyun-openapi/test/function_test/nlp/
A Dnlp_wordsegment_ft.cc21 CommonClient client(key, secret, configuration); in TEST() local
32 auto outcome = client.commonResponse(request); in TEST()
47 CommonClient client(key, secret, configuration); in TEST() local
58 auto outcome = client.commonResponse(request); in TEST()
73 CommonClient client(key, secret, configuration); in TEST() local
85 auto outcome = client.commonResponse(request); in TEST()
100 CommonClient client(key, secret, configuration); in TEST() local
114 auto outcome = client.commonResponse(request); in TEST()
129 CommonClient client(key, secret, configuration); in TEST() local
143 auto outcome = client.commonResponse(request); in TEST()
/AliOS-Things-master/components/SDL2/src/audio/wasapi/
A DSDL_wasapi.c173 IAudioClient_Stop(this->hidden->client); in WasapiFailed()
271 if (!this->hidden->client) { in RecoverWasapiIfLost()
326 IAudioClient_Stop(this->hidden->client); in WASAPI_WaitDevice()
425 if (this->hidden->client) { in ReleaseWasapiDevice()
426 IAudioClient_Stop(this->hidden->client); in ReleaseWasapiDevice()
428 IAudioClient_Release(this->hidden->client); in ReleaseWasapiDevice()
429 this->hidden->client = NULL; in ReleaseWasapiDevice()
511 IAudioClient *client = this->hidden->client; in WASAPI_PrepDevice() local
521 SDL_assert(client != NULL); in WASAPI_PrepDevice()
634 ret = IAudioClient_Start(client); in WASAPI_PrepDevice()
[all …]
/AliOS-Things-master/components/py_engine/modules/network/http/
A Dhttpclient.c42 httpclient_t client; member
83 httpclient_t client = { 0 }; in http_client_new() local
86 http_client_obj->client = client; in http_client_new()
120 ret = httpclient_get(&http_client_obj->client, url, in obj_http_get()
192 http_client_obj->client.header = header; in http_set_header()
290 ret = httpclient_recv(&http_client_obj->client, in obj_http_recv()
470 httpclient_reset(&http_client_obj->client); in obj_http_reset()
541 httpclient_clse(&http_client_obj->client); in obj_http_close()
578 httpclient_t client = { 0 }; in task_http_download_func() local
599 ret = httpclient_conn(&client, req_url); in task_http_download_func()
[all …]
/AliOS-Things-master/components/oss/src/encryption/
A DCryptoModule.cc61 PutObjectOutcome CryptoModule::PutObjectSecurely(const std::shared_ptr<OssClientImpl>& client, cons… in PutObjectSecurely() argument
71 addUserAgent(putRequest.MetaData(), client->configuration().userAgent); in PutObjectSecurely()
74 return client->PutObject(putRequest); in PutObjectSecurely()
110 getRequest.setUserAgent(getUserAgent(client->configuration().userAgent)); in GetObjectSecurely()
122 auto outcome = client->GetObject(getRequest); in GetObjectSecurely()
135 …Outcome CryptoModule::InitiateMultipartUploadSecurely(const std::shared_ptr<OssClientImpl>& client, in InitiateMultipartUploadSecurely() argument
152 addUserAgent(initRequest.MetaData(), client->configuration().userAgent); in InitiateMultipartUploadSecurely()
154 auto outcome = client->InitiateMultipartUpload(initRequest); in InitiateMultipartUploadSecurely()
162 PutObjectOutcome CryptoModule::UploadPartSecurely(const std::shared_ptr<OssClientImpl>& client, con… in UploadPartSecurely() argument
186 uRequest.setUserAgent(getUserAgent(client->configuration().userAgent)); in UploadPartSecurely()
[all …]

Completed in 93 milliseconds

12345