http://permalink.gmane.org/gmane.comp.lib.state-threads.user hourly 1 1901-01-01T00:00+00:00 http://gmane.org/img/gmane-25t.png http://gmane.org http://permalink.gmane.org/gmane.comp.lib.state-threads.user/99 <pre>This was on two different Linux boxes, one 2.6.25.11-97.fc9.x86_64, and another 2.6.35.14-96.fc14.i686. No VMs. I've just tried on another box running 3.2.6-3.fc16.x86_64, and that seems to work correctly just like yours. Perhaps it's just specific Linux kernels. I don't think anyone's got the patience to sit there and test which kernels don't play well. ----- Original Message ----- From: Michael Abbott &lt;yahmja&lt; at &gt;yahoo.com&gt; To: CN &lt;cuongn7&lt; at &gt;yahoo.com.au&gt; Cc: "state-threads-users&lt; at &gt;lists.sourceforge.net" &lt;state-threads-users&lt; at &gt;lists.sourceforge.net&gt; Sent: Wednesday, 5 December 2012 5:11 AM Subject: Re: [ST-users] _st_epoll_dispatch firing too often On what OS?  Your test program works fine for me on Linux and OS X: 1354644462832661 MAIN diff = 1002671 1354644463832701 MAIN diff = 999990 1354644464832747 MAIN diff = 1000027 1354644465832793 MAIN diff = 1000026 1354644466832836 MAIN diff = 1000020 (I made it print the current st_utime() instead of the pointers, in the first column.) The "ST diff" messages neve</pre> CN 2012-12-04T23:33:54 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/98 <pre> On what OS? Your test program works fine for me on Linux and OS X: 1354644462832661 MAIN diff = 1002671 1354644463832701 MAIN diff = 999990 1354644464832747 MAIN diff = 1000027 1354644465832793 MAIN diff = 1000026 1354644466832836 MAIN diff = 1000020 (I made it print the current st_utime() instead of the pointers, in the first column.) The "ST diff" messages never even appear. Are you running in a virtual machine? VMs have been known to fire timers at unexpected times. ------------------------------------------------------------------------------ LogMeIn Rescue: Anywhere, Anytime Remote support for IT. Free Trial Remotely access PCs and mobile devices and provide instant support Improve your efficiency, and focus on delivering more value-add services Discover what IT Professionals Know. Rescue delivers http://p.sf.net/sfu/logmein_12329d2d </pre> Michael Abbott 2012-12-04T18:11:48 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/97 <pre>_st_epoll_dispatch seems to fire too often when the sleepq is not empty.  My guess is that it has something to do with granularity. Here's some basic code to reproduce: #include &lt;stdio.h&gt; #include "st.h" int main(int argc, char *argv[]) {     st_utime_t t1, t2;     st_set_eventsys(ST_EVENTSYS_ALT);     st_init();     for (;;) {         t1 = st_utime();         st_sleep(1);         t2 = st_utime();         fprintf(stderr, "%p MAIN diff = %llu\n", st_thread_self(), t2 - t1);     }     return 0; } And add some logging to event.c &lt; at &gt; line 1244. ie. 1243:  timeout = (int) (min_timeout / 1000); 1244:  if (timeout == 0 &amp;&amp; _ST_SLEEPQ-&gt;due &gt; _ST_LAST_CLOCK) 1245:      fprintf(stderr, "%p ST   diff=%llu\n", _ST_SLEEPQ, _ST_SLEEPQ-&gt;due - _ST_LAST_CLOCK); 1245: } You'll also need "#include &lt;stdio.h&gt;" . If you run the test, you'll see something like: 0x805f068 MAIN diff = 999992 0x805f068 ST   diff=241 0x805f068 ST   diff=222 0x805f068 ST   diff=210 0x805f068 ST   diff=199</pre> CN 2012-12-03T01:48:01 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/96 <pre>I'm curious as to why the docs constain st_sendmsg() and st_recvmsg() to UDP? To quote from http://state-threads.sourceforge.net/docs/reference.html#sendmsg "A file descriptor object identifier (see st_netfd_t) representing a UDP socket" But I don't see anything in the st code that requires this constraint, furthermore I've long used st_sendmsg() and st_recvmsg() on TCP sockets as it's the only way to do an inter-process fdpass with this sort of code: control-&gt;cmsg_level = SOL_SOCKET; control-&gt;cmsg_type = SCM_RIGHTS; My guess is that it's just an historical accident in the docs that might have been cloned from st_sendto()/st_recvfrom() function - which are constrained to UDP. Mark. ------------------------------------------------------------------------------ Learn Windows Azure Live! Tuesday, Dec 13, 2011 Microsoft is holding a special Learn Windows Azure training event for developers. It will provide a great way to learn Windows Azure and what it provides. You can attend the event by watching</pre> Mark Delany 2011-12-18T03:06:01 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/95 <pre>Hi guys, Valgrind outputs very weird warnings. Please check the log file I've attached. The properties of the threads are correct when you print them and they work as expected. There is no stack smashing/overflowing. Tests are made with the latest version of STL. Regards, H. Hamdi ------------------------------------------------------------------------------ RSA(R) Conference 2012 Save $700 by Nov 18 Register now http://p.sf.net/sfu/rsa-sfdev2dev1_______________________________________________ State-threads-users mailing list State-threads-users&lt; at &gt;lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/state-threads-users </pre> Hamdi Hamdi 2011-11-06T09:49:34 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/94 <pre> Programs using State Threads should fork before creating threads. One idiom is to have a master process which forks and uses no threads itself, while the child processes manage their own threads. State Threads does not provide a way to "kill" a thread. Instead each thread can check a flag in its main loop to see whether it should exit. The flag can be a global variable or a pointer passed as the arg to st_thread_create(). For threads which are blocking, st_thread_interrupt() wakes them up but does not kill them. Your "IAmSpartacus" example is close but I'd code it this way: int run_logger = 1; st_thread_t logger_thread = st_thread_create(..., &amp;run_logger, ...); ... if (fork() == 0) { run_logger = 0; st_thread_interrupt(logger_thread); } ... static void *flush_acclog_buffer(int *keep_running) { while (*keep_running) { if (st_sleep(ACCLOG_FLUSH_INTERVAL) == 0) logbuf_flush(); } return NULL; } ------------------------------------------------------------------------------ The demand </pre> Michael Abbott 2011-10-20T16:46:51 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/93 <pre>Hi All, I have a process A that creates a thread to do logging, then forks another process B. How do I get B to terminate any existing inherited threads such as the logging thread. Using the "server.c" as an example, where flush_acclog_buffer()  is running in a thread, is there something cleaner than than: int IAmSpartacus = 1; ... IAmSpartacus = 0; if (fork() &gt; 0) {    IAmSpartacus = 1; } ... static void *flush_acclog_buffer(void *arg) {     for ( ; IAmSpartacus == 1 ; ) { st_sleep(ACCLOG_FLUSH_INTERVAL); logbuf_flush();     }     return NULL; } ------------------------------------------------------------------------------ The demand for IT networking professionals continues to grow, and the demand for specialized networking skills is growing even more rapidly. Take a complimentary Learning&lt; at &gt;Ciosco Self-Assessment and learn about Cisco certifications, training, and career opportunities. http://p.sf.net/sfu/cisco-dev2dev </pre> Cuong Nguyen 2011-10-20T12:45:18 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/92 <pre>Hi Dear ST Developers and Users, I am reading ST 1.9's source has encounter a piece of code that I can't figure out for a week. In stk.c, in the body of the function _st_stack_t *_st_stack_new(int stack_size) I understand this function is to allocate memory space for the stack. And update the stack records. There is this piece for (qp = _st_free_stacks.next; qp != &amp;_st_free_stacks; qp = qp-&gt;next) //when is _st_free_stack.next!= qp? { ts = _ST_THREAD_STACK_PTR(qp); /* Here I lookup what _ST_THREAD_STACK_PTR does and found #define offsetof(type, identifier) (/***/ (size_t)&amp;(/**/( (type *)0)-&gt;identifier/**/) /***/) It looks like this macro finds a instance of "_st_stack_t"'s element "links" 's address and cast it into size_t type? I am totally confused about this! Cast address 0 points to _st_stack_t type variable, but the space is never allocated yet. How does this work? #define _ST_THREAD_STACK_PTR(_qp) \ (/**/ (_st_stack_t *)(/***/ (char*)(_qp) - offsetof(_st_stack_t, links) /***/) /**/) cas</pre> Alfred Zhong 2011-09-21T01:40:58 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/91 <pre>Oh my god! + _ST_PAGE_SIZE - 1 if stk_size is just x times of the _ST_PAGE_SIZE, the integer division will return exactly x b/c of the -1. if stk_size is smaller than x times of _ST_PAGE_SIZE, the integer division will return exactly x, and ignore the remaining &gt;x but &lt;x+1 That is smart! If the purpose is in the comment or docs will be better to understand Thanks a lot, John! Alfred On Wed, Aug 10, 2011 at 1:11 PM, John Newton &lt;jnewton&lt; at &gt;gmail.com&gt; wrote: ------------------------------------------------------------------------------ uberSVN's rich system and user administration capabilities and model configuration take the hassle out of deploying and managing Subversion and the tools developers use with it. Learn more about uberSVN and get a free download at: http://p.sf.net/sfu/wandisco-dev2dev _______________________________________________ State-threads-users mailing list State-threads-users&lt; at &gt;lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/state-threads-users </pre> Alfred Zhong 2011-08-10T17:32:59 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/90 <pre>The line you are asking about is a "round up" to the next page size calculation. For example, if getpagesize() returns 4096, and the "stk_size" parameter is 10,000 it would round up to the next even page size. (the division is doing integer math) Hope this helps! On Wed, Aug 10, 2011 at 9:06 AM, Alfred Zhong &lt;alfchung02&lt; at &gt;gmail.com&gt; wrote: ------------------------------------------------------------------------------ uberSVN's rich system and user administration capabilities and model configuration take the hassle out of deploying and managing Subversion and the tools developers use with it. Learn more about uberSVN and get a free download at: http://p.sf.net/sfu/wandisco-dev2dev _______________________________________________ State-threads-users mailing list State-threads-users&lt; at &gt;lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/state-threads-users </pre> John Newton 2011-08-10T17:11:21 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/89 <pre>Hi, I am new to state thread library and am reading the source code of ST to study implementation of threading. in the st_thread_create() function there is this code piece if (stk_size == 0) stk_size = ST_DEFAULT_STACK_SIZE; // I know this is to set the stack size to a default size, if the input size is 0 stk_size = ((stk_size + _ST_PAGE_SIZE - 1) / _ST_PAGE_SIZE) * _ST_PAGE_SIZE; //what does this mean? Look like it equals (stk_size + ST_PAGE_SIZE -1) unless the previous division gives 0. I am totally confused and can't find the answer in the code or the docs, please help! Thanks a lot! Alfred ------------------------------------------------------------------------------ uberSVN's rich system and user administration capabilities and model configuration take the hassle out of deploying and managing Subversion and the tools developers use with it. Learn more about uberSVN and get a free download at: http://p.sf.net/sfu/wandisco-dev2dev _______________________________________________ State-thre</pre> Alfred Zhong 2011-08-10T16:06:00 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/88 <pre> Yes and no. Yes, in that st_poll() does directly support waiting for I/O only. No, because other async operations can map to I/O by reading and writing a pipe or socketpair. For instance, user-defined lock functions could write something to a pipe whenever they lock or unlock a lock, and another thread could poll and read from the pipe to learn when such actions happen. This is how we recommend translating UNIX signals to I/O operations too; see http://state-threads.sourceforge.net/docs/notes.html ------------------------------------------------------------------------------ Come build with us! The BlackBerry&amp;reg; Developer Conference in SF, CA is the only developer event you need to attend this year. Jumpstart your developing skills, take BlackBerry mobile applications to market and stay ahead of the curve. Join us from November 9&amp;#45;12, 2009. Register now&amp;#33; http://p.sf.net/sfu/devconf </pre> Michael Abbott 2009-09-17T16:34:28 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/87 <pre> Correct me if I'm wrong, but that only applies to I/O, as opposed to asynchronous operations in general, such as mutex locking, sleeping (though I know there's a timeout parameter already for this), or any other user-defined asynchronous operation. </pre> Yang Zhang 2009-09-16T20:12:21 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/86 <pre> st_poll() ------------------------------------------------------------------------------ Come build with us! The BlackBerry&amp;reg; Developer Conference in SF, CA is the only developer event you need to attend this year. Jumpstart your developing skills, take BlackBerry mobile applications to market and stay ahead of the curve. Join us from November 9&amp;#45;12, 2009. Register now&amp;#33; http://p.sf.net/sfu/devconf </pre> Michael Abbott 2009-09-16T18:54:27 http://permalink.gmane.org/gmane.comp.lib.state-threads.user/85 <pre>What would be the easiest way to be able to wait on multiple asynchronous operations without having to create a thread per operation? I'm trying to write my own primitives for this, but I'm not sure it's possible without modifying ST itself. Any thoughts would be greatly appreciated. </pre> Yang Zhang 2009-09-14T18:40:40 Search the mailing list at Gmane query http://search.gmane.org/?group=$group=gmane.comp.lib.state-threads.user