core/sqf/monitor/linux/monitor.h

///////////////////////////////////////////////////////////////////////////////
//
// @@@ START COPYRIGHT @@@
//
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements.  See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership.  The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License.  You may obtain a copy of the License at
//
//   http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied.  See the License for the
// specific language governing permissions and limitations
// under the License.
//
// @@@ END COPYRIGHT @@@
//
///////////////////////////////////////////////////////////////////////////////

#ifndef MONITOR_H_
#define MONITOR_H_

#include "tmsync.h"
#include "process.h"


#define MAX_PROCESSES       2048
#define MAX_IO_OUTSTANDING  MAX_PROCESSES*4

#define SUCCESS 0
#define FAILURE 1


enum OpType
{
    OpNull,
    OpRecv,
    OpSend
#ifndef USE_BARRIER
    ,
    OpWake
#endif
};

class CMonitor : public CTmSync_Container
{
friend class SQ_LocalIOToClient;
friend class CExternalReq;
public:
    int OpenCount;
    int NoticeCount;
    int ProcessCount;
    int NumOutstandingIO;     // Current # of I/Os outstanding
    int NumOutstandingSends;  // Current # of Sends outstanding

    CMonitor( int procTermSig );
    ~CMonitor( void );

    bool  CompleteProcessStartup( struct message_def *msg );
    void  CreateZookeeperClient( void );
    void  IncOpenCount(void);
    void  IncNoticeCount(void);
    void  IncProcessCount(void);
    void  DecrOpenCount(void);
    void  DecrNoticeCount(void);
    void  DecrProcessCount(void);
    void  StartPrimitiveProcesses( void );  
    void  StartZookeeperClient( void );
    void  openProcessMap ( void );
    void  writeProcessMapEntry ( const char * buf );
    void  writeProcessMapBegin( const char *name
                              , int nid
                              , int pid
                              , int verifier
                              , int parentNid
                              , int parentPid
                              , int parentVerifier
                              , const char *program );
    void  writeProcessMapEnd( const char *name
                            , int nid
                            , int pid
                            , int verifier
                            , int parentNid
                            , int parentPid
                            , int parentVerifier
                            , const char *program );
    int   GetProcTermSig() { return procTermSig_; }
    int   PackProcObjs(char *&buffer);
    void  UnpackProcObjs(char *&buffer, int procCount);
#ifdef USE_SEQUENCE_NUM
    long long GetTimeSeqNum();  // time based seq number
#endif
protected:
private:
    int  Last_error;     // last MPI error returned
    int  processMapFd;   // file desc for process map file

#ifdef DELAY_TP
    void Delay_TP(char *tpName);
#endif

    char *ProcCopy(char *bufPtr, CProcess *process);

 private:
    int procTermSig_;

#ifdef USE_SEQUENCE_NUM
    struct timespec savedTime_;  // for time based seq num
    CLock TimeSeqNumLock_;       // lock for savedTime_
#endif
};

#endif /*MONITOR_H_*/