#ifndef __XRDSSITASKREAL_HH__
#define __XRDSSITASKREAL_HH__
/******************************************************************************/
/*                                                                            */
/*                     X r d S s i T a s k R e a l . h h                      */
/*                                                                            */
/* (c) 2013 by the Board of Trustees of the Leland Stanford, Jr., University  */
/*   Produced by Andrew Hanushevsky for Stanford University under contract    */
/*              DE-AC02-76-SFO0515 with the Department of Energy              */
/*                                                                            */
/* This file is part of the XRootD software suite.                            */
/*                                                                            */
/* XRootD 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 3 of the License, or (at your     */
/* option) any later version.                                                 */
/*                                                                            */
/* XRootD 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 XRootD in a file called COPYING.LESSER (LGPL license) and file  */
/* COPYING (GPL license).  If not, see <http://www.gnu.org/licenses/>.        */
/*                                                                            */
/* The copyright holder's institutional names and contributor's names may not */
/* be used to endorse or promote products derived from this software without  */
/* specific prior written permission of the institution or contributor.       */
/******************************************************************************/

#include "XrdSsi/XrdSsiErrInfo.hh"
#include "XrdSsi/XrdSsiEvent.hh"
#include "XrdSsi/XrdSsiPacer.hh"
#include "XrdSsi/XrdSsiStream.hh"
#include "XrdSsi/XrdSsiResponder.hh"

class XrdSsiRequest;
class XrdSsiSessReal;
class XrdSysSemaphore;

class XrdSsiTaskReal : public XrdSsiEvent,     public XrdSsiPacer,
                       public XrdSsiResponder, public XrdSsiStream
{
public:

enum TaskStat {isPend=0, isWrite, isSync, isReady, isDone, isDead};

void   Detach(bool force=false);

void   Finished(      XrdSsiRequest  &rqstR,
                const XrdSsiRespInfo &rInfo,
                      bool            cancel=false);

void  *Implementation() {return (void *)this;}

bool   Kill();

inline
int    ID() {return tskID;}

inline
void   Init(XrdSsiRequest *rP, unsigned short tmo=0)
           {rqstP = rP, tStat = isPend; tmOut = tmo; wPost = 0;
            mhPend = false; defer = false;
            attList.next = attList.prev = this;
            if (mdResp) {delete mdResp; mdResp = 0;}
           }

void   PostError();

void   Redrive();
const 
char  *RequestID() {return rqstP->GetRequestID();}

void   SchedError(XrdSsiErrInfo *eInfo=0);

void   SendError();

bool   SendRequest(const char *node);

int    SetBuff(XrdSsiErrInfo &eRef, char *buff, int blen, bool &last);

bool   SetBuff(XrdSsiErrInfo &eRef, char *buff, int blen);

void   SetTaskID(uint32_t tid) {tskID = tid;}

bool   XeqEvent(XrdCl::XRootDStatus *status, XrdCl::AnyObject **respP);

       XrdSsiTaskReal(XrdSsiSessReal *sP)
                     : XrdSsiEvent("TaskReal"),
                       XrdSsiStream(XrdSsiStream::isPassive),
                       sessP(sP), mdResp(0), wPost(0), tskID(0),
                       mhPend(false), defer(false)
                    {}

      ~XrdSsiTaskReal() {if (mdResp) delete mdResp;}

struct dlQ {XrdSsiTaskReal *next; XrdSsiTaskReal *prev;};
dlQ             attList;

enum respType     {isBad=0, isAlert, isData, isStream};

private:

bool              Ask4Resp();
respType          GetResp(XrdCl::AnyObject **respP, char *&dbuf, int &dlen);
bool              RespErr(XrdCl::XRootDStatus *status);
bool              XeqEnd(bool getLock);

XrdSsiErrInfo     errInfo;
XrdSsiSessReal   *sessP;
XrdSsiRequest    *rqstP;
XrdCl::AnyObject *mdResp;
XrdSysSemaphore  *wPost;
char             *dataBuff;
int               dataRlen;
TaskStat          tStat;
uint32_t          tskID;
unsigned short    tmOut;
bool              mhPend;
bool              defer;
};
#endif