c@118
|
1 /* -*- c-basic-offset: 4 indent-tabs-mode: nil -*- vi:set ts=8 sts=4 sw=4: */
|
c@118
|
2 /*
|
c@118
|
3 Piper C++
|
c@118
|
4
|
c@118
|
5 An API for audio analysis and feature extraction plugins.
|
c@118
|
6
|
c@118
|
7 Centre for Digital Music, Queen Mary, University of London.
|
c@118
|
8 Copyright 2006-2016 Chris Cannam and QMUL.
|
c@118
|
9
|
c@118
|
10 Permission is hereby granted, free of charge, to any person
|
c@118
|
11 obtaining a copy of this software and associated documentation
|
c@118
|
12 files (the "Software"), to deal in the Software without
|
c@118
|
13 restriction, including without limitation the rights to use, copy,
|
c@118
|
14 modify, merge, publish, distribute, sublicense, and/or sell copies
|
c@118
|
15 of the Software, and to permit persons to whom the Software is
|
c@118
|
16 furnished to do so, subject to the following conditions:
|
c@118
|
17
|
c@118
|
18 The above copyright notice and this permission notice shall be
|
c@118
|
19 included in all copies or substantial portions of the Software.
|
c@118
|
20
|
c@118
|
21 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
c@118
|
22 EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
c@118
|
23 MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
c@118
|
24 NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR
|
c@118
|
25 ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
|
c@118
|
26 CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
c@118
|
27 WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
c@118
|
28
|
c@118
|
29 Except as contained in this notice, the names of the Centre for
|
c@118
|
30 Digital Music; Queen Mary, University of London; and Chris Cannam
|
c@118
|
31 shall not be used in advertising or otherwise to promote the sale,
|
c@118
|
32 use or other dealings in this Software without prior written
|
c@118
|
33 authorization.
|
c@118
|
34 */
|
c@90
|
35
|
c@90
|
36 #ifndef PIPER_SYNCHRONOUS_TRANSPORT_H
|
c@90
|
37 #define PIPER_SYNCHRONOUS_TRANSPORT_H
|
c@90
|
38
|
c@90
|
39 #include <vector>
|
c@92
|
40 #include <cstdlib>
|
c@121
|
41 #include <stdexcept>
|
c@90
|
42
|
c@97
|
43 namespace piper_vamp {
|
c@97
|
44 namespace client {
|
c@90
|
45
|
c@92
|
46 class MessageCompletenessChecker // interface
|
c@92
|
47 {
|
c@92
|
48 public:
|
c@92
|
49 virtual ~MessageCompletenessChecker() = default;
|
c@92
|
50
|
c@92
|
51 virtual bool isComplete(const std::vector<char> &message) const = 0;
|
c@92
|
52 };
|
c@92
|
53
|
c@121
|
54 class ServerCrashed : public std::runtime_error
|
c@121
|
55 {
|
c@121
|
56 public:
|
c@121
|
57 ServerCrashed() : std::runtime_error("Piper server exited unexpectedly") {}
|
c@121
|
58 };
|
c@121
|
59
|
c@90
|
60 class SynchronousTransport // interface
|
c@90
|
61 {
|
c@90
|
62 public:
|
c@92
|
63 virtual ~SynchronousTransport() = default;
|
c@92
|
64
|
c@126
|
65 /**
|
c@126
|
66 * Set a completeness checker object. The caller retains ownership
|
c@126
|
67 * of the checker and must ensure its lifespan outlives the transport.
|
c@126
|
68 */
|
c@92
|
69 virtual void setCompletenessChecker(MessageCompletenessChecker *) = 0;
|
c@90
|
70
|
c@126
|
71 /**
|
c@126
|
72 * Make a synchronous call, passing a serialised request in the data array
|
c@126
|
73 * of length bytes, and return the result.
|
c@126
|
74 *
|
c@126
|
75 * The slow flag is a hint that the recipient may take longer than usual
|
c@126
|
76 * to process this request and so the caller may wish to be more relaxed
|
c@126
|
77 * about idling to wait for the reply. (This shouldn't make any difference
|
c@126
|
78 * with a sensible blocking network API, but you never know...)
|
c@126
|
79 *
|
c@126
|
80 * May throw ServerCrashed if the server endpoint disappeared during the
|
c@126
|
81 * call. Throws std::logic_error if isOK() is not true at the time of
|
c@126
|
82 * calling, so check that before you call.
|
c@126
|
83 */
|
c@126
|
84 virtual std::vector<char> call(const char *data, size_t bytes, bool slow) = 0;
|
c@126
|
85
|
c@126
|
86 /**
|
c@126
|
87 * Check whether the transport was initialised correctly and is working.
|
c@126
|
88 * This will return false if the endpoint could not be initialised or
|
c@126
|
89 * the endpoint service has crashed or become unavailable. Always check
|
c@126
|
90 * this before using call().
|
c@126
|
91 */
|
c@90
|
92 virtual bool isOK() const = 0;
|
c@90
|
93 };
|
c@90
|
94
|
c@90
|
95 }
|
c@94
|
96 }
|
c@90
|
97
|
c@90
|
98 #endif
|