]> xenbits.xensource.com Git - people/vhanquez/xen-unstable.git/commitdiff
xenstore: set read_thread stacksize
authorSimon Rowe <simon.rowe@eu.citrix.com>
Thu, 7 Jun 2012 17:23:00 +0000 (18:23 +0100)
committerSimon Rowe <simon.rowe@eu.citrix.com>
Thu, 7 Jun 2012 17:23:00 +0000 (18:23 +0100)
xs_watch() creates a thread to wake watchers using default attributes. The
stacksize can be quite large (8 MB on Linux), applications that link against
xenstore end up having a larger memory footprint than necessary.

Signed-off-by: Simon Rowe <simon.rowe@eu.citrix.com>
Acked-by: Ian Jackson <ian.jackson@eu.citrix.com>
Committed-by: Ian Jackson <ian.jackson@eu.citrix.com>
tools/xenstore/xs.c

index e12a4a3ca0eddaf466b69b9adb6988a0eadef8f4..b756f8402a174092fae2a1aed1490952b76ca458 100644 (file)
@@ -702,21 +702,36 @@ bool xs_watch(struct xs_handle *h, const char *path, const char *token)
        struct iovec iov[2];
 
 #ifdef USE_PTHREAD
+#define READ_THREAD_STACKSIZE (16 * 1024)
+
        /* We dynamically create a reader thread on demand. */
        mutex_lock(&h->request_mutex);
        if (!h->read_thr_exists) {
                sigset_t set, old_set;
+               pthread_attr_t attr;
+
+               if (pthread_attr_init(&attr) != 0) {
+                       mutex_unlock(&h->request_mutex);
+                       return false;
+               }
+               if (pthread_attr_setstacksize(&attr, READ_THREAD_STACKSIZE) != 0) {
+                       pthread_attr_destroy(&attr);
+                       mutex_unlock(&h->request_mutex);
+                       return false;
+               }
 
                sigfillset(&set);
                pthread_sigmask(SIG_SETMASK, &set, &old_set);
 
-               if (pthread_create(&h->read_thr, NULL, read_thread, h) != 0) {
+               if (pthread_create(&h->read_thr, &attr, read_thread, h) != 0) {
                        pthread_sigmask(SIG_SETMASK, &old_set, NULL);
+                       pthread_attr_destroy(&attr);
                        mutex_unlock(&h->request_mutex);
                        return false;
                }
                h->read_thr_exists = 1;
                pthread_sigmask(SIG_SETMASK, &old_set, NULL);
+               pthread_attr_destroy(&attr);
        }
        mutex_unlock(&h->request_mutex);
 #endif