Ck::IO::impl::WriteSession Class Reference

Inheritance diagram for Ck::IO::impl::WriteSession:

[legend]

Collaboration diagram for Ck::IO::impl::WriteSession:

[legend]

Public Member Functions
	WriteSession (FileToken file_, size_t offset_, size_t bytes_)
	WriteSession (CkMigrateMessage *m)
void	forwardData (const char *data, size_t bytes, size_t offset)
void	syncData ()
void	flushBuffer (buffer &buf, size_t bufferOffset)
Private Attributes
const FileInfo *	file
size_t	sessionOffset
size_t	myOffset
size_t	sessionBytes
size_t	myBytes
size_t	myBytesWritten
FileToken	token
map< size_t, struct buffer >	bufferMap
Data Structures
struct	buffer

---

Detailed Description

Definition at line 271 of file ckio.C.

---

Constructor & Destructor Documentation

Ck::IO::impl::WriteSession::WriteSession	(	FileToken	file_,
		size_t	offset_,
		size_t	bytes_
	)			[inline]

Definition at line 303 of file ckio.C.

References Ck::IO::impl::FileInfo::fd, file, myBytes, myOffset, sessionBytes, and sessionOffset.

Ck::IO::impl::WriteSession::WriteSession

(

CkMigrateMessage *

m

)

[inline]

Definition at line 318 of file ckio.C.

---

Member Function Documentation

void Ck::IO::impl::WriteSession::forwardData	(	const char *	data,
		size_t	bytes,
		size_t	offset
	)			[inline]

Definition at line 320 of file ckio.C.

References bufferMap, Ck::IO::impl::WriteSession::buffer::expect(), file, flushBuffer(), Ck::IO::impl::WriteSession::buffer::insertData(), Ck::IO::impl::WriteSession::buffer::isFull(), max(), min(), myBytes, myBytesWritten, myOffset, Ck::IO::impl::FileInfo::opts, and Ck::IO::Options::writeStripe.

Here is the call graph for this function:

void Ck::IO::impl::WriteSession::syncData

(

)

[inline]

Definition at line 352 of file ckio.C.

References bufferMap, Ck::IO::impl::director, Ck::IO::impl::fatalError(), Ck::IO::impl::FileInfo::fd, file, fsync(), CkReduction::max_int, Ck::IO::impl::FileInfo::name, status, and token.

Here is the call graph for this function:

void Ck::IO::impl::WriteSession::flushBuffer	(	buffer &	buf,
		size_t	bufferOffset
	)			[inline]

Definition at line 382 of file ckio.C.

References Ck::IO::impl::WriteSession::buffer::array, Ck::IO::impl::WriteSession::buffer::bytes_filled_so_far, CmiPwrite(), PUP::d, Ck::IO::impl::fatalError(), Ck::IO::impl::FileInfo::fd, file, PUP::l, myBytesWritten, and Ck::IO::impl::FileInfo::name.

Referenced by forwardData().

Here is the call graph for this function:

Here is the caller graph for this function:

---

Field Documentation

const FileInfo* Ck::IO::impl::WriteSession::file [private]

Definition at line 272 of file ckio.C.

Referenced by flushBuffer(), forwardData(), syncData(), and WriteSession().

size_t Ck::IO::impl::WriteSession::sessionOffset [private]

Definition at line 273 of file ckio.C.

Referenced by WriteSession().

size_t Ck::IO::impl::WriteSession::myOffset [private]

Definition at line 273 of file ckio.C.

Referenced by forwardData(), and WriteSession().

size_t Ck::IO::impl::WriteSession::sessionBytes [private]

Definition at line 274 of file ckio.C.

Referenced by WriteSession().

size_t Ck::IO::impl::WriteSession::myBytes [private]

Definition at line 274 of file ckio.C.

Referenced by forwardData(), and WriteSession().

size_t Ck::IO::impl::WriteSession::myBytesWritten [private]

Definition at line 274 of file ckio.C.

Referenced by flushBuffer(), and forwardData().

FileToken Ck::IO::impl::WriteSession::token [private]

Definition at line 275 of file ckio.C.

Referenced by syncData().

map<size_t, struct buffer> Ck::IO::impl::WriteSession::bufferMap [private]

Definition at line 300 of file ckio.C.

Referenced by forwardData(), and syncData().

---

The documentation for this class was generated from the following file:

• libs/ck-libs/io/ckio.C