@@ -32,6 +32,8 @@ typedef struct _sselect {

         int sizeresult;

         int readresultreturned;

         int writeresultreturned;

+        int sizeuserptr;

+        void **userptr;

 } _sselect;

@@ -47,6 +49,11 @@ typedef struct _sselect {

                 s.sin_port=htons(port)

 #endif

+#define USERPTRBLOCKSIZE 1024

+

+static int sselect_adduserptr(_sselect *ssel, int fd, void *userptr);

+static int sselect_clearuserptr(_sselect *ssel, int fd);

+

 char *

 ipv4_genip(char *hostname, long *resulthostsize)

 {

@@ -231,6 +238,20 @@ sselect_init(void)

         return((sselect *)ssel);

 }

+void

+sselect_free(sselect *paramssel)

+{

+        _sselect *ssel=(_sselect *)paramssel;

+        if(ssel==NULL)

+                return;

+        if(ssel->userptr!=NULL) {

+                ssel->sizeuserptr=0;

+                free(ssel->userptr),ssel->userptr=NULL;

+        }

+        free(ssel),ssel=NULL;

+}

+

+

 int

 sselect_reset(sselect *paramssel)

 {

@@ -243,15 +264,21 @@ sselect_reset(sselect *paramssel)

         ssel->numfd=0;

         FD_ZERO(&(ssel->readresult));

         FD_ZERO(&(ssel->writeresult));

+        memset(ssel->userptr,0,sizeof(void *)*ssel->sizeuserptr);

         return(0);

 }

 int

-sselect_addread(sselect *paramssel, int fd)

+sselect_addread(sselect *paramssel, int fd, void *userptr)

 {

         _sselect *ssel=(_sselect *)paramssel;

         if(ssel==NULL || fd<0 || FD_ISSET(fd,&(ssel->readset)))

                 return(-1);

+        if(userptr!=NULL) {

+                if(sselect_adduserptr(ssel, fd, userptr)!=0)

+                        return(-1);

+        } else

+                sselect_clearuserptr(ssel,fd);

         FD_SET(fd,&(ssel->readset));

         if(fd>ssel->maxfd)

                 ssel->maxfd=fd;

@@ -261,11 +288,16 @@ sselect_addread(sselect *paramssel, int fd)

 int

-sselect_addwrite(sselect *paramssel, int fd)

+sselect_addwrite(sselect *paramssel, int fd, void *userptr)

 {

         _sselect *ssel=(_sselect *)paramssel;

         if(ssel==NULL || fd<0 || FD_ISSET(fd,&(ssel->writeset)))

                 return(-1);

+        if(userptr!=NULL) {

+                if(sselect_adduserptr(ssel, fd, userptr)!=0)

+                        return(-1);

+        } else

+                sselect_clearuserptr(ssel,fd);

         FD_SET(fd,&(ssel->writeset));

         if(fd>ssel->maxfd)

                 ssel->maxfd=fd;

@@ -386,6 +418,15 @@ sselect_getwritefiltered(sselect *paramssel, fd_set *filter, int *fds, int sizef

         return(n);

 }

+void *

+sselect_getuserptr(sselect *paramssel, int fd)

+{

+        _sselect *ssel=(_sselect *)paramssel;

+        if(ssel==NULL || fd<0 || fd>=ssel->sizeuserptr)

+                return(NULL);

+        return(ssel->userptr[fd]);

+}

+

 /* aux functions */

 void

@@ -408,3 +449,34 @@ sock_setunsafe(int fd)

         setsockopt(fd,SOL_SOCKET,SO_LINGER,(void *)&ltime,sizeof(ltime));

 }

+/* local functions */

+static int

+sselect_adduserptr(_sselect *ssel, int fd, void *userptr)

+{

+        if(ssel==NULL || fd<0)

+                return(-1);

+        if(ssel->sizeuserptr<(fd+1)) {

+                void **newptr;

+                int newsize;

+                newsize=(fd+USERPTRBLOCKSIZE)/USERPTRBLOCKSIZE;

+                newsize*=USERPTRBLOCKSIZE;

+                if((newptr=realloc(ssel->userptr,sizeof(void *)*newsize))==NULL)

+                        return(-1);

+                ssel->userptr=newptr;

+                memset(ssel->userptr+ssel->sizeuserptr,sizeof(void *)*(newsize-ssel->sizeuserptr),0);

+        }

+        ssel->userptr[fd]=userptr;

+        return(0);

+}

+

+static int

+sselect_clearuserptr(_sselect *ssel, int fd)

+{

+        if(ssel==NULL || fd<0)

+                return(-1);

+        if(ssel->sizeuserptr<(fd+1))

+                return(0);

+        ssel->userptr[fd]=NULL;

+        return(0);

+}

+

@@ -33,14 +33,16 @@ int sock_queued(int fd);

 int sock_setblocking(int fd, int block);

 sselect *sselect_init(void);

+void sselect_free(sselect *ssel);

 int sselect_reset(sselect *ssel);

-int sselect_addread(sselect *ssel, int fd);

-int sselect_addwrite(sselect *ssel, int fd);

+int sselect_addread(sselect *ssel, int fd, void *userptr);

+int sselect_addwrite(sselect *ssel, int fd, void *userptr);

 int sselect_delread(sselect *ssel, int fd);

 int sselect_delwrite(sselect *ssel, int fd);

 int sselect_wait(sselect *ssel, int ms);

 int sselect_getread(sselect *ssel, int *fds, int sizefds);

 int sselect_getwrite(sselect *ssel, int *fds, int sizefds);

+void *sselect_getuserptr(sselect *ssel, int fd);

 /* advanced sselect functions */

 int sselect_getreadfiltered(sselect *ssel, fd_set *filter, int *fds, int sizefds);