o 634 dmtcp_coordinator.cpp ostringstream o;
o 635 dmtcp_coordinator.cpp o << "Status..." << std::endl
o 642 dmtcp_coordinator.cpp o << "disabled (checkpoint manually instead)" << std::endl;
o 644 dmtcp_coordinator.cpp o << theCheckpointInterval << std::endl;
o 647 dmtcp_coordinator.cpp o << "Exit on last client: " << exitOnLast << std::endl
o 653 dmtcp_coordinator.cpp printf("%s", o.str().c_str());
o 886 dmtcp_coordinator.cpp ostringstream o;
o 887 dmtcp_coordinator.cpp o << tmpDir
o 889 dmtcp_coordinator.cpp JTRACE("Removing sharedArea file.") (o.str());
o 890 dmtcp_coordinator.cpp unlink(o.str().c_str());
o 1369 dmtcp_coordinator.cpp ostringstream o;
o 1372 dmtcp_coordinator.cpp o << string(ckptDir) << "/"
o 1375 dmtcp_coordinator.cpp o << "_" << std::setw(5) << std::setfill('0') << compId.computationGeneration();
o 1377 dmtcp_coordinator.cpp o << "." << RESTART_SCRIPT_EXT;
o 1378 dmtcp_coordinator.cpp uniqueFilename = o.str();
o 1435 dmtcp_coordinator.cpp ostringstream o;
o 1437 dmtcp_coordinator.cpp o << " " << *file;
o 1439 dmtcp_coordinator.cpp fprintf ( fp, "given_ckpt_files=\"%s\"\n\n", o.str().c_str());
o 96 dmtcpmessagetypes.cpp ostream& dmtcp::operator << ( dmtcp::ostream& o, const WorkerState& s )
o 98 dmtcpmessagetypes.cpp o << "WorkerState::";
o 101 dmtcpmessagetypes.cpp #define OSHIFTPRINTF(name) case WorkerState::name: o << #name; break;
o 115 dmtcpmessagetypes.cpp o << (int)s.value();
o 117 dmtcpmessagetypes.cpp return o;
o 136 dmtcpmessagetypes.cpp ostream& dmtcp::operator << ( dmtcp::ostream& o, const DmtcpMessageType & s )
o 142 dmtcpmessagetypes.cpp #define OSHIFTPRINTF(name) case name: o << #name; break;
o 193 dmtcpmessagetypes.cpp return o;
o 89 dmtcpmessagetypes.h ostream& operator << (ostream& o, const DmtcpMessageType& s);
o 175 dmtcpmessagetypes.h dmtcp::ostream& operator << ( dmtcp::ostream& o, const WorkerState& s );
o 209 dmtcpworker.cpp ostringstream o;
o 210 dmtcpworker.cpp o << "/proc/self/fd/" << PROTECTED_JASSERTLOG_FD;
o 211 dmtcpworker.cpp return jalib::Filesystem::ResolveSymlink(o.str());
o 220 dmtcpworker.cpp ostringstream o;
o 221 dmtcpworker.cpp o << "========================================\n"
o 229 dmtcpworker.cpp Util::writeAll(fd, o.str().c_str(), o.str().length());
o 112 plugin/ipc/connection.cpp void Connection::serialize(jalib::JBinarySerializer& o)
o 115 plugin/ipc/connection.cpp o & _id & _type & _fcntlFlags & _fcntlOwner & _fcntlSignal;
o 116 plugin/ipc/connection.cpp o.serializeVector(_fds);
o 117 plugin/ipc/connection.cpp serializeSubClass(o);
o 96 plugin/ipc/connection.h void serialize(jalib::JBinarySerializer& o);
o 98 plugin/ipc/connection.h virtual void serializeSubClass(jalib::JBinarySerializer& o) = 0;
o 41 plugin/ipc/connectionidentifier.cpp void ConnectionIdentifier::serialize (jalib::JBinarySerializer& o)
o 44 plugin/ipc/connectionidentifier.cpp o & _nextConId;
o 85 plugin/ipc/connectionidentifier.cpp ostream& dmtcp::operator<<(ostream& o, const ConnectionIdentifier& id)
o 87 plugin/ipc/connectionidentifier.cpp o << std::hex << id.hostid()
o 91 plugin/ipc/connectionidentifier.cpp return o;
o 47 plugin/ipc/connectionidentifier.h static void serialize ( jalib::JBinarySerializer& o );
o 113 plugin/ipc/connectionidentifier.h ostream& operator<<(ostream& o, const ConnectionIdentifier& id);
o 223 plugin/ipc/connectionlist.cpp void ConnectionList::serialize(jalib::JBinarySerializer& o)
o 228 plugin/ipc/connectionlist.cpp ConnectionIdentifier::serialize(o);
o 233 plugin/ipc/connectionlist.cpp o & numCons;
o 235 plugin/ipc/connectionlist.cpp if (o.isWriter()) {
o 242 plugin/ipc/connectionlist.cpp o & key & type;
o 243 plugin/ipc/connectionlist.cpp con.serialize(o);
o 253 plugin/ipc/connectionlist.cpp o & key & type;
o 256 plugin/ipc/connectionlist.cpp con->serialize(o);
o 270 plugin/ipc/connectionlist.cpp ostringstream o;
o 271 plugin/ipc/connectionlist.cpp o << "\n";
o 276 plugin/ipc/connectionlist.cpp o << fds[j];
o 278 plugin/ipc/connectionlist.cpp o << "," ;
o 280 plugin/ipc/connectionlist.cpp o << "\t" << i->first << "\t" << c->str();
o 281 plugin/ipc/connectionlist.cpp o << "\n";
o 283 plugin/ipc/connectionlist.cpp JTRACE("ConnectionList") (dmtcp_get_uniquepid_str()) (o.str());
o 61 plugin/ipc/connectionlist.h void serialize(jalib::JBinarySerializer& o);
o 81 plugin/ipc/event/eventconnection.cpp void EpollConnection::serializeSubClass(jalib::JBinarySerializer& o)
o 84 plugin/ipc/event/eventconnection.cpp o & _type & _stat;
o 85 plugin/ipc/event/eventconnection.cpp o.serializeMap(_fdToEvent);
o 180 plugin/ipc/event/eventconnection.cpp void EventFdConnection::serializeSubClass(jalib::JBinarySerializer& o)
o 183 plugin/ipc/event/eventconnection.cpp o & _initval & _flags;
o 241 plugin/ipc/event/eventconnection.cpp void SignalFdConnection::serializeSubClass(jalib::JBinarySerializer& o)
o 244 plugin/ipc/event/eventconnection.cpp o & _flags & _mask & _fdsi;
o 300 plugin/ipc/event/eventconnection.cpp void InotifyConnection::serializeSubClass(jalib::JBinarySerializer& o)
o 303 plugin/ipc/event/eventconnection.cpp o & _type & _stat;
o 94 plugin/ipc/event/eventconnection.h virtual void serializeSubClass(jalib::JBinarySerializer& o);
o 124 plugin/ipc/event/eventconnection.h virtual void serializeSubClass(jalib::JBinarySerializer& o);
o 155 plugin/ipc/event/eventconnection.h virtual void serializeSubClass(jalib::JBinarySerializer& o);
o 192 plugin/ipc/event/eventconnection.h virtual void serializeSubClass(jalib::JBinarySerializer& o);
o 487 plugin/ipc/file/fileconnection.cpp void PtyConnection::serializeSubClass(jalib::JBinarySerializer& o)
o 490 plugin/ipc/file/fileconnection.cpp o & _ptsName & _virtPtsName & _masterName & _type;
o 491 plugin/ipc/file/fileconnection.cpp o & _flags & _mode & _preExistingCTTY;
o 931 plugin/ipc/file/fileconnection.cpp void FileConnection::serializeSubClass(jalib::JBinarySerializer& o)
o 934 plugin/ipc/file/fileconnection.cpp o & _path & _rel_path;
o 935 plugin/ipc/file/fileconnection.cpp o & _offset & _st_dev & _st_ino & _st_size & _ckpted_file & _rmtype;
o 1052 plugin/ipc/file/fileconnection.cpp void FifoConnection::serializeSubClass(jalib::JBinarySerializer& o)
o 1055 plugin/ipc/file/fileconnection.cpp o & _path & _rel_path & _savedRelativePath & _mode & _in_data;
o 1170 plugin/ipc/file/fileconnection.cpp void PosixMQConnection::serializeSubClass(jalib::JBinarySerializer& o)
o 1173 plugin/ipc/file/fileconnection.cpp o & _name & _oflag & _mode & _attr;
o 71 plugin/ipc/file/fileconnection.h virtual void serializeSubClass(jalib::JBinarySerializer& o);
o 107 plugin/ipc/file/fileconnection.h virtual void serializeSubClass(jalib::JBinarySerializer& o) {}
o 146 plugin/ipc/file/fileconnection.h virtual void serializeSubClass(jalib::JBinarySerializer& o);
o 206 plugin/ipc/file/fileconnection.h virtual void serializeSubClass(jalib::JBinarySerializer& o);
o 242 plugin/ipc/file/fileconnection.h virtual void serializeSubClass(jalib::JBinarySerializer& o);
o 202 plugin/ipc/socket/connectionrewirer.cpp ostringstream o;
o 203 plugin/ipc/socket/connectionrewirer.cpp o << dmtcp_get_uniquepid_str() << "_" << dmtcp_get_coordinator_timestamp();
o 204 plugin/ipc/socket/connectionrewirer.cpp string str = o.str();
o 314 plugin/ipc/socket/connectionrewirer.cpp ostringstream o;
o 315 plugin/ipc/socket/connectionrewirer.cpp o << "Pending Incoming:\n";
o 319 plugin/ipc/socket/connectionrewirer.cpp o << i->first << " numFds=" << con->getFds().size()
o 322 plugin/ipc/socket/connectionrewirer.cpp o << "Pending Outgoing:\n";
o 325 plugin/ipc/socket/connectionrewirer.cpp o << i->first << " numFds=" << con->getFds().size()
o 328 plugin/ipc/socket/connectionrewirer.cpp JNOTE("Pending connections") (o.str());
o 104 plugin/ipc/socket/socketconnection.cpp void SocketConnection::serialize(jalib::JBinarySerializer& o)
o 107 plugin/ipc/socket/socketconnection.cpp o & _sockDomain & _sockType & _sockProtocol & _peerType;
o 111 plugin/ipc/socket/socketconnection.cpp o & numSockOpts;
o 112 plugin/ipc/socket/socketconnection.cpp if (o.isWriter()) {
o 118 plugin/ipc/socket/socketconnection.cpp o & numLvl;
o 127 plugin/ipc/socket/socketconnection.cpp o & lvlVal & numOpts;
o 137 plugin/ipc/socket/socketconnection.cpp o & optType & bufLen;
o 138 plugin/ipc/socket/socketconnection.cpp o.readOrWrite(buffer.buffer(), bufLen);
o 143 plugin/ipc/socket/socketconnection.cpp o & numLvl;
o 151 plugin/ipc/socket/socketconnection.cpp o & lvlVal & numOpts;
o 159 plugin/ipc/socket/socketconnection.cpp o & optType & bufLen;
o 162 plugin/ipc/socket/socketconnection.cpp o.readOrWrite(buffer.buffer(), bufLen);
o 628 plugin/ipc/socket/socketconnection.cpp void TcpConnection::serializeSubClass(jalib::JBinarySerializer& o)
o 631 plugin/ipc/socket/socketconnection.cpp o & _listenBacklog & _bindAddrlen & _bindAddr & _remotePeerId;
o 632 plugin/ipc/socket/socketconnection.cpp SocketConnection::serialize(o);
o 685 plugin/ipc/socket/socketconnection.cpp void RawSocketConnection::serializeSubClass(jalib::JBinarySerializer& o)
o 688 plugin/ipc/socket/socketconnection.cpp SocketConnection::serialize(o);
o 57 plugin/ipc/socket/socketconnection.h void serialize(jalib::JBinarySerializer& o);
o 117 plugin/ipc/socket/socketconnection.h virtual void serializeSubClass(jalib::JBinarySerializer& o);
o 146 plugin/ipc/socket/socketconnection.h virtual void serializeSubClass(jalib::JBinarySerializer& o);
o 130 plugin/pid/pid.cpp ostringstream o;
o 131 plugin/pid/pid.cpp o << dmtcp_get_tmpdir() << "/dmtcpPidMap."
o 134 plugin/pid/pid.cpp pidMapFile = o.str();
o 346 plugin/svipc/sysvipc.cpp void SysVIPC::serialize(jalib::JBinarySerializer& o)
o 348 plugin/svipc/sysvipc.cpp _virtIdTable.serialize(o);
o 93 plugin/svipc/sysvipc.h void serialize(jalib::JBinarySerializer& o);
o 277 processinfo.cpp ostringstream o;
o 278 processinfo.cpp o << _ckptDir << "/"
o 283 processinfo.cpp _ckptFileName = o.str() + CKPT_FILE_SUFFIX;
o 284 processinfo.cpp _ckptFilesSubDir = o.str() + CKPT_FILES_SUBDIR_SUFFIX;
o 541 processinfo.cpp void ProcessInfo::serialize(jalib::JBinarySerializer& o)
o 546 processinfo.cpp o & _elfType;
o 547 processinfo.cpp o & _isRootOfProcessTree & _pid & _sid & _ppid & _gid & _fgid & _generation;
o 548 processinfo.cpp o & _procname & _hostname & _launchCWD & _ckptCWD & _upid & _uppid;
o 549 processinfo.cpp o & _compGroup & _numPeers & _noCoordinator & _argvSize & _envSize;
o 550 processinfo.cpp o & _restoreBufAddr & _savedHeapStart & _savedBrk;
o 551 processinfo.cpp o & _vdsoStart & _vdsoEnd & _vvarStart & _vvarEnd;
o 552 processinfo.cpp o & _ckptDir & _ckptFileName & _ckptFilesSubDir;
o 565 processinfo.cpp JTRACE("Serializing ChildPid Table") (_childTable.size()) (o.filename());
o 566 processinfo.cpp o.serializeMap(_childTable);
o 72 processinfo.h void serialize ( jalib::JBinarySerializer& o );
o 138 shareddata.cpp ostringstream o;
o 139 shareddata.cpp o << tmpDir << "/dmtcpSharedArea."
o 142 shareddata.cpp int fd = _real_open(o.str().c_str(), O_RDWR | O_CREAT | O_EXCL, 0600);
o 144 shareddata.cpp fd = _real_open(o.str().c_str(), O_RDWR, 0600);
o 141 uniquepid.cpp ostream& dmtcp::operator<< ( dmtcp::ostream& o,const UniquePid& id )
o 143 uniquepid.cpp o << std::hex << id.hostid() << '-' << std::dec << id.pid() << '-' << std::hex << id.time() << std::dec;
o 144 uniquepid.cpp return o;
o 147 uniquepid.cpp ostream& dmtcp::operator<< ( dmtcp::ostream& o,const DmtcpUniqueProcessId& id )
o 149 uniquepid.cpp o << std::hex << id._hostid<< '-' << std::dec << id._pid << '-' << std::hex << id._time << std::dec;
o 150 uniquepid.cpp return o;
o 169 uniquepid.cpp ostringstream o;
o 170 uniquepid.cpp o << *this;
o 171 uniquepid.cpp return o.str();
o 187 uniquepid.cpp void UniquePid::serialize ( jalib::JBinarySerializer& o )
o 192 uniquepid.cpp if ( o.isWriter() )
o 198 uniquepid.cpp o & theCurrentProcess & theParentProcess;
o 200 uniquepid.cpp if ( o.isReader() )
o 70 uniquepid.h static void serialize( jalib::JBinarySerializer& o );
o 84 uniquepid.h ostream& operator << ( ostream& o,const UniquePid& id );
o 85 uniquepid.h ostream& operator << ( ostream& o,const DmtcpUniqueProcessId& id );
o 159 util_init.cpp ostringstream o;
o 160 util_init.cpp o << tmpdirenv << "/dmtcp-" << userName << "@" << hostname;
o 161 util_init.cpp string tmpDir = o.str();
o 179 util_init.cpp ostringstream o;
o 180 util_init.cpp o << tmpDir;
o 181 util_init.cpp o << "/jassertlog.";
o 182 util_init.cpp o << UniquePid::ThisProcess();
o 183 util_init.cpp o << "_";
o 185 util_init.cpp o << jalib::Filesystem::GetProgramName();
o 187 util_init.cpp o << procname;
o 190 util_init.cpp JASSERT_SET_LOG(o.str(), tmpDir, UniquePid::ThisProcess().toString());