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];