LSST Applications g063fba187b+ea58ee1f2e,g0f08755f38+c959026f09,g12f32b3c4e+e8fc1d5a1e,g1653933729+a8ce1bb630,g168dd56ebc+a8ce1bb630,g1a0ca8cf93+2f198f2aa8,g28da252d5a+7e025d8f94,g2bbee38e9b+c076ca1133,g2bc492864f+c076ca1133,g3156d2b45e+41e33cbcdc,g347aa1857d+c076ca1133,g35bb328faa+a8ce1bb630,g3a166c0a6a+c076ca1133,g3e281a1b8c+b162652f75,g414038480c+6cfc39b08c,g41af890bb2+d4c324d475,g5fbc88fb19+17cd334064,g6b1c1869cb+878204452a,g781aacb6e4+a8ce1bb630,g7e767a00ed+7def0f636c,g80478fca09+a0d7f63753,g82479be7b0+60cf5d37e7,g8554a5dd34+0e332c04ee,g858d7b2824+c959026f09,g89c8672015+ff349045bf,g9125e01d80+a8ce1bb630,g9726552aa6+3a8748fa0c,ga5288a1d22+59736ba80c,gb58c049af0+d64f4d3760,gc28159a63d+c076ca1133,gcf0d15dbbd+efb7d8614d,gda3e153d99+c959026f09,gda6a2b7d83+efb7d8614d,gdaeeff99f8+1711a396fd,ge2409df99d+2c01d16122,ge79ae78c31+c076ca1133,gf0baf85859+50e8a91c63,gfb92a5be7c+c959026f09,w.2024.47
LSST Data Management Base Package
Loading...
Searching...
No Matches
Channel.cc
Go to the documentation of this file.
1/*
2 * LSST Data Management System
3 * Copyright 2017 AURA/LSST.
4 *
5 * This product includes software developed by the
6 * LSST Project (http://www.lsst.org/).
7 *
8 * This program is free software: you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License as published by
10 * the Free Software Foundation, either version 3 of the License, or
11 * (at your option) any later version.
12 *
13 * This program is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 * GNU General Public License for more details.
17 *
18 * You should have received a copy of the LSST License Statement and
19 * the GNU General Public License along with this program. If not,
20 * see <https://www.lsstcorp.org/LegalNotices/>.
21 */
22
23#include "astshim/base.h"
24#include "astshim/KeyMap.h"
25#include "astshim/Object.h"
26#include "astshim/Stream.h"
27#include "astshim/Channel.h"
28
29namespace ast {
30
32 : Channel(astChannel(detail::source, detail::sink, "%s", options.c_str()), stream) {
33 assertOK();
34}
35
36Channel::Channel(AstChannel *chan, Stream &stream, bool isFits)
37 : Object(reinterpret_cast<AstObject *>(chan)), _stream(stream) {
38 astPutChannelData(getRawPtr(), &_stream);
39 _stream.setIsFits(isFits);
40 assertOK();
41}
42
43Channel::Channel(AstChannel *chan) : Object(reinterpret_cast<AstObject *>(chan)), _stream() { assertOK(); }
44
46 if (_stream.hasStdStream()) {
47 // avoid any attempt to read or write while the stream is being destroyed
48 astPutChannelData(getRawPtr(), nullptr);
49 }
50}
51
53 AstObject *rawRet = reinterpret_cast<AstObject *>(astRead(getRawPtr()));
54 assertOK(rawRet);
55 if (!rawRet) {
56 throw std::runtime_error("Could not read an AST object from this channel");
57 }
58 return Object::fromAstObject<Object>(rawRet, false);
59}
60
61int Channel::write(Object const &object) {
62 int ret = astWrite(getRawPtr(), object.getRawPtr());
63 assertOK();
64 return ret;
65}
66
68 AstKeyMap *rawKeyMap =
69 reinterpret_cast<AstKeyMap *>(astWarnings(reinterpret_cast<AstChannel const *>(getRawPtr())));
70 assertOK();
71 return rawKeyMap ? KeyMap(rawKeyMap) : KeyMap();
72}
73
74} // namespace ast
Channel provides input/output of AST objects.
Definition Channel.h:60
virtual ~Channel()
Definition Channel.cc:45
KeyMap warnings() const
Return a KeyMap holding the text of any warnings issued as a result of the previous invocation of rea...
Definition Channel.cc:67
Channel(Stream &stream, std::string const &options="")
Construct a channel that uses a provided Stream.
Definition Channel.cc:31
std::shared_ptr< Object > read()
Read an object from a channel.
Definition Channel.cc:52
int write(Object const &object)
Write an object to a channel.
Definition Channel.cc:61
KeyMap is used to store a set of values with associated keys which identify the values.
Definition KeyMap.h:83
Abstract base class for all AST objects.
Definition Object.h:51
AstObject const * getRawPtr() const
Get the raw AST pointer.
Definition Object.h:292
A stream for ast::Channel.
Definition Stream.h:41
bool hasStdStream()
Return true if this Stream has an input or output std::stream.
Definition Stream.h:73
void setIsFits(bool isFits)
set isFits
Definition Stream.h:129
AST wrapper classes and functions.
void assertOK(AstObject *rawPtr1=nullptr, AstObject *rawPtr2=nullptr)
Throw std::runtime_error if AST's state is bad.
Definition base.cc:49