CDomainSocket Class Reference

#include <CDomainSocket.h>

Inheritance diagram for CDomainSocket:

List of all members.

Public Member Functions
	CDomainSocket ()
	CDomainSocket (const string &inPath)
	~CDomainSocket ()
bool	listenToPath (const string &inPath)
string	getPath () const
virtual void	serveStream (int)
virtual bool	acceptAndServe ()
	operator bool () const
Protected Attributes
bool	mIsInitialized
string	mPath
struct sockaddr_un	mSocketStructure

---

Detailed Description

A structure that opens/closes a domain socket for a given path and sets the file permissions to 0600.

This class will be used with select to be the entry to the local search engine.

See also:

: CMultiServer

Definition at line 56 of file CDomainSocket.h.

---

Constructor & Destructor Documentation

CDomainSocket::CDomainSocket

(

)

constructor

Definition at line 2 of file CDomainSocket.cc.

                            :
  mIsInitialized(false){
};

CDomainSocket::CDomainSocket

(

const string &

inPath

)

constructor: copy the path, otherwise do nothing

Definition at line 7 of file CDomainSocket.cc.

References listenToPath().

                                                :
  mIsInitialized(false){
  this->listenToPath(inPath);
};

CDomainSocket::~CDomainSocket

(

)

destroy this: close the socket

Definition at line 13 of file CDomainSocket.cc.

References mIsInitialized, and CSocket::mSocketDescriptor.

                             {
  if(mIsInitialized){
    close(mSocketDescriptor);
  }
};

---

Member Function Documentation

bool CDomainSocket::listenToPath

(

const string &

inPath

)

set the path of the domain socket and listen to it

set the path of the domain socket

Definition at line 19 of file CDomainSocket.cc.

References mIsInitialized, mPath, CSocket::mSocketDescriptor, and mSocketStructure.

Referenced by CDomainSocket().

                                                    {
  mPath=inPath;
  
  if (( mSocketDescriptor= socket(AF_UNIX, SOCK_STREAM, 0)) == -1) {
    perror("socket");
    return false;//no exit
  }
  
  mSocketStructure.sun_family = AF_UNIX;
  
  cout << "Making socket for path " << mPath << endl;
  strcpy(mSocketStructure.sun_path, mPath.c_str());
  unlink(mSocketStructure.sun_path);
  
  int len = strlen(mSocketStructure.sun_path) + sizeof(mSocketStructure.sun_family);
  if (bind(mSocketDescriptor, (struct sockaddr *)&mSocketStructure, len) == -1) {
    perror("bind");
    return 0;
  }
  if (listen(mSocketDescriptor, 5) == -1) {
    perror("listen");
    return 0;
  }
  
  if(chmod(mPath.c_str(), 
     S_IRUSR|S_IWUSR)){
    perror("chmod");
    return 0;
  }
  mIsInitialized=1;
  return 1;
};

string CDomainSocket::getPath

(

)

const

get the path of the socket

Definition at line 56 of file CDomainSocket.cc.

References mPath.

Referenced by acceptAndServe().

                                  {
  return mPath;
}

void CDomainSocket::serveStream

(

int

inSocket

)

[virtual]

Serve from the socket that accepted

Reimplemented from CSocket.

Definition at line 60 of file CDomainSocket.cc.

Referenced by acceptAndServe().

                                           {
  int done = 0;
  char str[2];
  string lMessage;
  int lRead(0);
  do {
    lRead = recv(inSocket, 
     str, 1, 0);
    if (lRead <= 0) {
      cerr << "here?" << endl;
      if (lRead < 0) perror("recv");
      done = 1;
    }else{
      str[lRead]=char(0);
      lMessage+=str;
    }
    
  } while (!done);

  cout << " after while" << endl;
  
  if (send(inSocket, lMessage.c_str(), lMessage.size(), 0) < 0) {
    perror("send");
  }
}

bool CDomainSocket::acceptAndServe

(

)

[virtual]

if we are here, this means there is data for one socket

Implements CSocket.

Definition at line 86 of file CDomainSocket.cc.

References getPath(), CSocket::getSocketDescriptor(), and serveStream().

                                  {
  struct sockaddr_un lAcceptedSocket;
  unsigned int t = sizeof(lAcceptedSocket);
  int s2(0);
  if ((s2 = accept(this->getSocketDescriptor(), (struct sockaddr *)&lAcceptedSocket, &t)) == -1) {
    perror("accept");
    return false;
  }
  {
    struct ucred lCredentials;
    socklen_t lSize = sizeof(lCredentials);
    if (getsockopt(s2, 
       SOL_SOCKET, 
       SO_PEERCRED, 
       &lCredentials, 
       &lSize) 
  == 0){
      // cred.uid now contains UID of the connecting process. 
      cout << "Socket credentials:" << endl
     << "Process ID: " << lCredentials.pid << endl
     << "User ID:    " << lCredentials.uid << endl
     << "Group ID:   " << lCredentials.gid << endl;
    }
  }
  cout << "connected: " << this->getPath() << endl;

  this->serveStream(s2);
  //close(s2); I cannot close sockets here, otherwise multithreading goes down the drain.
  return true;
}

CDomainSocket::operator bool

(

)

const [virtual]

get the path of the socket

Reimplemented from CSocket.

Definition at line 52 of file CDomainSocket.cc.

References mIsInitialized.

                                 {
  return mIsInitialized;
}

---

Member Data Documentation

bool CDomainSocket::mIsInitialized [protected]

has this been initialized ?

Reimplemented from CSocket.

Definition at line 59 of file CDomainSocket.h.

Referenced by listenToPath(), operator bool(), and ~CDomainSocket().

string CDomainSocket::mPath [protected]

the path to the socket (visible in the file system)

Definition at line 61 of file CDomainSocket.h.

Referenced by getPath(), and listenToPath().

struct sockaddr_un CDomainSocket::mSocketStructure [read, protected]

the socket structure of the local socket

Definition at line 63 of file CDomainSocket.h.

Referenced by listenToPath().

---

The documentation for this class was generated from the following files:

• gift/GIFTServer/CDomainSocket.h
• gift/GIFTServer/CDomainSocket.cc