Skip navigation links

MySQL Newsletter - Subscribe Today!

The world's most popular open source database

MySQL 5.1: mysql/src/5.1-dbg/storage/ndb/src/kernel/blocks/ndbfs/AsyncFile.cpp File Reference

mysql/src/5.1-dbg/storage/ndb/src/kernel/blocks/ndbfs/AsyncFile.cpp File Reference

#include <ndb_global.h>
#include <my_sys.h>
#include <my_pthread.h>
#include "AsyncFile.hpp"
#include <ErrorHandlingMacros.hpp>
#include <kernel_types.h>
#include <ndbd_malloc.hpp>
#include <NdbThread.h>
#include <signaldata/FsRef.hpp>
#include <signaldata/FsOpenReq.hpp>
#include <signaldata/FsReadWriteReq.hpp>
#include <sys/uio.h>
#include <dirent.h>

Include dependency graph for AsyncFile.cpp:

Go to the source code of this file.


Defines

#define DEBUG(x)
#define PRINT_ERRORANDFLAGS(f)
#define WRITEBUFFERSIZE   262144

Functions

void * runAsyncFile (void *arg)
NdbOut & operator<< (NdbOut &out, const Request &req)

Variables

const char * actionName []
static int numAsyncFiles = 0
bool Global_useO_SYNC
bool Global_unlinkO_CREAT
Uint32 Global_syncFreq

Define Documentation

#define DEBUG ( x   ) 

Definition at line 58 of file AsyncFile.cpp.

#define PRINT_ERRORANDFLAGS ( f   ) 

Definition at line 59 of file AsyncFile.cpp.

Referenced by AsyncFile::openReq().

#define WRITEBUFFERSIZE   262144

Definition at line 66 of file AsyncFile.cpp.

Referenced by AsyncFile::run().

Function Documentation

NdbOut& operator<< ( NdbOut &  out,
const Request &  req 
)

Definition at line 1197 of file AsyncFile.cpp.

01198 {
01199   out << "[ Request: file: " << hex << req.file 
01200       << " userRef: " << hex << req.theUserReference
01201       << " userData: " << dec << req.theUserPointer
01202       << " theFilePointer: " << req.theFilePointer
01203       << " action: ";
01204   switch(req.action){
01205   case Request::open:
01206     out << "open";
01207     break;
01208   case Request::close:
01209     out << "close";
01210     break;
01211   case Request::closeRemove:
01212     out << "closeRemove";
01213     break;
01214   case Request::read:   // Allways leave readv directly after 
01215     out << "read";
01216     break;
01217   case Request::readv:
01218     out << "readv";
01219     break;
01220   case Request::write:// Allways leave writev directly after 
01221     out << "write";
01222     break;
01223   case Request::writev:
01224     out << "writev";
01225     break;
01226   case Request::writeSync:// Allways leave writevSync directly after 
01227     out << "writeSync";
01228     break;
01229     // writeSync because SimblockAsyncFileSystem depends on it
01230   case Request::writevSync:
01231     out << "writevSync";
01232     break;
01233   case Request::sync:
01234     out << "sync";
01235     break;
01236   case Request::end:
01237     out << "end";
01238     break;
01239   case Request::append:
01240     out << "append";
01241     break;
01242   case Request::rmrf:
01243     out << "rmrf";
01244     break;
01245   default:
01246     out << (Uint32)req.action;
01247     break;
01248   }
01249   out << " ]";
01250   return out;
01251 }

void* runAsyncFile ( void *  arg  ) 

Definition at line 84 of file AsyncFile.cpp.

References NULL.

Referenced by AsyncFile::doStart().

00085 {
00086   ((AsyncFile*)arg)->run();
00087   return (NULL);
00088 }

Here is the caller graph for this function:

Variable Documentation

const char* actionName[]

Initial value:

 {
  "open",
  "close",
  "closeRemove",
  "read",
  "readv",
  "write",
  "writev",
  "writeSync",
  "writevSync",
  "sync",
  "end" }

Definition at line 69 of file AsyncFile.cpp.

Uint32 Global_syncFreq

Definition at line 1058 of file Ndbfs.cpp.

bool Global_unlinkO_CREAT

Definition at line 1057 of file Ndbfs.cpp.

Referenced by AsyncFile::openReq().

bool Global_useO_SYNC

Definition at line 1056 of file Ndbfs.cpp.

int numAsyncFiles = 0 [static]

Definition at line 82 of file AsyncFile.cpp.

Referenced by AsyncFile::doStart().

Generated on Sat Sep 9 19:14:43 2006 for MySQL 5.1 by  doxygen 1.4.7