sharedDataHeader 43 shareddata.cpp static struct SharedData::Header *sharedDataHeader = NULL;
sharedDataHeader 79 shareddata.cpp memset(sharedDataHeader, 0, size);
sharedDataHeader 81 shareddata.cpp strcpy(sharedDataHeader->versionStr, SHM_VERSION_STR);
sharedDataHeader 83 shareddata.cpp sharedDataHeader->coordHost[0] = '\0';
sharedDataHeader 84 shareddata.cpp sharedDataHeader->coordPort = -1;
sharedDataHeader 85 shareddata.cpp sharedDataHeader->ckptInterval = -1;
sharedDataHeader 87 shareddata.cpp sharedDataHeader->dlsymOffset = 0;
sharedDataHeader 88 shareddata.cpp sharedDataHeader->dlsymOffset_m32 = 0;
sharedDataHeader 89 shareddata.cpp sharedDataHeader->numSysVShmIdMaps = 0;
sharedDataHeader 90 shareddata.cpp sharedDataHeader->numSysVSemIdMaps = 0;
sharedDataHeader 91 shareddata.cpp sharedDataHeader->numSysVMsqIdMaps = 0;
sharedDataHeader 92 shareddata.cpp sharedDataHeader->numPtraceIdMaps = 0;
sharedDataHeader 93 shareddata.cpp sharedDataHeader->numPtyNameMaps = 0;
sharedDataHeader 94 shareddata.cpp sharedDataHeader->initialized = true;
sharedDataHeader 95 shareddata.cpp sharedDataHeader->numIncomingConMaps = 0;
sharedDataHeader 96 shareddata.cpp memcpy(&sharedDataHeader->compId, compId, sizeof(*compId));
sharedDataHeader 97 shareddata.cpp memcpy(&sharedDataHeader->coordInfo, coordInfo, sizeof (*coordInfo));
sharedDataHeader 98 shareddata.cpp memcpy(&sharedDataHeader->localIPAddr, localIPAddr, sizeof (*localIPAddr));
sharedDataHeader 104 shareddata.cpp sharedDataHeader->nextVirtualPtyId = nextVirtualPtyId;
sharedDataHeader 106 shareddata.cpp sharedDataHeader->nextVirtualPtyId = 0;
sharedDataHeader 108 shareddata.cpp JASSERT(strlen(tmpDir) < sizeof(sharedDataHeader->tmpDir) - 1) (tmpDir);
sharedDataHeader 109 shareddata.cpp strcpy(sharedDataHeader->tmpDir, tmpDir);
sharedDataHeader 111 shareddata.cpp JASSERT(strlen(installDir) < sizeof(sharedDataHeader->installDir) - 1)
sharedDataHeader 113 shareddata.cpp strcpy(sharedDataHeader->installDir, installDir);
sharedDataHeader 118 shareddata.cpp return sharedDataHeader != NULL;
sharedDataHeader 165 shareddata.cpp sharedDataHeader = (struct Header*) addr;
sharedDataHeader 186 shareddata.cpp if (!Util::strStartsWith(sharedDataHeader->versionStr,
sharedDataHeader 188 shareddata.cpp JASSERT(false) (sharedDataHeader->versionStr) (SHM_VERSION_STR)
sharedDataHeader 193 shareddata.cpp JTRACE("Shared area mapped") (sharedDataHeader);
sharedDataHeader 198 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 199 shareddata.cpp sharedDataHeader->numInodeConnIdMaps = 0;
sharedDataHeader 204 shareddata.cpp if (sharedDataHeader != NULL) {
sharedDataHeader 205 shareddata.cpp nextVirtualPtyId = sharedDataHeader->nextVirtualPtyId;
sharedDataHeader 207 shareddata.cpp sharedDataHeader->numIncomingConMaps = 0;
sharedDataHeader 210 shareddata.cpp JASSERT(_real_munmap(sharedDataHeader, size) == 0) (JASSERT_ERRNO);
sharedDataHeader 211 shareddata.cpp sharedDataHeader = NULL;
sharedDataHeader 217 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 222 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 224 shareddata.cpp (const struct sockaddr_in*) &sharedDataHeader->coordInfo.addr;
sharedDataHeader 231 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 233 shareddata.cpp (const struct sockaddr_in*) &sharedDataHeader->coordInfo.addr;
sharedDataHeader 239 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 240 shareddata.cpp JASSERT(sharedDataHeader->tmpDir[0] != '\0');
sharedDataHeader 241 shareddata.cpp return string(sharedDataHeader->tmpDir);
sharedDataHeader 246 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 247 shareddata.cpp JASSERT(sharedDataHeader->tmpDir[0] != '\0');
sharedDataHeader 248 shareddata.cpp if (len <= strlen(sharedDataHeader->tmpDir)) {
sharedDataHeader 251 shareddata.cpp strcpy(buf, sharedDataHeader->tmpDir);
sharedDataHeader 257 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 258 shareddata.cpp return sharedDataHeader->installDir;
sharedDataHeader 263 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 264 shareddata.cpp return sharedDataHeader->coordInfo.interval;
sharedDataHeader 269 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 270 shareddata.cpp sharedDataHeader->compId._computation_generation = generation;
sharedDataHeader 274 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 275 shareddata.cpp return sharedDataHeader->compId;
sharedDataHeader 280 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 281 shareddata.cpp return sharedDataHeader->coordInfo.id;
sharedDataHeader 286 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 287 shareddata.cpp return sharedDataHeader->coordInfo.timeStamp;
sharedDataHeader 292 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 294 shareddata.cpp *len = sharedDataHeader->coordInfo.addrLen;
sharedDataHeader 295 shareddata.cpp memcpy(addr, &sharedDataHeader->coordInfo.addr, *len);
sharedDataHeader 300 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 303 shareddata.cpp (struct sockaddr_in*) &sharedDataHeader->coordInfo.addr;
sharedDataHeader 309 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 311 shareddata.cpp memcpy(in, &sharedDataHeader->localIPAddr, sizeof *in);
sharedDataHeader 317 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 318 shareddata.cpp JASSERT(sharedDataHeader->dlsymOffset == 0 ||
sharedDataHeader 319 shareddata.cpp sharedDataHeader->dlsymOffset == dlsymOffset)
sharedDataHeader 320 shareddata.cpp (dlsymOffset) (sharedDataHeader->dlsymOffset);
sharedDataHeader 322 shareddata.cpp JASSERT(sharedDataHeader->dlsymOffset_m32 == 0 ||
sharedDataHeader 323 shareddata.cpp sharedDataHeader->dlsymOffset_m32 == dlsymOffset_m32)
sharedDataHeader 324 shareddata.cpp (dlsymOffset_m32) (sharedDataHeader->dlsymOffset_m32);
sharedDataHeader 325 shareddata.cpp sharedDataHeader->dlsymOffset = dlsymOffset;
sharedDataHeader 326 shareddata.cpp sharedDataHeader->dlsymOffset_m32 = dlsymOffset_m32;
sharedDataHeader 331 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 332 shareddata.cpp return sharedDataHeader->dlsymOffset;
sharedDataHeader 337 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 338 shareddata.cpp return sharedDataHeader->dlsymOffset_m32;
sharedDataHeader 344 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 346 shareddata.cpp for (size_t i = 0; i < sharedDataHeader->numPidMaps; i++) {
sharedDataHeader 347 shareddata.cpp if (sharedDataHeader->pidMap[i].virt == virt) {
sharedDataHeader 348 shareddata.cpp res = sharedDataHeader->pidMap[i].real;
sharedDataHeader 358 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 360 shareddata.cpp for (i = 0; i < sharedDataHeader->numPidMaps; i++) {
sharedDataHeader 361 shareddata.cpp if (sharedDataHeader->pidMap[i].virt == virt) {
sharedDataHeader 362 shareddata.cpp sharedDataHeader->pidMap[i].real = real;
sharedDataHeader 366 shareddata.cpp if (i == sharedDataHeader->numPidMaps) {
sharedDataHeader 367 shareddata.cpp JASSERT(sharedDataHeader->numPidMaps < MAX_PID_MAPS);
sharedDataHeader 368 shareddata.cpp sharedDataHeader->pidMap[i].virt = virt;
sharedDataHeader 369 shareddata.cpp sharedDataHeader->pidMap[i].real = real;
sharedDataHeader 370 shareddata.cpp sharedDataHeader->numPidMaps++;
sharedDataHeader 380 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 384 shareddata.cpp nmaps = sharedDataHeader->numSysVShmIdMaps;
sharedDataHeader 385 shareddata.cpp map = sharedDataHeader->sysvShmIdMap;
sharedDataHeader 389 shareddata.cpp nmaps = sharedDataHeader->numSysVSemIdMaps;
sharedDataHeader 390 shareddata.cpp map = sharedDataHeader->sysvSemIdMap;
sharedDataHeader 394 shareddata.cpp nmaps = sharedDataHeader->numSysVMsqIdMaps;
sharedDataHeader 395 shareddata.cpp map = sharedDataHeader->sysvMsqIdMap;
sharedDataHeader 416 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 420 shareddata.cpp nmaps = &sharedDataHeader->numSysVShmIdMaps;
sharedDataHeader 421 shareddata.cpp map = sharedDataHeader->sysvShmIdMap;
sharedDataHeader 425 shareddata.cpp nmaps = &sharedDataHeader->numSysVSemIdMaps;
sharedDataHeader 426 shareddata.cpp map = sharedDataHeader->sysvSemIdMap;
sharedDataHeader 430 shareddata.cpp nmaps = &sharedDataHeader->numSysVMsqIdMaps;
sharedDataHeader 431 shareddata.cpp map = sharedDataHeader->sysvMsqIdMap;
sharedDataHeader 456 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 458 shareddata.cpp for (size_t i = 0; i < sharedDataHeader->numPtraceIdMaps; i++) {
sharedDataHeader 459 shareddata.cpp if (sharedDataHeader->ptraceIdMap[i].tracerId == tracerId) {
sharedDataHeader 460 shareddata.cpp childId = sharedDataHeader->ptraceIdMap[i].childId;
sharedDataHeader 461 shareddata.cpp sharedDataHeader->ptraceIdMap[i] =
sharedDataHeader 462 shareddata.cpp sharedDataHeader->ptraceIdMap[sharedDataHeader->numPtraceIdMaps];
sharedDataHeader 463 shareddata.cpp sharedDataHeader->numPtraceIdMaps--;
sharedDataHeader 473 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 475 shareddata.cpp for (i = 0; i < sharedDataHeader->numPtraceIdMaps; i++) {
sharedDataHeader 476 shareddata.cpp if (sharedDataHeader->ptraceIdMap[i].tracerId == tracerId) {
sharedDataHeader 481 shareddata.cpp if (i == sharedDataHeader->numPtraceIdMaps) {
sharedDataHeader 482 shareddata.cpp JASSERT(sharedDataHeader->numPtraceIdMaps < MAX_PTRACE_ID_MAPS);
sharedDataHeader 483 shareddata.cpp sharedDataHeader->numPtraceIdMaps++;
sharedDataHeader 485 shareddata.cpp sharedDataHeader->ptraceIdMap[i].tracerId = tracerId;
sharedDataHeader 486 shareddata.cpp sharedDataHeader->ptraceIdMap[i].childId = childId;
sharedDataHeader 492 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 493 shareddata.cpp JASSERT(sharedDataHeader->nextVirtualPtyId != (unsigned) -1);
sharedDataHeader 497 shareddata.cpp jalib::XToString(sharedDataHeader->nextVirtualPtyId++);
sharedDataHeader 499 shareddata.cpp JASSERT(sharedDataHeader->numPtyNameMaps < MAX_PTY_NAME_MAPS);
sharedDataHeader 500 shareddata.cpp size_t n = sharedDataHeader->numPtyNameMaps++;
sharedDataHeader 503 shareddata.cpp strcpy(sharedDataHeader->ptyNameMap[n].real, real);
sharedDataHeader 504 shareddata.cpp strcpy(sharedDataHeader->ptyNameMap[n].virt, virt.c_str());
sharedDataHeader 512 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 515 shareddata.cpp for (size_t i = 0; i < sharedDataHeader->numPtyNameMaps; i++) {
sharedDataHeader 516 shareddata.cpp if (strcmp(virt, sharedDataHeader->ptyNameMap[i].virt) == 0) {
sharedDataHeader 517 shareddata.cpp JASSERT(strlen(sharedDataHeader->ptyNameMap[i].real) < len);
sharedDataHeader 518 shareddata.cpp strcpy(out, sharedDataHeader->ptyNameMap[i].real);
sharedDataHeader 527 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 530 shareddata.cpp for (size_t i = 0; i < sharedDataHeader->numPtyNameMaps; i++) {
sharedDataHeader 531 shareddata.cpp if (strcmp(real, sharedDataHeader->ptyNameMap[i].real) == 0) {
sharedDataHeader 532 shareddata.cpp JASSERT(strlen(sharedDataHeader->ptyNameMap[i].virt) < len);
sharedDataHeader 533 shareddata.cpp strcpy(out, sharedDataHeader->ptyNameMap[i].virt);
sharedDataHeader 542 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 544 shareddata.cpp size_t n = sharedDataHeader->numPtyNameMaps++;
sharedDataHeader 547 shareddata.cpp strcpy(sharedDataHeader->ptyNameMap[n].real, real);
sharedDataHeader 548 shareddata.cpp strcpy(sharedDataHeader->ptyNameMap[n].virt, virt);
sharedDataHeader 556 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 559 shareddata.cpp size_t n = sharedDataHeader->numIncomingConMaps++;
sharedDataHeader 560 shareddata.cpp memcpy(sharedDataHeader->incomingConMap[n].id, ids[i], CON_ID_LEN);
sharedDataHeader 561 shareddata.cpp memcpy(&sharedDataHeader->incomingConMap[n].addr, &receiverAddr, len);
sharedDataHeader 562 shareddata.cpp sharedDataHeader->incomingConMap[n].len = len;
sharedDataHeader 569 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 570 shareddata.cpp *map = sharedDataHeader->incomingConMap;
sharedDataHeader 571 shareddata.cpp *nmaps = sharedDataHeader->numIncomingConMaps;
sharedDataHeader 576 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 578 shareddata.cpp size_t startIdx = sharedDataHeader->numInodeConnIdMaps;
sharedDataHeader 579 shareddata.cpp sharedDataHeader->numInodeConnIdMaps += maps.size();
sharedDataHeader 583 shareddata.cpp sharedDataHeader->inodeConnIdMap[startIdx + i] = maps[i];
sharedDataHeader 589 shareddata.cpp if (sharedDataHeader == NULL) initialize();
sharedDataHeader 591 shareddata.cpp if (sharedDataHeader->numInodeConnIdMaps > 0) {
sharedDataHeader 592 shareddata.cpp for (int i = sharedDataHeader->numInodeConnIdMaps - 1; i >= 0; i--) {
sharedDataHeader 593 shareddata.cpp InodeConnIdMap& map = sharedDataHeader->inodeConnIdMap[i];