device_auth.c - OpenGrok cross reference for /base/security/device_auth/services/device

Lines Matching refs:receivedMsg
56     CJson *receivedMsg;
176 static int32_t AddGroupInfoToContextByInput(const CJson *receivedMsg, CJson *context)
178     const char *groupId = GetStringFromJson(receivedMsg, FIELD_GROUP_ID);
183     const char *groupName = GetStringFromJson(receivedMsg, FIELD_GROUP_NAME);
404     int32_t res = ProcessDevSession(realTask->sessionId, realTask->receivedMsg, &isFinish);
426     FreeJson(realTask->receivedMsg);
429 static void InitProcSessionTask(ProcSessionTask *task, int64_t sessionId, CJson *receivedMsg)
434     task->receivedMsg = receivedMsg;
454 static int32_t AddOriginDataForPlugin(CJson *receivedMsg, const uint8_t *data)
456     if ((receivedMsg == NULL) || (data == NULL)) {
460     return AddStringToJson(receivedMsg, FIELD_PLUGIN_EXT_DATA, (const char *)data);
463 static int32_t PushProcSessionTask(int64_t sessionId, CJson *receivedMsg)
470     InitProcSessionTask(task, sessionId, receivedMsg);
641     const CJson *receivedMsg, CJson *context)
643     const char *groupId = GetStringFromJson(receivedMsg, FIELD_GROUP_ID);
670         res = AddGroupInfoToContextByInput(receivedMsg, context);
723     const CJson *receivedMsg, CJson *context)
733     res = AddServerReqInfoToContext(requestId, appId, opCode, receivedMsg, context);
739     if (GetByteFromJson(receivedMsg, FIELD_CHANNEL_ID, (uint8_t *)&channelId, sizeof(int64_t)) == HC_SUCCESS) {
747 static const char *GetAppIdFromReceivedMsg(const CJson *receivedMsg)
749     const char *appId = GetStringFromJson(receivedMsg, FIELD_APP_ID);
757 static int32_t OpenServerBindSession(int64_t requestId, const CJson *receivedMsg)
759     const char *appId = GetAppIdFromReceivedMsg(receivedMsg);
766     if (GetIntFromJson(receivedMsg, FIELD_GROUP_OP, &opCode) != HC_SUCCESS) {
767         if (GetIntFromJson(receivedMsg, FIELD_OP_CODE, &opCode) != HC_SUCCESS) {
783     int32_t res = BuildServerBindContext(requestId, appId, opCode, receivedMsg, context);
815     CJson *receivedMsg = CreateJsonFromString((const char *)data);
816     if (receivedMsg == NULL) {
822         res = OpenServerBindSession(requestId, receivedMsg);
824             FreeJson(receivedMsg);
828     res = PushProcSessionTask(requestId, receivedMsg);
830         FreeJson(receivedMsg);
1070 static int32_t OpenServerAuthSession(int64_t requestId, const CJson *receivedMsg, const DeviceAuthCallback *callback)
1073     if (GetIntFromJson(receivedMsg, FIELD_AUTH_FORM, &opCode) != HC_SUCCESS) {
1074         if (GetIntFromJson(receivedMsg, FIELD_OP_CODE, &opCode) != HC_SUCCESS) {
1108     int64_t requestId, const CJson *receivedMsg, const DeviceAuthCallback *callback)
1111     if (GetIntFromJson(receivedMsg, FIELD_OP_CODE, &opCode) != HC_SUCCESS) {
1170     CJson *receivedMsg = CreateJsonFromString((const char *)data);
1171     if (receivedMsg == NULL) {
1177         res = OpenServerAuthSession(authReqId, receivedMsg, gaCallback);
1179             FreeJson(receivedMsg);
1184         res = AddOriginDataForPlugin(receivedMsg, data);
1186             FreeJson(receivedMsg);
1190     res = PushProcSessionTask(authReqId, receivedMsg);
1192         FreeJson(receivedMsg);
1297     CJson *receivedMsg = CreateJsonFromString(data);
1299     if (receivedMsg == NULL) {
1305         res = OpenServerAuthSessionForP2P(authReqId, receivedMsg, callback);
1307             FreeJson(receivedMsg);
1311     res = PushProcSessionTask(authReqId, receivedMsg);
1313         FreeJson(receivedMsg);