| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110 | #include <stdio.h>#include <stdlib.h>#include <string.h>#include <hiredis.h>#include <hiredis_ssl.h>#include <win32.h>int main(int argc, char **argv) {    unsigned int j;    redisSSLContext *ssl;    redisSSLContextError ssl_error;    redisContext *c;    redisReply *reply;    if (argc < 4) {        printf("Usage: %s <host> <port> <cert> <key> [ca]\n", argv[0]);        exit(1);    }    const char *hostname = (argc > 1) ? argv[1] : "127.0.0.1";    int port = atoi(argv[2]);    const char *cert = argv[3];    const char *key = argv[4];    const char *ca = argc > 4 ? argv[5] : NULL;    redisInitOpenSSL();    ssl = redisCreateSSLContext(ca, NULL, cert, key, NULL, &ssl_error);    if (!ssl) {        printf("SSL Context error: %s\n",                redisSSLContextGetError(ssl_error));        exit(1);    }    struct timeval tv = { 1, 500000 }; // 1.5 seconds    redisOptions options = {0};    REDIS_OPTIONS_SET_TCP(&options, hostname, port);    options.connect_timeout = &tv;    c = redisConnectWithOptions(&options);    if (c == NULL || c->err) {        if (c) {            printf("Connection error: %s\n", c->errstr);            redisFree(c);        } else {            printf("Connection error: can't allocate redis context\n");        }        exit(1);    }    if (redisInitiateSSLWithContext(c, ssl) != REDIS_OK) {        printf("Couldn't initialize SSL!\n");        printf("Error: %s\n", c->errstr);        redisFree(c);        exit(1);    }    /* PING server */    reply = redisCommand(c,"PING");    printf("PING: %s\n", reply->str);    freeReplyObject(reply);    /* Set a key */    reply = redisCommand(c,"SET %s %s", "foo", "hello world");    printf("SET: %s\n", reply->str);    freeReplyObject(reply);    /* Set a key using binary safe API */    reply = redisCommand(c,"SET %b %b", "bar", (size_t) 3, "hello", (size_t) 5);    printf("SET (binary API): %s\n", reply->str);    freeReplyObject(reply);    /* Try a GET and two INCR */    reply = redisCommand(c,"GET foo");    printf("GET foo: %s\n", reply->str);    freeReplyObject(reply);    reply = redisCommand(c,"INCR counter");    printf("INCR counter: %lld\n", reply->integer);    freeReplyObject(reply);    /* again ... */    reply = redisCommand(c,"INCR counter");    printf("INCR counter: %lld\n", reply->integer);    freeReplyObject(reply);    /* Create a list of numbers, from 0 to 9 */    reply = redisCommand(c,"DEL mylist");    freeReplyObject(reply);    for (j = 0; j < 10; j++) {        char buf[64];        snprintf(buf,64,"%u",j);        reply = redisCommand(c,"LPUSH mylist element-%s", buf);        freeReplyObject(reply);    }    /* Let's check what we have inside the list */    reply = redisCommand(c,"LRANGE mylist 0 -1");    if (reply->type == REDIS_REPLY_ARRAY) {        for (j = 0; j < reply->elements; j++) {            printf("%u) %s\n", j, reply->element[j]->str);        }    }    freeReplyObject(reply);    /* Disconnects and frees the context */    redisFree(c);    redisFreeSSLContext(ssl);    return 0;}
 |