Connection.h

/* 
   EyeDB Object Database Management System
   Copyright (C) 1994-2008 SYSRA
   
   EyeDB 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.
   
   EyeDB 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 this library; if not, write to the Free Software
   Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA 
*/

/*
   Author: Eric Viara <viara@sysra.com>
*/


#ifndef _EYEDB_CONNECTION_H
#define _EYEDB_CONNECTION_H

class ConnHandle;

namespace eyedb {

  class ConnectionPeer;
  class ServerMessageDisplayer;

  class Connection {

    // ----------------------------------------------------------------------
    // Connection Interface
    // ----------------------------------------------------------------------
  public:
    Connection();

    Connection(bool opening, const char *host = DefaultHost,
               const char *port = DefaultIDBPort);

    Status open(const char *host = DefaultHost,
                const char *port = DefaultIDBPort);

    Status close();

    const char *getHost() const;

    const char *getIDBPort() const;

    int getServerUid() const;

    int getServerPid() const;

    Status sendInterrupt();

    ConnHandle *getConnHandle() {return connh;}

    ~Connection();

    static void setDefaultHost(const char *host);

    static const char *getDefaultHost();

    static void setDefaultIDBPort(const char *port);

    static const char *getDefaultIDBPort();

    static void setAuthRequired(Bool set_auth_required);

    static void setDefaultUser(const char *user);

    static const char *getDefaultUser();

    static void setDefaultPasswd(const char *passwd);

    static const char *getDefaultPasswd();

    static std::string makeUser(const char *_ser);

    static const char
      LocalHost[],
      DefaultHost[],
      DefaultIDBPort[],
      DefaultIDBPortValue[];

    void *setUserData(void *ud);

    void *getUserData(void);

    const void *getUserData(void) const;

    Status echoServerMessages(const ServerMessageDisplayer &dsp) const;

    // could be called from server side only
    static Bool isBackendInterrupted();

    static void setServerMessage(const char *msg);

    static void setOutOfBandData(unsigned int type, unsigned char *data,
                                 unsigned int len);

    // ----------------------------------------------------------------------
    // Connection Private Part
    // ----------------------------------------------------------------------
  private:
    friend class ConnectionPeer;

    char *host;
    char *port;
    int sv_pid, sv_uid;
    void *user_data;
    void *oql_info;

    static char *default_host, *default_port, *default_user, *default_passwd;

    static Bool set_auth_required;

    ConnHandle *connh;

    Status echoServerMessages(unsigned int mask, FILE *fd, std::ostream *os) const;

    // ----------------------------------------------------------------------
    // Connection Restricted Access (conceptually private)
    // ----------------------------------------------------------------------
  public:
    static void init();
    static void _release();
    void *setOQLInfo(void *);
    void *getOQLInfo();
    struct ServerMessageContext;
  };

  class ServerMessageDisplayer {
  public:
    virtual void display(const char *msg) const = 0;
    virtual ~ServerMessageDisplayer() {}
  };

  class StdServerMessageDisplayer : public ServerMessageDisplayer {

  public:
    StdServerMessageDisplayer(FILE *fd = stdout);
    StdServerMessageDisplayer(std::ostream &);

    virtual void display(const char *msg) const;

    virtual ~StdServerMessageDisplayer() {}

  private:
    FILE *fd;
    std::ostream *os;
  };

}

#endif

---