Commit 302ec809 authored by Yann Garcia's avatar Yann Garcia
Browse files

First run of ESRP test

parent 0d88cb80

ccsrc/Framework/include/params.hh

+3 −1
Original line number Diff line number Diff line
@@ -34,7 +34,9 @@ public: //! \publicsection 
  static const std::string& longitude;             //! Test system Longitude parameter name

  

  static const std::string& server;                //! HTTP server address (e.g. www.etsi.org)

  static const std::string& port;                  //! Commsignia HTTP server port. Default: 80

  static const std::string& port;                  //! HTTP server port. Default: 80

  static const std::string& server_mode;           //! Does the test sytem acting as a server. Default: 0

  static const std::string& local_port;            //! Local listener port. Default: 80

  static const std::string& use_ssl;               //! Set to 1 to use SSL to communicate with the HTTP server. Default: false



  static const std::string& sip_url;

ccsrc/Framework/src/params.cc

+2 −0
Original line number Diff line number Diff line
@@ -30,6 +30,8 @@ const std::string& params::longitude = std::string("longitude"); 


const std::string& params::server = std::string("server");

const std::string& params::port = std::string("port");

const std::string& params::server_mode = std::string("server_mode");

const std::string& params::local_port = std::string("local_port");

const std::string& params::use_ssl = std::string("use_ssl");



const std::string& params::sip_url = std::string("sip_url");

ccsrc/Ports/LibSip/SipPort.cc

+26 −0
Original line number Diff line number Diff line
@@ -86,6 +86,32 @@ namespace LibSip__Interface { 


  } // End of user_stop method



  void SipPort::receiveMsg (const LibSip__SIPTypesAndValues::Request& p_ind, const params& p_params) {

    loggers::get_instance().log_msg(">>> SipPort::receive_msg: ", p_ind);

    

    // Sanity check

    if (!p_ind.is_bound()) {

      return;

    }



    if (p_ind.requestLine().method() == LibSip__SIPTypesAndValues::Method::INVITE__E) {

      incoming_message(LibSip__SIPTypesAndValues::INVITE__Request(p_ind.requestLine(), p_ind.msgHeader(), p_ind.messageBody(), p_ind.payload()));

    } else {

      incoming_message(p_ind);

    }

  } // End of method receiveMsg

  

  void SipPort::receiveMsg (const LibSip__SIPTypesAndValues::Response& p_ind, const params& p_params) {

    loggers::get_instance().log_msg(">>> SipPort::receive_msg: ", p_ind);

    

    // Sanity check

    if (!p_ind.is_bound()) {

      return;

    }

    

    incoming_message(p_ind);

  } // End of method receiveMsg

  

  void SipPort::outgoing_send(const LibSip__SIPTypesAndValues::INVITE__Request& send_par, const Address4SIP *destination_address)

  {

    loggers::get_instance().log_msg(">>> SipPort::outgoing_send: ", send_par);

ccsrc/Ports/LibSip/SipPort.hh

+3 −1
Original line number Diff line number Diff line
@@ -21,7 +21,9 @@ namespace LibSip__Interface { 
    ~SipPort();



    void set_parameter(const char *parameter_name, const char *parameter_value);

    void receiveMsg (const LibSip__SIPTypesAndValues::REGISTER__Request&, const params&);

    

    void receiveMsg (const LibSip__SIPTypesAndValues::Request& p_ind, const params& p_params);

    void receiveMsg (const LibSip__SIPTypesAndValues::Response& p_ind, const params& p_params);



  private:

    /* void Handle_Fd_Event(int fd, boolean is_readable,

ccsrc/Protocols/Sip/sip_codec_request.cc

+8 −4
Original line number Diff line number Diff line
@@ -253,11 +253,15 @@ int sip_codec_request::encode_request_headers(const LibSip__SIPTypesAndValues::M 
      return -1;

    }

  }

  

  // TODO continue

  int i = 0;

  osip_header_t* h_;

  while (::osip_message_get_header(p_sip_message, i++, &h_) == 0) {

    loggers::get_instance().warning("sip_codec_request::encode_request_headers (1): '%s'/'%s' was not processed", h_->hname, h_->hvalue);

  const osip_list_t* p = &(p_sip_message->headers);

  unsigned int pos = 0;

  unsigned int size = ::osip_list_size(p);

  loggers::get_instance().log("Unknown header size: %d\n", size);

  while (pos < size) {

    const osip_header_t* header = (const osip_header_t*)osip_list_get(p, pos++);

    loggers::get_instance().log("%p: hname=%s : hvalue=%s\n", header, header->hname, header->hvalue);

  } // End of 'while' statement

  

  return 0;