| /** |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| */ |
| |
| /* |
| * XSEC |
| * |
| * XSECBinTXFMInputStream := Implement the BinInputStream around Transforms. |
| * |
| * Author(s): Berin Lautenbach |
| * |
| * $ID$ |
| * |
| * $LOG$ |
| * |
| */ |
| |
| |
| #include <xsec/utils/XSECBinTXFMInputStream.hpp> |
| #include <xsec/transformers/TXFMBase.hpp> |
| #include <xsec/transformers/TXFMChain.hpp> |
| #include <xsec/framework/XSECError.hpp> |
| |
| // --------------------------------------------------------------------------- |
| // Constructors/Destructors |
| // --------------------------------------------------------------------------- |
| |
| |
| XSECBinTXFMInputStream::XSECBinTXFMInputStream(TXFMChain * lst, bool deleteWhenDone) : |
| mp_txfm(lst->getLastTxfm()), |
| mp_chain(lst), |
| m_deleteWhenDone(deleteWhenDone), |
| m_deleted(false), |
| m_done(false), |
| m_currentIndex(0) { |
| |
| if (mp_txfm->getOutputType() != TXFMBase::BYTE_STREAM) { |
| |
| throw XSECException(XSECException::TransformError, |
| "Cannot wrapper a non BYTE_STREAM TXFM with XSECBinTXFMInputStream"); |
| |
| } |
| |
| } |
| |
| XSECBinTXFMInputStream::~XSECBinTXFMInputStream() { |
| |
| if (m_deleteWhenDone == true && m_deleted == false) { |
| |
| delete mp_chain; |
| m_deleted = true; |
| |
| } |
| |
| } |
| |
| // --------------------------------------------------------------------------- |
| // Stream methods |
| // --------------------------------------------------------------------------- |
| |
| void XSECBinTXFMInputStream::reset(void) {} |
| |
| #ifdef XSEC_XERCES_64BITSAFE |
| XMLFilePos |
| #else |
| unsigned int |
| #endif |
| XSECBinTXFMInputStream::curPos() const { |
| return m_currentIndex; |
| } |
| |
| xsecsize_t XSECBinTXFMInputStream::readBytes(XMLByte* const toFill, |
| const xsecsize_t maxToRead) { |
| |
| if (m_done == true) |
| return 0; |
| |
| xsecsize_t bytesRead = mp_txfm->readBytes(toFill, maxToRead); |
| |
| if (bytesRead == 0) { |
| |
| if (m_deleteWhenDone) { |
| |
| delete mp_chain; |
| mp_txfm = 0; |
| mp_chain = 0; |
| m_deleted = true; |
| |
| } |
| |
| m_done = true; |
| |
| } |
| |
| m_currentIndex += bytesRead; |
| |
| return bytesRead; |
| |
| } |
| |
| #ifdef XSEC_XERCES_INPUTSTREAM_HAS_CONTENTTYPE |
| const XMLCh* XSECBinTXFMInputStream::getContentType() const { |
| return NULL; |
| } |
| #endif |