From 4dabd9c0472deb49573fdafef2fa413e59703f19 Mon Sep 17 00:00:00 2001 From: Steven Bennetts Date: Fri, 2 Mar 2007 21:25:50 +0000 Subject: merge release@58699 beta-1-14-0@58707 -> release --- indra/llvfs/llvfsthread.cpp | 64 ++++++++++++++++++--------------------------- 1 file changed, 26 insertions(+), 38 deletions(-) (limited to 'indra/llvfs/llvfsthread.cpp') diff --git a/indra/llvfs/llvfsthread.cpp b/indra/llvfs/llvfsthread.cpp index 619c1b9bb3..57cdb7626e 100644 --- a/indra/llvfs/llvfsthread.cpp +++ b/indra/llvfs/llvfsthread.cpp @@ -20,10 +20,10 @@ //============================================================================ // Run on MAIN thread //static -void LLVFSThread::initClass(bool local_is_threaded, bool local_run_always) +void LLVFSThread::initClass(bool local_is_threaded) { llassert(sLocal == NULL); - sLocal = new LLVFSThread(local_is_threaded, local_run_always); + sLocal = new LLVFSThread(local_is_threaded); } //static @@ -47,8 +47,8 @@ void LLVFSThread::cleanupClass() //---------------------------------------------------------------------------- -LLVFSThread::LLVFSThread(bool threaded, bool runalways) : - LLQueuedThread("VFS", threaded, runalways) +LLVFSThread::LLVFSThread(bool threaded) : + LLQueuedThread("VFS", threaded) { } @@ -145,38 +145,26 @@ S32 LLVFSThread::writeImmediate(LLVFS* vfs, const LLUUID &file_id, const LLAsset } -LLVFSThread::handle_t LLVFSThread::rename(LLVFS* vfs, const LLUUID &file_id, const LLAssetType::EType file_type, - const LLUUID &new_id, const LLAssetType::EType new_type, U32 flags) -{ - handle_t handle = generateHandle(); +// LLVFSThread::handle_t LLVFSThread::rename(LLVFS* vfs, const LLUUID &file_id, const LLAssetType::EType file_type, +// const LLUUID &new_id, const LLAssetType::EType new_type, U32 flags) +// { +// handle_t handle = generateHandle(); - LLUUID* new_idp = new LLUUID(new_id); // deleted with Request - // new_type is passed as "numbytes" - Request* req = new Request(handle, 0, flags, FILE_RENAME, vfs, file_id, file_type, - (U8*)new_idp, 0, (S32)new_type); +// LLUUID* new_idp = new LLUUID(new_id); // deleted with Request +// // new_type is passed as "numbytes" +// Request* req = new Request(handle, 0, flags, FILE_RENAME, vfs, file_id, file_type, +// (U8*)new_idp, 0, (S32)new_type); - bool res = addRequest(req); - if (!res) - { - llerrs << "LLVFSThread::read called after LLVFSThread::cleanupClass()" << llendl; - req->deleteRequest(); - handle = nullHandle(); - } +// bool res = addRequest(req); +// if (!res) +// { +// llerrs << "LLVFSThread::read called after LLVFSThread::cleanupClass()" << llendl; +// req->deleteRequest(); +// handle = nullHandle(); +// } - return handle; -} - -//============================================================================ -// Runs on its OWN thread - -bool LLVFSThread::processRequest(QueuedRequest* qreq) -{ - Request *req = (Request*)qreq; - - bool complete = req->processIO(); - - return complete; -} +// return handle; +// } //============================================================================ @@ -223,7 +211,7 @@ LLVFSThread::Request::Request(handle_t handle, U32 priority, U32 flags, } // dec locks as soon as a request finishes -void LLVFSThread::Request::finishRequest() +void LLVFSThread::Request::finishRequest(bool completed) { if (mOperation == FILE_WRITE) { @@ -241,13 +229,13 @@ void LLVFSThread::Request::finishRequest() void LLVFSThread::Request::deleteRequest() { - if (getStatus() == STATUS_QUEUED || getStatus() == STATUS_ABORT) + if (getStatus() == STATUS_QUEUED) { llerrs << "Attempt to delete a queued LLVFSThread::Request!" << llendl; } if (mOperation == FILE_WRITE) { - if (mFlags & AUTO_DELETE) + if (mFlags & FLAG_AUTO_DELETE) { delete [] mBuffer; } @@ -260,7 +248,7 @@ void LLVFSThread::Request::deleteRequest() LLQueuedThread::QueuedRequest::deleteRequest(); } -bool LLVFSThread::Request::processIO() +bool LLVFSThread::Request::processRequest() { bool complete = false; if (mOperation == FILE_READ) @@ -283,7 +271,7 @@ bool LLVFSThread::Request::processIO() mVFS->renameFile(mFileID, mFileType, *new_idp, new_type); mFileID = *new_idp; complete = true; - //llinfos << llformat("LLVFSThread::WRITE '%s': %d bytes arg:%d",getFilename(),mBytesRead) << llendl; + //llinfos << llformat("LLVFSThread::RENAME '%s': %d bytes arg:%d",getFilename(),mBytesRead) << llendl; } else { -- cgit v1.2.3