RetroSearch Browse

()) {

180 ". It refers to un unknown queue class"

);

187

this

= found->second;

201 for

(list<string>::const_iterator

= values.begin();

202 val

!= values.end(); ++

) {

203 if

"timeout"

)

205 else if

"notif_hifreq_interval"

)

208 else if

"notif_hifreq_period"

)

210 else if

"notif_lofreq_mult"

)

212 else if

"notif_handicap"

)

214 else if

"dump_buffer_size"

)

216 else if

"dump_client_buffer_size"

)

219 else if

"dump_aff_buffer_size"

)

221 else if

"dump_group_buffer_size"

)

224 else if

"run_timeout"

)

226 else if

"read_timeout"

)

228 else if

"program"

)

230 else if

"failed_retries"

)

232 else if

"read_failed_retries"

)

236

failed_retries_preread);

237 else if

"max_jobs_per_client"

)

239 else if

"blacklist_time"

)

241 else if

"read_blacklist_time"

)

245

blacklist_time_preread);

246 else if

"max_input_size"

)

248 else if

"max_output_size"

)

250 else if

"subm_host"

)

252 else if

"wnode_host"

)

254 else if

"reader_host"

)

256 else if

"wnode_timeout"

)

258 else if

"reader_timeout"

)

260 else if

"pending_timeout"

)

262 else if

"max_pending_wait_timeout"

)

265 else if

"max_pending_read_wait_timeout"

)

268 else if

"description"

)

270 else if

"scramble_job_keys"

)

272 else if

"client_registry_timeout_worker_node"

)

275 else if

"client_registry_min_worker_nodes"

)

278 else if

"client_registry_timeout_admin"

)

281 else if

"client_registry_min_admins"

)

284 else if

"client_registry_timeout_submitter"

)

287 else if

"client_registry_min_submitters"

)

290 else if

"client_registry_timeout_reader"

)

293 else if

"client_registry_min_readers"

)

296 else if

"client_registry_timeout_unknown"

)

299 else if

"client_registry_min_unknowns"

)

305 bool

linked_sections_ok;

308

&linked_sections_ok);

310

k != queue_linked_sections.

(); ++k)

318 "client_registry_timeout_worker_node"

)

319

". It must be > "

321 double

fixed_timeout =

332 "client_registry_timeout_reader"

)

333

". It must be > "

335 double

fixed_timeout =

342 return

linked_sections_ok;

351 bool

include_class_cmp,

352 bool

include_description)

const 367

diff,

"notif_hifreq_interval"

373

diff,

"notif_hifreq_period"

383

diff,

"notif_handicap"

407

diff,

"run_timeout"

413

diff,

"read_timeout"

435

diff,

"blacklist_time"

441

diff,

"read_blacklist_time"

467

diff,

"wnode_timeout"

473

diff,

"reader_timeout"

479

diff,

"pending_timeout"

485

diff,

"max_pending_wait_timeout"

491

diff,

"max_pending_read_wait_timeout"

531

diff,

"client_registry_timeout_submitter"

546

diff,

"client_registry_timeout_reader"

561

diff,

"client_registry_timeout_unknown"

579

list<string> deleted;

580

list<string> changed;

584 string

old_section = k->first;

588

deleted.push_back(old_section);

591 if

(k->second != found->second)

592

changed.push_back(old_section);

597 string

new_section = k->first;

600

added.push_back(new_section);

603 if

(!added.empty()) {

605 for

(list<string>::const_iterator k = added.begin();

606

k != added.end(); ++k)

608

diff.

(

"linked_section_added"

, added_sections);

611 if

(!deleted.empty()) {

613 for

(list<string>::const_iterator k = deleted.begin();

614

k != deleted.end(); ++k)

616

diff.

(

"linked_section_deleted"

, deleted_sections);

619 if

(!changed.empty()) {

621 for

(list<string>::const_iterator k = changed.begin();

622

k != changed.end(); ++k) {

627 string

>::const_iterator val_iter;

628 string

changed_section_name = *k;

631 string

old_value = val_iter->second;

633 string

new_value = val_iter->second;

637

section_changes.

(changed_section_name, values);

638

changed_sections.

Append

(section_changes);

641

diff.

client_registry_min_admins

(

"linked_section_changed"

, changed_sections);

652 bool

url_encoded)

const 658 string

prefix(

"OK:"

);

659 string

suffix(

": "

);

660 string

separator(

"\n"

);

674 result

.append(

"static"

);

676 result

.append(

"dynamic"

);

677 result

.append(separator);

679 result

.append(prefix).append(

"qclass"

).append(suffix).append(

qclass

).append(separator)

681

.append(prefix).append(

"max_aff_slots"

).append(suffix).append(to_string(

max_aff_slots

)).append(separator)

682

.append(prefix).append(

"aff_slots_used"

).append(suffix).append(to_string(

aff_slots_used

)).append(separator)

683

.append(prefix).append(

"max_group_slots"

).append(suffix).append(to_string(

max_group_slots

)).append(separator)

684

.append(prefix).append(

"group_slots_used"

).append(suffix).append(to_string(

group_slots_used

)).append(separator)

685

.append(prefix).append(

"max_scope_slots"

).append(suffix).append(to_string(

max_scope_slots

)).append(separator)

686

.append(prefix).append(

"scope_slots_used"

).append(suffix).append(to_string(

scope_slots_used

)).append(separator)

687

.append(prefix).append(

"clients"

).append(suffix).append(to_string(

clients

)).append(separator)

688

.append(prefix).append(

"groups"

).append(suffix).append(to_string(

groups

)).append(separator)

689

.append(prefix).append(

"gc_backlog"

).append(suffix).append(to_string(

gc_backlog

)).append(separator)

690

.append(prefix).append(

"notif_count"

).append(suffix).append(to_string(

notif_count

)).append(separator);

692 result

.append(prefix).append(

"pause"

).append(suffix);

694 result

.append(

"pullback"

);

696 result

.append(

"nopullback"

);

698 result

.append(

"nopause"

);

699 result

.append(separator);

703

.append(prefix).append(

"timeout"

).append(suffix).append(to_string(

timeout

Sec

())).append(separator)

706

.append(prefix).append(

"notif_lofreq_mult"

).append(suffix).append(to_string(

notif_lofreq_mult

)).append(separator)

708

.append(prefix).append(

"dump_buffer_size"

).append(suffix).append(to_string(

dump_buffer_size

)).append(separator)

709

.append(prefix).append(

"dump_client_buffer_size"

).append(suffix).append(to_string(

dump_client_buffer_size

)).append(separator)

710

.append(prefix).append(

"dump_aff_buffer_size"

).append(suffix).append(to_string(

dump_aff_buffer_size

)).append(separator)

711

.append(prefix).append(

"dump_group_buffer_size"

).append(suffix).append(to_string(

dump_group_buffer_size

)).append(separator)

714

.append(prefix).append(

"failed_retries"

).append(suffix).append(to_string(

failed_retries

)).append(separator)

715

.append(prefix).append(

"read_failed_retries"

).append(suffix).append(to_string(

read_failed_retries

)).append(separator)

716

.append(prefix).append(

"max_jobs_per_client"

).append(suffix).append(to_string(

max_jobs_per_client

)).append(separator)

719

.append(prefix).append(

"max_input_size"

).append(suffix).append(to_string(

max_input_size

)).append(separator)

720

.append(prefix).append(

"max_output_size"

).append(suffix).append(to_string(

max_output_size

)).append(separator)

730

.append(prefix).append(

"client_registry_min_admins"

).append(suffix).append(to_string(

)).append(separator)

734

.append(prefix).append(

"client_registry_min_readers"

).append(suffix).append(to_string(

client_registry_min_readers

)).append(separator)

736

.append(prefix).append(

"client_registry_min_unknowns"

).append(suffix).append(to_string(

client_registry_min_unknowns

)).append(separator);

747

.append(linked_section.first)

759

.append(linked_section.first)

776 "timeout=\""

+ to_string(

timeout

Sec

()) +

"\"\n" 833

min_timeout.tv_sec = min_timeout.tv_sec / 10;

834

min_timeout.tv_nsec = min_timeout.tv_nsec / 10;

835

min_timeout.tv_nsec += (min_timeout.tv_sec % 10) * (

kNSecsPerSecond

/ 10);

838 if

(min_timeout < limit)

846 const string

& sname,

847

vector<string> & warnings)

859 const string

& sname,

860

vector<string> & warnings)

869 ". It must be > 0.0"

);

877 const string

& sname,

878

vector<string> & warnings)

885 double val

= reg.

(sname,

"notif_hifreq_interval"

891 ". It must be > 0.0"

);

899 const string

& sname,

900

vector<string> & warnings)

907 double val

= reg.

(sname,

"notif_hifreq_period"

912 ". It must be > 0.0"

);

920 const string

& sname,

921

vector<string> & warnings)

927 int val

= reg.

(sname,

"notif_lofreq_mult"

932 ". It must be > 0"

);

940 const string

& sname,

941

vector<string> & warnings)

952 ". It must be >= 0.0"

);

960 const string

& sname,

961

vector<string> & warnings)

967 int val

= reg.

(sname,

"dump_buffer_size"

972 ". It must be not less than "

980 ". It must be not larger than "

989 const string

& sname,

990

vector<string> & warnings)

997 int val

= reg.

(sname,

"dump_client_buffer_size"

1002 ". It must be not less than "

1010 ". It must be not larger than "

1019 const string

& sname,

1020

vector<string> & warnings)

1026 int val

= reg.

(sname,

"dump_aff_buffer_size"

1031 ". It must be not less than "

1039 ". It must be not larger than "

1048 const string

& sname,

1049

vector<string> & warnings)

1051 bool ok

NS_ValidateInt

(reg, sname,

"dump_group_buffer_size"

, warnings);

1055 int val

= reg.

(sname,

"dump_group_buffer_size"

1060 ". It must be not less than "

1067 ". It must be not larger than "

1076 const string

& sname,

1077

vector<string> & warnings)

1087 ". It must be >= 0.0"

);

1096 const string

& sname,

1097

vector<string> & warnings)

1107 ". It must be >= 0.0"

);

1116 const string

& sname,

1117

vector<string> & warnings)

1127 ". The value length ("

1128

to_string(

.size()) +

" bytes) " 1129 "exceeds the max allowed length ("

1138 const string

& sname,

1139

vector<string> & warnings)

1149 ". It must be >= 0"

);

1157 const string

& sname,

1158

vector<string> & warnings,

1159 unsigned int

failed_retries)

1170 ". It must be >= 0"

);

1178 const string

& sname,

1179

vector<string> & warnings)

1185 int val

= reg.

(sname,

"max_jobs_per_client"

1190 ". It must be >= 0"

);

1198 const string

& sname,

1199

vector<string> & warnings)

1210 ". It must be >= 0.0"

);

1218 const string

& sname,

1219

vector<string> & warnings,

1227 double val

= reg.

(sname,

"read_blacklist_time"

1232 ". It must be >= 0.0"

);

1240 const string

& sname,

1241

vector<string> & warnings)

1256 ". It could not be converted to " 1257 "unsigned integer: "

+ ex.what());

1262 ". It could not be converted to " 1263 "unsigned integer"

);

1270 ". It must not be larger than "

1281 const string

& sname,

1282

vector<string> & warnings)

1297 ". It could not be converted to " 1298 "unsigned integer: "

+ ex.what());

1303 ". It could not be converted to " 1304 "unsigned integer"

);

1311 ". It must not be larger than "

1322 const string

& sname,

1323

vector<string> & warnings)

1333 ". The value length ("

1334

to_string(

.size()) +

" bytes) " 1335 "exceeds the max allowed length ("

1344 const string

& sname,

1345

vector<string> & warnings)

1355 ". The value length ("

1356

to_string(

.size()) +

" bytes) " 1357 "exceeds the max allowed length ("

1366 const string

& sname,

1367

vector<string> & warnings)

1377 ". The value length ("

1378

to_string(

.size()) +

" bytes) " 1379 "exceeds the max allowed length ("

1388 const string

& sname,

1389

vector<string> & warnings)

1400 ". It must be > 0.0"

);

1408 const string

& sname,

1409

vector<string> & warnings)

1420 ". It must be > 0.0"

);

1428 const string

& sname,

1429

vector<string> & warnings)

1435 double val

= reg.

(sname,

"pending_timeout"

1440 ". It must be > 0.0"

);

1448 const string

& sname,

1449

vector<string> & warnings)

1456 double val

= reg.

(sname,

"max_pending_wait_timeout"

1461 ". It must be >= 0.0"

);

1469 const string

& sname,

1470

vector<string> & warnings)

1477 double val

= reg.

(sname,

"max_pending_read_wait_timeout"

1482

". It must be >= 0.0"

);

1490 const string

& sname,

1491

vector<string> & warnings)

1500 ". The value length ("

1501

to_string(descr.size()) +

" bytes) " 1502 "exceeds the max allowed length ("

1511 const string

& sname,

1512

vector<string> & warnings)

1524 const string

& sname,

1525

vector<string> & warnings)

1527 double

calc_default =

1533 "client_registry_timeout_worker_node"

1538 double val

= reg.

(sname,

"client_registry_timeout_worker_node"

1543 "client_registry_timeout_worker_node"

)

1544

". It must be > "

1554 const string

& sname,

1555

vector<string> & warnings)

1562 int val

= reg.

(sname,

"client_registry_min_worker_nodes"

1567 "client_registry_min_worker_nodes"

) +

1568 ". It must be > 0"

);

1577 const string

& sname,

1578

vector<string> & warnings)

1585 double val

= reg.

(sname,

"client_registry_timeout_admin"

1590 "client_registry_timeout_admin"

) +

1591 ". It must be > 0.0"

);

1600 const string

& sname,

1601

vector<string> & warnings)

1608 int val

= reg.

(sname,

"client_registry_min_admins"

1613 "client_registry_min_admins"

) +

1614 ". It must be > 0"

);

1624 const string

& sname,

1625

vector<string> & warnings)

1628 "client_registry_timeout_submitter"

1633 double val

= reg.

(sname,

"client_registry_timeout_submitter"

1638 "client_registry_timeout_submitter"

) +

1639 ". It must be > 0.0"

);

1648 const string

& sname,

1649

vector<string> & warnings)

1652 "client_registry_min_submitters"

, warnings);

1656 int val

= reg.

(sname,

"client_registry_min_submitters"

1661 "client_registry_min_submitters"

) +

1662 ". It must be > 0"

);

1671 const string

& sname,

1672

vector<string> & warnings)

1674 double

calc_default =

1680 "client_registry_timeout_reader"

1685 double val

= reg.

(sname,

"client_registry_timeout_reader"

1690 "client_registry_timeout_reader"

)

1691

". It must be > "

1701 const string

& sname,

1702

vector<string> & warnings)

1709 int val

= reg.

(sname,

"client_registry_min_readers"

1714 "client_registry_min_readers"

) +

1715 ". It must be > 0"

);

1724 const string

& sname,

1725

vector<string> & warnings)

1728 "client_registry_timeout_unknown"

, warnings);

1732 double val

= reg.

(sname,

"client_registry_timeout_unknown"

1737 "client_registry_timeout_unknown"

) +

1738 ". It must be > 0.0"

);

1747 const string

& sname,

1748

vector<string> & warnings)

1751 "client_registry_min_unknowns"

, warnings);

1755 int val

= reg.

(sname,

"client_registry_min_unknowns"

1760 "client_registry_min_unknowns"

) +

1761 ". It must be > 0"

);

1770 const string

& sname,

1771

vector<string> & warnings,

1772 bool

* linked_sections_ok)

1776

list<string> available_sections;

1778

*linked_sections_ok =

true

;

1783 for

(list<string>::const_iterator k =

entries

.begin();

1785 const string

& entry = *k;

1789 if

(entry ==

"linked_section_"

) {

1790

warnings.push_back(

"Validating config file: unexpected entry name " 1792 ". Referring name is missed"

);

1801 if

(ref_section.empty()) {

1803 ". Referred section name is missed"

);

1806 if

(find(available_sections.begin(),

1807

available_sections.end(),

1808

ref_section) == available_sections.end()) {

1810 ". It refers to an unknown section"

);

1815

conf_linked_sections[entry] = ref_section;

1823

k = conf_linked_sections.

begin

(); k != conf_linked_sections.

();

1825 if

(!prefixes.empty())

1827

prefixes += k->first;

1828 if

(!sections.empty())

1830

sections += k->second;

1833

warnings.push_back(

"Validating config file: total length of the " 1834 "serialized linked section prefixes ("

1835

to_string(prefixes.size()) +

1836 " bytes) exceeds the limit ("

1838 "bytes) in the section "

+ sname);

1839

*linked_sections_ok =

false

;

1842

warnings.push_back(

"Validating config file: total length of the " 1843 "serialized linked section names ("

1844

to_string(prefixes.size()) +

1845 " bytes) exceeds the limit ("

1847 "bytes) in the section "

+ sname);

1848

*linked_sections_ok =

false

;

1853

k = conf_linked_sections.

begin

(); k != conf_linked_sections.