ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/BDB/BDB.pm
(Generate patch)

Comparing BDB/BDB.pm (file contents):
Revision 1.15 by root, Thu Sep 13 21:34:00 2007 UTC vs.
Revision 1.18 by root, Tue Dec 4 11:07:39 2007 UTC

72use strict 'vars'; 72use strict 'vars';
73 73
74use base 'Exporter'; 74use base 'Exporter';
75 75
76BEGIN { 76BEGIN {
77 our $VERSION = '1.1'; 77 our $VERSION = '1.2';
78 78
79 our @BDB_REQ = qw( 79 our @BDB_REQ = qw(
80 db_env_open db_env_close db_env_txn_checkpoint db_env_lock_detect 80 db_env_open db_env_close db_env_txn_checkpoint db_env_lock_detect
81 db_env_memp_sync db_env_memp_trickle 81 db_env_memp_sync db_env_memp_trickle
82 db_open db_close db_compact db_sync db_put db_get db_pget db_del db_key_range 82 db_open db_close db_compact db_sync db_put db_get db_pget db_del db_key_range
179 db_sequence_remove (DB_SEQUENCE *seq, DB_TXN_ornull *txnid = 0, U32 flags = 0, SV *callback = &PL_sv_undef) 179 db_sequence_remove (DB_SEQUENCE *seq, DB_TXN_ornull *txnid = 0, U32 flags = 0, SV *callback = &PL_sv_undef)
180 flags: TXN_NOSYNC 180 flags: TXN_NOSYNC
181 181
182=head4 db_txn_finish (DB_TXN *txn, U32 flags = 0, SV *callback = &PL_sv_undef) 182=head4 db_txn_finish (DB_TXN *txn, U32 flags = 0, SV *callback = &PL_sv_undef)
183 183
184This is not a Berkeley DB function but a BDB module extension. It is very 184This is not actually a Berkeley DB function but a BDB module
185extension. The background for this exytension is: It is very annoying to
185annoying to have to check every single BDB function for error returns and 186have to check every single BDB function for error returns and provide a
186provide a codepath out of your transaction. While the BDB module still 187codepath out of your transaction. While the BDB module still makes this
187makes this possible, it contains the following extensions: 188possible, it contains the following extensions:
188 189
189When a transaction-protected function returns any operating system 190When a transaction-protected function returns any operating system
190error (errno > 0), BDB will set the C<TXN_DEADLOCK> flag on the 191error (errno > 0), BDB will set the C<TXN_DEADLOCK> flag on the
191transaction. This flag is also set by Berkeley DB functions externally 192transaction. This flag is also set by Berkeley DB functions themselves
192when an operation fails with LOCK_DEADLOCK, and it causes all further 193when an operation fails with LOCK_DEADLOCK, and it causes all further
193operations on that transaction (including C<db_txn_commit>) to fail. 194operations on that transaction (including C<db_txn_commit>) to fail.
194 195
195The C<db_txn_finish> request will look at this flag, and, if it is set, 196The C<db_txn_finish> request will look at this flag, and, if it is set,
196will automatically call C<db_txn_abort> (setting errno to C<LOCK_DEADLOCK> 197will automatically call C<db_txn_abort> (setting errno to C<LOCK_DEADLOCK>
197if it isn't set). If it isn't set, it will call C<db_txn_commit> and 198if it isn't set to something else yet). If it isn't set, it will call
198return the error normally. 199C<db_txn_commit> and return the error normally.
199 200
200How to use this? Easy: just write your transaction normally: 201How to use this? Easy: just write your transaction normally:
201 202
202 my $txn = $db_env->txn_begin; 203 my $txn = $db_env->txn_begin;
203 db_get $db, $txn, "key", my $data; 204 db_get $db, $txn, "key", my $data;
208That is, handle only the expected errors. If something unexpected happens 209That is, handle only the expected errors. If something unexpected happens
209(EIO, LOCK_NOTGRANTED or a deadlock in either db_get or db_put), then the remaining 210(EIO, LOCK_NOTGRANTED or a deadlock in either db_get or db_put), then the remaining
210requests (db_put in this case) will simply be skipped (they will fail with 211requests (db_put in this case) will simply be skipped (they will fail with
211LOCK_DEADLOCK) and the transaction will be aborted. 212LOCK_DEADLOCK) and the transaction will be aborted.
212 213
213You cna use the C<< $txn->failed >> method to check wether a transaction 214You can use the C<< $txn->failed >> method to check wether a transaction
214has failed in this way and abort further processing (excluding 215has failed in this way and abort further processing (excluding
215C<db_txn_finish>). 216C<db_txn_finish>).
216 217
217=head3 DB_ENV/database environment methods 218=head3 DB_ENV/database environment methods
218 219
434interactiveness when perl is not fast enough to process all requests in 435interactiveness when perl is not fast enough to process all requests in
435time. 436time.
436 437
437For interactive programs, values such as C<0.01> to C<0.1> should be fine. 438For interactive programs, values such as C<0.01> to C<0.1> should be fine.
438 439
439Example: Install an Event watcher that automatically calls 440Example: Install an EV watcher that automatically calls
440BDB::poll_cb with low priority, to ensure that other parts of the 441BDB::poll_cb with low priority, to ensure that other parts of the
441program get the CPU sometimes even under high AIO load. 442program get the CPU sometimes even under high load.
442 443
443 # try not to spend much more than 0.1s in poll_cb 444 # try not to spend much more than 0.1s in poll_cb
444 BDB::max_poll_time 0.1; 445 BDB::max_poll_time 0.1;
445 446
446 # use a low priority so other tasks have priority 447 my $bdb_poll = EV::io BDB::poll_fileno, EV::READ, \&BDB::poll_cb);
447 Event->io (fd => BDB::poll_fileno,
448 poll => 'r', nice => 1,
449 cb => &BDB::poll_cb);
450 448
451=item BDB::poll_wait 449=item BDB::poll_wait
452 450
453If there are any outstanding requests and none of them in the result 451If there are any outstanding requests and none of them in the result
454phase, wait till the result filehandle becomes ready for reading (simply 452phase, wait till the result filehandle becomes ready for reading (simply
466 464
467 BDB::poll_wait, BDB::poll_cb 465 BDB::poll_wait, BDB::poll_cb
468 466
469=item BDB::flush 467=item BDB::flush
470 468
471Wait till all outstanding AIO requests have been handled. 469Wait till all outstanding BDB requests have been handled.
472 470
473Strictly equivalent to: 471Strictly equivalent to:
474 472
475 BDB::poll_wait, BDB::poll_cb 473 BDB::poll_wait, BDB::poll_cb
476 while BDB::nreqs; 474 while BDB::nreqs;
481 479
482=over 4 480=over 4
483 481
484=item BDB::min_parallel $nthreads 482=item BDB::min_parallel $nthreads
485 483
486Set the minimum number of AIO threads to C<$nthreads>. The current 484Set the minimum number of BDB threads to C<$nthreads>. The current
487default is C<8>, which means eight asynchronous operations can execute 485default is C<8>, which means eight asynchronous operations can execute
488concurrently at any one time (the number of outstanding requests, 486concurrently at any one time (the number of outstanding requests,
489however, is unlimited). 487however, is unlimited).
490 488
491BDB starts threads only on demand, when an AIO request is queued and 489BDB starts threads only on demand, when an BDB request is queued and
492no free thread exists. Please note that queueing up a hundred requests can 490no free thread exists. Please note that queueing up a hundred requests can
493create demand for a hundred threads, even if it turns out that everything 491create demand for a hundred threads, even if it turns out that everything
494is in the cache and could have been processed faster by a single thread. 492is in the cache and could have been processed faster by a single thread.
495 493
496It is recommended to keep the number of threads relatively low, as some 494It is recommended to keep the number of threads relatively low, as some
501Under most circumstances you don't need to call this function, as the 499Under most circumstances you don't need to call this function, as the
502module selects a default that is suitable for low to moderate load. 500module selects a default that is suitable for low to moderate load.
503 501
504=item BDB::max_parallel $nthreads 502=item BDB::max_parallel $nthreads
505 503
506Sets the maximum number of AIO threads to C<$nthreads>. If more than the 504Sets the maximum number of BDB threads to C<$nthreads>. If more than the
507specified number of threads are currently running, this function kills 505specified number of threads are currently running, this function kills
508them. This function blocks until the limit is reached. 506them. This function blocks until the limit is reached.
509 507
510While C<$nthreads> are zero, aio requests get queued but not executed 508While C<$nthreads> are zero, aio requests get queued but not executed
511until the number of threads has been increased again. 509until the number of threads has been increased again.
614 612
615=head2 FORK BEHAVIOUR 613=head2 FORK BEHAVIOUR
616 614
617This module should do "the right thing" when the process using it forks: 615This module should do "the right thing" when the process using it forks:
618 616
619Before the fork, IO::AIO enters a quiescent state where no requests 617Before the fork, BDB enters a quiescent state where no requests
620can be added in other threads and no results will be processed. After 618can be added in other threads and no results will be processed. After
621the fork the parent simply leaves the quiescent state and continues 619the fork the parent simply leaves the quiescent state and continues
622request/result processing, while the child frees the request/result queue 620request/result processing, while the child frees the request/result queue
623(so that the requests started before the fork will only be handled in the 621(so that the requests started before the fork will only be handled in the
624parent). Threads will be started on demand until the limit set in the 622parent). Threads will be started on demand until the limit set in the
625parent process has been reached again. 623parent process has been reached again.
626 624
627In short: the parent will, after a short pause, continue as if fork had 625In short: the parent will, after a short pause, continue as if fork had
628not been called, while the child will act as if IO::AIO has not been used 626not been called, while the child will act as if BDB has not been used
629yet. 627yet.
630 628
631=head2 MEMORY USAGE 629=head2 MEMORY USAGE
632 630
633Per-request usage: 631Per-request usage:
656 TXN_DEADLOCK flag will be set on the transaction. See C<db_txn_finish>, 654 TXN_DEADLOCK flag will be set on the transaction. See C<db_txn_finish>,
657 above. 655 above.
658 656
659=head1 SEE ALSO 657=head1 SEE ALSO
660 658
661L<Coro::AIO>. 659L<Coro::BDB>, L<IO::AIO>.
662 660
663=head1 AUTHOR 661=head1 AUTHOR
664 662
665 Marc Lehmann <schmorp@schmorp.de> 663 Marc Lehmann <schmorp@schmorp.de>
666 http://home.schmorp.de/ 664 http://home.schmorp.de/

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines