Bio::EnsEMBL::Hive::Semaphore Class Reference

Inheritance diagram for Bio::EnsEMBL::Hive::Semaphore:

Public Member Functions
public	local_jobs_counter ()
public	remote_jobs_counter ()
public	dependent_semaphore_url ()
public	dependent_semaphore ()
public	ultimate_dependent_job ()
public	url_query_params ()
public	check_if_ripe ()
public	increase_by ()
public	reblock_by ()
public	fetch_my_raw_accu_data ()
public	fetch_my_local_controlling_jobs ()
public	release_if_ripe ()
public	decrease_by ()
Public Member Functions inherited from Bio::EnsEMBL::Hive::Storable
public Bio::EnsEMBL::Hive::Storable	new ()
public Int	dbID ()
public Bio::EnsEMBL::Hive::DBSQL::BaseAdaptor	adaptor ()
public	DESTROY ()
public	AUTOLOAD ()
Public Member Functions inherited from Bio::EnsEMBL::Hive::Cacheable
public	hive_pipeline ()
public	is_local_to ()
public	count_local_and_remote_objects ()
public	relative_display_name ()
public	relative_url ()
public	display_name ()
public	unikey ()

Detailed Description

Description

    A Semaphore object is our main instrument of fine-grained job control.
    It is controlled (blocked) by a group of "fan" jobs and remote semaphores and has
    either a dependent local job or a dependent remote semaphore
    that will be unblocked when both local_jobs_counter and remote_jobs_counter reach zeros.

Definition at line 13 of file Semaphore.pm.

Member Function Documentation

check_if_ripe()

public Bio::EnsEMBL::Hive::Semaphore::check_if_ripe

(

)

Undocumented method

Code:

decrease_by()

public Bio::EnsEMBL::Hive::Semaphore::decrease_by

(

)

Undocumented method

Code:

dependent_semaphore()

public Bio::EnsEMBL::Hive::Semaphore::dependent_semaphore

(

)

Undocumented method

Code:

dependent_semaphore_url()

public Bio::EnsEMBL::Hive::Semaphore::dependent_semaphore_url

(

)

Undocumented method

Code:

fetch_my_local_controlling_jobs()

public Bio::EnsEMBL::Hive::Semaphore::fetch_my_local_controlling_jobs

(

)

Undocumented method

Code:

fetch_my_raw_accu_data()

public Bio::EnsEMBL::Hive::Semaphore::fetch_my_raw_accu_data

(

)

Undocumented method

Code:

increase_by()

public Bio::EnsEMBL::Hive::Semaphore::increase_by

(

)

Undocumented method

Code:

local_jobs_counter()

public Bio::EnsEMBL::Hive::Semaphore::local_jobs_counter

(

)

Undocumented method

Code:

reblock_by()

public Bio::EnsEMBL::Hive::Semaphore::reblock_by

(

)

Undocumented method

Code:

release_if_ripe()

public Bio::EnsEMBL::Hive::Semaphore::release_if_ripe

(

)

Undocumented method

Code:

remote_jobs_counter()

public Bio::EnsEMBL::Hive::Semaphore::remote_jobs_counter

(

)

Undocumented method

Code:

ultimate_dependent_job()

public Bio::EnsEMBL::Hive::Semaphore::ultimate_dependent_job

(

)

Undocumented method

Code:

url_query_params()

public Bio::EnsEMBL::Hive::Semaphore::url_query_params

(

)

Undocumented method

Code:

---

The documentation for this class was generated from the following file:

• modules/Bio/EnsEMBL/Hive/Semaphore.pm