binaryurp/source/outgoingrequests.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*************************************************************************
   3 *
   4 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   5 *
   6 * Copyright 2000, 2011 Oracle and/or its affiliates.
   7 *
   8 * OpenOffice.org - a multi-platform office productivity suite
   9 *
  10 * This file is part of OpenOffice.org.
  11 *
  12 * OpenOffice.org is free software: you can redistribute it and/or modify
  13 * it under the terms of the GNU Lesser General Public License version 3
  14 * only, as published by the Free Software Foundation.
  15 *
  16 * OpenOffice.org is distributed in the hope that it will be useful,
  17 * but WITHOUT ANY WARRANTY; without even the implied warranty of
  18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  19 * GNU Lesser General Public License version 3 for more details
  20 * (a copy is included in the LICENSE file that accompanied this code).
  21 *
  22 * You should have received a copy of the GNU Lesser General Public License
  23 * version 3 along with OpenOffice.org.  If not, see
  24 * <http://www.openoffice.org/license.html>
  25 * for a copy of the LGPLv3 License.
  26 *
  27 ************************************************************************/
  28
  29 #include "sal/config.h"
  30
  31 #include "com/sun/star/uno/RuntimeException.hpp"
  32 #include "rtl/byteseq.hxx"
  33 #include "osl/mutex.hxx"
  34
  35 #include "lessoperators.hxx"
  36 #include "outgoingrequest.hxx"
  37 #include "outgoingrequests.hxx"
  38
  39 namespace binaryurp {
  40
  41 namespace {
  42
  43 namespace css = com::sun::star;
  44
  45 }
  46
  47 OutgoingRequests::OutgoingRequests() {}
  48
  49 OutgoingRequests::~OutgoingRequests() {}
  50
  51 void OutgoingRequests::push(
  52     rtl::ByteSequence const & tid, OutgoingRequest const & request)
  53 {
  54     osl::MutexGuard g(mutex_);
  55     map_[tid].push_back(request);
  56 }
  57
  58 OutgoingRequest OutgoingRequests::top(rtl::ByteSequence const & tid) {
  59     osl::MutexGuard g(mutex_);
  60     Map::iterator i(map_.find(tid));
  61     if (i == map_.end()) {
  62         throw css::uno::RuntimeException(
  63             rtl::OUString(
  64                 RTL_CONSTASCII_USTRINGPARAM("URP: reply for unknown TID")),
  65             css::uno::Reference< css::uno::XInterface >());
  66     }
  67     OSL_ASSERT(!i->second.empty());
  68     return i->second.back();
  69 }
  70
  71 void OutgoingRequests::pop(rtl::ByteSequence const & tid) throw () {
  72     osl::MutexGuard g(mutex_);
  73     Map::iterator i(map_.find(tid));
  74     OSL_ASSERT(i != map_.end());
  75     i->second.pop_back();
  76     if (i->second.empty()) {
  77         map_.erase(i);
  78     }
  79 }
  80
  81 }
  82
  83 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */