int compare_and_set_val()

in agent/src/c/service/fsof_redis.c [40:145]

• 91 lines of code
• 22 McCabe index (conditional complexity)

int compare_and_set_val(const struct fsof_message *message) {
    struct redisReply *object = NULL;
    struct redisReply *reply = fsof_redis_get(message->key);
    if (reply != NULL && reply->elements > 0 && message->count > 0) {
        //mt_array_t *same_list = mt_array_create(message->count,sizeof(struct array_object));
        mt_array_t *new_list = mt_array_create(message->count,sizeof(struct array_object));
        mt_array_t *delete_list = mt_array_create(message->count,sizeof(struct array_object));
        //assert(same_list != NULL);
        assert(new_list != NULL);
        assert(delete_list != NULL);

        struct array_object *tmp_object = NULL;
        int i = 0;
        int j = 0;
        for (; i < reply->elements; i++) {
            object = reply->element[i]; 
            if (object != NULL) {
                for (; j < message->count; j++) {
                    if (strcmp(object->str,message->value[j]) == 0) {//equal
                        break;
                    }
                } 

                if (j == message->count) {//not found need delete
                    tmp_object = (struct array_object*)mt_array_push(delete_list);
                    assert(tmp_object != NULL);
                    if (tmp_object != NULL) {
                        tmp_object->data_ptr = object->str;
                    }
                }

                if (j < message->count) { //found same value
                    //nothing to do
                }

                j = 0;
            }
        }

        i = j = 0;
        for (; i < message->count; i++) {
            for (; j < reply->elements; j++) {
                object = reply->element[j]; 
                if (strcmp(object->str,message->value[i]) == 0) {//equal
                    break;
                }
            }

            if (j == reply->elements) { // not found new value 
                tmp_object = (struct array_object*)mt_array_push(new_list);
                assert(tmp_object != NULL);
                if (tmp_object != NULL) {
                    tmp_object->data_ptr = message->value[i];
                }
            }

            j = 0;
        }

        if (delete_list->nelts > 0) {
            struct array_object *ptr = NULL;
            struct redisReply *tmp_reply = NULL;
            i = 0;
            for (; i < delete_list->nelts; i++) {
                ptr = (struct array_object*)(delete_list->elts + i * delete_list->size);
                fsof_log_info(INFO,"BEGIN Delete val is %s succeed,key is %s\n",ptr->data_ptr,message->key);
__DELETE_AGAIN:
                tmp_reply = redisCommand(g_redis_conn,"lrem %s 0 %s",message->key,ptr->data_ptr); //delete value
                if (tmp_reply == NULL) {
                    fsof_redis_close();
                    fsof_redis_init(unix_path);
                    goto __DELETE_AGAIN;
                }

                fsof_log_info(INFO,"Delete val is %s succeed,key is %s\n",ptr->data_ptr,message->key);
                freeReplyObject(tmp_reply);
            }
        }

        if (new_list->nelts > 0) {
            i = 0;
            struct array_object *ptr = NULL;
            struct redisReply *tmp_reply = NULL;
            for (; i < new_list->nelts; i++) {
                ptr = (struct array_object*)(new_list->elts + i * new_list->size);
__NEW_AGAIN:
                tmp_reply = redisCommand(g_redis_conn,"lpush %s %s",message->key,ptr->data_ptr);
                if (tmp_reply == NULL) {
                    fsof_redis_close();
                    fsof_redis_init(unix_path);
                    goto __NEW_AGAIN;
                }
                fsof_log_info(INFO,"Insert val is %s succeed,key is %s\n",ptr->data_ptr,message->key);
                freeReplyObject(tmp_reply);
            }
        }

        mt_array_destroy(delete_list);
        mt_array_destroy(new_list);
        //mt_array_destroy(same_list);
        freeReplyObject(reply);  
    } else {
        return fsof_redis_setval(message); //directly set new value list
    }
    return 0;
}