search for: add_timer

I''m tracking performance on the machine I installed yesterday. mutt running on one Xen instance, accessing via imap to another instance, accessing via nfs the maildir in another instances, seems little laggy when moving up and down the message index list. Network latency seems low < 30ms on average. So I was tracking vmstat. On the mutt instances is seems reasonable: [nic@shell:~]

...ve(&gnttab_list_lock, flags); + if (entry) + list_add_tail(&entry->list, &deferred_list); + else if (list_empty(&deferred_list)) + break; + } + if (!list_empty(&deferred_list) && !timer_pending(&deferred_timer)) { + deferred_timer.expires = jiffies + HZ; + add_timer(&deferred_timer); + } + spin_unlock_irqrestore(&gnttab_list_lock, flags); +} + +static void gnttab_add_deferred(grant_ref_t ref, struct page *page) +{ + struct deferred_entry *entry = kmalloc(sizeof(*entry), GFP_ATOMIC); + const char *what = KERN_WARNING "leaking"; + + if (entry)...

...topping the machine, but do not output the last writes to users. Some way to tell that there''s no one connected or no more pending traffic or the like would be great. I finally set up a flag to stop allowing incoming connections, and after the code to close existing connections, used EM#add_timer to kill the server. That worked, but isn''t necessarily scalable. Two seconds may be long enough now, but later I may need 5, or 10, if there are a lot of connections. I''d much rather trigger it off the actual event I''m interested in, being a lack of pending outgoing dat...

Hi I thought this should suspend the task by 1 minute, but it starts immediately: MiddleMan.ask_work( :worker => :bar_worker, :worker_method => :test_method, :trigger_args => { :start => (Time.now + 1.minute)}) Is the start argument not allowed in the new backgroundrb (mine is at rev HEAD (=314))? What can I do about this? I really need to suspend starting the task as I want

My ajax code does not work on ie and konkeror. It does work on firefox. The code is <%= link_to_remote( "Add Another", :update => "event_times", :url => { :action => :add_time , :indice => @indice, :date_start_day=>@datetime.start_date}, :position => :bottom, :complete

I have a bunch of real uses for BackgroundDrb, but I also a very simple need to delay sending an email for about 5 seconds after a rails action completes. Basically I need to leave time for the DB to commit and sync to the slaves before the email can be sent Is BackgroundDb the right tool for this job? Any other suggestions on ways to implement this? (I have seen suggestions to create a

...s usual you define your workers in a worker directory and they will be picked and run. Now, It should be noted that, part of stability that comes to new version is because of total lack of threads. Even timers are implemented using evented model of programming. Right now, we have two methods "add_timer" and "add_periodic_timer" available in all the workers, which can be used to schedule a job. A sample use case is: def worker_init add_periodic_timer(10) { puts "Hello World : #{Time.now}"} end Older version of BackgrounDrb was having a seperate file which was used f...

...ve(&gnttab_list_lock, flags); + if (entry) + list_add_tail(&entry->list, &deferred_list); + else if (list_empty(&deferred_list)) + break; + } + if (!list_empty(&deferred_list) && !timer_pending(&deferred_timer)) { + deferred_timer.expires = jiffies + HZ; + add_timer(&deferred_timer); + } + spin_unlock_irqrestore(&gnttab_list_lock, flags); +} + +static void gnttab_add_deferred(grant_ref_t ref, bool readonly, + struct page *page) +{ + struct deferred_entry *entry = kmalloc(sizeof(*entry), GFP_ATOMIC); + const char *what = KERN_WARNING "leaking&qu...

Hey guys, Firstly, I''m new to the list and great work with backgroundrb, it''s sweet!!! I''ve just started noticing an issue and i''m wondering if there is a standard fix. The situation is as follows: 1. In my model''s after_save I call my worker asynchronously with the active record object''s id as a parameter (the record that has just

My Rails application requires a very busy worker process running in the background at all times. I am launching this non-interactive process using script/runner. This process is very busy and is communicating with the MySQL server constantly. As I started putting some load on the system to test, I started running into performance issues. I have since discovered that Rails is only using 1

...est" inside worker will not be invoked for them. You will find support for schedules very rough around the edges. Reason is, You can use add_periodic_timer(5) { foo_job } to do any kind of scheduling. add_periodic_timer takes number of seconds as argument. for one shot timers, you can use: add_timer(5) { foo_job } Core of new version of bdrb is implemented on a networking library called "packet". It needs its own introduction. But now, inside each worker you can start evented network connections. You have some methods like: connect("localhost",5678,FooHandler) start_ser...

...ap subprocess > Abort trap > The following code is called to connect the pipe: EventMachine::run do > # Open the connection to the dvipng shell command > EventMachine::popen $mock_dvipng_executable, > Workers::DviToPng::PipeProtocol > EM::next_tick { > EventMachine::add_timer(3) { EventMachine::stop; violated("Event loop > took too long.") } > } > end > This bug seems to happen on the first or second attempt, and then it magically goes away. Any ideas? Thanks, Duane Johnson -------------- next part -------------- An HTML attachment was scrubbe...

...ow this because when I reset domains (virsh reset VM) I see messages appear from the Handlers::notify_readable(), which should then invoke Libvirt::event_invoke_handle_callback() - but the output from the callbacks never appears. Typical output from the program looks like: add_handle fd=11 events=1 add_timer interval=-1 :notify_readable id=0 fd=11 events=1 update_timer id=0 interval=0 :notify_readable id=0 fd=11 events=1 :notify_readable id=0 fd=11 events=1 ... When I enabled debugging by setting LIBVIRT_DEBUG to 1 the output from libvirt appears to be the same as event_test.rb (excluding memory addre...

Hi again, I was just looking around for ESFQ sources, and I see that the main site is down, and only has kernel 2.6.4 patches. Is ESFQ maintained? If so, where can I find patches for 2.6.10? Thanks, -justin _______________________________________________ LARTC mailing list / LARTC@mailman.ds9a.nl http://mailman.ds9a.nl/mailman/listinfo/lartc HOWTO: http://lartc.org/

...f6cb kernel(__wake_up) = 0x642e54ac kernel(_read_lock) = 0x1a75caa3 kernel(_spin_lock) = 0x973873ab kernel(_spin_lock_bh) = 0x93cbd1ec kernel(_spin_lock_irq) = 0xecde1418 kernel(_spin_lock_irqsave) = 0x712aa29b kernel(_spin_unlock_bh) = 0x3aa1dbcf kernel(_spin_unlock_irqrestore) = 0x4b07e779 kernel(add_timer) = 0x46085e4f kernel(alloc_netdev_mq) = 0xafbc0d15 kernel(autoremove_wake_function) = 0xc8b57c27 kernel(boot_tvec_bases) = 0xfc6256b9 kernel(call_rcu) = 0x1251d30f kernel(complete) = 0xe456bd3a kernel(consume_skb) = 0x0de0cf25 kernel(cpu_possible_mask) = 0x76a495c1 kernel(csum_partial) = 0xe113bbbc...

...firmed. Fortunately, LIST_DELETE - doesn't do this. --RR */ LIST_DELETE(&ip_conntrack_hash [hash_conntrack(&ct->tuplehash[IP_CT_DIR_ORIGINAL].tuple)], &ct->tuplehash[IP_CT_DIR_ORIGINAL]); @@ -467,6 +464,7 @@ ct->timeout.expires +=3D jiffies; add_timer(&ct->timeout); atomic_inc(&ct->ct_general.use); + set_bit(IPS_CONFIRMED_BIT, &ct->status); WRITE_UNLOCK(&ip_conntrack_lock); return NF_ACCEPT; } @@ -585,7 +583,7 @@ connection. Too bad: we're in trouble anyway. */ static inline int unreplied(const stru...

hi i tried the example given on the examples page to duplicate selected traffic like tc qdisc add dev eth0 root handle 1: prio tc qdisc add dev eth0 parent 1:3 handle 3: netem duplicate 40% tc filter add dev eth0 protocol ip parent 1:0 prio 3 u32 match ip dst 11.0.2.2 flowid 1:3 when i ping from 11.0.2.2 to this interface my machine hangs. the same thing works for drop or delay. i would

...ue %p@%lu %ld\n", + skb, jiffies, delay); + + /* it''s baked enough */ + if (delay <= 0) { + __skb_unlink(skb, &q->qdelay); + del_timer(&q->timer); + return skb; + } + + if (!timer_pending(&q->timer)) { + q->timer.expires = jiffies + delay; + add_timer(&q->timer); + } + } + return NULL; +} + +/* Dequeue packet. + * If packet needs to be held up, then put in the delay + * queue and set timer to wakeup later. + */ +static struct sk_buff *netem_dequeue(struct Qdisc *sch) +{ + struct netem_sched_data *q = (struct netem_sched_data *)sch->da...

...r; + } + + now = get_clock() + vcpu->arch.sie_block->epoch; + if (vcpu->arch.sie_block->ckc < now) { + __unset_cpu_idle(vcpu); + return 0; + } + + sltime = (vcpu->arch.sie_block->ckc - now) / (0xf4240000ul / HZ) + 1; + + vcpu->arch.ckc_timer.expires = jiffies + sltime; + + add_timer(&vcpu->arch.ckc_timer); + VCPU_EVENT(vcpu, 5, "enabled wait timer:%lx jiffies", sltime); +no_timer: + spin_lock_bh(&vcpu->arch.local_int.float_int->lock); + spin_lock_bh(&vcpu->arch.local_int.lock); + __set_cpu_idle(vcpu); + vcpu->arch.local_int.timer_due = 0; +...

The HTB scheduler code is a mess, this patch set does some basic house cleaning. The first four should cause no code change, but the last two need more testing. -- Stephen Hemminger <shemminger@osdl.org> "And in the Packet there writ down that doome" - To unsubscribe from this list: send the line "unsubscribe netdev" in the body of a message to