[질문] poll 함수에서 OUT 이벤트 사용과 관련하여 ..

아래와 같이 폴을 이용하여 소켓에 이벤트 체킹을 해보았습니다.

그런데, 문제는 저의 예상과 달리,

소켓 버퍼가 꽉 차 있는데도, 폴의 OUT 체크에서 쓰기 가능으로 나타납니다.

그 결과 write에서 EAGAIN 과 함께 리소스 템포랠리 언어베일러블 이 납니다.

솔라리스 5.7에서 테스트 해보았고요,

이것이 폴만의 문제인지, 제 소스의 문제인지..
셀렉트로 바꾸면 잘 돌아갈지 궁금합니다.

     18 int
     19 polling(int timeout, d4g_hash_t *map)
     20 {
     21         int i, j, r, n;
     22         d4g_hash_iter_t *items;
     23         struct pollfd *pollfds;
     24 
     25         //printf("poll :\n");
     26         if (map == NULL) {
     27                 map = socket_map;
     28         }
     29         if (map == NULL)
     30                 return (0);
     31 
     32         /* make to reallor or ..something like that */
     33         n = d4g_hash_get_nelem(map);
     34 
     35         //printf("connected [%d]\n", n);
     36         pollfds = (struct pollfd *)calloc(n, sizeof(struct pollfd));
     37         if (pollfds == NULL) {
     38                 //perror("calloc failed\n");
     39                 exit (1);
     40         }
     41 
     42         /* race condition */
     43         for (items = d4g_hash_begin(map), i = 0;
     44                 items != NULL;
     45                 items = d4g_hash_iter_next(items), i++) {
     46 
     47                 //printf("[total:%d >= i:%d]\n", n,i);
     48 
     49                 pollfds[i].fd = ((sb_cham_t *)items->data)->socket->fd;
     50                 pollfds[i].events = 0;
     51                 pollfds[i].revents = 0;
     52
     53                 if (readable(((sb_cham_t *)items->data))) {
     54                         pollfds[i].events |= POLLIN;
     55                         //printf("Poll in oring[%d]\n", i);
     56                 }
     57 
     58                 if (writable(((sb_cham_t *)items->data))) {
     59                         //pollfds[i].events |= POLLWRNORM; 
     60                         pollfds[i].events |= POLLOUT;
     61                         //printf("Poll out oring[%d]\n", i);
     62                 }
     63         }
     64 
     65         /* i can be i - 1 */
     66         r = poll(pollfds, n, timeout);
     67         if (r < 0) { /* crictical error */
     68                 free(pollfds);
     69                 exit (0);
     70         }
     71 
     72         for (j = 0; j < n ; j++)
     73                 if (pollfds[j].revents & POLLIN) {
     74                         items = d4g_hash_lookup(map, &(pollfds[j].fd));
     75                         if (items == NULL)
     76                                 continue;
     77                         handle_read_event(((sb_cham_t *)items->data));
     78                 }
     79 
     80 
     81         for (j = 0; j < n ; j++)
     82                 //if (pollfds[j].revents & POLLWRNORM) {
     83                 if (pollfds[j].revents & POLLOUT) {
     84                         items = d4g_hash_lookup(map, &(pollfds[j].fd));
     85                         if (items == NULL)
     86                                 continue;
     87                         handle_write_event(((sb_cham_t *)items->data));
     88                 }
     89 
     90         free(pollfds);
     91         return (0);
     92 }