request.cc

nandflash文件系统源代码

/*!
 * \brief Parse out the headers from a STATS message.
 */
int
parseHandlerOpenFiles(Properties &prop, MetaRequest **r)
{
	seq_t seq = prop.getValue("Cseq", (seq_t) -1);

	*r = new MetaOpenFiles(seq);
	return 0;
}

/*!
 * \brief Generate response (a string) for various requests that
 * describes the result of the request execution.  The generated
 * response string is based on the KFS protocol.  All follow the same
 * model:
 * @param[out] os: A string stream that contains the response.
 */
void
MetaLookup::response(ostringstream &os)
{
	static string fname[] = { "empty", "file", "dir" };

	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	if (status < 0) {
		os << "\r\n";
		return;
	}
	os << "File-handle: " << toString(result.id()) << "\r\n";
	os << "Type: " << fname[result.type] << "\r\n";
	os << "Chunk-count: " << toString(result.chunkcount) << "\r\n";
	os << "File-size: " << toString(result.filesize) << "\r\n";
	os << "Replication: " << toString(result.numReplicas) << "\r\n";
	sendtime(os, "M-Time:", result.mtime, "\r\n");
	sendtime(os, "C-Time:", result.ctime, "\r\n");
	sendtime(os, "CR-Time:", result.crtime, "\r\n\r\n");
}

void
MetaLookupPath::response(ostringstream &os)
{
	static string fname[] = { "empty", "file", "dir" };

	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	if (status < 0) {
		os << "\r\n";
		return;
	}
	os << "File-handle: " << toString(result.id()) << "\r\n";
	os << "Type: " << fname[result.type] << "\r\n";
	os << "Chunk-count: " << toString(result.chunkcount) << "\r\n";
	os << "File-size: " << toString(result.filesize) << "\r\n";
	os << "Replication: " << toString(result.numReplicas) << "\r\n";
	sendtime(os, "M-Time:", result.mtime, "\r\n");
	sendtime(os, "C-Time:", result.ctime, "\r\n");
	sendtime(os, "CR-Time:", result.crtime, "\r\n\r\n");
}

void
MetaCreate::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	if (status < 0) {
		os << "\r\n";
		return;
	}
	os << "File-handle: " << toString(fid) << "\r\n\r\n";
}

void
MetaRemove::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaMkdir::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	if (status < 0) {
		os << "\r\n";
		return;
	}
	os << "File-handle: " << toString(fid) << "\r\n\r\n";
}

void
MetaRmdir::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaReaddir::response(ostringstream &os)
{
	vector<MetaDentry>::iterator iter;
	string res;
	int numEntries = 0;

	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	if (status < 0) {
		os << "\r\n";
		return;
	}
	// Send over the names---1 name per line so it is easy to
	// extract it out
	// XXX This should include the file id also, and probably
	// the other NFS READDIR elements, namely a cookie and
	// eof indicator to support reading less than a whole
	// directory at a time.
	for (iter = v.begin(); iter != v.end(); ++iter) {
		// "/" doesn't have "/" as an entry in it.
		if ((dir == ROOTFID) && (iter->getName() == "/"))
			continue;

		res = res + iter->getName() + "\n";
		++numEntries;
	}
	os << "Num-Entries: " << numEntries << "\r\n";
	os << "Content-length: " << res.length() << "\r\n\r\n";
	if (res.length() > 0)
		os << res;
}

void
MetaReaddirPlus::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	if (status < 0) {
		os << "\r\n";
		return;
	}
	os << "Num-Entries: " << numEntries << "\r\n";
	os << "Content-length: " << v.str().length() << "\r\n\r\n";
	os << v.str();
}

void
MetaRename::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaGetalloc::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	if (status < 0) {
		os << "\r\n";
		return;
	}
	os << "Chunk-handle: " << chunkId << "\r\n";
	os << "Chunk-version: " << chunkVersion << "\r\n";
	os << "Num-replicas: " << locations.size() << "\r\n";

	assert(locations.size() > 0);

	os << "Replicas:";
	for_each(locations.begin(), locations.end(), ListServerLocations(os));
	os << "\r\n\r\n";
}

void
MetaGetlayout::response(ostringstream &os)
{
	vector<ChunkLayoutInfo>::iterator iter;
	ChunkLayoutInfo l;
	string res;

	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	if (status < 0) {
		os << "\r\n";
		return;
	}
	os << "Num-chunks: " << v.size() << "\r\n";
	// Send over the layout info
	for (iter = v.begin(); iter != v.end(); ++iter) {
		l = *iter;
		res = res + l.toString();
	}
	os << "Content-length: " << res.length() << "\r\n\r\n";

	if (res.length() > 0)
		os << res;
}

void
MetaGetDirSummary::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	if (status < 0) {
		os << "\r\n";
		return;
	}
	os << "Num-files: " << numFiles << "\r\n";
	os << "Num-bytes: " << numBytes << "\r\n\r\n";
}

class PrintChunkServerLocations {
	ostringstream &os;
public:
	PrintChunkServerLocations(ostringstream &out): os(out) { }
	void operator () (ChunkServerPtr &s)
	{
		os << " " <<  s->ServerID();
	}
};

void
MetaAllocate::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	if (status < 0) {
		os << "\r\n";
		return;
	}
	os << "Chunk-handle: " << chunkId << "\r\n";
	os << "Chunk-version: " << chunkVersion << "\r\n";

	os << "Master: " << master->ServerID() << "\r\n";
	os << "Num-replicas: " << servers.size() << "\r\n";

	assert(servers.size() > 0);
	os << "Replicas:";
	for_each(servers.begin(), servers.end(), PrintChunkServerLocations(os));
	os << "\r\n\r\n";
}

void
MetaLeaseAcquire::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	if (status >= 0) {
		os << "Lease-id: " << leaseId << "\r\n";
	}
	os << "\r\n";
}

void
MetaLeaseRenew::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaLeaseRelinquish::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaHello::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaChunkCorrupt::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaTruncate::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaChangeFileReplication::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Num-replicas: " << numReplicas << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaRetireChunkserver::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaToggleRebalancing::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaToggleWORM::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaExecuteRebalancePlan::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";
}

void
MetaPing::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	os << "Build-version: " << KFS::KFS_BUILD_VERSION_STRING << "\r\n";
	os << "Source-version: " << KFS::KFS_SOURCE_REVISION_STRING << "\r\n";
	if (gWormMode)
		os << "WORM: " << 1 << "\r\n";
	else
		os << "WORM: " << 0 << "\r\n";
	os << "System Info: " << systemInfo << "\r\n";
	os << "Servers: " << servers << "\r\n";
	os << "Retiring Servers: " << retiringServers << "\r\n";
	os << "Down Servers: " << downServers << "\r\n\r\n";
}

void
MetaUpServers::response(ostringstream &os)
{
    os << "OK\r\n";
    os << "Cseq: " << opSeqno << "\r\n";
    os << "Status: " << status << "\r\n";
    os << "Content-length: " << stringStream.str().length() << "\r\n\r\n";
    if (stringStream.str().length() > 0)
        os << stringStream.str();
}

void
MetaStats::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	os << stats << "\r\n";
}

void
MetaDumpChunkToServerMap::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n\r\n";

	/*
    	ostringstream v;
	gLayoutManager.DumpChunkToServerMap(v);
	os << "Content-length: " << v.str().length() << "\r\n\r\n";
	if (v.str().length() > 0)
	    os << v.str();
	*/
}

void
MetaOpenFiles::response(ostringstream &os)
{
	os << "OK\r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Status: " << status << "\r\n";
	os << "Read: " << openForRead << "\r\n";
	os << "Write: " << openForWrite << "\r\n\r\n";
}

/*!
 * \brief Generate request (a string) that should be sent to the chunk
 * server.  The generated request string is based on the KFS
 * protocol.  All follow the same model:
 * @param[out] os: A string stream that contains the response.
 */
void
MetaChunkAllocate::request(ostringstream &os)
{
	MetaAllocate *allocOp = static_cast<MetaAllocate *>(req);
	assert(allocOp != NULL);

	os << "ALLOCATE \r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Version: KFS/1.0\r\n";
	os << "File-handle: " << allocOp->fid << "\r\n";
	os << "Chunk-handle: " << allocOp->chunkId << "\r\n";
	os << "Chunk-version: " << allocOp->chunkVersion << "\r\n";
	if (leaseId >= 0) {
		os << "Lease-id: " << leaseId << "\r\n";
	}

	os << "Num-servers: " << allocOp->servers.size() << "\r\n";
	assert(allocOp->servers.size() > 0);

	os << "Servers:";
	for_each(allocOp->servers.begin(), allocOp->servers.end(),
			PrintChunkServerLocations(os));
	os << "\r\n\r\n";
}

void
MetaChunkDelete::request(ostringstream &os)
{
	os << "DELETE \r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Version: KFS/1.0\r\n";
	os << "Chunk-handle: " << chunkId << "\r\n\r\n";
}

void
MetaChunkTruncate::request(ostringstream &os)
{
	os << "TRUNCATE \r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Version: KFS/1.0\r\n";
	os << "Chunk-handle: " << chunkId << "\r\n";
	os << "Chunk-size: " << chunkSize << "\r\n\r\n";
}

void
MetaChunkHeartbeat::request(ostringstream &os)
{
	os << "HEARTBEAT \r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Version: KFS/1.0\r\n\r\n";
}

void
MetaChunkStaleNotify::request(ostringstream &os)
{
	string s;
	vector<chunkId_t>::size_type i;

	os << "STALE_CHUNKS \r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Version: KFS/1.0\r\n";
	os << "Num-chunks: " << staleChunkIds.size() << "\r\n";
	for (i = 0; i < staleChunkIds.size(); ++i) {
		s += toString(staleChunkIds[i]);
		s += " ";
	}
	os << "Content-length: " << s.length() << "\r\n\r\n";
	os << s;
}

void
MetaChunkRetire::request(ostringstream &os)
{
	os << "RETIRE \r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Version: KFS/1.0\r\n\r\n";
}

void
MetaChunkVersChange::request(ostringstream &os)
{
	os << "CHUNK_VERS_CHANGE \r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Version: KFS/1.0\r\n";
	os << "File-handle: " << fid << "\r\n";
	os << "Chunk-handle: " << chunkId << "\r\n";
	os << "Chunk-version: " << chunkVersion << "\r\n\r\n";
}

void
MetaChunkReplicate::request(ostringstream &os)
{
	os << "REPLICATE \r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Version: KFS/1.0\r\n";
	os << "File-handle: " << fid << "\r\n";
	os << "Chunk-handle: " << chunkId << "\r\n";
	os << "Chunk-version: " << chunkVersion << "\r\n";
	os << "Chunk-location: " << srcLocation.ToString() << "\r\n\r\n";
}

void
MetaChunkSize::request(ostringstream &os)
{
	os << "SIZE \r\n";
	os << "Cseq: " << opSeqno << "\r\n";
	os << "Version: KFS/1.0\r\n";
	os << "File-handle: " << fid << "\r\n";
	os << "Chunk-handle: " << chunkId << "\r\n\r\n";
}