Lines Matching defs:requestId

61     int64_t requestId;
304 static int32_t AddClientReqInfoToContext(int32_t osAccountId, int64_t requestId, const char *appId, CJson *context)
323     if (AddInt64StringToJson(context, FIELD_REQUEST_ID, requestId) != HC_SUCCESS) {
324         LOGE("add requestId to context fail.");
359 static int32_t BuildClientBindContext(int32_t osAccountId, int64_t requestId, const char *appId,
362     int32_t res = AddClientReqInfoToContext(osAccountId, requestId, appId, context);
368     res = OpenChannel(channelType, context, requestId, &channelId);
539 static int32_t StartClientBindSession(int32_t osAccountId, int64_t requestId, const char *appId,
547     int32_t res = BuildClientBindContext(osAccountId, requestId, appId, callback, context);
561     res = OpenDevSession(requestId, appId, &params);
568         res = PushStartSessionTask(requestId);
601 static int32_t AddMemberToGroupInner(int32_t osAccountId, int64_t requestId, const char *appId, const char *addParams)
604     SET_TRACE_ID(requestId);
605     ADD_PERFORM_DATA(requestId, true, true, HcGetCurTimeInMillis());
620         requestId, osAccountId, appId);
626     return StartClientBindSession(osAccountId, requestId, appId, addParams, callback);
629 static int32_t AddMemberToGroup(int32_t osAccountId, int64_t requestId, const char *appId, const char *addParams)
631     int32_t res = AddMemberToGroupInner(osAccountId, requestId, appId, addParams);
640 static int32_t AddServerReqInfoToContext(int64_t requestId, const char *appId, int32_t opCode,
656     if (AddInt64StringToJson(context, FIELD_REQUEST_ID, requestId) != HC_SUCCESS) {
657         LOGE("add requestId to context fail.");
722 static int32_t BuildServerBindContext(int64_t requestId, const char *appId, int32_t opCode,
733     res = AddServerReqInfoToContext(requestId, appId, opCode, receivedMsg, context);
757 static int32_t OpenServerBindSession(int64_t requestId, const CJson *receivedMsg)
772     char *returnDataStr = ProcessRequestCallback(requestId, opCode, NULL, callback);
783     int32_t res = BuildServerBindContext(requestId, appId, opCode, receivedMsg, context);
796     res = OpenDevSession(requestId, appId, &params);
801 static int32_t ProcessBindData(int64_t requestId, const uint8_t *data, uint32_t dataLen)
804     SET_TRACE_ID(requestId);
805     if (!IsSessionExist(requestId)) {
806         ADD_PERFORM_DATA(requestId, true, false, HcGetCurTimeInMillis());
808         UPDATE_PERFORM_DATA_BY_SELF_INDEX(requestId, HcGetCurTimeInMillis());
814     LOGI("[Start]: RequestProcessBindData! [ReqId]: %" PRId64, requestId);
821     if (!IsSessionExist(requestId)) {
822         res = OpenServerBindSession(requestId, receivedMsg);
828     res = PushProcSessionTask(requestId, receivedMsg);
836 static int32_t BuildClientAuthContext(int32_t osAccountId, int64_t requestId, const char *appId, CJson *context)
870     if (AddInt64StringToJson(context, FIELD_REQUEST_ID, requestId) != HC_SUCCESS) {
871         LOGE("add requestId to context fail.");
980 static int32_t BuildServerAuthContext(int64_t requestId, int32_t opCode, const char *appId, CJson *context)
1009     if (AddInt64StringToJson(context, FIELD_REQUEST_ID, requestId) != HC_SUCCESS) {
1010         LOGE("add requestId to context fail.");
1024 static int32_t BuildServerP2PAuthContext(int64_t requestId, int32_t opCode, const char *appId, CJson *context)
1055     if (AddInt64StringToJson(context, FIELD_REQUEST_ID, requestId) != HC_SUCCESS) {
1056         LOGE("add requestId to context fail.");
1070 static int32_t OpenServerAuthSession(int64_t requestId, const CJson *receivedMsg, const DeviceAuthCallback *callback)
1079     char *returnDataStr = ProcessRequestCallback(requestId, opCode, NULL, callback);
1096     int32_t res = BuildServerAuthContext(requestId, opCode, appId, context);
1102     res = OpenDevSession(requestId, appId, &params);
1108     int64_t requestId, const CJson *receivedMsg, const DeviceAuthCallback *callback)
1115     char *returnDataStr = ProcessRequestCallback(requestId, opCode, NULL, callback);
1144     int32_t res = BuildServerP2PAuthContext(requestId, opCode, appId, context);
1150     res = OpenDevSession(requestId, appId, &params);
1198 static void CancelRequest(int64_t requestId, const char *appId)
1201     SET_TRACE_ID(requestId);
1207     LOGI("cancel request. [AppId]: %s, [ReqId]: %" PRId64, appId, requestId);
1208     CancelDevSession(requestId, appId);
1370 DEVICE_AUTH_API_PUBLIC int32_t CancelAuthRequest(int64_t requestId, const char *authParams)
1373     SET_TRACE_ID(requestId);
1378     LOGI("cancel request. [ReqId]: %" PRId64, requestId);
1379     CancelDevSession(requestId, DEFAULT_PACKAGE_NAME);
1484     SET_TRACE_ID(task->requestId);
1486     int32_t res = StartDevSession(task->requestId);
1489         CloseDevSession(task->requestId);
1493 static void InitSoftBusTask(SoftBusTask *task, int64_t requestId)
1497     task->requestId = requestId;
1500 static int OnChannelOpenedCb(int64_t requestId, int result)
1504         CloseDevSession(requestId);
1507     LOGI("[Start]: OnChannelOpened! [ReqId]: %" PRId64, requestId);
1511         CloseDevSession(requestId);
1514     InitSoftBusTask(task, requestId);
1517         CloseDevSession(requestId);
1529 static void OnBytesReceivedCb(int64_t requestId, uint8_t *data, uint32_t dataLen)
1535     (void)ProcessBindData(requestId, data, dataLen);