readerfactory.c

Go to the documentation of this file.

/*
 * MUSCLE SmartCard Development ( https://pcsclite.apdu.fr/ )
 *
 * Copyright (C) 1999-2004
 *  David Corcoran <corcoran@musclecard.com>
 * Copyright (C) 2003-2004
 *  Damien Sauveron <damien.sauveron@labri.fr>
 * Copyright (C) 2002-2024
 *  Ludovic Rousseau <ludovic.rousseau@free.fr>
 * Copyright (C) 2009
 *  Jean-Luc Giraud <jlgiraud@googlemail.com>
 *
Redistribution and use in source and binary forms, with or without
modification, are permitted provided that the following conditions
are met:
 
1. Redistributions of source code must retain the above copyright
   notice, this list of conditions and the following disclaimer.
2. Redistributions in binary form must reproduce the above copyright
   notice, this list of conditions and the following disclaimer in the
   documentation and/or other materials provided with the distribution.
3. The name of the author may not be used to endorse or promote products
   derived from this software without specific prior written permission.
 
THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */
 
#include "config.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <errno.h>
#include <fcntl.h>
#include <pthread.h>
#include <stdatomic.h>
#include <stdbool.h>
 
#include "misc.h"
#include "pcscd.h"
#include "debuglog.h"
#include "readerfactory.h"
#include "dyn_generic.h"
#include "sys_generic.h"
#include "eventhandler.h"
#include "ifdwrapper.h"
#include "hotplug.h"
#include "configfile.h"
#include "utils.h"
 
static READER_CONTEXT * sReadersContexts[PCSCLITE_MAX_READERS_CONTEXTS];
READER_STATE readerStates[PCSCLITE_MAX_READERS_CONTEXTS];
static int maxReaderHandles = PCSC_MAX_READER_HANDLES;
static DWORD dwNumReadersContexts = 0;
#ifdef USE_SERIAL
static char *ConfigFile = NULL;
static int ConfigFileCRC = 0;
#endif
static pthread_mutex_t LockMutex = PTHREAD_MUTEX_INITIALIZER;
int16_t ReaderEvents = 1;
 
static LONG removeReader(READER_CONTEXT * sReader);
 
static int RDR_CLIHANDLES_seeker(const void *el, const void *key)
{
    const RDR_CLIHANDLES *rdrCliHandles = el;
 
    if ((el == NULL) || (key == NULL))
    {
        Log3(PCSC_LOG_CRITICAL,
            "RDR_CLIHANDLES_seeker called with NULL pointer: el=%p, key=%p",
            el, key);
        return 0;
    }
 
    if (rdrCliHandles->hCard == *(SCARDHANDLE *)key)
        return 1;
 
    return 0;
}
 
 
LONG _RefReader(READER_CONTEXT * sReader)
{
    if (0 == sReader->reference)
        return SCARD_E_READER_UNAVAILABLE;
 
    sReader->reference += 1;
 
    return SCARD_S_SUCCESS;
}
 
LONG _UnrefReader(READER_CONTEXT * sReader)
{
    if (0 == sReader->reference)
        return SCARD_E_READER_UNAVAILABLE;
 
    sReader->reference -= 1;
 
    if (0 == sReader->reference)
        removeReader(sReader);
 
    return SCARD_S_SUCCESS;
}
 
LONG RFAllocateReaderSpace(unsigned int customMaxReaderHandles)
{
    int i;  /* Counter */
 
    if (customMaxReaderHandles != 0)
        maxReaderHandles = customMaxReaderHandles;
 
    /* Allocate each reader structure */
    for (i = 0; i < PCSCLITE_MAX_READERS_CONTEXTS; i++)
    {
        sReadersContexts[i] = malloc(sizeof(READER_CONTEXT));
        sReadersContexts[i]->vHandle = NULL;
        atomic_init(&sReadersContexts[i]->hLockId, 0);
        atomic_init(&sReadersContexts[i]->contexts, 0);
        atomic_init(&sReadersContexts[i]->reference, 0);
 
        /* Zero out each value in the struct */
        memset(readerStates[i].readerName, 0, MAX_READERNAME);
        memset(readerStates[i].cardAtr, 0, MAX_ATR_SIZE);
        readerStates[i].eventCounter = 0;
        readerStates[i].readerState = 0;
        readerStates[i].readerSharing = 0;
        readerStates[i].cardAtrLength = READER_NOT_INITIALIZED;
        readerStates[i].cardProtocol = SCARD_PROTOCOL_UNDEFINED;
 
        sReadersContexts[i]->readerState = &readerStates[i];
    }
 
    /* Create public event structures */
    return EHInitializeEventStructures();
}
 
LONG RFAddReader(const char *readerNameLong, int port, const char *library,
    const char *device)
{
    DWORD dwContext = 0, dwGetSize;
    UCHAR ucGetData[1], ucThread[1];
    LONG rv, parentNode;
    int i, j;
    int lrv = 0;
    char *readerName = NULL;
 
    if ((readerNameLong == NULL) || (library == NULL) || (device == NULL))
        return SCARD_E_INVALID_VALUE;
 
#ifdef FILTER_NAMES
    const char *ro_filter = SYS_GetEnv("PCSCLITE_FILTER_IGNORE_READER_NAMES");
    if (ro_filter)
    {
        char *filter, *next;
 
        /* get a RW copy of the env string */
        filter = alloca(strlen(ro_filter)+1);
        strcpy(filter, ro_filter);
 
        while (filter)
        {
            /* ':' is the separator */
            next = strchr(filter, ':');
            if (next)
            {
                /* NUL terminate the current pattern */
                *next = '\0';
            }
 
            /* if filter is non empty and found in the reader name */
            if (*filter && strstr(readerNameLong, filter))
            {
                Log3(PCSC_LOG_ERROR,
                    "Reader name \"%s\" contains \"%s\": ignored",
                    readerNameLong, filter);
                return SCARD_E_READER_UNAVAILABLE;
            }
 
            if (next)
                /* next pattern */
                filter = next+1;
            else
                /* end */
                filter = NULL;
        }
    }
#endif
 
    /* allocate memory that is automatically freed */
    readerName = alloca(strlen(readerNameLong)+1);
    strcpy(readerName, readerNameLong);
 
    /* Reader name too long? also count " 00 00"*/
    if (strlen(readerName) > MAX_READERNAME - sizeof(" 00 00"))
    {
        Log3(PCSC_LOG_ERROR,
            "Reader name too long: %zd chars instead of max %zd. Truncating!",
            strlen(readerName), MAX_READERNAME - sizeof(" 00 00"));
        readerName[MAX_READERNAME - sizeof(" 00 00")] = '\0';
    }
 
    /* Same name, same port, same device - duplicate reader cannot be used */
    if (dwNumReadersContexts != 0)
    {
        for (i = 0; i < PCSCLITE_MAX_READERS_CONTEXTS; i++)
        {
            if (sReadersContexts[i]->vHandle != 0)
            {
                char lpcStripReader[MAX_READERNAME];
                int tmplen;
 
                /* get the reader name without the reader and slot numbers */
                strncpy(lpcStripReader,
                    sReadersContexts[i]->readerState->readerName,
                    sizeof(lpcStripReader));
                tmplen = strlen(lpcStripReader);
                lpcStripReader[tmplen - 6] = 0;
 
                if ((strcmp(readerName, lpcStripReader) == 0)
                    && (port == sReadersContexts[i]->port)
                    && (strcmp(device, sReadersContexts[i]->device) == 0))
                {
                    Log1(PCSC_LOG_ERROR, "Duplicate reader found.");
                    return SCARD_E_DUPLICATE_READER;
                }
            }
        }
    }
 
    /* We must find an empty slot to put the reader structure */
    for (i = 0; i < PCSCLITE_MAX_READERS_CONTEXTS; i++)
    {
        if (sReadersContexts[i]->vHandle == 0)
        {
            dwContext = i;
            break;
        }
    }
 
    if (i == PCSCLITE_MAX_READERS_CONTEXTS)
    {
        /* No more spots left return */
        return SCARD_E_NO_MEMORY;
    }
 
    /* Check and set the readername to see if it must be enumerated */
    parentNode = RFSetReaderName(sReadersContexts[dwContext], readerName,
        library, port);
    if (parentNode < -1)
        return SCARD_E_NO_MEMORY;
 
    sReadersContexts[dwContext]->library = strdup(library);
    sReadersContexts[dwContext]->device = strdup(device);
    sReadersContexts[dwContext]->version = 0;
    sReadersContexts[dwContext]->port = port;
    sReadersContexts[dwContext]->mMutex = NULL;
    sReadersContexts[dwContext]->contexts = 0;
    sReadersContexts[dwContext]->pthThread = 0;
    sReadersContexts[dwContext]->hLockId = 0;
    sReadersContexts[dwContext]->LockCount = 0;
    sReadersContexts[dwContext]->vHandle = NULL;
    sReadersContexts[dwContext]->pFeeds = NULL;
    sReadersContexts[dwContext]->pMutex = NULL;
    sReadersContexts[dwContext]->pthCardEvent = NULL;
 
    lrv = list_init(&sReadersContexts[dwContext]->handlesList);
    if (lrv < 0)
    {
        Log2(PCSC_LOG_CRITICAL, "list_init failed with return value: %d", lrv);
        return SCARD_E_NO_MEMORY;
    }
 
    lrv = list_attributes_seeker(&sReadersContexts[dwContext]->handlesList,
        RDR_CLIHANDLES_seeker);
    if (lrv < 0)
    {
        Log2(PCSC_LOG_CRITICAL,
            "list_attributes_seeker failed with return value: %d", lrv);
        return SCARD_E_NO_MEMORY;
    }
 
    (void)pthread_mutex_init(&sReadersContexts[dwContext]->handlesList_lock,
        NULL);
 
    (void)pthread_mutex_init(&sReadersContexts[dwContext]->powerState_lock,
        NULL);
    sReadersContexts[dwContext]->powerState = POWER_STATE_UNPOWERED;
 
    /* reference count */
    sReadersContexts[dwContext]->reference = 1;
 
    /* If a clone to this reader exists take some values from that clone */
    if (parentNode >= 0 && parentNode < PCSCLITE_MAX_READERS_CONTEXTS)
    {
        sReadersContexts[dwContext]->pFeeds =
          sReadersContexts[parentNode]->pFeeds;
        *(sReadersContexts[dwContext])->pFeeds += 1;
        sReadersContexts[dwContext]->vHandle =
          sReadersContexts[parentNode]->vHandle;
        sReadersContexts[dwContext]->mMutex =
          sReadersContexts[parentNode]->mMutex;
        sReadersContexts[dwContext]->pMutex =
          sReadersContexts[parentNode]->pMutex;
 
        /* Call on the parent driver to see if it is thread safe */
        dwGetSize = sizeof(ucThread);
        rv = IFDGetCapabilities(sReadersContexts[parentNode],
            TAG_IFD_THREAD_SAFE, &dwGetSize, ucThread);
 
        if (rv == IFD_SUCCESS && dwGetSize == 1 && ucThread[0] == 1)
        {
            Log1(PCSC_LOG_INFO, "Driver is thread safe");
            sReadersContexts[dwContext]->mMutex = NULL;
            sReadersContexts[dwContext]->pMutex = NULL;
        }
        else
            *(sReadersContexts[dwContext])->pMutex += 1;
    }
 
    if (sReadersContexts[dwContext]->pFeeds == NULL)
    {
        sReadersContexts[dwContext]->pFeeds = malloc(sizeof(int));
 
        /* Initialize pFeeds to 1, otherwise multiple
           cloned readers will cause pcscd to crash when
           RFUnloadReader unloads the driver library
           and there are still devices attached using it --mikeg*/
        *(sReadersContexts[dwContext])->pFeeds = 1;
    }
 
    if (sReadersContexts[dwContext]->mMutex == 0)
    {
        sReadersContexts[dwContext]->mMutex =
            malloc(sizeof(pthread_mutex_t));
        (void)pthread_mutex_init(sReadersContexts[dwContext]->mMutex, NULL);
    }
 
    if (sReadersContexts[dwContext]->pMutex == NULL)
    {
        sReadersContexts[dwContext]->pMutex = malloc(sizeof(int));
        *(sReadersContexts[dwContext])->pMutex = 1;
    }
 
    dwNumReadersContexts += 1;
 
    rv = RFInitializeReader(sReadersContexts[dwContext]);
    if (rv != SCARD_S_SUCCESS)
    {
        int log_level = PCSC_LOG_ERROR;
        if (SCARD_E_UNKNOWN_READER == rv)
            log_level = PCSC_LOG_INFO;
 
        /* Cannot connect to reader. Exit gracefully */
        Log2(log_level, "%s init failed.", readerName);
        (void)RFRemoveReader(readerName, port, REMOVE_READER_NO_FLAG);
        return rv;
    }
 
    /* asynchronous card movement?  */
    {
        RESPONSECODE (*fct)(DWORD, int) = NULL;
 
        dwGetSize = sizeof(fct);
 
        rv = IFDGetCapabilities(sReadersContexts[dwContext],
            TAG_IFD_POLLING_THREAD_WITH_TIMEOUT, &dwGetSize, (PUCHAR)&fct);
        if ((rv != SCARD_S_SUCCESS) || (dwGetSize != sizeof(fct)))
        {
            Log1(PCSC_LOG_INFO, "Using the pcscd polling thread");
        }
        else
        {
            sReadersContexts[dwContext]->pthCardEvent = fct;
            Log1(PCSC_LOG_INFO, "Using the reader polling thread");
        }
 
        rv = EHSpawnEventHandler(sReadersContexts[dwContext]);
        if (rv != SCARD_S_SUCCESS)
        {
            Log2(PCSC_LOG_ERROR, "%s init failed.", readerName);
            (void)RFRemoveReader(readerName, port, REMOVE_READER_NO_FLAG);
            return rv;
        }
    }
 
    /* we have one more reader */
    ReaderEvents++;
    /* wrap? */
    if (ReaderEvents < 0)
        ReaderEvents = 1;
 
    /* Call on the driver to see if there are multiple slots */
    dwGetSize = sizeof(ucGetData);
    rv = IFDGetCapabilities((sReadersContexts[dwContext]),
        TAG_IFD_SLOTS_NUMBER, &dwGetSize, ucGetData);
 
    int nbSlots = ucGetData[0];
    if (rv != IFD_SUCCESS || dwGetSize != 1 || nbSlots == 0)
        /* Reader does not have this defined.  Must be a single slot
         * reader so we can just return SCARD_S_SUCCESS. */
        return SCARD_S_SUCCESS;
 
    if (1 == nbSlots)
        /* Reader has only one slot */
        return SCARD_S_SUCCESS;
 
    /*
     * Check the number of slots and create a different
     * structure for each one accordingly
     */
 
    /* Initialize the rest of the slots */
    for (j = 1; j < nbSlots; j++)
    {
        char *tmpReader = NULL;
        DWORD dwContextB = 0;
        RESPONSECODE (*fct)(DWORD, int) = NULL;
 
        /* We must find an empty spot to put the reader structure */
        for (i = 0; i < PCSCLITE_MAX_READERS_CONTEXTS; i++)
        {
            if (sReadersContexts[i]->vHandle == 0)
            {
                dwContextB = i;
                break;
            }
        }
 
        if (i == PCSCLITE_MAX_READERS_CONTEXTS)
        {
            /* No more slot left return */
            RFRemoveReader(readerName, port, REMOVE_READER_NO_FLAG);
            return SCARD_E_NO_MEMORY;
        }
 
        /* Copy the previous reader name and increment the slot number */
        tmpReader = sReadersContexts[dwContextB]->readerState->readerName;
        memcpy(tmpReader,
            sReadersContexts[dwContext]->readerState->readerName,
            sizeof(sReadersContexts[dwContextB]->readerState->readerName));
        snprintf(tmpReader + strlen(tmpReader) - 2, 3, "%02X", j);
 
        sReadersContexts[dwContextB]->library =
            sReadersContexts[dwContext]->library;
        sReadersContexts[dwContextB]->device =
            sReadersContexts[dwContext]->device;
        sReadersContexts[dwContextB]->version =
          sReadersContexts[dwContext]->version;
        sReadersContexts[dwContextB]->port =
          sReadersContexts[dwContext]->port;
        sReadersContexts[dwContextB]->vHandle =
          sReadersContexts[dwContext]->vHandle;
        sReadersContexts[dwContextB]->mMutex =
          sReadersContexts[dwContext]->mMutex;
        sReadersContexts[dwContextB]->pMutex =
          sReadersContexts[dwContext]->pMutex;
        sReadersContexts[dwContextB]->slot =
            sReadersContexts[dwContext]->slot + j;
        sReadersContexts[dwContextB]->pthCardEvent = NULL;
 
        /*
         * Added by Dave - slots did not have a pFeeds
         * parameter so it was by luck they were working
         */
        sReadersContexts[dwContextB]->pFeeds =
          sReadersContexts[dwContext]->pFeeds;
 
        /* Added by Dave for multiple slots */
        *(sReadersContexts[dwContextB])->pFeeds += 1;
 
        sReadersContexts[dwContextB]->contexts = 0;
        sReadersContexts[dwContextB]->hLockId = 0;
        sReadersContexts[dwContextB]->LockCount = 0;
 
        lrv = list_init(&sReadersContexts[dwContextB]->handlesList);
        if (lrv < 0)
        {
            Log2(PCSC_LOG_CRITICAL, "list_init failed with return value: %d", lrv);
            return SCARD_E_NO_MEMORY;
        }
 
        lrv = list_attributes_seeker(&sReadersContexts[dwContextB]->handlesList,
            RDR_CLIHANDLES_seeker);
        if (lrv < 0)
        {
            Log2(PCSC_LOG_CRITICAL,
                    "list_attributes_seeker failed with return value: %d", lrv);
            return SCARD_E_NO_MEMORY;
        }
 
        (void)pthread_mutex_init(&sReadersContexts[dwContextB]->handlesList_lock, NULL);
        (void)pthread_mutex_init(&sReadersContexts[dwContextB]->powerState_lock,
            NULL);
        sReadersContexts[dwContextB]->powerState = POWER_STATE_UNPOWERED;
 
        /* reference count */
        sReadersContexts[dwContextB]->reference = 1;
 
        /* Call on the parent driver to see if the slots are thread safe */
        dwGetSize = sizeof(ucThread);
        rv = IFDGetCapabilities((sReadersContexts[dwContext]),
            TAG_IFD_SLOT_THREAD_SAFE, &dwGetSize, ucThread);
 
        if (rv == IFD_SUCCESS && dwGetSize == 1 && ucThread[0] == 1)
        {
            Log1(PCSC_LOG_INFO, "Driver is slot thread safe");
 
            sReadersContexts[dwContextB]->library =
                strdup(sReadersContexts[dwContext]->library);
            sReadersContexts[dwContextB]->device =
                strdup(sReadersContexts[dwContext]->device);
            sReadersContexts[dwContextB]->mMutex =
                malloc(sizeof(pthread_mutex_t));
            (void)pthread_mutex_init(sReadersContexts[dwContextB]->mMutex,
                NULL);
 
            sReadersContexts[dwContextB]->pMutex = malloc(sizeof(int));
            *(sReadersContexts[dwContextB])->pMutex = 1;
        }
        else
            *(sReadersContexts[dwContextB])->pMutex += 1;
 
        dwNumReadersContexts += 1;
 
        rv = RFInitializeReader(sReadersContexts[dwContextB]);
        if (rv != SCARD_S_SUCCESS)
        {
            /* Cannot connect to slot. Exit gracefully */
            (void)RFRemoveReader(readerName, port, REMOVE_READER_NO_FLAG);
            return rv;
        }
 
        /* asynchronous card movement? */
        dwGetSize = sizeof(fct);
 
        rv = IFDGetCapabilities((sReadersContexts[dwContextB]),
            TAG_IFD_POLLING_THREAD_WITH_TIMEOUT, &dwGetSize, (PUCHAR)&fct);
        if ((rv != SCARD_S_SUCCESS) || (dwGetSize != sizeof(fct)))
        {
            Log1(PCSC_LOG_INFO, "Using the pcscd polling thread");
        }
        else
        {
            sReadersContexts[dwContextB]->pthCardEvent = fct;
            Log1(PCSC_LOG_INFO, "Using the reader polling thread");
        }
 
        rv = EHSpawnEventHandler(sReadersContexts[dwContextB]);
        if (rv != SCARD_S_SUCCESS)
        {
            Log2(PCSC_LOG_ERROR, "%s init failed.", readerName);
            (void)RFRemoveReader(readerName, port, REMOVE_READER_NO_FLAG);
            return rv;
        }
    }
 
    return SCARD_S_SUCCESS;
}
 
LONG RFRemoveReader(const char *readerName, int port, int flags)
{
    char lpcStripReader[MAX_READERNAME];
    int i;
#ifdef FILTER_NAMES
    const char *extend;
#endif
    int extend_size = 0;
 
    if (readerName == NULL)
        return SCARD_E_INVALID_VALUE;
 
#ifdef FILTER_NAMES
    extend = SYS_GetEnv("PCSCLITE_FILTER_EXTEND_READER_NAMES");
    if (extend)
        extend_size = strlen(extend);
#endif
 
    for (i = 0; i < PCSCLITE_MAX_READERS_CONTEXTS; i++)
    {
        if (sReadersContexts[i] && (sReadersContexts[i]->vHandle != 0))
        {
            strncpy(lpcStripReader,
                sReadersContexts[i]->readerState->readerName,
                sizeof(lpcStripReader));
            lpcStripReader[strlen(lpcStripReader) - 6 - extend_size] = 0;
 
            /* Compare only the significant part of the reader name */
            if ((strncmp(readerName, lpcStripReader, MAX_READERNAME - sizeof(" 00 00")) == 0)
                && (port == sReadersContexts[i]->port))
            {
                if (flags & REMOVE_READER_FLAG_REMOVED)
                {
                    UCHAR tagValue[1];
                    DWORD valueLength;
                    LONG ret;
 
                    /* signal to the driver that the reader has been removed */
                    valueLength = sizeof(tagValue);
                    ret = IFDGetCapabilities(sReadersContexts[i],
                        TAG_IFD_DEVICE_REMOVED, &valueLength, tagValue);
                    if ((IFD_SUCCESS) == ret && (1 == tagValue[0]))
                    {
                        tagValue[0] = 1;
                        IFDSetCapabilities(sReadersContexts[i],
                            TAG_IFD_DEVICE_REMOVED, sizeof tagValue, tagValue);
                    }
                }
 
                /* remove the reader */
                UNREF_READER(sReadersContexts[i])
            }
        }
    }
 
    /* we have one less reader */
    ReaderEvents++;
    /* wrap? */
    if (ReaderEvents < 0)
        ReaderEvents = 1;
 
    return SCARD_S_SUCCESS;
}
 
LONG removeReader(READER_CONTEXT * sContext)
{
    /* Try to destroy the thread */
    if (sContext -> pthThread)
        EHDestroyEventHandler(sContext);
 
    if ((NULL == sContext->pMutex) || (NULL == sContext->pFeeds))
    {
        Log1(PCSC_LOG_ERROR,
                "Trying to remove an already removed driver");
        return SCARD_E_INVALID_VALUE;
    }
 
    RFUnInitializeReader(sContext);
 
    *sContext->pMutex -= 1;
 
    /* free shared resources when the last slot is closed */
    if (0 == *sContext->pMutex)
    {
        (void)pthread_mutex_destroy(sContext->mMutex);
        free(sContext->mMutex);
        sContext->mMutex = NULL;
        free(sContext->library);
        free(sContext->device);
        free(sContext->pMutex);
        sContext->pMutex = NULL;
    }
 
    *sContext->pFeeds -= 1;
 
    /* Added by Dave to free the pFeeds variable */
    if (*sContext->pFeeds == 0)
    {
        free(sContext->pFeeds);
        sContext->pFeeds = NULL;
    }
 
    (void)pthread_mutex_destroy(&sContext->powerState_lock);
    sContext->version = 0;
    sContext->port = 0;
    sContext->contexts = 0;
    sContext->slot = 0;
    sContext->hLockId = 0;
    sContext->LockCount = 0;
    sContext->vHandle = NULL;
 
    (void)pthread_mutex_lock(&sContext->handlesList_lock);
    while (list_size(&sContext->handlesList) != 0)
    {
        int lrv;
        RDR_CLIHANDLES *currentHandle;
 
        currentHandle = list_get_at(&sContext->handlesList, 0);
        lrv = list_delete_at(&sContext->handlesList, 0);
        if (lrv < 0)
            Log2(PCSC_LOG_CRITICAL,
                    "list_delete_at failed with return value: %d", lrv);
 
        free(currentHandle);
    }
    (void)pthread_mutex_unlock(&sContext->handlesList_lock);
    (void)pthread_mutex_destroy(&sContext->handlesList_lock);
    list_destroy(&sContext->handlesList);
    dwNumReadersContexts -= 1;
 
    /* signal an event to clients */
    EHSignalEventToClients();
 
    return SCARD_S_SUCCESS;
}
 
LONG RFSetReaderName(READER_CONTEXT * rContext, const char *readerName,
    const char *libraryName, int port)
{
    LONG parent = -1;   /* reader number of the parent of the clone */
    DWORD valueLength;
    int currentDigit = -1;
    int supportedChannels = 0;
    bool usedDigits[PCSCLITE_MAX_READERS_CONTEXTS];
    int i;
    const char *extend = "";
 
    /* Clear the list */
    for (i = 0; i < PCSCLITE_MAX_READERS_CONTEXTS; i++)
        usedDigits[i] = false;
 
    if (dwNumReadersContexts != 0)
    {
        for (i = 0; i < PCSCLITE_MAX_READERS_CONTEXTS; i++)
        {
            if (sReadersContexts[i]->vHandle != 0)
            {
                if (strcmp(sReadersContexts[i]->library, libraryName) == 0)
                {
                    UCHAR tagValue[1];
                    LONG ret;
 
                    /* Ask the driver if it supports multiple channels */
                    valueLength = sizeof(tagValue);
                    ret = IFDGetCapabilities(sReadersContexts[i],
                        TAG_IFD_SIMULTANEOUS_ACCESS,
                        &valueLength, tagValue);
 
                    if ((ret == IFD_SUCCESS) && (valueLength == 1) &&
                        (tagValue[0] > 1))
                    {
                        supportedChannels = tagValue[0];
                        Log2(PCSC_LOG_INFO,
                            "Support %d simultaneous readers", tagValue[0]);
                    }
                    else
                        supportedChannels = 1;
 
                    /* Check to see if it is a hotplug reader and different */
                    if ((((sReadersContexts[i]->port & 0xFFFF0000) ==
                            PCSCLITE_HP_BASE_PORT)
                        && (sReadersContexts[i]->port != port))
                        || (supportedChannels > 1))
                    {
                        const char *reader = sReadersContexts[i]->readerState->readerName;
 
                        /*
                         * tells the caller who the parent of this
                         * clone is so it can use its shared
                         * resources like mutex/etc.
                         */
                        parent = i;
 
                        /*
                         * If the same reader already exists and it is
                         * hotplug then we must look for others and
                         * enumerate the readername
                         */
                        currentDigit = strtol(reader + strlen(reader) - 5, NULL, 16);
 
                        /* This spot is taken */
                        usedDigits[currentDigit] = true;
                    }
                }
            }
        }
    }
 
    /* default value */
    i = 0;
 
    /* Other identical readers exist on the same bus */
    if (currentDigit != -1)
    {
        for (i = 0; i < PCSCLITE_MAX_READERS_CONTEXTS; i++)
        {
            /* get the first free digit */
            if (usedDigits[i] == false)
                break;
        }
 
        if (i == PCSCLITE_MAX_READERS_CONTEXTS)
        {
            Log2(PCSC_LOG_ERROR, "Max number of readers reached: %d", PCSCLITE_MAX_READERS_CONTEXTS);
            return -2;
        }
 
        if (i >= supportedChannels)
        {
            Log3(PCSC_LOG_ERROR, "Driver %s does not support more than "
                "%d reader(s). Maybe the driver should support "
                "TAG_IFD_SIMULTANEOUS_ACCESS", libraryName, supportedChannels);
            return -2;
        }
    }
 
#ifdef FILTER_NAMES
    extend = SYS_GetEnv("PCSCLITE_FILTER_EXTEND_READER_NAMES");
    if (NULL == extend)
        extend = "";
#endif
 
    snprintf(rContext->readerState->readerName,
        sizeof(rContext->readerState->readerName), "%s%s %02X 00",
        readerName, extend, i);
 
    /* Set the slot in 0xDDDDCCCC */
    rContext->slot = i << 16;
 
    return parent;
}
 
LONG RFReaderInfo(const char *readerName, READER_CONTEXT ** sReader)
{
    int i;
 
    if (readerName == NULL)
        return SCARD_E_UNKNOWN_READER;
 
    for (i = 0; i < PCSCLITE_MAX_READERS_CONTEXTS; i++)
    {
        if (sReadersContexts[i]->vHandle != 0)
        {
            if (strcmp(readerName,
                sReadersContexts[i]->readerState->readerName) == 0)
            {
                /* Increase reference count */
                REF_READER(sReadersContexts[i])
 
                *sReader = sReadersContexts[i];
                return SCARD_S_SUCCESS;
            }
        }
    }
 
    return SCARD_E_UNKNOWN_READER;
}
 
LONG RFReaderInfoById(SCARDHANDLE hCard, READER_CONTEXT * * sReader)
{
    int i;
 
    for (i = 0; i < PCSCLITE_MAX_READERS_CONTEXTS; i++)
    {
        if (sReadersContexts[i]->vHandle != 0)
        {
            RDR_CLIHANDLES * currentHandle;
            (void)pthread_mutex_lock(&sReadersContexts[i]->handlesList_lock);
            currentHandle = list_seek(&sReadersContexts[i]->handlesList,
                &hCard);
            (void)pthread_mutex_unlock(&sReadersContexts[i]->handlesList_lock);
            if (currentHandle != NULL)
            {
                /* Increase reference count */
                REF_READER(sReadersContexts[i])
 
                *sReader = sReadersContexts[i];
                return SCARD_S_SUCCESS;
            }
        }
    }
 
    return SCARD_E_INVALID_VALUE;
}
 
LONG RFLoadReader(READER_CONTEXT * rContext)
{
    LONG ret = SCARD_S_SUCCESS;
    if (rContext->vHandle != 0)
    {
        Log2(PCSC_LOG_INFO, "Reusing already loaded driver for %s",
            rContext->library);
        /* Another reader exists with this library loaded */
        return SCARD_S_SUCCESS;
    }
 
    rContext->vHandle = DYN_LoadLibrary(rContext->library);
    if (NULL == rContext->vHandle)
        ret = SCARD_F_UNKNOWN_ERROR;
    return ret;
}
 
LONG RFBindFunctions(READER_CONTEXT * rContext)
{
    int rv;
    void *f;
 
    rv = DYN_GetAddress(rContext->vHandle, &f, "IFDHCreateChannelByName", true);
    if (SCARD_S_SUCCESS == rv)
    {
        /* Ifd Handler 3.0 found */
        rContext->version = IFD_HVERSION_3_0;
    }
    else
    {
        rv = DYN_GetAddress(rContext->vHandle, &f, "IFDHCreateChannel", false);
        if (SCARD_S_SUCCESS == rv)
        {
            /* Ifd Handler 2.0 found */
            rContext->version = IFD_HVERSION_2_0;
        }
        else
        {
            /* Neither version of the IFD Handler was found - exit */
            Log1(PCSC_LOG_CRITICAL, "IFDHandler functions missing");
            return SCARD_F_UNKNOWN_ERROR;
        }
    }
 
    if (rContext->version == IFD_HVERSION_2_0)
    {
        /* The following binds version 2.0 of the IFD Handler specs */
#define GET_ADDRESS_OPTIONALv2(s, code) \
{ \
    void *f1 = NULL; \
    int rvl = DYN_GetAddress(rContext->vHandle, &f1, "IFDH" #s, false); \
    if (SCARD_S_SUCCESS != rvl) \
    { \
        code \
    } \
    rContext->psFunctions.psFunctions_v2.pvf ## s = f1; \
}
 
#define GET_ADDRESSv2(s) \
    GET_ADDRESS_OPTIONALv2(s, \
        Log1(PCSC_LOG_CRITICAL, "IFDHandler functions missing: " #s ); \
        return(rv); )
 
        Log1(PCSC_LOG_INFO, "Loading IFD Handler 2.0");
 
        GET_ADDRESSv2(CreateChannel)
        GET_ADDRESSv2(CloseChannel)
        GET_ADDRESSv2(GetCapabilities)
        GET_ADDRESSv2(SetCapabilities)
        GET_ADDRESSv2(PowerICC)
        GET_ADDRESSv2(TransmitToICC)
        GET_ADDRESSv2(ICCPresence)
        GET_ADDRESS_OPTIONALv2(SetProtocolParameters, )
 
        GET_ADDRESSv2(Control)
    }
    else if (rContext->version == IFD_HVERSION_3_0)
    {
        /* The following binds version 3.0 of the IFD Handler specs */
#define GET_ADDRESS_OPTIONALv3(s, code) \
{ \
    void *f1 = NULL; \
    int rvl = DYN_GetAddress(rContext->vHandle, &f1, "IFDH" #s, false); \
    if (SCARD_S_SUCCESS != rvl) \
    { \
        code \
    } \
    rContext->psFunctions.psFunctions_v3.pvf ## s = f1; \
}
 
#define GET_ADDRESSv3(s) \
    GET_ADDRESS_OPTIONALv3(s, \
        Log1(PCSC_LOG_CRITICAL, "IFDHandler functions missing: " #s ); \
        return(rv); )
 
        Log1(PCSC_LOG_INFO, "Loading IFD Handler 3.0");
 
        GET_ADDRESSv2(CreateChannel)
        GET_ADDRESSv2(CloseChannel)
        GET_ADDRESSv2(GetCapabilities)
        GET_ADDRESSv2(SetCapabilities)
        GET_ADDRESSv2(PowerICC)
        GET_ADDRESSv2(TransmitToICC)
        GET_ADDRESSv2(ICCPresence)
        GET_ADDRESS_OPTIONALv2(SetProtocolParameters, )
 
        GET_ADDRESSv3(CreateChannelByName)
        GET_ADDRESSv3(Control)
    }
    else
    {
        /* Who knows what could have happened for it to get here. */
        Log1(PCSC_LOG_CRITICAL, "IFD Handler not 1.0/2.0 or 3.0");
        return SCARD_F_UNKNOWN_ERROR;
    }
 
    return SCARD_S_SUCCESS;
}
 
LONG RFUnBindFunctions(READER_CONTEXT * rContext)
{
    /* Zero out everything */
    memset(&rContext->psFunctions, 0, sizeof(rContext->psFunctions));
 
    return SCARD_S_SUCCESS;
}
 
LONG RFUnloadReader(READER_CONTEXT * rContext)
{
    /* Make sure no one else is using this library */
    if (*rContext->pFeeds == 1)
    {
        Log1(PCSC_LOG_INFO, "Unloading reader driver.");
        (void)DYN_CloseLibrary(rContext->vHandle);
        rContext->vHandle = NULL;
    }
 
    rContext->vHandle = NULL;
 
    return SCARD_S_SUCCESS;
}
 
LONG RFCheckSharing(SCARDHANDLE hCard, READER_CONTEXT * rContext)
{
    if (rContext->hLockId == 0 || rContext->hLockId == hCard)
        return SCARD_S_SUCCESS;
    else
        return SCARD_E_SHARING_VIOLATION;
}
 
LONG RFLockSharing(SCARDHANDLE hCard, READER_CONTEXT * rContext)
{
    LONG rv;
 
    (void)pthread_mutex_lock(&LockMutex);
    rv = RFCheckSharing(hCard, rContext);
    if (SCARD_S_SUCCESS == rv)
    {
        rContext->LockCount += 1;
        rContext->hLockId = hCard;
    }
    (void)pthread_mutex_unlock(&LockMutex);
 
    return rv;
}
 
LONG RFUnlockSharing(SCARDHANDLE hCard, READER_CONTEXT * rContext)
{
    LONG rv;
 
    (void)pthread_mutex_lock(&LockMutex);
    rv = RFCheckSharing(hCard, rContext);
    if (SCARD_S_SUCCESS == rv)
    {
        if (PCSCLITE_SHARING_EXCLUSIVE_CONTEXT == rContext->contexts)
        {
            if (rContext->LockCount > 1)
                rContext->LockCount -= 1;
            else
                rv = SCARD_E_NOT_TRANSACTED;
        }
        else
        {
            if (rContext->LockCount > 0)
            {
                rContext->LockCount -= 1;
                if (0 == rContext->LockCount)
                    rContext->hLockId = 0;
            }
            else
                /* rContext->LockCount == 0 */
                rv = SCARD_E_NOT_TRANSACTED;
        }
    }
    (void)pthread_mutex_unlock(&LockMutex);
 
    return rv;
}
 
LONG RFUnlockAllSharing(SCARDHANDLE hCard, READER_CONTEXT * rContext)
{
    LONG rv;
 
    (void)pthread_mutex_lock(&LockMutex);
    rv = RFCheckSharing(hCard, rContext);
    if (SCARD_S_SUCCESS == rv)
    {
        rContext->LockCount = 0;
        rContext->hLockId = 0;
    }
    (void)pthread_mutex_unlock(&LockMutex);
 
    return rv;
}
 
LONG RFInitializeReader(READER_CONTEXT * rContext)
{
    LONG rv = SCARD_S_SUCCESS;
    RESPONSECODE rvd;
 
    /* Spawn the event handler thread */
    Log3(PCSC_LOG_INFO, "Attempting startup of %s using %s",
        rContext->readerState->readerName, rContext->library);
 
#ifndef PCSCLITE_STATIC_DRIVER
    /* loads the library */
    rv = RFLoadReader(rContext);
    if (rv != SCARD_S_SUCCESS)
    {
        Log2(PCSC_LOG_ERROR, "RFLoadReader failed: 0x%lX", rv);
        return rv;
    }
 
    /* binds the functions */
    rv = RFBindFunctions(rContext);
 
    if (rv != SCARD_S_SUCCESS)
    {
        Log2(PCSC_LOG_ERROR, "RFBindFunctions failed: 0x%lX", rv);
        (void)RFUnloadReader(rContext);
        return rv;
    }
#else
    /* define a fake vHandle. Can be any value except NULL */
    rContext->vHandle = RFInitializeReader;
#endif
 
    /* tries to open the port */
    rvd = IFDOpenIFD(rContext);
 
    if (rvd != IFD_SUCCESS)
    {
        int log_level = PCSC_LOG_CRITICAL;
        rv = SCARD_E_INVALID_TARGET;
 
        if (IFD_NO_SUCH_DEVICE == rvd)
        {
            /* wrong interface on a composite device? */
            log_level = PCSC_LOG_INFO;
            rv = SCARD_E_UNKNOWN_READER;
        }
 
        Log3(log_level, "Open Port 0x%X Failed (%s)",
            rContext->port, rContext->device);
 
        /* IFDOpenIFD() failed */
        /* the reader was not started correctly */
        rContext->slot = -1;
    }
 
    return rv;
}
 
void RFUnInitializeReader(READER_CONTEXT * rContext)
{
    Log2(PCSC_LOG_INFO, "Attempting shutdown of %s.",
        rContext->readerState->readerName);
 
    /* Do not close a reader if IFDOpenIFD() failed in RFInitializeReader() */
    if (rContext->slot != -1)
        (void)IFDCloseIFD(rContext);
 
    (void)RFUnBindFunctions(rContext);
    (void)RFUnloadReader(rContext);
 
    /*
     * Zero out the public status struct to allow it to be recycled and
     * used again
     */
    memset(rContext->readerState->readerName, 0,
        sizeof(rContext->readerState->readerName));
    memset(rContext->readerState->cardAtr, 0,
        sizeof(rContext->readerState->cardAtr));
    rContext->readerState->readerState = 0;
    rContext->readerState->eventCounter = 0;
    rContext->readerState->readerSharing = 0;
    rContext->readerState->cardAtrLength = READER_NOT_INITIALIZED;
    rContext->readerState->cardProtocol = SCARD_PROTOCOL_UNDEFINED;
 
    return;
}
 
SCARDHANDLE RFCreateReaderHandle(READER_CONTEXT * rContext)
{
    SCARDHANDLE randHandle;
    LONG ret;
 
    (void)rContext;
 
    do
    {
        READER_CONTEXT *dummy_reader;
 
        /* Create a random handle with 32 bits check to see if it already is
         * used. */
        /* FIXME: THIS IS NOT STRONG ENOUGH: A 128-bit token should be
         * generated.  The client and server would associate token and hCard
         * for authentication. */
        randHandle = SYS_RandomInt();
 
        /* do we already use this hCard somewhere? */
        ret = RFReaderInfoById(randHandle, &dummy_reader);
        if (SCARD_S_SUCCESS == ret)
            UNREF_READER(dummy_reader)
    }
    while (SCARD_S_SUCCESS == ret);
 
    /* Once the for loop is completed w/o restart a good handle was
     * found and the loop can be exited. */
    return randHandle;
}
 
LONG RFAddReaderHandle(READER_CONTEXT * rContext, SCARDHANDLE hCard)
{
    int listLength, lrv;
    RDR_CLIHANDLES *newHandle;
    LONG rv = SCARD_S_SUCCESS;
 
    (void)pthread_mutex_lock(&rContext->handlesList_lock);
    listLength = list_size(&rContext->handlesList);
 
    /* Throttle the number of possible handles */
    if (listLength >= maxReaderHandles)
    {
        Log2(PCSC_LOG_CRITICAL,
            "Too many handles opened, exceeding configured max (%d)",
            maxReaderHandles);
        rv = SCARD_E_NO_MEMORY;
        goto end;
    }
 
    newHandle = malloc(sizeof(RDR_CLIHANDLES));
    if (NULL == newHandle)
    {
        Log1(PCSC_LOG_CRITICAL, "malloc failed");
        rv = SCARD_E_NO_MEMORY;
        goto end;
    }
 
    newHandle->hCard = hCard;
    atomic_init(&newHandle->dwEventStatus, 0);
 
    lrv = list_append(&rContext->handlesList, newHandle);
    if (lrv < 0)
    {
        free(newHandle);
        Log2(PCSC_LOG_CRITICAL, "list_append failed with return value: %d",
            lrv);
        rv = SCARD_E_NO_MEMORY;
    }
end:
    (void)pthread_mutex_unlock(&rContext->handlesList_lock);
    return rv;
}
 
LONG RFRemoveReaderHandle(READER_CONTEXT * rContext, SCARDHANDLE hCard)
{
    RDR_CLIHANDLES *currentHandle;
    int lrv;
    LONG rv = SCARD_S_SUCCESS;
 
    (void)pthread_mutex_lock(&rContext->handlesList_lock);
    currentHandle = list_seek(&rContext->handlesList, &hCard);
    if (NULL == currentHandle)
    {
        Log2(PCSC_LOG_CRITICAL, "list_seek failed to locate hCard=%lX", hCard);
        rv = SCARD_E_INVALID_HANDLE;
        goto end;
    }
 
    lrv = list_delete(&rContext->handlesList, currentHandle);
    if (lrv < 0)
        Log2(PCSC_LOG_CRITICAL,
            "list_delete failed with return value: %d", lrv);
 
    free(currentHandle);
 
end:
    (void)pthread_mutex_unlock(&rContext->handlesList_lock);
 
    /* Not Found */
    return rv;
}
 
void RFSetReaderEventState(READER_CONTEXT * rContext, DWORD dwEvent)
{
    /* Set all the handles for that reader to the event */
    int list_index, listSize;
    RDR_CLIHANDLES *currentHandle;
 
    (void)pthread_mutex_lock(&rContext->handlesList_lock);
    listSize = list_size(&rContext->handlesList);
 
    for (list_index = 0; list_index < listSize; list_index++)
    {
        currentHandle = list_get_at(&rContext->handlesList, list_index);
        if (NULL == currentHandle)
        {
            Log2(PCSC_LOG_CRITICAL, "list_get_at failed at index %d",
                list_index);
            continue;
        }
 
        currentHandle->dwEventStatus = dwEvent;
    }
    (void)pthread_mutex_unlock(&rContext->handlesList_lock);
 
    if (SCARD_REMOVED == dwEvent)
    {
        /* unlock the card */
        rContext->hLockId = 0;
        rContext->LockCount = 0;
    }
 
    return;
}
 
LONG RFCheckReaderEventState(READER_CONTEXT * rContext, SCARDHANDLE hCard)
{
    LONG rv;
    RDR_CLIHANDLES *currentHandle;
    DWORD dwEventStatus;
 
    (void)pthread_mutex_lock(&rContext->handlesList_lock);
    currentHandle = list_seek(&rContext->handlesList, &hCard);
    (void)pthread_mutex_unlock(&rContext->handlesList_lock);
    if (NULL == currentHandle)
    {
        /* Not Found */
        Log2(PCSC_LOG_CRITICAL, "list_seek failed for hCard 0x%lX", hCard);
        return SCARD_E_INVALID_HANDLE;
    }
 
    dwEventStatus = currentHandle->dwEventStatus;
    switch(dwEventStatus)
    {
        case 0:
            rv = SCARD_S_SUCCESS;
            break;
 
        case SCARD_REMOVED:
            rv = SCARD_W_REMOVED_CARD;
            break;
 
        case SCARD_RESET:
            rv = SCARD_W_RESET_CARD;
            break;
 
        default:
            rv = SCARD_E_INVALID_VALUE;
    }
 
    return rv;
}
 
LONG RFClearReaderEventState(READER_CONTEXT * rContext, SCARDHANDLE hCard)
{
    RDR_CLIHANDLES *currentHandle;
 
    (void)pthread_mutex_lock(&rContext->handlesList_lock);
    currentHandle = list_seek(&rContext->handlesList, &hCard);
    (void)pthread_mutex_unlock(&rContext->handlesList_lock);
    if (NULL == currentHandle)
        /* Not Found */
        return SCARD_E_INVALID_HANDLE;
 
    currentHandle->dwEventStatus = 0;
 
    /* hCards should be unique so we
     * should be able to return
     * as soon as we have a hit */
    return SCARD_S_SUCCESS;
}
 
LONG RFCheckReaderStatus(READER_CONTEXT * rContext)
{
    if (rContext->readerState->readerState & SCARD_UNKNOWN)
        return SCARD_E_READER_UNAVAILABLE;
    else
        return SCARD_S_SUCCESS;
}
 
void RFCleanupReaders(void)
{
    int i;
 
    Log1(PCSC_LOG_INFO, "entering cleaning function");
    for (i = 0; i < PCSCLITE_MAX_READERS_CONTEXTS; i++)
    {
        if (sReadersContexts[i]->vHandle != 0)
        {
            LONG rv;
            char lpcStripReader[MAX_READERNAME];
 
            Log2(PCSC_LOG_INFO, "Stopping reader: %s",
                sReadersContexts[i]->readerState->readerName);
 
            strncpy(lpcStripReader,
                sReadersContexts[i]->readerState->readerName,
                sizeof(lpcStripReader));
            /* strip the 6 last char ' 00 00' */
            lpcStripReader[strlen(lpcStripReader) - 6] = '\0';
 
            rv = RFRemoveReader(lpcStripReader, sReadersContexts[i]->port,
                REMOVE_READER_NO_FLAG);
 
            if (rv != SCARD_S_SUCCESS)
                Log2(PCSC_LOG_ERROR, "RFRemoveReader error: %s", rv2text(rv));
        }
 
        free(sReadersContexts[i]);
        sReadersContexts[i] = NULL;
    }
 
#ifdef USE_SERIAL
    if (ConfigFile)
    {
        free(ConfigFile);
        ConfigFile = NULL;
    }
#endif
}
 
#ifdef USE_USB
void RFWaitForReaderInit(void)
{
    bool need_to_wait;
 
    do
    {
        need_to_wait = false;
        for (int i = 0; i < PCSCLITE_MAX_READERS_CONTEXTS; i++)
        {
            /* reader is present */
            if (sReadersContexts[i] && sReadersContexts[i]->vHandle != NULL)
            {
                /* but card state is not yet available */
                if (READER_NOT_INITIALIZED
                    == sReadersContexts[i]->readerState->cardAtrLength)
                {
                    Log2(PCSC_LOG_DEBUG, "Waiting init for reader: %s",
                        sReadersContexts[i]->readerState->readerName);
                    need_to_wait = true;
                }
            }
        }
 
        if (need_to_wait)
            SYS_USleep(10*1000); /* 10 ms */
    } while (need_to_wait);
}
#endif
 
#ifdef USE_SERIAL
int RFStartSerialReaders(const char *readerconf)
{
    SerialReader *reader_list = NULL;
    int i, rv;
 
    /* remember the configuration filename for RFReCheckReaderConf() */
    ConfigFile = strdup(readerconf);
 
    rv = DBGetReaderListDir(readerconf, &reader_list);
 
    /* the list is empty */
    if (NULL == reader_list)
        return rv;
 
    for (i=0; reader_list[i].pcFriendlyname; i++)
    {
        int j;
 
        (void)RFAddReader(reader_list[i].pcFriendlyname,
            reader_list[i].channelId,
            reader_list[i].pcLibpath, reader_list[i].pcDevicename);
 
        /* update the ConfigFileCRC (this false "CRC" is very weak) */
        for (j=0; j<reader_list[i].pcFriendlyname[j]; j++)
            ConfigFileCRC += reader_list[i].pcFriendlyname[j];
        for (j=0; j<reader_list[i].pcLibpath[j]; j++)
            ConfigFileCRC += reader_list[i].pcLibpath[j];
        for (j=0; j<reader_list[i].pcDevicename[j]; j++)
            ConfigFileCRC += reader_list[i].pcDevicename[j];
 
        /* free strings allocated by DBGetReaderListDir() */
        free(reader_list[i].pcFriendlyname);
        free(reader_list[i].pcLibpath);
        free(reader_list[i].pcDevicename);
    }
    free(reader_list);
 
    return rv;
}
 
void RFReCheckReaderConf(void)
{
    SerialReader *reader_list = NULL;
    int i, crc;
 
    (void)DBGetReaderListDir(ConfigFile, &reader_list);
 
    /* the list is empty */
    if (NULL == reader_list)
        return;
 
    crc = 0;
    for (i=0; reader_list[i].pcFriendlyname; i++)
    {
        int j;
 
        /* calculate a local crc */
        for (j=0; j<reader_list[i].pcFriendlyname[j]; j++)
            crc += reader_list[i].pcFriendlyname[j];
        for (j=0; j<reader_list[i].pcLibpath[j]; j++)
            crc += reader_list[i].pcLibpath[j];
        for (j=0; j<reader_list[i].pcDevicename[j]; j++)
            crc += reader_list[i].pcDevicename[j];
    }
 
    /* cancel if the configuration file has been modified */
    if (crc != ConfigFileCRC)
    {
        Log2(PCSC_LOG_CRITICAL,
            "configuration file: %s has been modified. Recheck canceled",
            ConfigFile);
        return;
    }
 
    for (i=0; reader_list[i].pcFriendlyname; i++)
    {
        int r;
        char present = false;
 
        Log2(PCSC_LOG_DEBUG, "refresh reader: %s",
            reader_list[i].pcFriendlyname);
 
        /* is the reader already present? */
        for (r = 0; r < PCSCLITE_MAX_READERS_CONTEXTS; r++)
        {
            if (sReadersContexts[r]->vHandle != 0)
            {
                char lpcStripReader[MAX_READERNAME];
                int tmplen;
 
                /* get the reader name without the reader and slot numbers */
                strncpy(lpcStripReader,
                    sReadersContexts[i]->readerState->readerName,
                    sizeof(lpcStripReader));
                tmplen = strlen(lpcStripReader);
                lpcStripReader[tmplen - 6] = 0;
 
                if ((strcmp(reader_list[i].pcFriendlyname, lpcStripReader) == 0)
                    && (reader_list[r].channelId == sReadersContexts[i]->port))
                {
                    DWORD dwStatus = 0;
 
                    /* the reader was already started */
                    present = true;
 
                    /* verify the reader is still connected */
                    if (IFDStatusICC(sReadersContexts[r], &dwStatus)
                        != SCARD_S_SUCCESS)
                    {
                        Log2(PCSC_LOG_INFO, "Reader %s disappeared",
                            reader_list[i].pcFriendlyname);
                        (void)RFRemoveReader(reader_list[i].pcFriendlyname,
                            reader_list[r].channelId, REMOVE_READER_NO_FLAG);
                    }
                }
            }
        }
 
        /* the reader was not present */
        if (!present)
            /* we try to add it */
            (void)RFAddReader(reader_list[i].pcFriendlyname,
                reader_list[i].channelId, reader_list[i].pcLibpath,
                reader_list[i].pcDevicename);
 
        /* free strings allocated by DBGetReaderListDir() */
        free(reader_list[i].pcFriendlyname);
        free(reader_list[i].pcLibpath);
        free(reader_list[i].pcDevicename);
    }
    free(reader_list);
}
#endif
 
int RFGetPowerState(READER_CONTEXT * rContext)
{
    (void)pthread_mutex_lock(&rContext->powerState_lock);
    int result = rContext->powerState;
    (void)pthread_mutex_unlock(&rContext->powerState_lock);
    return result;
}
 
void RFSetPowerState(READER_CONTEXT * rContext, int value)
{
    (void)pthread_mutex_lock(&rContext->powerState_lock);
    rContext->powerState = value;
    (void)pthread_mutex_unlock(&rContext->powerState_lock);
}