ThreadData.H

Go to the documentation of this file.

// Copyright (c) 2000, Compaq Computer Corporation
// Copyright (C) 2001, Compaq Computer Corporation
// 
// This file is part of Vesta.
// 
// Vesta is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public
// License as published by the Free Software Foundation; either
// version 2.1 of the License, or (at your option) any later version.
// 
// Vesta is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
// Lesser General Public License for more details.
// 
// You should have received a copy of the GNU Lesser General Public
// License along with Vesta; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

// File: ThreadData.H

#ifndef ThreadData_H
#define ThreadData_H

#include "EvalBasics.H"
#include <CacheC.H>
#include <BufStream.H>

//
// Thread-specific data for threads started by _par_map
//
struct ThreadData {
  // List of all extant ThreadData objects
  static Basics::mutex mu;
  static ThreadData* head;
  ThreadData* prev;
  ThreadData* next; 

  // Fields of individual ThreadData objects
  int id;           // Dense, small integer ids.  Main thread should be 0.
  int funcCallDepth;
  Basics::OBufStream *traceRes;
  Exprs *callStack;
  ThreadData *parent;
  int parentCallStackSize;
  CacheEntry::IndicesApp* orphanCIs;
  
  // !! add more fields if needed
};

// Create thread-specific data for the current thread.  Call this
// routine once from each new thread after forking it.  Caller assigns
// ids.  Also OK to call repeatedly from the same thread (e.g., the
// main thread); each call frees the old ThreadData and creates a
// fresh one.  The ThreadData object is automatically freed when a
// thread terminates.
ThreadData* ThreadDataCreate(int id, CacheEntry::IndicesApp *threadCIs);

// Get thread-specific data for the current thread.
ThreadData* ThreadDataGet();

// Initialize module.  Also calls ThreadDataCreate(0) for main thread.
void ThreadDataInit();

inline Text ThreadLabel()
{
  return ((maxThreads > 1)
          ? IntToText(ThreadDataGet()->id) + "/"
          : Text(""));
}

#endif // ThreadData_H

---