Home
last modified time | relevance | path

Searched refs:client_id (Results 1 – 25 of 49) sorted by relevance

12

/third_party/libwebsockets/lib/roles/mqtt/client/
Dclient-mqtt.c45 lws_mqtt_generate_id(struct lws* wsi, lws_mqtt_str_t **ms, const char *client_id) in lws_mqtt_generate_id() argument
52 if (client_id) in lws_mqtt_generate_id()
53 len = strlen(client_id); in lws_mqtt_generate_id()
63 if (client_id) { in lws_mqtt_generate_id()
64 lws_strnncpy((char *)buf, client_id, len, len + 1); in lws_mqtt_generate_id()
113 if (lws_mqtt_generate_id(wsi, &c->id, cp->client_id)) { in lws_create_client_mqtt_object()
120 if (cp->clean_start || !(cp->client_id && in lws_create_client_mqtt_object()
121 cp->client_id[0])) in lws_create_client_mqtt_object()
131 lws_free((void *)cp->client_id); in lws_create_client_mqtt_object()
/third_party/grpc/examples/python/data_transmission/
Dserver.py35 (request.client_id, request.request_data))
48 (request.client_id, request.request_data))
59 (request.client_id, request.request_data))
83 (request.client_id, request.request_data))
Dclient.py40 request = demo_pb2.Request(client_id=CLIENT_ID,
59 client_id=CLIENT_ID,
74 request = demo_pb2.Request(client_id=CLIENT_ID,
96 client_id=CLIENT_ID,
/third_party/ffmpeg/libavformat/
Drtmphttp.c44 char client_id[64]; ///< client ID used for all requests except the first one member
63 "/%s/%s/%d", cmd, rt->client_id, rt->seq++); in rtmp_http_send_cmd()
237 ret = ffurl_read(rt->stream, rt->client_id + off, sizeof(rt->client_id) - off); in rtmp_http_open()
243 if (off == sizeof(rt->client_id)) { in rtmp_http_open()
248 while (off > 0 && av_isspace(rt->client_id[off - 1])) in rtmp_http_open()
250 rt->client_id[off] = '\0'; in rtmp_http_open()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_server.cc187 int32_t client_id; in CreateService() local
223 client_id = curr_cs->num_clients_.fetch_add(1); in CreateService()
224 MS_LOG(INFO) << "Duplicate request from client " + std::to_string(client_id) + " for " + in CreateService()
239 client_id = cs->num_clients_.fetch_add(1); in CreateService()
250 auto numa_id = client_id % GetNumaNodeCount(); in CreateService()
261 bld.add_client_id(client_id); in CreateService()
327 auto client_id = rq->client_id(); in FastCacheRow() local
328 CHECK_FAIL_RETURN_UNEXPECTED(client_id != -1, "Client ID not set"); in FastCacheRow()
363 … std::to_string(static_cast<int8_t>(state)) + ". Client id: " + std::to_string(client_id)); in FastCacheRow()
366 "Cookie mismatch. Client id: " + std::to_string(client_id)); in FastCacheRow()
[all …]
Dcache_arena.cc71 Status CachedSharedMemory::AllocateSharedMemory(int32_t client_id, size_t sz, void **p) { in AllocateSharedMemory() argument
74 auto begin_slot = client_id % shm_pool_.size(); in AllocateSharedMemory()
89 void CachedSharedMemory::DeallocateSharedMemory(int32_t client_id, void *p) { in DeallocateSharedMemory() argument
90 auto begin_slot = client_id % shm_pool_.size(); in DeallocateSharedMemory()
Dcache_request.h173 explicit FreeSharedBlockRequest(connection_id_type connection_id, int32_t client_id, int64_t addr) in FreeSharedBlockRequest() argument
177 rq_.set_client_id(client_id); in FreeSharedBlockRequest()
219 return std::make_shared<FreeSharedBlockRequest>(rq_.connection_id(), rq_.client_id(), addr_); in GenerateFreeBlockRequest()
437 …explicit AllocateSharedBlockRequest(connection_id_type connection_id, int32_t client_id, size_t re… in AllocateSharedBlockRequest() argument
441 rq_.set_client_id(client_id); in AllocateSharedBlockRequest()
478 explicit ConnectResetRequest(connection_id_type connection_id, int32_t client_id) in ConnectResetRequest() argument
481 rq_.set_client_id(client_id); in ConnectResetRequest()
487 CHECK_FAIL_RETURN_UNEXPECTED(rq_.client_id() != -1, "Invalid client id"); in Prepare()
Dcache_arena.h58 Status AllocateSharedMemory(int32_t client_id, size_t sz, void **p);
61 void DeallocateSharedMemory(int32_t client_id, void *p);
/third_party/flutter/engine/flutter/shell/platform/glfw/
Dtext_input_plugin.cc142 int client_id = client_id_json.GetInt(); in HandleMethodCall() local
143 if (input_models_.find(client_id) == input_models_.end()) { in HandleMethodCall()
152 client_id, in HandleMethodCall()
153 std::make_unique<TextInputModel>(client_id, client_config))); in HandleMethodCall()
155 active_model_ = input_models_[client_id].get(); in HandleMethodCall()
204 args->PushBack(model->client_id(), allocator); in EnterPressed()
/third_party/flutter/engine/flutter/shell/platform/windows/
Dtext_input_plugin.cc143 int client_id = client_id_json.GetInt(); in HandleMethodCall() local
144 if (input_models_.find(client_id) == input_models_.end()) { in HandleMethodCall()
153 client_id, in HandleMethodCall()
154 std::make_unique<TextInputModel>(client_id, client_config))); in HandleMethodCall()
156 active_model_ = input_models_[client_id].get(); in HandleMethodCall()
205 args->PushBack(model->client_id(), allocator); in EnterPressed()
/third_party/ltp/testcases/kernel/sound/
Dsnd_seq01.c27 static int client_id; variable
44 .client = client_id in reinit_pool()
75 SAFE_IOCTL(fd, SNDRV_SEQ_IOCTL_CLIENT_ID, &client_id); in setup()
77 ssev.dest.client = client_id; in setup()
/third_party/pulseaudio/src/modules/x11/
Dmodule-x11-xsmp.c112 char t[256], *vendor, *client_id; in pa__init() local
174 &callbacks, NULL, &client_id, in pa__init()
200 …g_info("Connected to session manager '%s' as '%s'.", vendor = SmcVendor(u->connection), client_id); in pa__init()
205 …plist_setf(data.proplist, PA_PROP_APPLICATION_NAME, "XSMP Session on %s as %s", vendor, client_id); in pa__init()
207 pa_proplist_sets(data.proplist, "xsmp.client.id", client_id); in pa__init()
212 free(client_id); in pa__init()
/third_party/flutter/engine/flutter/shell/platform/common/cpp/
Dtext_input_model.h19 TextInputModel(int client_id, const rapidjson::Value& config);
79 int client_id() const { return client_id_; } in client_id() function
Dtext_input_model.cc31 TextInputModel::TextInputModel(int client_id, const rapidjson::Value& config) in TextInputModel() argument
33 client_id_(client_id), in TextInputModel()
/third_party/grpc/src/core/lib/security/credentials/jwt/
Djson_token.cc94 !grpc_copy_json_string_property(json, "client_id", &result.client_id) || in grpc_auth_json_key_create_from_json()
136 if (json_key->client_id != nullptr) { in grpc_auth_json_key_destruct()
137 gpr_free(json_key->client_id); in grpc_auth_json_key_destruct()
138 json_key->client_id = nullptr; in grpc_auth_json_key_destruct()
Djson_token.h38 char* client_id; member
/third_party/curl/lib/
Dmqtt.c204 static int add_client_id(const char *client_id, const size_t client_id_len, in add_client_id() argument
211 memcpy(&pkt[start + 2], client_id, MQTT_CLIENTID_LEN); in add_client_id()
257 char client_id[MQTT_CLIENTID_LEN + 1] = "curl"; in mqtt_connect() local
295 result = Curl_rand_hex(data, (unsigned char *)&client_id[clen], in mqtt_connect()
298 rc = add_client_id(client_id, strlen(client_id), packet, pos + 1); in mqtt_connect()
300 failf(data, "Client ID length mismatched: [%lu]", strlen(client_id)); in mqtt_connect()
304 infof(data, "Using client id '%s'", client_id); in mqtt_connect()
/third_party/grpc/src/core/lib/security/credentials/oauth2/
Doauth2_credentials.cc83 !grpc_copy_json_string_property(json, "client_id", &result.client_id) || in grpc_auth_refresh_token_create_from_json()
109 if (refresh_token->client_id != nullptr) { in grpc_auth_refresh_token_destruct()
110 gpr_free(refresh_token->client_id); in grpc_auth_refresh_token_destruct()
111 refresh_token->client_id = nullptr; in grpc_auth_refresh_token_destruct()
446 GRPC_REFRESH_TOKEN_POST_BODY_FORMAT_STRING, refresh_token_.client_id, in fetch_oauth2()
484 refresh_token_.client_id, in debug_string()
496 token->type, token->client_id); in create_loggable_refresh_token()
/third_party/grpc/test/core/security/
Djson_token_test.cc107 GPR_ASSERT(json_key.client_id != nullptr && in test_parse_json_key_success()
108 strcmp(json_key.client_id, in test_parse_json_key_success()
381 GPR_ASSERT(refresh_token.client_id != nullptr && in test_parse_refresh_token_success()
382 (strcmp(refresh_token.client_id, in test_parse_refresh_token_success()
/third_party/mesa3d/src/glx/apple/
Dappledri.c245 XAppleDRICreateSurface(dpy, screen, drawable, client_id, key, uid) in XAppleDRICreateSurface() argument
249 unsigned int client_id;
266 req->client_id = client_id;
Dappledri.h103 unsigned int client_id, unsigned int key[2],
/third_party/curl/tests/server/
Dmqttd.c503 char client_id[MAX_CLIENT_ID_LENGTH]; in mqttit() local
602 memcpy(client_id, &buffer[12], client_id_length); in mqttit()
603 client_id[client_id_length] = 0; in mqttit()
605 logmsg("MQTT client connect accepted: %s", client_id); in mqttit()
/third_party/libwebsockets/lib/secure-streams/protocols/
Dss-mqtt.c528 ct->ccp.client_id = NULL; in secstream_connect_munge_mqtt()
530 ct->ccp.client_id = (const char *)p; in secstream_connect_munge_mqtt()
532 __func__, ct->ccp.client_id); in secstream_connect_munge_mqtt()
536 ct->ccp.client_id = NULL; in secstream_connect_munge_mqtt()
/third_party/lwip/src/include/lwip/apps/
Dmqtt.h70 const char *client_id; member
/third_party/grpc/src/core/lib/security/credentials/external/
Dexternal_account_credentials.h47 std::string client_id; member

12