36   curl_socket_t *sockets;  member
49 static void removeFd(struct Sockets *sockets, curl_socket_t fd, int mention)  in removeFd()  argument
56   for(i = 0; i < sockets->count; ++i) {  in removeFd()
57     if(sockets->sockets[i] == fd) {  in removeFd()
58       if(i < sockets->count - 1)  in removeFd()
59         memmove(&sockets->sockets[i], &sockets->sockets[i + 1],  in removeFd()
60               sizeof(curl_socket_t) * (sockets->count - (i + 1)));  in removeFd()
61       --sockets->count;  in removeFd()
69 static void addFd(struct Sockets *sockets, curl_socket_t fd, const char *what)  in addFd()  argument
76   removeFd(sockets, fd, 0);  in addFd()
80   if(!sockets->sockets) {  in addFd()
81     sockets->sockets = malloc(sizeof(curl_socket_t) * 20U);  in addFd()
82     if(!sockets->sockets)  in addFd()
84     sockets->max_count = 20;  in addFd()
86   else if(sockets->count + 1 > sockets->max_count) {  in addFd()
87     curl_socket_t *oldptr = sockets->sockets;  in addFd()
88     sockets->sockets = realloc(oldptr, sizeof(curl_socket_t) *  in addFd()
89                                (sockets->max_count + 20));  in addFd()
90     if(!sockets->sockets) {  in addFd()
92       sockets->sockets = oldptr;  in addFd()
95     sockets->max_count += 20;  in addFd()
100   sockets->sockets[sockets->count] = fd;  in addFd()
101   ++sockets->count;  in addFd()
110   struct ReadWriteSockets *sockets = userp;  in curlSocketCallback()  local
116     addFd(&sockets->read, s, "read");  in curlSocketCallback()
119     addFd(&sockets->write, s, "write");  in curlSocketCallback()
122     removeFd(&sockets->read, s, 1);  in curlSocketCallback()
123     removeFd(&sockets->write, s, 0);  in curlSocketCallback()
192 static void updateFdSet(struct Sockets *sockets, fd_set* fdset,  in updateFdSet()  argument
196   for(i = 0; i < sockets->count; ++i) {  in updateFdSet()
197     FD_SET(sockets->sockets[i], fdset);  in updateFdSet()
198     if(*maxFd < sockets->sockets[i] + 1) {  in updateFdSet()
199       *maxFd = sockets->sockets[i] + 1;  in updateFdSet()
218 static void checkFdSet(CURLM *curl, struct Sockets *sockets, fd_set *fdset,  in checkFdSet()  argument
222   for(i = 0; i < sockets->count; ++i) {  in checkFdSet()
223     if(FD_ISSET(sockets->sockets[i], fdset)) {  in checkFdSet()
224       notifyCurl(curl, sockets->sockets[i], evBitmask, name);  in checkFdSet()
237   struct ReadWriteSockets sockets = {{NULL, 0, 0}, {NULL, 0, 0}};  in test()  local
300   multi_setopt(m, CURLMOPT_SOCKETDATA, &sockets);  in test()
314     updateFdSet(&sockets.read, &readSet, &maxFd);  in test()
315     updateFdSet(&sockets.write, &writeSet, &maxFd);  in test()
330     checkFdSet(m, &sockets.read, &readSet, CURL_CSELECT_IN, "read");  in test()
331     checkFdSet(m, &sockets.write, &writeSet, CURL_CSELECT_OUT, "write");  in test()
359   free(sockets.read.sockets);  in test()
360   free(sockets.write.sockets);  in test()