src/j_jdwp.cc

   1 ///
   2 /// \file       j_jdwp.cc
   3 ///             JDWP socket communication implementation
   4 ///
   5
   6 /*
   7     Copyright (C) 2009, Nicolas VIVIEN
   8
   9     This program is free software; you can redistribute it and/or modify
  10     it under the terms of the GNU General Public License as published by
  11     the Free Software Foundation; either version 2 of the License, or
  12     (at your option) any later version.
  13
  14     This program is distributed in the hope that it will be useful,
  15     but WITHOUT ANY WARRANTY; without even the implied warranty of
  16     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  17
  18     See the GNU General Public License in the COPYING file at the
  19     root directory of this project for more details.
  20 */
  21
  22 #include "j_jdwp.h"
  23 #include "data.h"
  24 #include <sstream>
  25 #include <iomanip>
  26 #include <errno.h>
  27 #include <unistd.h>
  28
  29 namespace Barry { namespace JDWP {
  30
  31
  32 ///////////////////////////////////////////////////////////////////////////////
  33 // JDWP::Error exception class
  34
  35 static std::string GetErrorString(int errcode, const std::string &str)
  36 {
  37         std::ostringstream oss;
  38         oss << "(";
  39
  40         if( errcode ) {
  41                 oss << std::setbase(10) << errcode << ", ";
  42         }
  43
  44 //      oss << strerror(-libusb_errno) << "): "
  45         oss << "): ";
  46         oss << str;
  47         return oss.str();
  48 }
  49
  50
  51 Error::Error(const std::string &str)
  52         : Barry::Error(GetErrorString(0, str))
  53         , m_errcode(0)
  54 {
  55 }
  56
  57
  58 Error::Error(int errcode, const std::string &str)
  59         : Barry::Error(GetErrorString(errcode, str))
  60         , m_errcode(errcode)
  61 {
  62 }
  63
  64
  65
  66 ///////////////////////////////////////////////////////////////////////////////
  67 // JDWP::JDWP communication class
  68
  69 JDWP::JDWP()
  70 {
  71 }
  72
  73
  74 JDWP::~JDWP()
  75 {
  76 }
  77
  78
  79 bool JDWP::Read(int socket, Barry::Data &data, int timeout)
  80 {
  81         int ret;
  82
  83         do {
  84                 data.QuickZap();
  85
  86                 ret = read(socket, (char*) data.GetBuffer(), data.GetBufSize());
  87
  88                 if( ret < 0 ) {
  89                         ret = -errno;
  90                         if (ret != -EINTR && ret != -EAGAIN ) {
  91                                 m_lasterror = ret;
  92                                 if( ret == -ETIMEDOUT )
  93                                         throw Timeout(ret, "Timeout in read");
  94                                 else
  95                                         throw Error(ret, "Error in read");
  96                         }
  97                 }
  98                 else
  99                         data.ReleaseBuffer(ret);
 100         } while( ret == -EINTR );
 101
 102         return ret >= 0;
 103 }
 104
 105
 106 bool JDWP::Write(int socket, const Barry::Data &data, int timeout)
 107 {
 108         int ret;
 109
 110         do {
 111                 ret = write(socket, (char*) data.GetData(), data.GetSize());
 112
 113                 if( ret < 0 && ret != -EINTR && ret != -EAGAIN ) {
 114                         m_lasterror = ret;
 115                         if( ret == -ETIMEDOUT )
 116                                 throw Timeout(ret, "Timeout in write (1)");
 117                         else
 118                                 throw Error(ret, "Error in write (1)");
 119                 }
 120         } while( ret == -EINTR || ret == -EAGAIN );
 121
 122         return ret >= 0;
 123 }
 124
 125
 126 bool JDWP::Write(int socket, const void *data, size_t size, int timeout)
 127 {
 128         int ret;
 129
 130         do {
 131                 ret = write(socket, (char*) data, size);
 132
 133                 if( ret < 0 && ret != -EINTR && ret != -EAGAIN ) {
 134                         m_lasterror = ret;
 135                         if( ret == -ETIMEDOUT )
 136                                 throw Timeout(ret, "Timeout in write (2)");
 137                         else
 138                                 throw Error(ret, "Error in write (2)");
 139                 }
 140         } while( ret == -EINTR || ret == -EAGAIN );
 141
 142         return ret >= 0;
 143 }
 144
 145 }} // namespace JDWP
 146