#include <Cprocess_clients.H>
Static Public Member Functions | |
static void | process_data_stream_ecm (const connection_waiter &my_connection_waiter) |
static void * | THREAD_process_data_stream (void *arg) |
static void | seek_emergency_handler (istream &in, const streampos pos) |
Static Private Member Functions | |
static void | process_data_stream (unix_io_stream &daten, const string client) |
Static Private Attributes | |
static CCriticalSection::Mutex | ServerMutex |
Definition at line 8 of file Cprocess_clients.H.
void Cprocess_clients::process_data_stream_ecm | ( | const connection_waiter & | my_connection_waiter | ) | [static] |
Definition at line 20 of file Cprocess_clients.cc.
References cerr, cout, cout_network(), ecm_curves_processed, elcu_Kurven, elcu_Phase1, elcu_Phase2, endl(), Factorization_to_file, flush(), isspace(), MAL(), mpz_clear(), mpz_cmp_ui(), mpz_gcd(), mpz_init(), mpz_pow_ui(), mpz_probab_prime_p(), mpz_remove(), mpz_set_ui(), mpz_sizeinbase(), mpz_swap(), n, peer_info(), Potenztest(), my_mpz_wrapper::probab_prime_checks, QsieveLogon, Recovery_buffer, RecoveryFile, ExitManager::StopFactorization(), and tune_parameters().
Referenced by main().
void Cprocess_clients::process_data_stream | ( | unix_io_stream & | daten, | |
const string | client | |||
) | [static, private] |
Definition at line 209 of file Cprocess_clients.cc.
References DynamicRelations::IstreamPool::acquire_istream(), statistical_data::AllClientStats, statistical_data::AllClientStats_Mutex, std::set< _Key, _Compare, _Alloc >::begin(), cerr, CmpqsPolynom::compute_next_polynomial(), cout, cout_network(), DynamicRelations::CRelation, difftimes(), CmpqsFactortypes::double_large_prime, statistical_data::DynamicFactorRating, DynamicFactorRelations, DynamicRelations::DynamicRelations_to_file, std::set< _Key, _Compare, _Alloc >::end(), endl(), CCriticalSection::enter(), exit(), TDynamicFactorRelation::factor, Factor_Threshold, Factorization_to_file, flush(), TDynamicFactorRelation::fpos, statistical_data::CClientStats::increment(), SpecialRelations::insert(), CServerDynamicFactorRelations::insert(), StaticRelations::insert(), is_dynamic_factor(), CRelation::is_valid(), isspace(), kN, CCriticalSection::leave(), CMutex::lock(), LogicalSieveSize, MAL(), MARK, CServerDynamicFactorRelations::monitoredSize(), mpz_clear(), mpz_cmp(), mpz_cmp_ui(), mpz_gcd(), mpz_init(), mpz_mod(), mpz_mul(), mpz_probab_prime_p(), mpz_remove(), mpz_set_ui(), mpz_sizeinbase(), n, Polynom, Potenztest(), my_mpz_wrapper::probab_prime_checks, statistical_data::CClientStats::PutTimeStamp(), QsieveLogon, read_restrictedName(), DynamicRelations::IstreamPool::release_istream(), CmpqsPolynom::save(), ServerMutex, Cnetwork_connection_methods::set_TCP_NODELAY(), setprecision(), CmpqsFactortypes::single_large_prime, StaticFactorbaseSettings::Size(), CServerDynamicFactorRelations::SLP_mutex, SpecialRelations::split_by_primefactor(), CmpqsFactortypes::static_prime, statistical_data::StatusReport(), ExitManager::StopFactorization(), CCriticalSection::try_enter(), CMutex::unlock(), and without_multi_combine_init.
Referenced by THREAD_process_data_stream().
void * Cprocess_clients::THREAD_process_data_stream | ( | void * | arg | ) | [static] |
Definition at line 832 of file Cprocess_clients.cc.
References cerr, communication_stream, endl(), peer_info(), process_data_stream(), ExitManager::register_cancel(), and ExitManager::unregister_cancel().
Referenced by main().
void Cprocess_clients::seek_emergency_handler | ( | istream & | in, | |
const streampos | pos | |||
) | [static] |
Definition at line 166 of file Cprocess_clients.cc.
References cerr, DynamicRelations::DynamicRelations_to_file, endl(), CCriticalSection::leave(), ServerMutex, and CCriticalSection::try_enter().
Referenced by main().
CCriticalSection::Mutex Cprocess_clients::ServerMutex [static, private] |
Definition at line 11 of file Cprocess_clients.H.
Referenced by process_data_stream(), and seek_emergency_handler().