infopipe_bar done
[monky] / src / conky.c
index 6048ece..0f5560c 100644 (file)
@@ -34,6 +34,9 @@
 #define MAIL_FILE "$MAIL"
 #define MAX_IF_BLOCK_DEPTH 5
 
+/* #define SIGNAL_BLOCKING */
+#undef SIGNAL_BLOCKING
+
 #ifdef X11
 
 /* alignments */
@@ -83,7 +86,6 @@ struct font_list *fonts = NULL;
 
 static void set_font();
 
-
 int addfont(const char *data_in)
 {
        if (font_count > MAX_FONTS) {
@@ -224,6 +226,7 @@ static int gap_x, gap_y;
 
 /* border */
 static int draw_borders;
+static int draw_graph_borders;
 static int stippled_borders;
 
 static int draw_shades, draw_outline;
@@ -239,6 +242,7 @@ static int set_transparent = 0;
 #ifdef OWN_WINDOW
 static int own_window = 0;
 static int background_colour = 0;
+static char wm_class_name[256];
 /* fixed size/pos is set if wm/user changes them */
 static int fixed_size = 0, fixed_pos = 0;
 #endif
@@ -257,6 +261,11 @@ int no_buffers;
 /* pad percentages to decimals? */
 static int pad_percents = 0;
 
+#ifdef TCP_PORT_MONITOR
+tcp_port_monitor_collection_args_t     tcp_port_monitor_collection_args;
+tcp_port_monitor_args_t                tcp_port_monitor_args;
+#endif
+
 /* Text that is shown */
 static char original_text[] =
     "$nodename - $sysname $kernel on $machine\n"
@@ -303,6 +312,7 @@ static int blockstart[MAX_IF_BLOCK_DEPTH];
 
 int check_mount(char *s)
 {
+#if defined(__linux__)
        int ret = 0;
        FILE *mtab = fopen("/etc/mtab", "r");
        if (mtab) {
@@ -319,11 +329,22 @@ int check_mount(char *s)
                ERR("Could not open mtab");
        }
        return ret;
+#elif defined(__FreeBSD__)
+       struct statfs *mntbuf;
+       int i, mntsize;
+
+       mntsize = getmntinfo(&mntbuf, MNT_NOWAIT);
+       for (i = mntsize - 1; i >= 0; i--)
+               if (strcmp(mntbuf[i].f_mntonname, s) == 0)
+                       return 1;
+
+       return 0;
+#endif
 }
 
 
 #ifdef X11
-static inline int calc_text_width(const char *s, unsigned int l)
+static inline int calc_text_width(const char *s, int l)
 {
 #ifdef XFT
        if (use_xft) {
@@ -844,7 +865,7 @@ enum text_object_type {
        OBJ_upspeedgraph,
        OBJ_uptime,
        OBJ_uptime_short,
-#ifdef __FreeBSD__
+#if defined(__FreeBSD__) && (defined(i386) || defined(__i386__))
        OBJ_apm_adapter,
        OBJ_apm_battery_time,
        OBJ_apm_battery_life,
@@ -858,6 +879,8 @@ enum text_object_type {
        OBJ_mpd_title,
        OBJ_mpd_artist,
        OBJ_mpd_album,
+       OBJ_mpd_random,
+       OBJ_mpd_repeat,
        OBJ_mpd_vol,
        OBJ_mpd_bitrate,
        OBJ_mpd_status,
@@ -866,8 +889,37 @@ enum text_object_type {
        OBJ_mpd_bar,
        OBJ_mpd_elapsed,
        OBJ_mpd_length,
+       OBJ_mpd_track,
        OBJ_mpd_percent,
 #endif
+#ifdef BMPX
+       OBJ_bmpx_title,
+       OBJ_bmpx_artist,
+       OBJ_bmpx_album,
+       OBJ_bmpx_track,
+       OBJ_bmpx_uri,
+       OBJ_bmpx_bitrate,
+#endif
+#ifdef INFOPIPE
+       OBJ_infopipe_protocol,
+       OBJ_infopipe_version,
+       OBJ_infopipe_status,
+       OBJ_infopipe_playlist_tunes,
+       OBJ_infopipe_playlist_currtune,
+       OBJ_infopipe_usec_position,
+       OBJ_infopipe_position,
+       OBJ_infopipe_usec_time,
+       OBJ_infopipe_time,
+       OBJ_infopipe_bitrate,
+       OBJ_infopipe_frequency,
+       OBJ_infopipe_channels,
+       OBJ_infopipe_title,
+       OBJ_infopipe_file,
+       OBJ_infopipe_bar,
+#endif
+#ifdef TCP_PORT_MONITOR
+       OBJ_tcp_portmon,
+#endif
 };
 
 struct text_object {
@@ -929,11 +981,25 @@ struct text_object {
                struct {
                        int a, b;
                } pair;         /* 2 */
+#ifdef TCP_PORT_MONITOR
+               struct {
+                       in_port_t  port_range_begin;  /* starting port to monitor */
+                       in_port_t  port_range_end;    /* ending port to monitor */
+                       int        item;              /* enum value from libtcp-portmon.h, e.g. COUNT, REMOTEIP, etc. */
+                       int        connection_index;  /* 0 to n-1 connections. */
+               } tcp_port_monitor;
+#endif
        } data;
 };
 
+struct text_object_list {
+  unsigned int text_object_count;
+  struct text_object *text_objects;
+};
+
 static unsigned int text_object_count;
 static struct text_object *text_objects;
+static void generate_text_internal(char *p, int p_max_size, struct text_object *objs, unsigned int object_count, struct information *cur);
 
 pthread_mutex_t mutex1 = PTHREAD_MUTEX_INITIALIZER;
 
@@ -956,86 +1022,116 @@ void *threaded_exec( struct text_object *obj ) {
        return NULL;
 }
 
-/* new_text_object() allocates a new zeroed text_object */
-static struct text_object *new_text_object()
+static struct text_object *new_text_object_internal()
 {
-       text_object_count++;
-       text_objects = (struct text_object *) realloc(text_objects,
-                                                     sizeof(struct
-                                                            text_object) *
-                                                     text_object_count);
-       memset(&text_objects[text_object_count - 1], 0,
-              sizeof(struct text_object));
-
-       return &text_objects[text_object_count - 1];
+  struct text_object *obj = malloc(sizeof(struct text_object));
+  memset(obj, 0, sizeof(struct text_object));    
+  return obj;
 }
 
-static void free_text_objects()
+#ifdef MLDONKEY
+void ml_cleanup()
+{
+       if (mlconfig.mldonkey_hostname) {
+               free(mlconfig.mldonkey_hostname);
+               mlconfig.mldonkey_hostname = NULL;
+       }
+}
+#endif
+
+static void free_text_objects(unsigned int count, struct text_object *objs)
 {
        unsigned int i;
-       for (i = 0; i < text_object_count; i++) {
-               switch (text_objects[i].type) {
+       for (i = 0; i < count; i++) {
+           switch (objs[i].type) {
                case OBJ_acpitemp:
-                       close(text_objects[i].data.i);
+                       close(objs[i].data.i);
                        break;
                case OBJ_acpitempf:
-                       close(text_objects[i].data.i);
+                       close(objs[i].data.i);
                        break;
                case OBJ_i2c:
-                       close(text_objects[i].data.i2c.fd);
+                       close(objs[i].data.i2c.fd);
                        break;
                case OBJ_time:
+                       free(objs[i].data.s);
+                       break;
                case OBJ_utime:
                case OBJ_if_existing:
                case OBJ_if_mounted:
                case OBJ_if_running:
-                       free(text_objects[i].data.ifblock.s);
+                       free(objs[i].data.ifblock.s);
+                       break;
+               case OBJ_tail:
+                       free(objs[i].data.tail.logfile);
+                       free(objs[i].data.tail.buffer);
                        break;
-               case OBJ_text:
-               case OBJ_font:
-                       free(text_objects[i].data.s);
+               case OBJ_text: case OBJ_font:
+                       free(objs[i].data.s);
                        break;
                case OBJ_exec:
-                       free(text_objects[i].data.s);
+                       free(objs[i].data.s);
                        break;
                case OBJ_execbar:
-                       free(text_objects[i].data.s);
+                       free(objs[i].data.s);
                        break;
                case OBJ_execgraph:
-                       free(text_objects[i].data.s);
+                       free(objs[i].data.s);
                        break;
 /*             case OBJ_execibar:
-                       free(text_objects[i].data.s);
+                       free(objs[i].data.s);
                        break;
                case OBJ_execigraph:
-                       free(text_objects[i].data.s);
+                       free(objs[i].data.s);
                        break;*/
 #ifdef MPD
                case OBJ_mpd_title:
                case OBJ_mpd_artist:
                case OBJ_mpd_album:
+               case OBJ_mpd_random:
+               case OBJ_mpd_repeat:
+               case OBJ_mpd_track:
                case OBJ_mpd_status:
                case OBJ_mpd_host:
 #endif
+#ifdef BMPX
+               case OBJ_bmpx_title:
+               case OBJ_bmpx_artist:
+               case OBJ_bmpx_album:
+               case OBJ_bmpx_track:
+               case OBJ_bmpx_uri:
+               case OBJ_bmpx_bitrate:
+#endif
                case OBJ_pre_exec:
                case OBJ_battery:
-                       free(text_objects[i].data.s);
+                       free(objs[i].data.s);
                        break;
 
                case OBJ_execi:
-                       free(text_objects[i].data.execi.cmd);
-                       free(text_objects[i].data.execi.buffer);
+                       free(objs[i].data.execi.cmd);
+                       free(objs[i].data.execi.buffer);
                        break;
                case OBJ_texeci:
-                       free(text_objects[i].data.execi.cmd);
-                       free(text_objects[i].data.execi.buffer);
+                       free(objs[i].data.execi.cmd);
+                       free(objs[i].data.execi.buffer);
+                       break;
+               case OBJ_top:
+                       if (info.first_process) {
+                               free_all_processes();
+                               info.first_process = NULL;
+                       }
+                       break;
+               case OBJ_top_mem:
+                       if (info.first_process) {
+                               free_all_processes();
+                               info.first_process = NULL;
+                       }
                        break;
                }
        }
-
-       free(text_objects);
-       text_objects = NULL;
-       text_object_count = 0;
+       free(objs);
+       //text_objects = NULL;
+       //text_object_count = 0;
 }
 
 void scan_mixer_bar(const char *arg, int *a, int *w, int *h)
@@ -1052,10 +1148,12 @@ void scan_mixer_bar(const char *arg, int *a, int *w, int *h)
        }
 }
 
+
 /* construct_text_object() creates a new text_object */
-static void construct_text_object(const char *s, const char *arg)
+static struct text_object *construct_text_object(const char *s, const char *arg)
 {
-       struct text_object *obj = new_text_object();
+    //struct text_object *obj = new_text_object();
+    struct text_object *obj = new_text_object_internal();
 
 #define OBJ(a, n) if (strcmp(s, #a) == 0) { obj->type = OBJ_##a; need_mask |= (1 << n); {
 #define END ; } } else
@@ -1204,9 +1302,9 @@ if (s[0] == '#') {
                obj->type = OBJ_text;
                snprintf(buf, 256, "${%s}", s);
                obj->data.s = strdup(buf);
-                   } else {
-                           obj->data.execi.cmd = strdup(arg + n);
-                   }
+       } else {
+               obj->data.execi.cmd = strdup(arg + n);
+       }
        END OBJ(execi, 0) unsigned int n;
 
        if (!arg
@@ -1297,7 +1395,7 @@ if (s[0] == '#') {
                ERR("i2c needs arguments");
                obj->type = OBJ_text;
                //obj->data.s = strdup("${i2c}");
-               return;
+               return NULL;
        }
 
        if (sscanf(arg, "%63s %63s %d", buf1, buf2, &n) != 3) {
@@ -1322,7 +1420,7 @@ if (s[0] == '#') {
                ERR("top needs arguments");
                obj->type = OBJ_text;
                //obj->data.s = strdup("${top}");
-               return;
+               return NULL;
        }
        if (sscanf(arg, "%63s %i", buf, &n) == 2) {
                if (strcmp(buf, "name") == 0) {
@@ -1335,18 +1433,18 @@ if (s[0] == '#') {
                        obj->data.top.type = TOP_MEM;
                } else {
                        ERR("invalid arg for top");
-                       return;
+                       return NULL;
                }
                if (n < 1 || n > 10) {
                        CRIT_ERR("invalid arg for top");
-                       return;
+                       return NULL;
                } else {
                        obj->data.top.num = n - 1;
                        top_cpu = 1;
                }
        } else {
                ERR("invalid args given for top");
-               return;
+               return NULL;
        }
        END OBJ(top_mem, INFO_TOP)
        char buf[64];
@@ -1355,7 +1453,7 @@ if (s[0] == '#') {
                ERR("top_mem needs arguments");
                obj->type = OBJ_text;
                obj->data.s = strdup("${top_mem}");
-               return;
+               return NULL;
        }
        if (sscanf(arg, "%63s %i", buf, &n) == 2) {
                if (strcmp(buf, "name") == 0) {
@@ -1368,18 +1466,18 @@ if (s[0] == '#') {
                        obj->data.top.type = TOP_MEM;
                } else {
                        ERR("invalid arg for top");
-                       return;
+                       return NULL;
                }
                if (n < 1 || n > 10) {
                        CRIT_ERR("invalid arg for top");
-                       return;
+                       return NULL;
                } else {
                        obj->data.top.num = n - 1;
                        top_mem = 1;
                }
        } else {
                ERR("invalid args given for top");
-               return;
+               return NULL;
        }
        END OBJ(addr, INFO_NET)
                if(arg) {
@@ -1402,16 +1500,16 @@ if (s[0] == '#') {
                ERR("tail needs arguments");
                obj->type = OBJ_text;
                obj->data.s = strdup("${tail}");
-               return;
+               return NULL;
        }
        if (sscanf(arg, "%63s %i %i", buf, &n1, &n2) == 2) {
                if (n1 < 1 || n1 > 30) {
                        CRIT_ERR("invalid arg for tail, number of lines must be between 1 and 30");
-                       return;
+                       return NULL;
                } else {
-                       FILE *fp;
-                       fp = fopen(buf, "rt");
-                       if (fp != NULL) {
+                       FILE *fp = NULL;
+                       fp = fopen(buf, "r");
+                       if (fp) {
                                obj->data.tail.logfile =
                                    malloc(TEXT_BUFFER_SIZE);
                                strcpy(obj->data.tail.logfile, buf);
@@ -1428,14 +1526,14 @@ if (s[0] == '#') {
                if (n1 < 1 || n1 > 30) {
                        CRIT_ERR
                            ("invalid arg for tail, number of lines must be between 1 and 30");
-                       return;
+                       return NULL;
                } else if (n2 < 1 || n2 < update_interval) {
                        CRIT_ERR
                            ("invalid arg for tail, interval must be greater than 0 and Conky's interval");
-                       return;
+                       return NULL;
                } else {
                        FILE *fp;
-                       fp = fopen(buf, "rt");
+                       fp = fopen(buf, "r");
                        if (fp != NULL) {
                                obj->data.tail.logfile =
                                    malloc(TEXT_BUFFER_SIZE);
@@ -1452,7 +1550,7 @@ if (s[0] == '#') {
 
        else {
                ERR("invalid args given for tail");
-               return;
+               return NULL;
        }
        obj->data.tail.buffer = malloc(TEXT_BUFFER_SIZE * 20); /* asumming all else worked */
        END OBJ(head, 0)
@@ -1462,15 +1560,15 @@ if (s[0] == '#') {
                ERR("head needs arguments");
                obj->type = OBJ_text;
                obj->data.s = strdup("${head}");
-               return;
+               return NULL;
        }
        if (sscanf(arg, "%63s %i %i", buf, &n1, &n2) == 2) {
                if (n1 < 1 || n1 > 30) {
                        CRIT_ERR("invalid arg for head, number of lines must be between 1 and 30");
-                       return;
+                       return NULL;
                } else {
                        FILE *fp;
-                       fp = fopen(buf, "rt");
+                       fp = fopen(buf, "r");
                        if (fp != NULL) {
                                obj->data.tail.logfile =
                                                malloc(TEXT_BUFFER_SIZE);
@@ -1488,14 +1586,14 @@ if (s[0] == '#') {
                if (n1 < 1 || n1 > 30) {
                        CRIT_ERR
                                        ("invalid arg for head, number of lines must be between 1 and 30");
-                       return;
+                       return NULL;
                } else if (n2 < 1 || n2 < update_interval) {
                        CRIT_ERR
                                        ("invalid arg for head, interval must be greater than 0 and Conky's interval");
-                       return;
+                       return NULL;
                } else {
                        FILE *fp;
-                       fp = fopen(buf, "rt");
+                       fp = fopen(buf, "r");
                        if (fp != NULL) {
                                obj->data.tail.logfile =
                                                malloc(TEXT_BUFFER_SIZE);
@@ -1512,7 +1610,7 @@ if (s[0] == '#') {
 
        else {
                ERR("invalid args given for head");
-               return;
+               return NULL;
        }
        obj->data.tail.buffer = malloc(TEXT_BUFFER_SIZE * 20); /* asumming all else worked */
        END OBJ(loadavg, INFO_LOADAVG) int a = 1, b = 2, c = 3, r = 3;
@@ -1686,8 +1784,8 @@ int a = stippled_borders, b = 1;
        }
        END OBJ(uptime_short, INFO_UPTIME) END OBJ(uptime, INFO_UPTIME) END
            OBJ(adt746xcpu, 0) END OBJ(adt746xfan, 0) END
-#ifdef __FreeBSD__
-       OBJ(apm_adapter, 0) END
+#if defined(__FreeBSD__) && (defined(i386) || defined(__i386__))
+        OBJ(apm_adapter, 0) END
        OBJ(apm_battery_life, 0) END
        OBJ(apm_battery_time, 0) END
 #endif /* __FreeBSD__ */
@@ -1699,16 +1797,139 @@ int a = stippled_borders, b = 1;
 #ifdef MPD
         OBJ(mpd_artist, INFO_MPD)
        END OBJ(mpd_title, INFO_MPD)
+       END OBJ(mpd_random, INFO_MPD)
+       END OBJ(mpd_repeat, INFO_MPD)
        END OBJ(mpd_elapsed, INFO_MPD)
        END OBJ(mpd_length, INFO_MPD)
+       END OBJ(mpd_track, INFO_MPD)
        END OBJ(mpd_percent, INFO_MPD)
        END OBJ(mpd_album, INFO_MPD) END OBJ(mpd_vol,
                                             INFO_MPD) END OBJ(mpd_bitrate,
                                                               INFO_MPD)
-       END OBJ(mpd_status, INFO_MPD) END OBJ(mpd_bar, INFO_MPD)
+       END OBJ(mpd_status, INFO_MPD)
+        END OBJ(mpd_bar, INFO_MPD)
         (void) scan_bar(arg, &obj->data.pair.a, &obj->data.pair.b);
        END
 #endif
+#ifdef BMPX
+       OBJ(bmpx_title, INFO_BMPX)
+       END
+       OBJ(bmpx_artist, INFO_BMPX)
+       END
+       OBJ(bmpx_album, INFO_BMPX)
+       END
+       OBJ(bmpx_track, INFO_BMPX)
+       END
+       OBJ(bmpx_uri, INFO_BMPX)
+       END
+       OBJ(bmpx_bitrate, INFO_BMPX)
+       END
+#endif
+#ifdef INFOPIPE
+       OBJ(infopipe_protocol, INFO_INFOPIPE) END
+       OBJ(infopipe_version, INFO_INFOPIPE) END
+       OBJ(infopipe_status, INFO_INFOPIPE) END
+       OBJ(infopipe_playlist_tunes, INFO_INFOPIPE) END
+       OBJ(infopipe_playlist_currtune, INFO_INFOPIPE) END
+       OBJ(infopipe_usec_position, INFO_INFOPIPE) END
+       OBJ(infopipe_position, INFO_INFOPIPE) END
+       OBJ(infopipe_usec_time, INFO_INFOPIPE) END
+       OBJ(infopipe_time, INFO_INFOPIPE) END
+       OBJ(infopipe_bitrate, INFO_INFOPIPE) END
+       OBJ(infopipe_frequency, INFO_INFOPIPE) END
+       OBJ(infopipe_channels, INFO_INFOPIPE) END
+       OBJ(infopipe_title, INFO_INFOPIPE) END
+       OBJ(infopipe_file, INFO_INFOPIPE) END
+       OBJ(infopipe_bar, INFO_INFOPIPE) 
+           (void) scan_bar(arg, &obj->a, &obj->b);
+       END
+#endif
+#ifdef TCP_PORT_MONITOR
+       OBJ(tcp_portmon, INFO_TCP_PORT_MONITOR) 
+               int argc, port_begin, port_end, item, connection_index;
+               char itembuf[32];
+               memset(itembuf,0,sizeof(itembuf));
+               connection_index=0;
+               /* massive argument checking */
+               if (!arg) {
+                       CRIT_ERR("tcp_portmon: needs arguments");
+               }
+               argc=sscanf(arg, "%d %d %31s %d", &port_begin, &port_end, itembuf, &connection_index);
+               if ( (argc != 3) && (argc != 4) ) 
+               {
+                       CRIT_ERR("tcp_portmon: requires 3 or 4 arguments");
+               }
+               if ( (port_begin<1) || (port_begin>65535) || (port_end<1) || (port_end>65535) )
+               {
+                       CRIT_ERR("tcp_portmon: port values must be from 1 to 65535");
+               }
+               if ( port_begin > port_end )
+               {
+                       CRIT_ERR("tcp_portmon: starting port must be <= ending port");
+               }
+               if ( strncmp(itembuf,"count",31) == 0 )
+                       item=COUNT;
+               else if ( strncmp(itembuf,"rip",31) == 0 )
+                       item=REMOTEIP;
+               else if ( strncmp(itembuf,"rhost",31) == 0 )
+                       item=REMOTEHOST;
+               else if ( strncmp(itembuf,"rport",31) == 0 )
+                       item=REMOTEPORT;
+               else if ( strncmp(itembuf,"lip",31) == 0 )
+                       item=LOCALIP;
+               else if ( strncmp(itembuf,"lhost",31) == 0 )
+                       item=LOCALHOST;
+               else if ( strncmp(itembuf,"lport",31) == 0 )
+                       item=LOCALPORT;
+               else if ( strncmp(itembuf,"lservice",31) == 0 )
+                       item=LOCALSERVICE;
+               else
+               {
+                       CRIT_ERR("tcp_portmon: invalid item specified"); 
+               }
+               if ( (argc==3) && (item!=COUNT) )
+               {
+                       CRIT_ERR("tcp_portmon: 3 argument form valid only for \"count\" item");
+               }
+               if ( (argc==4) && (connection_index<0) )
+               {
+                       CRIT_ERR("tcp_portmon: connection index must be non-negative");
+               }
+               /* ok, args looks good. save the text object data */
+               obj->data.tcp_port_monitor.port_range_begin = (in_addr_t)port_begin;
+               obj->data.tcp_port_monitor.port_range_end = (in_addr_t)port_end;
+               obj->data.tcp_port_monitor.item = item;
+               obj->data.tcp_port_monitor.connection_index = connection_index;
+
+               /* if the port monitor collection hasn't been created, we must create it */
+               if ( !info.p_tcp_port_monitor_collection )
+               {
+                       info.p_tcp_port_monitor_collection = 
+                               create_tcp_port_monitor_collection( &tcp_port_monitor_collection_args );
+                       if ( !info.p_tcp_port_monitor_collection )
+                       {
+                               CRIT_ERR("tcp_portmon: unable to create port monitor collection");
+                       }
+               }
+
+               /* if a port monitor for this port does not exist, create one and add it to the collection */
+               if ( find_tcp_port_monitor( info.p_tcp_port_monitor_collection, port_begin, port_end ) == NULL )
+               {
+                       tcp_port_monitor_t * p_monitor = 
+                               create_tcp_port_monitor( port_begin, port_end, &tcp_port_monitor_args );
+                       if ( !p_monitor )
+                       {
+                               CRIT_ERR("tcp_portmon: unable to create port monitor");
+                       }
+                       /* add the newly created monitor to the collection */
+                       if ( insert_tcp_port_monitor_into_collection( info.p_tcp_port_monitor_collection,
+                                                                     p_monitor ) != 0 )
+                       {
+                               CRIT_ERR("tcp_portmon: unable to add port monitor to collection");
+                       }
+               }
+       END
+#endif
        {
                char buf[256];
                ERR("unknown variable %s", s);
@@ -1717,43 +1938,48 @@ int a = stippled_borders, b = 1;
                obj->data.s = strdup(buf);
        }
 #undef OBJ
+
+       return obj;
 }
 
-/* append_text() appends text to last text_object if it's text, if it isn't
- * it creates a new text_object */
-static void append_text(const char *s)
+static struct text_object *create_plain_text(const char *s)
 {
-       struct text_object *obj;
-
-       if (s == NULL || *s == '\0')
-               return;
+  struct text_object *obj;
 
-       obj = text_object_count ? &text_objects[text_object_count - 1] : 0;
+  if (s == NULL || *s == '\0') {
+      return NULL;
+  }
+  
+  obj = new_text_object_internal();
 
-       /* create a new text object? */
-       if (!obj || obj->type != OBJ_text) {
-               obj = new_text_object();
-               obj->type = OBJ_text;
-               obj->data.s = strdup(s);
-       } else {
-               /* append */
-               obj->data.s = (char *) realloc(obj->data.s,
-                                              strlen(obj->data.s) +
-                                              strlen(s) + 1);
-               strcat(obj->data.s, s);
-       }
+  obj->type = OBJ_text;
+  obj->data.s = strdup(s);
+  return obj;
 }
 
-static void extract_variable_text(const char *p)
+static struct text_object_list *extract_variable_text_internal(const char *p)
 {
-       const char *s = p;
-
-       free_text_objects();
-
+    struct text_object_list *retval;
+    struct text_object *obj;
+    const char *s = p;
+    
+    retval = malloc(sizeof(struct text_object_list));
+    memset(retval, 0, sizeof(struct text_object_list));
+    retval->text_object_count = 0;
+       
        while (*p) {
                if (*p == '$') {
                        *(char *) p = '\0';
-                       append_text(s);
+                       obj = create_plain_text(s);
+                       if(obj != NULL) {
+                           // allocate memory for the object
+                           retval->text_objects = realloc(retval->text_objects, 
+                                                          sizeof(struct text_object) * (retval->text_object_count+1));
+                           // assign the new object to the end of the list.
+                           memcpy(&retval->text_objects[retval->text_object_count++],
+                                  obj, sizeof(struct text_object));
+                           free(obj);
+                       }
                        *(char *) p = '$';
                        p++;
                        s = p;
@@ -1812,44 +2038,85 @@ static void extract_variable_text(const char *p)
                                                p++;
                                        }
 
-                                       construct_text_object(buf, arg);
+                                       // create new object
+                                       obj = construct_text_object(buf, arg);
+                                       if(obj != NULL) {
+                                           // allocate memory for the object
+                                           retval->text_objects = realloc(retval->text_objects, 
+                                                                          sizeof(struct text_object) * (retval->text_object_count+1));
+                                           // assign the new object to the end of the list.
+                                           memcpy(&retval->text_objects[retval->text_object_count++],
+                                                  obj, sizeof(struct text_object));
+                                           free(obj);
+                                       }
                                }
                                continue;
-                       } else
-                               append_text("$");
+                       } else {
+                           obj = create_plain_text("$");
+                           if(obj != NULL) {
+                               // allocate memory for the object
+                               retval->text_objects = realloc(retval->text_objects, 
+                                                              sizeof(struct text_object) * (retval->text_object_count+1));
+                               // assign the new object to the end of the list.
+                               memcpy(&retval->text_objects[retval->text_object_count++],
+                                      obj, sizeof(struct text_object));
+                               free(obj);
+                           }
+                       }
                }
-
                p++;
        }
-       append_text(s);
+       obj = create_plain_text(s);
+       if(obj != NULL) {
+           // allocate memory for the object
+           retval->text_objects = realloc(retval->text_objects,
+                                          sizeof(struct text_object) * (retval->text_object_count+1));
+           // assign the new object to the end of the list.
+           memcpy(&retval->text_objects[retval->text_object_count++],
+                  obj, sizeof(struct text_object));
+           free(obj);
+       }
+
        if (blockdepth) {
                ERR("one or more $endif's are missing");
        }
-}
 
-double current_update_time, last_update_time;
+       return retval;
+}
 
-static void generate_text()
+static void extract_variable_text(const char *p)
 {
-       unsigned int i, n;
-       struct information *cur = &info;
-       char *p;
+  struct text_object_list *list;
 
-       special_count = 0;
+  free_text_objects(text_object_count, text_objects);
+  text_object_count = 0;
+  text_objects = NULL;
 
-       /* update info */
+#ifdef MLDONKEY        
+  ml_cleanup();
+#endif /* MLDONKEY */
+         
+  list = extract_variable_text_internal(p);
+  text_objects = list->text_objects;
+  text_object_count = list->text_object_count;
 
-       current_update_time = get_time();
+  free(list);
 
-       update_stuff(cur);
+  return;
+}
 
-       /* generate text */
+void parse_conky_vars(char * text, char * p, struct information *cur) { 
+       struct text_object_list *object_list = extract_variable_text_internal(text);
+       generate_text_internal(p, P_MAX_SIZE, object_list->text_objects, object_list->text_object_count, cur);
+       free(object_list);
+}
 
-       n = TEXT_BUFFER_SIZE * 4 - 2;
-       p = text_buffer;
+static void generate_text_internal(char *p, int p_max_size, struct text_object *objs, unsigned int object_count, struct information *cur)
+{
+    unsigned int i;
 
-       for (i = 0; i < text_object_count; i++) {
-               struct text_object *obj = &text_objects[i];
+       for (i = 0; i < object_count; i++) {
+               struct text_object *obj = &objs[i];
 
 #define OBJ(a) break; case OBJ_##a:
 
@@ -1862,7 +2129,7 @@ static void generate_text()
                        OBJ(acpitemp) {
                                /* does anyone have decimals in acpi temperature? */
                                if (!use_spacer)
-                                       snprintf(p, n, "%d", (int)
+                                       snprintf(p, p_max_size, "%d", (int)
                                                        get_acpi_temperature(obj->
                                                                        data.
                                                                        i));
@@ -1875,7 +2142,7 @@ static void generate_text()
                        OBJ(acpitempf) {
                                /* does anyone have decimals in acpi temperature? */
                                if (!use_spacer)
-                                       snprintf(p, n, "%d", (int)
+                                       snprintf(p, p_max_size, "%d", (int)
                                                        ((get_acpi_temperature(obj->
                                                                        data.
                                                                        i)+ 40) * 9.0 / 5 - 40));
@@ -1886,39 +2153,42 @@ static void generate_text()
                                                                        i)+ 40) * 9.0 / 5 - 40));
                        }
                        OBJ(freq) {
-                               snprintf(p, n, "%.0f", get_freq());
+                               get_freq(p, p_max_size, "%.0f", 1); /* pk */
                        }
                        OBJ(freq_g) {
-                               float ghz = (float)(get_freq()/1000);
-                               //printf("%f\n", ghz);
-                               snprintf(p, n, "%'.2f", ghz);
+                               get_freq(p, p_max_size, "%'.2f", 1000); /* pk */
                        }
                        OBJ(freq_dyn) {
-                               snprintf(p, n, "%.0f", get_freq_dynamic());
+                               if (use_spacer) {
+                                       get_freq_dynamic(p, 6, "%.0f     ", 1 ); /* pk */
+                               } else {
+                                       get_freq_dynamic(p, p_max_size, "%.0f", 1 ); /* pk */
+                               }
                        }
                        OBJ(freq_dyn_g) {
-                               float ghz = (float)(get_freq_dynamic()/1000);
-                               snprintf(p, n, "%'.2f", ghz);
+                               if (use_spacer) {
+                                       get_freq_dynamic(p, 6, "%'.2f     ", 1000); /* pk */
+                               } else {
+                                       get_freq_dynamic(p, p_max_size, "%'.2f", 1000); /* pk */
+                               }
                        }
                        OBJ(adt746xcpu) {
-                               snprintf(p, n, "%s", get_adt746x_cpu());
+                               get_adt746x_cpu(p, p_max_size); /* pk */
                        }
                        OBJ(adt746xfan) {
-                               snprintf(p, n, "%s", get_adt746x_fan());
+                               get_adt746x_fan(p, p_max_size); /* pk */
                        }
                        OBJ(acpifan) {
-                               snprintf(p, n, "%s", get_acpi_fan());
+                               get_acpi_fan(p, p_max_size);  /* pk */
                        }
                        OBJ(acpiacadapter) {
-                               snprintf(p, n, "%s",
-                                        get_acpi_ac_adapter());
+                               get_acpi_ac_adapter(p, p_max_size); /* pk */
                        }
                        OBJ(battery) {
-                               get_battery_stuff(p, n, obj->data.s);
+                               get_battery_stuff(p, p_max_size, obj->data.s);
                        }
                        OBJ(buffers) {
-                               human_readable(cur->buffers * 1024, p,
-                                              255);
+                               human_readable(cur->buffers * 1024, p, 255);
                        }
                        OBJ(cached) {
                                human_readable(cur->cached * 1024, p, 255);
@@ -1929,7 +2199,7 @@ static void generate_text()
                                        CRIT_ERR("attempting to use more CPUs then you have!");
                                }
                                if (!use_spacer)
-                                       snprintf(p, n, "%*d", pad_percents,
+                                       snprintf(p, p_max_size, "%*d", pad_percents,
                                                (int) round_to_int(cur->cpu_usage[obj->data.cpu_index] *
                                                        100.0));
                                else
@@ -1954,31 +2224,31 @@ static void generate_text()
                        }
 #if defined(__linux__)
                        OBJ(i8k_version) {
-                               snprintf(p, n, "%s", i8k.version);
+                               snprintf(p, p_max_size, "%s", i8k.version);
                        }
                        OBJ(i8k_bios) {
-                               snprintf(p, n, "%s", i8k.bios);
+                               snprintf(p, p_max_size, "%s", i8k.bios);
                        }
                        OBJ(i8k_serial) { 
-                               snprintf(p, n, "%s", i8k.serial);
+                               snprintf(p, p_max_size, "%s", i8k.serial);
                        }
                        OBJ(i8k_cpu_temp) { 
-                               snprintf(p, n, "%s", i8k.cpu_temp);
+                               snprintf(p, p_max_size, "%s", i8k.cpu_temp);
                        }
                        OBJ(i8k_cpu_tempf) { 
                                int cpu_temp;
                                sscanf(i8k.cpu_temp, "%d", &cpu_temp);
-                               snprintf(p, n, "%.1f", cpu_temp*(9.0/5.0)+32.0);
+                               snprintf(p, p_max_size, "%.1f", cpu_temp*(9.0/5.0)+32.0);
                        }
                        OBJ(i8k_left_fan_status) { 
                                int left_fan_status;
                                sscanf(i8k.left_fan_status, "%d", &left_fan_status);
                                if(left_fan_status == 0) {
-                                       snprintf(p, n,"off");
+                                       snprintf(p, p_max_size,"off");
                                } if(left_fan_status == 1) {
-                                       snprintf(p, n, "low");
+                                       snprintf(p, p_max_size, "low");
                                }       if(left_fan_status == 2) {
-                                       snprintf(p, n, "high");
+                                       snprintf(p, p_max_size, "high");
                                }
 
                        }
@@ -1986,32 +2256,32 @@ static void generate_text()
                                int right_fan_status;
                                sscanf(i8k.right_fan_status, "%d", &right_fan_status);
                                if(right_fan_status == 0) {
-                                       snprintf(p, n,"off");
+                                       snprintf(p, p_max_size,"off");
                                } if(right_fan_status == 1) {
-                                       snprintf(p, n, "low");
+                                       snprintf(p, p_max_size, "low");
                                }       if(right_fan_status == 2) {
-                                       snprintf(p, n, "high");
+                                       snprintf(p, p_max_size, "high");
                                }
                        }
                        OBJ(i8k_left_fan_rpm) { 
-                               snprintf(p, n, "%s", i8k.left_fan_rpm);
+                               snprintf(p, p_max_size, "%s", i8k.left_fan_rpm);
                        }
                        OBJ(i8k_right_fan_rpm) { 
-                               snprintf(p, n, "%s", i8k.right_fan_rpm);
+                               snprintf(p, p_max_size, "%s", i8k.right_fan_rpm);
                        }
                        OBJ(i8k_ac_status) { 
                                int ac_status;
                                sscanf(i8k.ac_status, "%d", &ac_status);
                                if(ac_status == -1) {
-                                       snprintf(p, n,"disabled (read i8k docs)");
+                                       snprintf(p, p_max_size,"disabled (read i8k docs)");
                                } if(ac_status == 0) {
-                                       snprintf(p, n, "off");
+                                       snprintf(p, p_max_size, "off");
                                }       if(ac_status == 1) {
-                                       snprintf(p, n, "on");
+                                       snprintf(p, p_max_size, "on");
                                }
                        }
                        OBJ(i8k_buttons_status) {
-                               snprintf(p, n, "%s", i8k.buttons_status); 
+                               snprintf(p, p_max_size, "%s", i8k.buttons_status); 
 
                        }
 #endif /* __linux__ */
@@ -2024,15 +2294,15 @@ static void generate_text()
                        OBJ(diskio) {
                                if (!use_spacer) {
                                        if (diskio_value > 1024*1024) {
-                                               snprintf(p, n, "%.1fG",
+                                               snprintf(p, p_max_size, "%.1fG",
                                                                (double)diskio_value/1024/1024);
                                        } else if (diskio_value > 1024) {
-                                               snprintf(p, n, "%.1fM",
+                                               snprintf(p, p_max_size, "%.1fM",
                                                                (double)diskio_value/1024);
                                        } else if (diskio_value > 0) {
-                                               snprintf(p, n, "%dK", diskio_value);
+                                               snprintf(p, p_max_size, "%dK", diskio_value);
                                        } else {
-                                               snprintf(p, n, "%d", diskio_value);
+                                               snprintf(p, p_max_size, "%d", diskio_value);
                                        }
                                } else {
                                        if (diskio_value > 1024*1024) {
@@ -2056,7 +2326,7 @@ static void generate_text()
        
                        OBJ(downspeed) {
                                if (!use_spacer) {
-                                       snprintf(p, n, "%d",
+                                       snprintf(p, p_max_size, "%d",
                                                 (int) (obj->data.net->
                                                        recv_speed /
                                                        1024));
@@ -2068,7 +2338,7 @@ static void generate_text()
                        }
                        OBJ(downspeedf) {
                                if (!use_spacer)
-                                       snprintf(p, n, "%.1f",
+                                       snprintf(p, p_max_size, "%.1f",
                                                 obj->data.net->
                                                 recv_speed / 1024.0);
                                else
@@ -2097,7 +2367,7 @@ static void generate_text()
                        }
 #ifdef HAVE_POPEN
                        OBJ(addr) {
-                               snprintf(p, n, "%u.%u.%u.%u",
+                               snprintf(p, p_max_size, "%u.%u.%u.%u",
                                         obj->data.net->addr.
                                         sa_data[2] & 255,
                                         obj->data.net->addr.
@@ -2109,30 +2379,30 @@ static void generate_text()
 
                        }
                        OBJ(linkstatus) {
-                               snprintf(p, n, "%d",
+                               snprintf(p, p_max_size, "%d",
                                         obj->data.net->linkstatus);
                        }
 
                        OBJ(exec) {
-                               char *p2 = p;
                                FILE *fp = popen(obj->data.s, "r");
-                               int n2 = fread(p, 1, n, fp);
+                               int length = fread(p, 1, p_max_size, fp);
                                (void) pclose(fp);
 
-                               p[n2] = '\0';
-                               if (n2 && p[n2 - 1] == '\n')
-                                       p[n2 - 1] = '\0';
-
-                               while (*p2) {
-                                       if (*p2 == '\001')
-                                               *p2 = ' ';
-                                       p2++;
-                               }
+                               /*output[length] = '\0';
+                               if (length > 0 && output[length - 1] == '\n') {
+                                       output[length - 1] = '\0';
+                               }*/
+                                       p[length] = '\0';
+                                       if (length > 0 && p[length - 1] == '\n') {
+                                               p[length - 1] = '\0';
+                                       }
+                                   
+                               //parse_conky_vars(output, p, cur);
                        }
                        OBJ(execbar) {
                                char *p2 = p;
                                FILE *fp = popen(obj->data.s, "r");
-                               int n2 = fread(p, 1, n, fp);
+                               int n2 = fread(p, 1, p_max_size, fp);
                                (void) pclose(fp);
 
                                p[n2] = '\0';
@@ -2159,7 +2429,7 @@ static void generate_text()
                        OBJ(execgraph) {
                                char *p2 = p;
                                FILE *fp = popen(obj->data.s, "r");
-                               int n2 = fread(p, 1, n, fp);
+                               int n2 = fread(p, 1, p_max_size, fp);
                                (void) pclose(fp);
 
                                p[n2] = '\0';
@@ -2184,12 +2454,12 @@ static void generate_text()
 
                        }
                        OBJ(execibar) {
-                               if (current_update_time - obj->data.execi.last_update < obj->data.execi.interval) {
+                               if (current_update_time - obj->data.execi.last_update < obj->data.execi.interval) {
                                        new_bar(p, 0, 4, (int) obj->f);
                                } else {
                                        char *p2 = p;
                                        FILE *fp = popen(obj->data.execi.cmd, "r");
-                                       int n2 = fread(p, 1, n, fp);
+                                       int n2 = fread(p, 1, p_max_size, fp);
                                        (void) pclose(fp);
                                        p[n2] = '\0';
                                        if (n2 && p[n2 - 1] == '\n')
@@ -2215,12 +2485,12 @@ static void generate_text()
                                }
                        }
                        OBJ(execigraph) {
-                               if (current_update_time - obj->data.execi.last_update < obj->data.execi.interval) {
+                               if (current_update_time - obj->data.execi.last_update < obj->data.execi.interval) {
                                        new_graph(p, 0, 25, obj->c, obj->d, (int) (obj->f), 100, 0);
                                } else {
                                        char *p2 = p;
                                        FILE *fp = popen(obj->data.execi.cmd, "r");
-                                       int n2 = fread(p, 1, n, fp);
+                                       int n2 = fread(p, 1, p_max_size, fp);
                                        (void) pclose(fp);
                                        p[n2] = '\0';
                                        if (n2 && p[n2 - 1] == '\n')
@@ -2247,56 +2517,44 @@ static void generate_text()
 
                        }
                        OBJ(execi) {
-                               if (current_update_time -
-                                   obj->data.execi.last_update <
-                                   obj->data.execi.interval) {
-                                       snprintf(p, n, "%s",
-                                                obj->data.execi.buffer);
+                               if (current_update_time - obj->data.execi.last_update < obj->data.execi.interval || obj->data.execi.interval == 0) {
+                                       snprintf(p, p_max_size, "%s", obj->data.execi.buffer);
                                } else {
-                                       char *p2 = obj->data.execi.buffer;
-                                       FILE *fp =
-                                           popen(obj->data.execi.cmd,
-                                                 "r");
-                                       int n2 =
-                                           fread(p2, 1, TEXT_BUFFER_SIZE,
-                                                 fp);
+                                       char *output = obj->data.execi.buffer;
+                                       FILE *fp = popen(obj->data.execi.cmd, "r");
+                                       //int length = fread(output, 1, TEXT_BUFFER_SIZE, fp);
+                                       int length = fread(output, 1, TEXT_BUFFER_SIZE, fp);
                                        (void) pclose(fp);
-
-                                       p2[n2] = '\0';
-                                       if (n2 && p2[n2 - 1] == '\n')
-                                               p2[n2 - 1] = '\0';
-
-                                       while (*p2) {
-                                               if (*p2 == '\001')
-                                                       *p2 = ' ';
-                                               p2++;
+                                   
+                                       output[length] = '\0';
+                                       if (length > 0 && output[length - 1] == '\n') {
+                                               output[length - 1] = '\0';
                                        }
-
-                                       snprintf(p, n, "%s",
-                                                obj->data.execi.buffer);
-
-                                       obj->data.execi.last_update =
-                                           current_update_time;
+                                       obj->data.execi.last_update = current_update_time;
+                                       snprintf(p, p_max_size, "%s", output);
                                }
+                               //parse_conky_vars(output, p, cur);
                        }
                        OBJ(texeci) {
                                static int running = 0;
-                               if (current_update_time - obj->data.execi.last_update < obj->data.execi.interval) {
-                                       snprintf(p, n, "%s", obj->data.execi.buffer);
+                               if (current_update_time - obj->data.execi.last_update < obj->data.execi.interval) {
+                                       snprintf(p, p_max_size, "%s", obj->data.execi.buffer);
                                } else {
                                        static pthread_t execthread;
+                                       if (running) {
+                                               pthread_join( execthread, NULL);
+                                               running = 0;
+                                       }
                                        if (!running) {
                                                running = 1;
                                                pthread_create( &execthread, NULL, (void*)threaded_exec, (void*) obj);
                                                pthread_mutex_lock( &mutex1 );
                                                obj->data.execi.last_update = current_update_time;
                                                pthread_mutex_unlock( &mutex1 );
-                                       } else {
-                                               pthread_join( execthread, NULL);
-                                               running = 0;
                                        }
-                                       snprintf(p, n, "%s", obj->data.execi.buffer);
+                                       snprintf(p, p_max_size, "%s", obj->data.execi.buffer);
                                }
+                               //parse_conky_vars(obj->data.execi.buffer, p, cur);
                        }
 #endif
                        OBJ(fs_bar) {
@@ -2327,7 +2585,7 @@ static void generate_text()
                        OBJ(fs_free_perc) {
                                if (obj->data.fs != NULL) {
                                        if (obj->data.fs->size)
-                                               snprintf(p, n, "%*d",
+                                               snprintf(p, p_max_size, "%*d",
                                                         pad_percents,
                                                         (int) ((obj->data.
                                                                 fs->
@@ -2336,7 +2594,7 @@ static void generate_text()
                                                                obj->data.
                                                                fs->size));
                                        else
-                                               snprintf(p, n, "0");
+                                               snprintf(p, p_max_size, "0");
                                }
                        }
                        OBJ(fs_size) {
@@ -2347,7 +2605,7 @@ static void generate_text()
                        OBJ(fs_used) {
                                if (obj->data.fs != NULL)
                                        human_readable(obj->data.fs->size -
-                                                      obj->data.fs->avail,
+                                                      (obj->data.fs->free ? obj->data.fs->free :obj->data.fs->avail),
                                                       p, 255);
                        }
                        OBJ(fs_bar_free) {
@@ -2382,14 +2640,14 @@ static void generate_text()
                                                                 fs->
                                                                 size)));
                                        else
-                                               snprintf(p, n, "0");
+                                               snprintf(p, p_max_size, "0");
                                }
                        }
                        OBJ(loadavg) {
                                float *v = info.loadavg;
 
                                if (obj->data.loadavg[2])
-                                       snprintf(p, n, "%.2f %.2f %.2f",
+                                       snprintf(p, p_max_size, "%.2f %.2f %.2f",
                                                 v[obj->data.loadavg[0] -
                                                   1],
                                                 v[obj->data.loadavg[1] -
@@ -2397,13 +2655,13 @@ static void generate_text()
                                                 v[obj->data.loadavg[2] -
                                                   1]);
                                else if (obj->data.loadavg[1])
-                                       snprintf(p, n, "%.2f %.2f",
+                                       snprintf(p, p_max_size, "%.2f %.2f",
                                                 v[obj->data.loadavg[0] -
                                                   1],
                                                 v[obj->data.loadavg[1] -
                                                   1]);
                                else if (obj->data.loadavg[0])
-                                       snprintf(p, n, "%.2f",
+                                       snprintf(p, p_max_size, "%.2f",
                                                 v[obj->data.loadavg[0] -
                                                   1]);
                        }
@@ -2425,9 +2683,9 @@ static void generate_text()
                                                 obj->data.i2c.type);
 
                                if (r >= 100.0 || r == 0)
-                                       snprintf(p, n, "%d", (int) r);
+                                       snprintf(p, p_max_size, "%d", (int) r);
                                else
-                                       snprintf(p, n, "%.1f", r);
+                                       snprintf(p, p_max_size, "%.1f", r);
                        }
                        OBJ(alignr) {
                                new_alignr(p, obj->data.i);
@@ -2462,10 +2720,10 @@ static void generate_text()
                                        if_jumped = 0;
                        }
                        OBJ(kernel) {
-                               snprintf(p, n, "%s", cur->uname_s.release);
+                               snprintf(p, p_max_size, "%s", cur->uname_s.release);
                        }
                        OBJ(machine) {
-                               snprintf(p, n, "%s", cur->uname_s.machine);
+                               snprintf(p, p_max_size, "%s", cur->uname_s.machine);
                        }
 
                        /* memory stuff */
@@ -2478,12 +2736,12 @@ static void generate_text()
                        OBJ(memperc) {
                                if (cur->memmax) {
                                        if (!use_spacer)
-                                               snprintf(p, n, "%*d",
+                                               snprintf(p, p_max_size, "%*lu",
                                                         pad_percents,
                                                         (cur->mem * 100) /
                                                         (cur->memmax));
                                        else
-                                               snprintf(p, 4, "%*d   ",
+                                               snprintf(p, 4, "%*lu   ",
                                                         pad_percents,
                                                         (cur->mem * 100) /
                                                         (cur->memmax));
@@ -2504,15 +2762,15 @@ static void generate_text()
                        }
                        /* mixer stuff */
                        OBJ(mixer) {
-                               snprintf(p, n, "%d",
+                               snprintf(p, p_max_size, "%d",
                                         mixer_get_avg(obj->data.l));
                        }
                        OBJ(mixerl) {
-                               snprintf(p, n, "%d",
+                               snprintf(p, p_max_size, "%d",
                                         mixer_get_left(obj->data.l));
                        }
                        OBJ(mixerr) {
-                               snprintf(p, n, "%d",
+                               snprintf(p, p_max_size, "%d",
                                         mixer_get_right(obj->data.l));
                        }
                        OBJ(mixerbar) {
@@ -2536,60 +2794,60 @@ static void generate_text()
 
                        /* mail stuff */
                        OBJ(mails) {
-                               snprintf(p, n, "%d", cur->mail_count);
+                               snprintf(p, p_max_size, "%d", cur->mail_count);
                        }
                        OBJ(new_mails) {
-                               snprintf(p, n, "%d", cur->new_mail_count);
+                               snprintf(p, p_max_size, "%d", cur->new_mail_count);
                        }
 #ifdef MLDONKEY
                        OBJ(ml_upload_counter) {
-                               snprintf(p, n, "%lld",
+                               snprintf(p, p_max_size, "%lld",
                                         mlinfo.upload_counter / 1048576);
                        }
                        OBJ(ml_download_counter) {
-                               snprintf(p, n, "%lld",
+                               snprintf(p, p_max_size, "%lld",
                                         mlinfo.download_counter /
                                         1048576);
                        }
                        OBJ(ml_nshared_files) {
-                               snprintf(p, n, "%i", mlinfo.nshared_files);
+                               snprintf(p, p_max_size, "%i", mlinfo.nshared_files);
                        }
                        OBJ(ml_shared_counter) {
-                               snprintf(p, n, "%lld",
+                               snprintf(p, p_max_size, "%lld",
                                         mlinfo.shared_counter / 1048576);
                        }
                        OBJ(ml_tcp_upload_rate) {
-                               snprintf(p, n, "%.2f",
+                               snprintf(p, p_max_size, "%.2f",
                                         (float) mlinfo.tcp_upload_rate /
                                         1024);
                        }
                        OBJ(ml_tcp_download_rate) {
-                               snprintf(p, n, "%.2f",
+                               snprintf(p, p_max_size, "%.2f",
                                         (float) mlinfo.tcp_download_rate /
                                         1024);
                        }
                        OBJ(ml_udp_upload_rate) {
-                               snprintf(p, n, "%.2f",
+                               snprintf(p, p_max_size, "%.2f",
                                         (float) mlinfo.udp_upload_rate /
                                         1024);
                        }
                        OBJ(ml_udp_download_rate) {
-                               snprintf(p, n, "%.2f",
+                               snprintf(p, p_max_size, "%.2f",
                                         (float) mlinfo.udp_download_rate /
                                         1024);
                        }
                        OBJ(ml_ndownloaded_files) {
-                               snprintf(p, n, "%i",
+                               snprintf(p, p_max_size, "%i",
                                         mlinfo.ndownloaded_files);
                        }
                        OBJ(ml_ndownloading_files) {
-                               snprintf(p, n, "%i",
+                               snprintf(p, p_max_size, "%i",
                                         mlinfo.ndownloading_files);
                        }
 #endif
 
                        OBJ(nodename) {
-                               snprintf(p, n, "%s",
+                               snprintf(p, p_max_size, "%s",
                                         cur->uname_s.nodename);
                        }
                        OBJ(outlinecolor) {
@@ -2597,21 +2855,21 @@ static void generate_text()
                        }
                        OBJ(processes) {
                                if (!use_spacer)
-                                       snprintf(p, n, "%d", cur->procs);
+                                       snprintf(p, p_max_size, "%hu", cur->procs);
                                else
-                                       snprintf(p, 5, "%d    ",
+                                       snprintf(p, 5, "%hu    ",
                                                 cur->procs);
                        }
                        OBJ(running_processes) {
                                if (!use_spacer)
-                                       snprintf(p, n, "%d",
+                                       snprintf(p, p_max_size, "%hu",
                                                 cur->run_procs);
                                else
-                                       snprintf(p, 3, "%d     ",
+                                       snprintf(p, 3, "%hu     ",
                                                 cur->run_procs);
                        }
                        OBJ(text) {
-                               snprintf(p, n, "%s", obj->data.s);
+                               snprintf(p, p_max_size, "%s", obj->data.s);
                        }
                        OBJ(shadecolor) {
                                new_bg(p, obj->data.l);
@@ -2632,13 +2890,13 @@ static void generate_text()
                                        strncpy(p, "No swap", 255);
                                } else {
                                        if (!use_spacer)
-                                               snprintf(p, 255, "%*u",
+                                               snprintf(p, 255, "%*lu",
                                                         pad_percents,
                                                         (cur->swap *
                                                          100) /
                                                         cur->swapmax);
                                        else
-                                               snprintf(p, 4, "%*u   ",
+                                               snprintf(p, 4, "%*lu   ",
                                                         pad_percents,
                                                         (cur->swap *
                                                          100) /
@@ -2652,18 +2910,18 @@ static void generate_text()
                                        (cur->swapmax) : 0);
                        }
                        OBJ(sysname) {
-                               snprintf(p, n, "%s", cur->uname_s.sysname);
+                               snprintf(p, p_max_size, "%s", cur->uname_s.sysname);
                        }
                        OBJ(time) {
                                time_t t = time(NULL);
                                struct tm *tm = localtime(&t);
                                setlocale(LC_TIME, "");
-                               strftime(p, n, obj->data.s, tm);
+                               strftime(p, p_max_size, obj->data.s, tm);
                        }
                        OBJ(utime) {
                                time_t t = time(NULL);
                                struct tm *tm = gmtime(&t);
-                               strftime(p, n, obj->data.s, tm);
+                               strftime(p, p_max_size, obj->data.s, tm);
                        }
                        OBJ(totaldown) {
                                human_readable(obj->data.net->recv, p,
@@ -2674,11 +2932,11 @@ static void generate_text()
                                               255);
                        }
                        OBJ(updates) {
-                               snprintf(p, n, "%d", total_updates);
+                               snprintf(p, p_max_size, "%d", total_updates);
                        }
                        OBJ(upspeed) {
                                if (!use_spacer)
-                                       snprintf(p, n, "%d",
+                                       snprintf(p, p_max_size, "%d",
                                                 (int) (obj->data.net->
                                                        trans_speed /
                                                        1024));
@@ -2690,7 +2948,7 @@ static void generate_text()
                        }
                        OBJ(upspeedf) {
                                if (!use_spacer)
-                                       snprintf(p, n, "%.1f",
+                                       snprintf(p, p_max_size, "%.1f",
                                                 obj->data.net->
                                                 trans_speed / 1024.0);
                                else
@@ -2706,33 +2964,33 @@ static void generate_text()
                                1024.0), obj->e, 1);
                        }
                        OBJ(uptime_short) {
-                               format_seconds_short(p, n,
+                               format_seconds_short(p, p_max_size,
                                                     (int) cur->uptime);
                        }
                        OBJ(uptime) {
-                               format_seconds(p, n, (int) cur->uptime);
+                               format_seconds(p, p_max_size, (int) cur->uptime);
                        }
 
-#ifdef __FreeBSD__
+#if defined(__FreeBSD__) && (defined(i386) || defined(__i386__))
                        OBJ(apm_adapter) {
-                               snprintf(p, n, "%s", get_apm_adapter());
+                               snprintf(p, p_max_size, "%s", get_apm_adapter());
                        }
                        OBJ(apm_battery_life) {
                                char    *msg;
                                msg = get_apm_battery_life();
-                               snprintf(p, n, "%s", msg);
+                               snprintf(p, p_max_size, "%s", msg);
                                free(msg);
                        }
                        OBJ(apm_battery_time) {
                                char    *msg;
                                msg = get_apm_battery_time();
-                               snprintf(p, n, "%s", msg);
+                               snprintf(p, p_max_size, "%s", msg);
                                free(msg);
                        }
 #endif /* __FreeBSD__ */
 #ifdef SETI
                        OBJ(seti_prog) {
-                               snprintf(p, n, "%.2f",
+                               snprintf(p, p_max_size, "%.2f",
                                         cur->seti_prog * 100.0f);
                        }
                        OBJ(seti_progbar) {
@@ -2741,28 +2999,37 @@ static void generate_text()
                                        (int) (cur->seti_prog * 255.0f));
                        }
                        OBJ(seti_credit) {
-                               snprintf(p, n, "%.0f", cur->seti_credit);
+                               snprintf(p, p_max_size, "%.0f", cur->seti_credit);
                        }
 #endif
 
 #ifdef MPD
                        OBJ(mpd_title) {
-                               snprintf(p, n, "%s", cur->mpd.title);
+                               snprintf(p, p_max_size, "%s", cur->mpd.title);
                        }
                        OBJ(mpd_artist) {
-                               snprintf(p, n, "%s", cur->mpd.artist);
+                               snprintf(p, p_max_size, "%s", cur->mpd.artist);
                        }
                        OBJ(mpd_album) {
-                               snprintf(p, n, "%s", cur->mpd.album);
+                               snprintf(p, p_max_size, "%s", cur->mpd.album);
+                       }
+                       OBJ(mpd_random) {
+                               snprintf(p, p_max_size, "%s", cur->mpd.random);
+                       }
+                       OBJ(mpd_repeat) {
+                               snprintf(p, p_max_size, "%s", cur->mpd.repeat);
+                       }
+                       OBJ(mpd_track) {
+                               snprintf(p, p_max_size, "%s", cur->mpd.track);
                        }
                        OBJ(mpd_vol) {
-                               snprintf(p, n, "%i", cur->mpd.volume);
+                               snprintf(p, p_max_size, "%i", cur->mpd.volume);
                        }
                        OBJ(mpd_bitrate) {
-                               snprintf(p, n, "%i", cur->mpd.bitrate);
+                               snprintf(p, p_max_size, "%i", cur->mpd.bitrate);
                        }
                        OBJ(mpd_status) {
-                               snprintf(p, n, "%s", cur->mpd.status);
+                               snprintf(p, p_max_size, "%s", cur->mpd.status);
                        }
                        OBJ(mpd_elapsed) {
                                int days = 0, hours = 0, minutes =
@@ -2782,14 +3049,14 @@ static void generate_text()
                                }
                                seconds = tmp;
                                if (days > 0)
-                                       snprintf(p, n, "%i days %i:%02i:%02i",
+                                       snprintf(p, p_max_size, "%i days %i:%02i:%02i",
                                                 days, hours, minutes,
                                                 seconds);
                                else if (hours > 0)
-                                       snprintf(p, n, "%i:%02i:%02i", hours,
+                                       snprintf(p, p_max_size, "%i:%02i:%02i", hours,
                                                 minutes, seconds);
                                else
-                                       snprintf(p, n, "%i:%02i", minutes,
+                                       snprintf(p, p_max_size, "%i:%02i", minutes,
                                                 seconds);
                        }
                        OBJ(mpd_length) {
@@ -2810,19 +3077,19 @@ static void generate_text()
                                }
                                seconds = tmp;
                                if (days > 0)
-                                       snprintf(p, n,
+                                       snprintf(p, p_max_size,
                                                 "%i days %i:%02i:%02i",
                                                 days, hours, minutes,
                                                 seconds);
                                else if (hours > 0)
-                                       snprintf(p, n, "%i:%02i:%02i", hours,
+                                       snprintf(p, p_max_size, "%i:%02i:%02i", hours,
                                                 minutes, seconds);
                                else
-                                       snprintf(p, n, "%i:%02i", minutes,
+                                       snprintf(p, p_max_size, "%i:%02i", minutes,
                                                 seconds);
                        }
                        OBJ(mpd_percent) {
-                               snprintf(p, n, "%2.0f",
+                               snprintf(p, p_max_size, "%2.0f",
                                         cur->mpd.progress * 100);
                        }
                        OBJ(mpd_bar) {
@@ -2832,6 +3099,76 @@ static void generate_text()
                                               255.0f));
                        }
 #endif
+#ifdef BMPX
+                       OBJ(bmpx_title) {
+                               snprintf(p, p_max_size, "%s", cur->bmpx.title);
+                       }
+                       OBJ(bmpx_artist) {
+                               snprintf(p, p_max_size, "%s", cur->bmpx.artist);
+                       }
+                       OBJ(bmpx_album) {
+                               snprintf(p, p_max_size, "%s", cur->bmpx.album);
+                       }
+                       OBJ(bmpx_uri) {
+                               snprintf(p, p_max_size, "%s", cur->bmpx.uri);
+                       }
+                       OBJ(bmpx_track) {
+                                snprintf(p, p_max_size, "%i", cur->bmpx.track);
+                       }
+                       OBJ(bmpx_bitrate) {
+                               snprintf(p, p_max_size, "%i", cur->bmpx.bitrate);
+                       }
+#endif
+#ifdef INFOPIPE
+                        OBJ(infopipe_protocol) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_PROTOCOL]);
+                       }
+                        OBJ(infopipe_version) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_VERSION]);
+                       }
+                        OBJ(infopipe_status) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_STATUS]);
+                       }
+                        OBJ(infopipe_playlist_tunes) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_PLAYLIST_TUNES]);
+                       }
+                        OBJ(infopipe_playlist_currtune) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_PLAYLIST_CURRTUNE]);
+                       }
+                        OBJ(infopipe_usec_position) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_USEC_POSITION]);
+                       }
+                        OBJ(infopipe_position) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_POSITION]);
+                       }
+                        OBJ(infopipe_usec_time) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_USEC_TIME]);
+                       }
+                        OBJ(infopipe_time) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_TIME]);
+                       }
+                        OBJ(infopipe_bitrate) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_BITRATE]);
+                       }
+                        OBJ(infopipe_frequency) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_FREQUENCY]);
+                       }
+                        OBJ(infopipe_channels) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_CHANNELS]);
+                       }
+                        OBJ(infopipe_title) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_TITLE]);
+                       }
+                        OBJ(infopipe_file) {
+                               snprintf(p, p_max_size, "%s", cur->infopipe.items[INFOPIPE_FILE]);
+                       }
+                       OBJ(infopipe_bar) {
+                               double progress;
+                               progress= atof(cur->infopipe.items[INFOPIPE_USEC_POSITION]) /
+                                         atof(cur->infopipe.items[INFOPIPE_USEC_TIME]);
+                               new_bar(p,obj->a,obj->b,(int)(progress*255.0f));
+                       }
+#endif
                        OBJ(top) {
                                if (obj->data.top.type == TOP_NAME
                                    && obj->data.top.num >= 0
@@ -2891,18 +3228,8 @@ static void generate_text()
                        }
 
 
-
-                       /*
-                        * I'm tired of everything being packed in
-                        * pee
-                        * poop
-                        */
-
-
                        OBJ(tail) {
-                               if (current_update_time -obj->data.tail.last_update < obj->data.tail.interval) {
-                                       snprintf(p, n, "%s", obj->data.tail.buffer);
-                               } else {
+                               if (current_update_time -obj->data.tail.last_update >= obj->data.tail.interval) {
                                        obj->data.tail.last_update = current_update_time;
                                        FILE *fp;
                                        int i;
@@ -2951,21 +3278,19 @@ static void generate_text()
                                                        if (obj->data.tail.buffer[strlen(obj->data.tail.buffer)-1] == '\n') {
                                                                obj->data.tail.buffer[strlen(obj->data.tail.buffer)-1] = '\0';
                                                        }
-                                                       snprintf(p, n, "%s", obj->data.tail.buffer);
 
                                                        freetail(freetmp);
-                                               }
-                                               else {
+                                               } else {
                                                        strcpy(obj->data.tail.buffer, "Logfile Empty");
-                                                       snprintf(p, n, "Logfile Empty");
-                                               }
-                                       }
-                               }
+                                               }  /* if readlines */
+                                       } /*  fp == NULL  */
+                               } /* if cur_upd_time >= */
+       
+                               //parse_conky_vars(obj->data.tail.buffer, p, cur);
+
                        }
                        OBJ(head) {
-                               if (current_update_time -obj->data.tail.last_update < obj->data.tail.interval) {
-                                       snprintf(p, n, "%s", obj->data.tail.buffer);
-                               } else {
+                               if (current_update_time -obj->data.tail.last_update >= obj->data.tail.interval) {
                                        obj->data.tail.last_update = current_update_time;
                                        FILE *fp;
                                        tailstring *head = NULL;
@@ -2974,8 +3299,7 @@ static void generate_text()
                                        fp = fopen(obj->data.tail.logfile, "rt");
                                        if (fp == NULL) {
                                                ERR("head logfile failed to open");
-                                       }
-                                       else {
+                                       } else {
                                                obj->data.tail.readlines = 0;
                                                while (fgets(obj->data.tail.buffer, TEXT_BUFFER_SIZE*20, fp) != NULL && obj->data.tail.readlines <= obj->data.tail.wantedlines) {
                                                        addtail(&head, obj->data.tail.buffer);
@@ -3001,15 +3325,39 @@ static void generate_text()
                                                        if (obj->data.tail.buffer[strlen(obj->data.tail.buffer)-1] == '\n') {
                                                                obj->data.tail.buffer[strlen(obj->data.tail.buffer)-1] = '\0';
                                                        }
-                                                       snprintf(p, n, "%s", obj->data.tail.buffer);
-                                               }
-                                               else {
+                                               } else {
                                                        strcpy(obj->data.tail.buffer, "Logfile Empty");
-                                                       snprintf(p, n, "Logfile Empty");
-                                               }
-                                       }
+                                               } /* if readlines > 0 */
+                                       } /* if fp == null */
+                               } /* cur_upd_time >= */
+
+                               //parse_conky_vars(obj->data.tail.buffer, p, cur);
+
+                       }
+#ifdef TCP_PORT_MONITOR
+                       OBJ(tcp_portmon)
+                       {
+                               /* grab a pointer to this port monitor */
+                               tcp_port_monitor_t * p_monitor = 
+                                       find_tcp_port_monitor( info.p_tcp_port_monitor_collection,
+                                                               obj->data.tcp_port_monitor.port_range_begin,
+                                                               obj->data.tcp_port_monitor.port_range_end );
+                               if ( !p_monitor ) {
+                                       snprintf(p, p_max_size, "monitor not found");
+                                       break;
+                               }
+
+                               /* now grab the text of interest */
+                               if ( peek_tcp_port_monitor( p_monitor, 
+                                                           obj->data.tcp_port_monitor.item, 
+                                                           obj->data.tcp_port_monitor.connection_index,
+                                                           p, p_max_size ) != 0 )
+                               {
+                                       snprintf(p, p_max_size, "monitor peek error");
+                                       break;
                                }
                        }
+#endif
 
                        break;
                }
@@ -3017,9 +3365,34 @@ static void generate_text()
                {
                        unsigned int a = strlen(p);
                        p += a;
-                       n -= a;
+                       p_max_size -= a;
                }
        }
+}
+
+
+double current_update_time, last_update_time;
+
+static void generate_text()
+{
+       struct information *cur = &info;
+       char *p;
+
+       special_count = 0;
+
+       /* update info */
+
+       current_update_time = get_time();
+
+       update_stuff(cur);
+
+       /* add things to the buffer */
+
+       /* generate text */
+
+       p = text_buffer;
+
+       generate_text_internal(p, P_MAX_SIZE, text_objects, text_object_count, cur);
 
        if (stuff_in_upper_case) {
                char *p;
@@ -3036,6 +3409,7 @@ static void generate_text()
        //free(p);
 }
 
+
 #ifdef X11
 static void set_font()
 {
@@ -3273,9 +3647,12 @@ static void draw_string(const char *s)
        width_of_s = get_string_width(s);
        if (out_to_console) {
                printf("%s\n", s);
+               fflush(stdout);   /* output immediately, don't buffer */
        }
        /* daemon_run(s);  the daemon can be called here, but we need to have a buffer in daemon_run() and we need to tell it when everything is ready to be sent */
-       strcpy(tmpstring1, s);
+       memset(tmpstring1,0,TEXT_BUFFER_SIZE);
+       memset(tmpstring2,0,TEXT_BUFFER_SIZE);
+       strncpy(tmpstring1, s, TEXT_BUFFER_SIZE-1);
        pos = 0;
        added = 0;
        char space[2];
@@ -3296,13 +3673,21 @@ static void draw_string(const char *s)
                        for (i2 = 0;
                             i2 < (8 - (1 + pos) % 8) && added <= max;
                             i2++) {
-                               tmpstring2[pos + i2] = ' ';
+                               /*
+                               if ( pos + i2 > TEXT_BUFFER_SIZE-1 )
+                                       fprintf(stderr,"buffer overrun detected\n");
+                               */
+                               tmpstring2[ MIN(pos + i2, TEXT_BUFFER_SIZE-1) ] = ' '; /* guard against overrun */
                                added++;
                        }
                        pos += i2;
                } else {
                        if (tmpstring1[i] != 9) {
-                               tmpstring2[pos] = tmpstring1[i];
+                               /*
+                               if ( pos > TEXT_BUFFER_SIZE-1 )
+                                        fprintf(stderr,"buffer overrun detected\n");
+                               */
+                               tmpstring2[ MIN(pos, TEXT_BUFFER_SIZE-1) ] = tmpstring1[i]; /* guard against overrun */
                                pos++;
                        }
                }
@@ -3531,7 +3916,7 @@ static void draw_line(char *s)
 
                        case BAR:
                                {
-                                       if (cur_x - maximum_width - text_start_x && maximum_width > 0) {
+                                       if (cur_x - text_start_x > maximum_width && maximum_width > 0) {
                                                break;
                                        }
                                        int h =
@@ -3587,7 +3972,7 @@ static void draw_line(char *s)
 
                        case GRAPH:
                        {
-                                       if (cur_x - maximum_width - text_start_x && maximum_width > 0) {
+                                       if (cur_x - text_start_x > maximum_width && maximum_width > 0) {
                                                break;
                                        }
                                        int h =
@@ -3609,15 +3994,10 @@ static void draw_line(char *s)
                                                w = text_start_x + text_width - cur_x - 1;
                                        if (w < 0)
                                                w = 0;
-                                       XSetLineAttributes(display,
-                                                          window.gc, 1,
-                                                          LineSolid,
-                                                          CapButt,
-                                                          JoinMiter);
-                                       XDrawRectangle(display,
-                                                      window.drawable,
-                                                      window.gc, cur_x,
-                                                      by, w, h);
+                                       if (draw_graph_borders) {
+                                               XSetLineAttributes(display, window.gc, 1, LineSolid, CapButt, JoinMiter);
+                                               XDrawRectangle(display,window.drawable, window.gc, cur_x, by, w, h);
+                                       }
                                        XSetLineAttributes(display,
                                                           window.gc, 1,
                                                           LineSolid,
@@ -3876,6 +4256,15 @@ static void update_text()
 
 static void main_loop()
 {
+#ifdef SIGNAL_BLOCKING
+       sigset_t  newmask, oldmask;
+
+       sigemptyset(&newmask);
+       sigaddset(&newmask,SIGINT);
+       sigaddset(&newmask,SIGTERM);
+       sigaddset(&newmask,SIGUSR1);
+#endif
+
 #ifdef X11
        Region region = XCreateRegion();
 #endif /* X11 */
@@ -3883,6 +4272,13 @@ static void main_loop()
        info.looped = 0;
        while (total_run_times == 0 || info.looped < total_run_times - 1) {
                info.looped++;
+
+#ifdef SIGNAL_BLOCKING
+               /* block signals.  we will inspect for pending signals later */
+               if (sigprocmask(SIG_BLOCK, &newmask, &oldmask) < 0)
+                       CRIT_ERR("unable to sigprocmask()");
+#endif
+
 #ifdef X11
                XFlush(display);
 
@@ -4103,23 +4499,68 @@ static void main_loop()
                }
 #endif /* X11 */
 
+#ifdef SIGNAL_BLOCKING
+               /* unblock signals of interest and let handler fly */
+               if (sigprocmask(SIG_SETMASK, &oldmask, NULL) < 0)
+                       CRIT_ERR("unable to sigprocmask()");
+#endif
+
+               switch(g_signal_pending) {
+               case SIGUSR1:
+                       {
+                       ERR("received SIGUSR1. reloading the config file.");
+                       reload_config();
+                       break;
+                       }
+               case SIGINT:
+               case SIGTERM:
+                       {
+                       ERR("received SIGINT or SIGTERM to terminate. bye!");
+                       clean_up();
+#ifdef X11
+                       XDestroyRegion(region);
+                       region = NULL;
+#endif /* X11 */
+                       return;  /* return from main_loop */
+                       /*break;*/
+                       }
+               default:
+                       {
+                       /* Reaching here means someone set a signal( SIGXXXX, signal_handler )
+                        * but didn't write any code to deal with it.   if you don't want to
+                        * handle a signal, don't set a handler on it in the first place. */
+                       if (g_signal_pending)
+                               ERR("ignoring signal (%d)", g_signal_pending);
+                       break;
+                       }
+               }
+               g_signal_pending=0;
+       
        }
+#ifdef X11
+       XDestroyRegion(region);
+       region = NULL;
+#endif /* X11 */
 }
 
 static void load_config_file(const char *);
 
-/* signal handler that reloads config file */
-static void reload_handler(int a)
+/* reload the config file */
+void reload_config(void)
 {
-       ERR("Conky: received signal %d, reloading config\n", a);
-
        if (current_config) {
                clear_fs_stats();
                load_config_file(current_config);
 #ifdef X11
                load_fonts();
                set_font();
+               XClearWindow(display, RootWindow(display, screen)); // clear the window first
+
 #endif /* X11 */
+#ifdef TCP_PORT_MONITOR
+               destroy_tcp_port_monitor_collection( info.p_tcp_port_monitor_collection );
+               info.p_tcp_port_monitor_collection = NULL; 
+#endif
                extract_variable_text(text);
                free(text);
                text = NULL;
@@ -4127,7 +4568,7 @@ static void reload_handler(int a)
        }
 }
 
-static void clean_up()
+void clean_up(void)
 {
 #ifdef X11
 #ifdef XDBE
@@ -4153,7 +4594,13 @@ static void clean_up()
        /* it is really pointless to free() memory at the end of program but ak|ra
         * wants me to do this */
 
-       free_text_objects();
+       free_text_objects(text_object_count, text_objects);
+       text_object_count = 0;
+       text_objects = NULL;
+
+#ifdef MLDONKEY        
+       ml_cleanup();
+#endif /* MLDONKEY */
 
        if (text != original_text)
                free(text);
@@ -4163,13 +4610,10 @@ static void clean_up()
 #ifdef SETI
        free(seti_dir);
 #endif
-}
-
-static void term_handler(int a)
-{
-       a = a;                  /* to get rid of warning */
-       clean_up();
-       exit(0);
+#ifdef TCP_PORT_MONITOR
+       destroy_tcp_port_monitor_collection( info.p_tcp_port_monitor_collection );
+       info.p_tcp_port_monitor_collection = NULL;
+#endif
 }
 
 static int string_to_bool(const char *s)
@@ -4234,8 +4678,9 @@ static void set_default_configurations(void)
        default_fg_color = WhitePixel(display, screen);
        default_bg_color = BlackPixel(display, screen);
        default_out_color = BlackPixel(display, screen);
-       draw_borders = 0;
        draw_shades = 1;
+       draw_borders = 0;
+       draw_graph_borders = 1;
        draw_outline = 0;
        set_first_font("6x10");
        gap_x = 5;
@@ -4245,6 +4690,7 @@ static void set_default_configurations(void)
        maximum_width = 0;
 #ifdef OWN_WINDOW
        own_window = 0;
+       strcpy(wm_class_name, "conky"); 
 #endif
        stippled_borders = 0;
        border_margin = 3;
@@ -4265,11 +4711,16 @@ static void set_default_configurations(void)
        update_interval = 10.0;
        stuff_in_upper_case = 0;
 #ifdef MLDONKEY
-       mlconfig.mldonkey_hostname = "127.0.0.1";
+       mlconfig.mldonkey_hostname = strdup("127.0.0.1");
        mlconfig.mldonkey_port = 4001;
        mlconfig.mldonkey_login = NULL;
        mlconfig.mldonkey_password = NULL;
 #endif
+
+#ifdef TCP_PORT_MONITOR
+       tcp_port_monitor_collection_args.min_port_monitors = MIN_PORT_MONITORS_DEFAULT;
+       tcp_port_monitor_args.min_port_monitor_connections = MIN_PORT_MONITOR_CONNECTIONS_DEFAULT;
+#endif
 }
 
 static void load_config_file(const char *f)
@@ -4279,8 +4730,7 @@ static void load_config_file(const char *f)
        FILE *fp;
 
        set_default_configurations();
-
-       fp = open_file(f, 0);
+       fp = fopen(f, "r");
        if (!fp)
                return;
 
@@ -4332,7 +4782,7 @@ static void load_config_file(const char *f)
 #define CONF2(a) if (strcasecmp(name, a) == 0)
 #define CONF(a) else CONF2(a)
 #define CONF3(a,b) \
-else if (strcasecmp(name, a) == 0 || strcasecmp(name, a) == 0)
+else if (strcasecmp(name, a) == 0 || strcasecmp(name, b) == 0)
 
 
 #ifdef X11
@@ -4454,6 +4904,9 @@ else if (strcasecmp(name, a) == 0 || strcasecmp(name, a) == 0)
                CONF("draw_borders") {
                        draw_borders = string_to_bool(value);
                }
+               CONF("draw_graph_borders") {
+                       draw_graph_borders = string_to_bool(value);
+               }
                CONF("draw_shades") {
                        draw_shades = string_to_bool(value);
                }
@@ -4473,12 +4926,10 @@ else if (strcasecmp(name, a) == 0 || strcasecmp(name, a) == 0)
                        use_xft = string_to_bool(value);
                }
                CONF("font") {
-                       if (!use_xft) {
-                               if (value) {
-                                       set_first_font(value);
-                               } else
-                                       CONF_ERR;
-                       }
+                       if (value) {
+                               set_first_font(value);
+                       } else
+                               CONF_ERR;
                }
                CONF("xftalpha") {
                        if (value && font_count >= 0)
@@ -4501,10 +4952,12 @@ else if (strcasecmp(name, a) == 0 || strcasecmp(name, a) == 0)
                }
                CONF("font") {
 #endif
-                       if (value) {
-                               set_first_font(value);
-                       } else
-                               CONF_ERR;
+                       if (use_xft) {
+                               if (value) {
+                                       set_first_font(value);
+                               } else
+                                       CONF_ERR;
+                       }
                }
                CONF("gap_x") {
                        if (value)
@@ -4603,6 +5056,10 @@ else if (strcasecmp(name, a) == 0 || strcasecmp(name, a) == 0)
                CONF("own_window") {
                        own_window = string_to_bool(value);
                }
+               CONF("wm_class_name") {
+                       strncpy(wm_class_name, value, sizeof(wm_class_name)-1);
+                       wm_class_name[sizeof(wm_class_name)-1] = 0;
+               }
                CONF("own_window_transparent") {
                        set_transparent = string_to_bool(value);
                }
@@ -4671,6 +5128,42 @@ else if (strcasecmp(name, a) == 0 || strcasecmp(name, a) == 0)
                        fclose(fp);
                        return;
                }
+#ifdef TCP_PORT_MONITOR
+               CONF("min_port_monitors") 
+               {
+                       if ( !value || 
+                            (sscanf(value, "%d", &tcp_port_monitor_collection_args.min_port_monitors) != 1) || 
+                            tcp_port_monitor_collection_args.min_port_monitors < 0 )
+                       {
+                               /* an error. use default, warn and continue. */
+                               tcp_port_monitor_collection_args.min_port_monitors = MIN_PORT_MONITORS_DEFAULT;
+                               CONF_ERR;
+                       }
+                       else if ( tcp_port_monitor_collection_args.min_port_monitors == 0 )
+                       {
+                               /* no error, just use default */
+                               tcp_port_monitor_collection_args.min_port_monitors = MIN_PORT_MONITORS_DEFAULT;
+                       }
+                       /* else tcp_port_monitor_collection_args.min_port_monitors > 0 as per config */
+               }
+               CONF("min_port_monitor_connections") 
+               {
+                       if ( !value || 
+                            (sscanf(value, "%d", &tcp_port_monitor_args.min_port_monitor_connections) != 1) 
+                            || tcp_port_monitor_args.min_port_monitor_connections < 0 )
+                       {
+                               /* an error. use default, warni and continue. */
+                               tcp_port_monitor_args.min_port_monitor_connections = MIN_PORT_MONITOR_CONNECTIONS_DEFAULT;
+                               CONF_ERR;
+                       }
+                       else if ( tcp_port_monitor_args.min_port_monitor_connections == 0 )
+                       {
+                               /* no error, just use default */
+                               tcp_port_monitor_args.min_port_monitor_connections = MIN_PORT_MONITOR_CONNECTIONS_DEFAULT;
+                       }
+                       /* else tcp_port_monitor_args.min_port_monitor_connections > 0 as per config */
+               }
+#endif
                else
                ERR("%s: %d: no such configuration: '%s'", f, line, name);
 
@@ -4698,6 +5191,16 @@ static const char *getopt_string = "vVdt:f:u:i:hc:w:x:y:a:"
 
 int main(int argc, char **argv)
 {
+       struct sigaction act, oact;
+
+       g_signal_pending=0;
+       memset(&info, 0, sizeof(info) );
+
+#ifdef TCP_PORT_MONITOR
+       tcp_port_monitor_collection_args.min_port_monitors = MIN_PORT_MONITORS_DEFAULT;
+       tcp_port_monitor_args.min_port_monitor_connections = MIN_PORT_MONITOR_CONNECTIONS_DEFAULT;
+#endif
+               
        /* handle command line parameters that don't change configs */
 #ifdef X11
        char *s;
@@ -4716,7 +5219,6 @@ int main(int argc, char **argv)
        }
        if (!setlocale(LC_CTYPE, "")) {
                ERR("Can't set the specified locale!\nCheck LANG, LC_CTYPE, LC_ALL.");
-               return 1;
        }
 #endif /* X11 */
        while (1) {
@@ -4785,11 +5287,6 @@ int main(int argc, char **argv)
        init_X11();
 #endif /* X11 */
 
-       tmpstring1 = (char *)
-           malloc(TEXT_BUFFER_SIZE);
-       tmpstring2 = (char *)
-           malloc(TEXT_BUFFER_SIZE);
-
        /* load current_config or CONFIG_FILE */
 
 #ifdef CONFIG_FILE
@@ -4909,15 +5406,16 @@ int main(int argc, char **argv)
 #if defined OWN_WINDOW
        init_window
            (own_window,
+            wm_class_name,
             text_width + border_margin * 2 + 1,
             text_height + border_margin * 2 + 1,
-            on_bottom, fixed_pos, set_transparent, background_colour);
+            on_bottom, fixed_pos, set_transparent, background_colour, info.uname_s.nodename);
 #else
        init_window
                (own_window,
                 text_width + border_margin * 2 + 1,
                 text_height + border_margin * 2 + 1,
-                on_bottom, set_transparent, background_colour);
+                on_bottom, set_transparent, background_colour, info.uname_s.nodename);
        
 #endif
 
@@ -4966,34 +5464,63 @@ int main(int argc, char **argv)
                }
        }
 
-       /* set SIGUSR1, SIGINT and SIGTERM handlers */
-       {
-               struct
-               sigaction sa;
-
-               sa.sa_handler = reload_handler;
-               sigemptyset(&sa.sa_mask);
-               sa.sa_flags = SA_RESTART;
-               if (sigaction(SIGUSR1, &sa, NULL) != 0)
-                       ERR("can't set signal handler for SIGUSR1: %s",
-                           strerror(errno));
+       /* Set signal handlers */
+       act.sa_handler = signal_handler;
+       sigemptyset(&act.sa_mask);
+       act.sa_flags = 0;
+#ifdef SA_RESTART
+       act.sa_flags |= SA_RESTART;
+#endif
 
-               sa.sa_handler = term_handler;
-               sigemptyset(&sa.sa_mask);
-               sa.sa_flags = SA_RESTART;
-               if (sigaction(SIGINT, &sa, NULL) != 0)
-                       ERR("can't set signal handler for SIGINT: %s",
-                           strerror(errno));
+       if ( sigaction(SIGINT,&act,&oact) < 0 ||
+            sigaction(SIGUSR1,&act,&oact) < 0 ||
+            sigaction(SIGTERM,&act,&oact) < 0 )
+       {
+               ERR("error setting signal handler: %s", strerror(errno) );
+       }
 
-               sa.sa_handler = term_handler;
-               sigemptyset(&sa.sa_mask);
-               sa.sa_flags = SA_RESTART;
-               if (sigaction(SIGTERM, &sa, NULL) != 0)
-                       ERR("can't set signal handler for SIGTERM: %s",
-                           strerror(errno));
+#ifdef INFOPIPE
+       /* joinable thread for infopipe activity */
+        pthread_attr_init(&info.infopipe.thread_attr);
+       pthread_attr_setdetachstate(&info.infopipe.thread_attr, PTHREAD_CREATE_JOINABLE);
+       /* init mutexex */
+       pthread_mutex_init(&info.infopipe.item_mutex, NULL);
+       pthread_mutex_init(&info.infopipe.runnable_mutex, NULL);
+       /* init runnable condition for worker thread */
+       pthread_mutex_lock(&info.infopipe.runnable_mutex);
+       info.infopipe.runnable=1;
+       pthread_mutex_unlock(&info.infopipe.runnable_mutex);
+       if (pthread_create(&info.infopipe.thread, &info.infopipe.thread_attr, infopipe_thread_func, NULL))
+       {
+           CRIT_ERR("unable to create infopipe thread!");
        }
+#endif
+
        main_loop();
-       free(tmpstring1);
-       free(tmpstring2);
+       
+#ifdef INFOPIPE
+       /* signal infopipe worker thread to terminate */
+       pthread_mutex_lock(&info.infopipe.runnable_mutex);
+       info.infopipe.runnable=0;
+       pthread_mutex_unlock(&info.infopipe.runnable_mutex);
+       /* destroy thread attribute and wait for thread */
+       pthread_attr_destroy(&info.infopipe.thread_attr);
+       if (pthread_join(info.infopipe.thread, NULL))
+       {
+           ERR("error joining infopipe thread");
+        }
+       /* destroy mutexes */
+       pthread_mutex_destroy(&info.infopipe.item_mutex);
+       pthread_mutex_destroy(&info.infopipe.runnable_mutex);
+#endif
+
        return 0;
 }
+
+void signal_handler(int sig)
+{
+       /* signal handler is light as a feather, as it should be. 
+        * we will poll g_signal_pending with each loop of conky
+        * and do any signal processing there, NOT here.  pkovacs. */
+       g_signal_pending=sig;
+}