Update of /usr/cvsroot/asterisk
In directory mongoose.digium.com:/tmp/cvs-serv14998

Modified Files:
        manager.c 
Log Message:
Fix manager bug (can't destroy a session while a thread is using it!)


Index: manager.c
===================================================================
RCS file: /usr/cvsroot/asterisk/manager.c,v
retrieving revision 1.114
retrieving revision 1.115
diff -u -d -r1.114 -r1.115
--- manager.c   28 Sep 2005 23:10:13 -0000      1.114
+++ manager.c   29 Sep 2005 20:37:01 -0000      1.115
@@ -1326,8 +1326,11 @@
        do {
                res = poll(fds, 1, -1);
                if (res < 0) {
-                       if (errno == EINTR)
+                       if (errno == EINTR) {
+                               if (s->dead)
+                                       return -1;
                                continue;
+                       }
                        ast_log(LOG_WARNING, "Select returned error: %s\n", 
strerror(errno));
                        return -1;
                } else if (res > 0) {
@@ -1435,7 +1438,7 @@
                s->next = sessions;
                sessions = s;
                ast_mutex_unlock(&sessionlock);
-               if (ast_pthread_create(&t, &attr, session_do, s))
+               if (ast_pthread_create(&s->t, &attr, session_do, s))
                        destroy_session(s);
        }
        pthread_attr_destroy(&attr);
@@ -1468,13 +1471,11 @@
        struct mansession *s;
        char tmp[4096];
        va_list ap;
-       struct mansession *next, *prev = NULL;
 
        ast_mutex_lock(&sessionlock);
        s = sessions;
        while(s) {
-               next = s->next;
-               if (((s->readperm & category) == category) && ((s->send_events 
& category) == category) ) {
+               if (((s->readperm & category) == category) && ((s->send_events 
& category) == category)) {
                        ast_mutex_lock(&s->__lock);
                        ast_cli(s->fd, "Event: %s\r\n", event);
                        ast_cli(s->fd, "Privilege: %s\r\n", 
authority_to_str(category, tmp, sizeof(tmp)));
@@ -1486,20 +1487,12 @@
                                append_event(s, tmp);
                        } else if (ast_carefulwrite(s->fd,tmp,strlen(tmp),100) 
< 0) {
                                ast_log(LOG_WARNING, "Disconnecting slow 
manager session!\n");
-                               /* Unlink from list */
-                               if (prev)
-                                       prev->next = next;
-                               else
-                                       sessions = next;
-                               ast_mutex_unlock(&s->__lock);
-                               free_session(s);
-                               s = next;
-                               continue;
+                               s->dead = 1;
+                               pthread_kill(s->t, SIGURG);
                        }
                        ast_mutex_unlock(&s->__lock);
                }
-               prev = s;
-               s = next;
+               s = s->next;
        }
        ast_mutex_unlock(&sessionlock);
        return 0;

_______________________________________________
Asterisk-Cvs mailing list
[email protected]
http://lists.digium.com/mailman/listinfo/asterisk-cvs

Reply via email to