/usr/include/sipxtapi/tao/TaoTransportTask.h is in libsipxtapi-dev 3.3.0~test17-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 | //
// Copyright (C) 2004-2006 SIPfoundry Inc.
// Licensed by SIPfoundry under the LGPL license.
//
// Copyright (C) 2004-2006 Pingtel Corp. All rights reserved.
// Licensed to SIPfoundry under a Contributor Agreement.
//
// $$
///////////////////////////////////////////////////////////////////////////////
#ifndef _TaoTransportTask_h_
#define _TaoTransportTask_h_
#if _MSC_VER >= 1000
#pragma once
#endif // _MSC_VER >= 1000
// SYSTEM INCLUDES
// APPLICATION INCLUDES
//#include <os/OsTask.h>
#include <os/OsServerTask.h>
#include <os/OsServerSocket.h>
#include <os/OsMsgQ.h>
#include "tao/TaoObject.h"
#include "tao/TaoMessage.h"
#include "tao/TaoObjectMap.h"
#include "tao/TaoReference.h"
// DEFINES
// MACROS
// EXTERNAL FUNCTIONS
// EXTERNAL VARIABLES
// CONSTANTS
// STRUCTS
// TYPEDEFS
// FORWARD DECLARATIONS
class TaoServerTask;
class TaoListeningTask;
//:Used to send messages, resposible for generating and maintaining transactions,
// resposible for putting TaoMessage out to the wire, maintains "keep alive"
// session with server, maintains sockets for incoming notification response
// messages, maintains db of outstanding transactions.
class TaoTransportTask : public OsServerTask
{
/* //////////////////////////// PUBLIC //////////////////////////////////// */
public:
/* ============================ CREATORS ================================== */
TaoTransportTask();
//:Default constructor
TaoTransportTask(const char * listenerHost, const char * listenerPort);
//:Constructor, establishes socket connection to host
TaoTransportTask(const int listenerPort);
//:Constructor, establishes socket connection to host
TaoTransportTask(const TaoTransportTask& rTaoTransportTask);
//:Copy constructor (not implemented for this class)
virtual ~TaoTransportTask();
//:Destructor
/* ============================ MANIPULATORS ============================== */
virtual UtlBoolean handleMessage(OsMsg& rMsg);
//:Handle an incoming message.
// If the message is not one that the object is prepared to process,
// the handleMessage() method in the derived class should return FALSE
// which will cause the OsServerTask::handleMessage() method to be
// invoked on the message.
int startListening(void);
int stopListening(void);
OsServerTask* getServer() { return mpServer; };
void setServer(OsServerTask* pServer) { mpServer = pServer; };
void setClient(TaoObjHandle hClient) { mClientHandle = hClient; };
/* ============================ ACCESSORS ============================== */
TaoStatus getListenSocket(OsConnectionSocket& socket);
/* //////////////////////////// PROTECTED ///////////////////////////////// */
protected:
void initialize();
/* //////////////////////////// PRIVATE /////////////////////////////////// */
private:
/* ============================ MANIPULATORS ============================== */
int send(TaoMessage& rMsg);
/* ============================ VARIABLES ================================ */
UtlString mRemoteHost; // remote TaoServer
int mRemotePort; // TaoServer's listener port
int mListenerPort; // this transport's listener port
TaoObjHandle mClientHandle;
OsServerSocket* mpListenSocket;
TaoListeningTask* mpTaoListeningTask;
TaoReference* mpSocketCnt;
OsServerTask* mpServer;
TaoObjectMap* mpSockets;
static TaoReference* mpTransactionCnt;
static int mRef;
};
#endif // _TaoTransportTask_h_
|