A RetroSearch Logo

Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Search Query:

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/ns__db__dump_8cpp_source.html below:

NCBI C++ ToolKit: src/app/netschedule/ns_db_dump.cpp Source File

66

job_props_fixed_size(sizeof(

SJobDump

)),

76  throw

runtime_error(

strerror

(errno));

85  throw

runtime_error(

"Incomplete dump file header"

);

89  throw

runtime_error(

strerror

(errno));

90  throw

runtime_error(

"Unknown dump file header reading error"

);

96  throw

runtime_error(

"Dump file header magic does not match the current one. " 97  "It is an older NetSchedule dump file and cannot be used. " 98  "The old dump files will be deleted."

);

101  throw

runtime_error(

"Dump file header magic does not match"

);

117  throw

runtime_error(

strerror

(errno));

126  throw

runtime_error(

"Incomplete dump file header"

);

130  throw

runtime_error(

strerror

(errno));

131  throw

runtime_error(

"Unknown dump file header reading error"

);

137  throw

runtime_error(

"Dump file header magic does not match the current one. " 138  "It is an older NetSchedule dump file and cannot be used. " 139  "The old dump files will be deleted."

);

142  throw

runtime_error(

"Dump file header magic does not match"

);

150

memset(

this

, 0,

sizeof

(

SJobDump

));

158  if

(fwrite(

this

,

sizeof

(

SJobDump

), 1,

f

) != 1)

159  throw

runtime_error(

strerror

(errno));

164  throw

runtime_error(

strerror

(errno));

169  size_t

fixed_size_from_header,

172

memset(

this

, 0,

sizeof

(

SJobDump

));

174  size_t

size_to_read =

min

(

sizeof

(

SJobDump

), fixed_size_from_header);

177  size_t

bytes = fread(

this

, 1, size_to_read,

f

);

178  if

(bytes != size_to_read) {

180  throw

runtime_error(

"Incomplete job record reading"

);

184  throw

runtime_error(

strerror

(errno));

185  throw

runtime_error(

"Unknown job record reading error"

);

187  if

(fixed_size_from_header > size_to_read) {

188  size_t

bytes_to_skip = fixed_size_from_header - size_to_read;

192  throw

runtime_error(

strerror

(errno));

193  throw

runtime_error(

"Unknown job record skipping error"

);

198  string msg

=

"Client IP has been stripped from "

+

202  " (job id "

+ to_string(

id

) +

")"

;

208  string msg

=

"Client session id has been stripped from "

+

212  " (job id "

+ to_string(

id

) +

")"

;

218  string msg

=

"PHID has been stripped from "

+

222  " (job id "

+ to_string(

id

) +

")"

;

228  throw

runtime_error(

"Job progress message size is more " 229  "than max allowed"

);

235  throw

runtime_error(

"Incomplete job progress message reading"

);

237  throw

runtime_error(

"Unexpected end of job info file. " 238  "Expected a progress message, got EOF"

);

240  throw

runtime_error(

strerror

(errno));

241  throw

runtime_error(

"Unknown job progress message reading error"

);

250  throw

runtime_error(

strerror

(errno));

251  throw

runtime_error(

"Unknown job record skipping error"

);

274  if

(fwrite(

this

,

sizeof

(

SJobIODump

), 1,

f

) != 1)

275  throw

runtime_error(

strerror

(errno));

280  throw

runtime_error(

strerror

(errno));

286  throw

runtime_error(

strerror

(errno));

296  size_t

size_to_read =

min

(

sizeof

(

SJobIODump

), fixed_size_from_header);

299  size_t

bytes = fread(

this

, 1, size_to_read,

f

);

300  if

(bytes != size_to_read) {

302  throw

runtime_error(

"Incomplete job i/o record reading"

);

304  throw

runtime_error(

"Unexpected end of job info file. " 305  "Expected a job i/o, got EOF"

);

307  throw

runtime_error(

strerror

(errno));

308  throw

runtime_error(

"Unknown job i/o reading error"

);

310  if

(fixed_size_from_header > size_to_read) {

311  size_t

bytes_to_skip = fixed_size_from_header - size_to_read;

315  throw

runtime_error(

strerror

(errno));

316  throw

runtime_error(

"Unknown job i/o record skipping error"

);

321  throw

runtime_error(

"Job input size is more " 322  "than max allowed"

);

328  throw

runtime_error(

"Incomplete job input reading"

);

330  throw

runtime_error(

"Unexpected end of job info file. " 331  "Expected an input, got EOF"

);

333  throw

runtime_error(

strerror

(errno));

334  throw

runtime_error(

"Unknown job input reading error"

);

339  throw

runtime_error(

"Job output size is more " 340  "than max allowed"

);

346  throw

runtime_error(

"Incomplete job output reading"

);

348  throw

runtime_error(

"Unexpected end of job info file. " 349  "Expected an output, got EOF"

);

351  throw

runtime_error(

strerror

(errno));

352  throw

runtime_error(

"Unknown job output reading error"

);

358

fixed_size_from_header -

362  throw

runtime_error(

strerror

(errno));

363  throw

runtime_error(

"Unknown job i/o record skipping error"

);

377  const char

* client_session,

378  const char

* err_msg)

385  throw

runtime_error(

strerror

(errno));

390  throw

runtime_error(

strerror

(errno));

395  throw

runtime_error(

strerror

(errno));

400  throw

runtime_error(

strerror

(errno));

406  char

* client_session,

412

fixed_size_from_header);

415  size_t

bytes = fread(

this

, 1, size_to_read,

f

);

416  if

(bytes != size_to_read) {

418  throw

runtime_error(

"Incomplete job event reading"

);

420  throw

runtime_error(

"Unexpected end of job info file. " 421  "Expected a job event, got EOF"

);

423  throw

runtime_error(

strerror

(errno));

424  throw

runtime_error(

"Unknown job event reading error"

);

426  if

(fixed_size_from_header > size_to_read) {

427  size_t

bytes_to_skip = fixed_size_from_header - size_to_read;

431  throw

runtime_error(

strerror

(errno));

432  throw

runtime_error(

"Unknown job event record skipping error"

);

437  throw

runtime_error(

"Job event client node size is more " 438  "than max allowed"

);

444  throw

runtime_error(

"Incomplete job event client node reading"

);

446  throw

runtime_error(

"Unexpected end of job info file. " 447  "Expected a client node, got EOF"

);

449  throw

runtime_error(

strerror

(errno));

450  throw

runtime_error(

"Unknown job event client node reading error"

);

455  throw

runtime_error(

"Job event client session size is more " 456  "than max allowed"

);

462  throw

runtime_error(

"Incomplete job event " 463  "client session reading"

);

465  throw

runtime_error(

"Unexpected end of job info file. " 466  "Expected a client session, got EOF"

);

468  throw

runtime_error(

strerror

(errno));

469  throw

runtime_error(

"Unknown job event " 470  "client session reading error"

);

475  throw

runtime_error(

"Job event error message size is more " 476  "than max allowed"

);

482  throw

runtime_error(

"Incomplete job event " 483  "error message reading"

);

485  throw

runtime_error(

"Unexpected end of job info file. " 486  "Expected an error message, got EOF"

);

488  throw

runtime_error(

strerror

(errno));

489  throw

runtime_error(

"Unknown job event " 490  "error message reading error"

);

497

fixed_size_from_header -

502  throw

runtime_error(

strerror

(errno));

503  throw

runtime_error(

"Unknown job event record skipping error"

);

523  throw

runtime_error(

strerror

(errno));

531

fixed_size_from_header);

534  size_t

bytes = fread(

this

, 1, size_to_read,

f

);

535  if

(bytes != size_to_read) {

537  throw

runtime_error(

"Incomplete affinity reading"

);

541  throw

runtime_error(

strerror

(errno));

542  throw

runtime_error(

"Unknown affinity reading error"

);

546  throw

runtime_error(

"Affinity token size is more " 547  "than max allowed"

);

549  if

(fixed_size_from_header > size_to_read) {

550  size_t

bytes_to_skip = fixed_size_from_header - size_to_read;

554  throw

runtime_error(

strerror

(errno));

555  throw

runtime_error(

"Unknown affinity skipping error"

);

574  throw

runtime_error(

strerror

(errno));

582

fixed_size_from_header);

585  size_t

bytes = fread(

this

, 1, size_to_read,

f

);

586  if

(bytes != size_to_read) {

588  throw

runtime_error(

"Incomplete job group reading"

);

592  throw

runtime_error(

strerror

(errno));

593  throw

runtime_error(

"Unknown job group reading error"

);

597  throw

runtime_error(

"Group token size is more " 598  "than max allowed"

);

600  if

(fixed_size_from_header > size_to_read) {

601  size_t

bytes_to_skip = fixed_size_from_header - size_to_read;

605  throw

runtime_error(

strerror

(errno));

606  throw

runtime_error(

"Unknown group skipping error"

);

625  throw

runtime_error(

strerror

(errno));

633

fixed_size_from_header);

636  size_t

bytes = fread(

this

, 1, size_to_read,

f

);

637  if

(bytes != size_to_read) {

639  throw

runtime_error(

"Incomplete queue description reading"

);

643  throw

runtime_error(

strerror

(errno));

644  throw

runtime_error(

"Unknown queue description reading error"

);

648  throw

runtime_error(

"Queue name size is more " 649  "than max allowed"

);

651  throw

runtime_error(

"Queue class name size is more " 652  "than max allowed"

);

654  throw

runtime_error(

"Program name size is more " 655  "than max allowed"

);

657  throw

runtime_error(

"Submitter hosts size is more " 658  "than max allowed"

);

660  throw

runtime_error(

"Worker node hosts size is more " 661  "than max allowed"

);

663  throw

runtime_error(

"Reader hosts size is more " 664  "than max allowed"

);

666  throw

runtime_error(

"Description size is more " 667  "than max allowed"

);

669  throw

runtime_error(

"Linked section prefixes size is more " 670  "than max allowed"

);

672  throw

runtime_error(

"Linked section names size is more " 673  "than max allowed"

);

675  if

(fixed_size_from_header > size_to_read) {

676  size_t

bytes_to_skip = fixed_size_from_header - size_to_read;

680  throw

runtime_error(

strerror

(errno));

681  throw

runtime_error(

"Unknown queue description skipping error"

);

699  throw

runtime_error(

strerror

(errno));

707

fixed_size_from_header);

710  size_t

bytes = fread(

this

, 1, size_to_read,

f

);

711  if

(bytes != size_to_read) {

713  throw

runtime_error(

"Incomplete linked section reading"

);

717  throw

runtime_error(

strerror

(errno));

718  throw

runtime_error(

"Unknown linked section reading error"

);

722  throw

runtime_error(

"Linked section name size is more " 723  "than max allowed"

);

725  throw

runtime_error(

"Linked section value name size is more " 726  "than max allowed"

);

728  throw

runtime_error(

"Linked section value size is more " 729  "than max allowed"

);

731  if

(fixed_size_from_header > size_to_read) {

732  size_t

bytes_to_skip = fixed_size_from_header - size_to_read;

736  throw

runtime_error(

strerror

(errno));

737  throw

runtime_error(

"Unknown linked section skipping error"

);

static CNcbiApplication * Instance(void)

Singleton method.

static CNetScheduleServer * GetInstance(void)

void RegisterAlert(EAlertType alert_type, const string &message)

static SQLCHAR output[256]

CVersionInfo GetVersion(void) const

Get the program version information.

#define ERR_POST(message)

Error posting with file, line number information but without error codes.

void Warning(CExceptionArgs_Base &args)

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

int GetMajor(void) const

Major version.

int GetMinor(void) const

Minor version.

int GetPatchLevel(void) const

Patch level.

const unsigned int kNetScheduleMaxDBDataSize

const unsigned int kNetScheduleMaxDBErrSize

#define NETSCHEDULED_STORAGE_VERSION_MAJOR

#define NETSCHEDULED_STORAGE_VERSION_PATCH

#define NETSCHEDULED_STORAGE_VERSION_MINOR

vector< Uint4 > kOldDumpMagic

const unsigned kMaxHitIdSize

const unsigned kLinkedSectionsList

const unsigned kMaxWorkerNodeIdSize

const unsigned kLinkedSectionValueSize

const unsigned kLinkedSectionValueNameSize

const unsigned kMaxSessionIdSize

const unsigned kMaxDescriptionSize

const unsigned kMaxClientIpSize

const Uint4 kDumpMagic(0xF0F0F0F0)

const unsigned kNetScheduleMaxOverflowSize

const unsigned kMaxQueueLimitsSize

const unsigned kMaxQueueNameSize

static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

int Read(FILE *f, size_t fixed_size_from_header)

int Read(FILE *f, size_t fixed_size_from_header)

void Write(FILE *f, const char *progress_msg)

char client_sid[kMaxSessionIdSize]

int Read(FILE *f, size_t fixed_size_from_header, char *progress_msg)

char client_ip[kMaxClientIpSize]

char ncbi_phid[kMaxHitIdSize]

void Write(FILE *f, const char *client_node, const char *client_session, const char *err_msg)

Uint4 client_session_size

int Read(FILE *f, size_t fixed_size_from_header, char *client_node, char *client_session, char *err_msg)

int Read(FILE *f, size_t fixed_size_from_header, char *input, char *output)

void Write(FILE *f, const char *input, const char *output)

int Read(FILE *f, size_t fixed_size_from_header)

int Read(FILE *f, size_t fixed_size_from_header)

Uint4 linked_section_prefixes_size

Uint4 linked_section_names_size


RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4