00001 /******************************************************************************* 00002 * Copyright (C) 2004 Vintela, Inc. All rights reserved. 00003 * Copyright (C) 2005 Novell, Inc. All rights reserved. 00004 * 00005 * Redistribution and use in source and binary forms, with or without 00006 * modification, are permitted provided that the following conditions are met: 00007 * 00008 * - Redistributions of source code must retain the above copyright notice, 00009 * this list of conditions and the following disclaimer. 00010 * 00011 * - Redistributions in binary form must reproduce the above copyright notice, 00012 * this list of conditions and the following disclaimer in the documentation 00013 * and/or other materials provided with the distribution. 00014 * 00015 * - Neither the name of Vintela, Inc., Novell, Inc., nor the names of its 00016 * contributors may be used to endorse or promote products derived from this 00017 * software without specific prior written permission. 00018 * 00019 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS ``AS IS'' 00020 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 00021 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 00022 * ARE DISCLAIMED. IN NO EVENT SHALL Vintela, Inc., Novell, Inc., OR THE 00023 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 00024 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 00025 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 00026 * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 00027 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 00028 * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 00029 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 00030 *******************************************************************************/ 00031 00032 00038 #include "blocxx/BLOCXX_config.h" 00039 #include "blocxx/UnnamedPipe.hpp" 00040 #include "blocxx/AutoPtr.hpp" 00041 #include "blocxx/String.hpp" 00042 #include "blocxx/StringBuffer.hpp" 00043 #include "blocxx/ExceptionIds.hpp" 00044 00045 namespace BLOCXX_NAMESPACE 00046 { 00047 00048 BLOCXX_DEFINE_EXCEPTION_WITH_ID(UnnamedPipe); 00049 00051 UnnamedPipe::~UnnamedPipe() 00052 { 00053 } 00055 int 00056 UnnamedPipe::writeInt(int value) 00057 { 00058 return this->write(&value, sizeof(int)); 00059 } 00061 int 00062 UnnamedPipe::writeString(const String& strData) 00063 { 00064 int rc; 00065 int len = static_cast<int>(strData.length()+1); 00066 if ((rc = this->writeInt(len)) != -1) 00067 { 00068 rc = this->write(strData.c_str(), len); 00069 } 00070 return rc; 00071 } 00073 int 00074 UnnamedPipe::readInt(int* value) 00075 { 00076 return this->read(value, sizeof(int)); 00077 } 00079 int 00080 UnnamedPipe::readString(String& strData) 00081 { 00082 int len; 00083 int rc; 00084 00085 if ((rc = this->readInt(&len)) != -1) 00086 { 00087 AutoPtrVec<char> p(new char[len+1]); 00088 00089 // writeString() writes the '\0' terminator, so we don't worry about it here. 00090 if ((rc = this->read(p.get(), len)) != -1) 00091 { 00092 strData = String(String::E_TAKE_OWNERSHIP, p.release(), len); 00093 } 00094 } 00095 return rc; 00096 } 00098 String 00099 UnnamedPipe::readAll() 00100 { 00101 char buf[1024]; 00102 int readbytes; 00103 StringBuffer retval; 00104 do 00105 { 00106 readbytes = this->read(buf, sizeof(buf)-1, true); // throws on error 00107 buf[readbytes] = 0; // null-terminate the buffer 00108 retval += buf; 00109 } while (readbytes > 0); // keep going until we don't fill up the buffer. 00110 return retval.releaseString(); 00111 } 00112 00113 } // end namespace BLOCXX_NAMESPACE 00114