Function rdbLoadS3

src/rdb-s3.cpp:74–116

}

int rdbLoadS3(char *s3bucket, rdbSaveInfo *rsi, int rdbflags)
{
    int status = EXIT_FAILURE;
    int fd[2];
    if (pipe(fd) != 0)
        return C_ERR;

    pid_t pid = fork();
    if (pid < 0)
    {
        close(fd[0]);
        close(fd[1]);
        return C_ERR;
    }

    if (pid == 0)
    {
        // child process
        dup2(fd[1], STDOUT_FILENO);
        close(fd[1]);
        close(fd[0]);
        execlp("aws", "aws", "s3", "cp", s3bucket, "-", nullptr);
        exit(EXIT_FAILURE);
    }
    else
    {
        close(fd[1]);
        if (rdbLoadS3Core(fd[0], rsi, rdbflags) != C_OK)
        {
            close(fd[0]);
            return C_ERR;
        }
        close(fd[0]);
        waitpid(pid, &status, 0);
    }
    
    if (status != EXIT_SUCCESS)
        serverLog(LL_WARNING, "Failed to load DB from AWS S3");
    else
        serverLog(LL_NOTICE,"DB loaded from AWS S3");
        
    return (status == EXIT_SUCCESS) ? C_OK : C_ERR;
}