| /thrift-3.4.0/lib/d/src/thrift/async/ |
| D | base.d | 26 * which can have a return value, throw exceptions, and which can be waited
31 * TAsyncManager, the same code as for synchronous I/O can be used for
60 * case of TAsyncSocketManager) and allows work items to be submitted for them.
63 * executing the work, which is one of the reasons for a TAsyncManager to be
77 * Submits a work item to be executed asynchronously.
80 * with the same transport are submitted, the second delegate will not be
85 * Optionally, a TCancellation instance can be specified. If present,
86 * triggering it will be considered a request to cancel the work item, if it
90 * (as probably half-written request or a half-read response would be left
95 * be associated with this TAsyncManager instance.
[all …]
|
| D | libevent.d | 75 // stop() should be safe to call, because either we don't have a worker in ~this()
76 // thread running and it is a no-op anyway, or it is guaranteed to be in ~this()
78 // be garbage collected yet. in ~this()
91 // Keep track that there is a new work item to be processed.
96 // We should be able to send the control message as a whole – we currently
97 // assume to be able to receive it at once as well. If this proves to be
100 // be changed to a more sophisticated scheme.
229 // Technically, only half barriers would be required here, but adding the in ensureWorkerThreadRunning()
259 // should be available, as we got notified by libevent). in receiveControlMsg()
269 "never be executed: %s", socketErrnoString(errno)); in receiveControlMsg()
[all …]
|
| /thrift-3.4.0/tutorial/netstd/ |
| D | README.md | 41 tcp - (default) tcp transport will be used (host - ""localhost"", port - 9090)
42 namedpipe - namedpipe transport will be used (pipe address - "".test"")
43 http - http transport will be used (http address - ""localhost:9090"")
44 tcptls - tcp transport with tls will be used (host - ""localhost"", port - 9090)
47 none - (default) no transport factory will be used
48 buffered - buffered transport factory will be used
49 framed - framed transport factory will be used (this must match the client)
52 binary - (default) binary protocol will be used
53 compact - compact protocol will be used
54 json - json protocol will be used
[all …]
|
| /thrift-3.4.0/lib/go/thrift/ |
| D | configuration.go | 67 // socket and transFactory will be overwritten by the one used by protoFactory
103 // If <= 0, DEFAULT_MAX_MESSAGE_SIZE will be used instead.
106 // If <= 0, DEFAULT_MAX_FRAME_SIZE will be used instead.
109 // MaxMessageSize will be used instead.
112 // Connect and socket timeouts to be used by TSocket and TSSLSocket.
116 // If <0, DEFAULT_CONNECT_TIMEOUT and DEFAULT_SOCKET_TIMEOUT will be
121 // TLS config to be used by TSSLSocket.
130 // The wrapped protocol id to be used in THeader transport/protocol.
146 // It's nil-safe. DEFAULT_MAX_MESSAGE_SIZE will be returned if tc is nil.
156 // It's nil-safe. DEFAULT_MAX_FRAME_SIZE will be returned if tc is nil.
[all …]
|
| /thrift-3.4.0/lib/cpp/src/thrift/protocol/ |
| D | TBase64Utils.h | 30 // in must be at least len bytes
31 // len must be 1, 2, or 3
32 // buf must be a buffer of at least 4 bytes and may not overlap in
36 // buf must be a buffer of at least 4 bytes and contain base64 encoded values
37 // buf will be changed to contain output bytes
38 // len is number of bytes to consume from input (must be 2, 3, or 4)
39 // no '=' padding should be included in the input
|
| /thrift-3.4.0/doc/specs/ |
| D | thrift-sasl-spec.txt | 1 A Thrift SASL message shall be a byte array of the following form:
5 The length fields shall be interpreted as integers, with the high byte sent
26 server a START message. The payload of this message will be the name of the
28 This mechanism name shall be 1-20 characters in length, and follow the
36 message length, followed by the potentially zero-length payload which may be a
44 of this message must be either "OK" or "COMPLETE", depending on whether the
61 protocol, its next message shall be the COMPLETE byte, followed by a 4-byte
63 payload. This payload will be empty except for those underlying security
70 message encoded in UTF-8 indicating failure. This message should be passed to
78 be passed to the protocol above the thrift transport by whatever mechanism is
[all …]
|
| D | thrift-tconfiguration.md | 35 …* There MUST be a standard CTOR (or equivalent thereof) that provides a default TConfiguration ins…
36 * The default values used SHOULD be implemented as outlined below.
53 The RecursionLimit defines, how deep structures may be nested into each other. The default named DE…
59 …th TFramedTransport. In contrast, MaxMessageSize is intended to be a general device to be used wit…
63 …when updating the remaining read byte count, the known message size should be set to frameSize + s…
67 If any limit is exceeded, an error should be thrown. Additionally, it may be helpful to check large…
75 1. If done right, it should not be a breaking change vis-á-vis compiling your source code that uses…
77 1. It may, however, be a breaking change in the way it limits the accepted overall size of messages…
89 Technically, remember that the instance is passed down the stack and should therefore be cheap on c…
|
| D | idl.md | 37 A namespace declares which namespaces/package/module/etc. the type definitions in this file will be…
59 …eceding value for any subsequent element. Any constant value that is supplied must be non-negative.
65 Structs are the fundamental compositional type in Thrift. The name of each field must be unique wit…
81 …n handling mechanisms in the target languages. The name of each field must be unique within the ex…
109 - Write: Required fields are always written and are expected to be set.
110 - Read: Required fields are always read and are expected to be contained in the input stream.
115 … soft versioning. Because they must be present on read, the fields cannot be deprecated. If a requ…
120 - Read: Optional fields may, or may not be part of the input stream.
128 - Read: Like optional, the field may, or may not be part of the input stream.
129 - Default values: may not be written (see next section)
[all …]
|
| D | thrift.tex | 28 % \copyrightdata{[to be supplied]}
54 intended to be taken as research, but rather it is an exposition on what we did
89 validated code that can be run without the need for
91 be as simple as possible for the developer, who can typically define all
105 a C++ programmer should be able to transparently exchange a strongly typed
107 programmer should be forced to write any code below the application layer
113 The same application code should be able to run against TCP stream sockets,
119 developer need not be concerned by this layer. Whether the service uses
121 All that matters is that the data can be read and written in a consistent,
126 it should be possible to add or remove fields in an object or alter the
[all …]
|
| D | thrift-parameter-validation-proposal.md | 15 …nerating codes for simple and unchangeable restraint, the web service will be more robust and deve…
16 … proposal). Take a long-term view, auto-generated parameter validation may be a step towards code-…
70 …will take the logical relation as "and". Simply put, commas in annotations can be treated as "and".
78 | const | must be constant | string, bool | sam…
79 | defined_only | must be defined value | enum | enu…
80 | not_nil | must not be empty | "true" | any…
95 | prefix | field prefix must be (case-sensitive) | string | str…
96 | suffix | suffix must be (case-sensitive) | string | str…
101 - Basic Regular Expression (BRE), the syntax of BRE can be found in [manual](https://www.gnu.org/so…
168 … compare more than one field. The referenced field must be within same struct. Identifier must be …
[all …]
|
| /thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/partial/ |
| D | ValidateTest.java | 44 "'nullArg' must not be null"); in testCheckNotNull()
60 "'negativeArg' must be a positive integer"); in testCheckPositiveInteger()
64 "'zero' must be a positive integer"); in testCheckPositiveInteger()
81 "'negativeArg' must not be negative"); in testCheckNotNegative()
135 "'string' must not be empty"); in testCheckNotNullAndNotEmpty()
140 "'array' must not be null"); in testCheckNotNullAndNotEmpty()
150 "'array' must not be null"); in testCheckNotNullAndNotEmpty()
160 "'array' must not be null"); in testCheckNotNullAndNotEmpty()
170 "'array' must not be null"); in testCheckNotNullAndNotEmpty()
180 "'array' must not be null"); in testCheckNotNullAndNotEmpty()
[all …]
|
| /thrift-3.4.0/lib/d/src/thrift/transport/ |
| D | base.d | 26 * An entity data can be read from and/or written to.
35 * If a transport is closed, it can be opened by calling open(), and vice
38 * While a transport should always be open when trying to read/write data,
43 * there is still data left to be read in the buffers. This choice has been
53 * A typical use case would be a server checking if it should process
81 * but waiting for new data to arrive would be required to fill the whole
82 * buffer, the readily available data will be immediately returned – use
107 * Must be called by clients when read is completed.
120 * and available to be read back in the future. Destroying a TTransport
122 * TTransport object with written but unflushed data, that data may be
[all …]
|
| /thrift-3.4.0/lib/d/src/thrift/server/ |
| D | base.d | 33 * implementation, custom code can be integrated into the processing pipeline,
34 * which can be used e.g. for gathering statistics.
44 * effort way – usually, it should be possible to immediately stop accepting
46 * processed, but this might not be the case for every conceivable
99 new TException("Input transport factory must not be null.")); in this()
101 new TException("Output transport factory must not be null.")); in this()
103 new TException("Input protocol factory must not be null.")); in this()
105 new TException("Output protocol factory must not be null.")); in this()
170 * Called when request handling for a client has been finished – can be used
176 * Called when the processor for a client call is about to be invoked.
|
| /thrift-3.4.0/lib/haxe/ |
| D | README.md | 39 target libraries need to be installed and how to achieve this.
46 manager, where possible. More detailed information can be found at the
54 this can be solved depending on your OSes bitness by either
67 Thrift Haxe bindings can be set up via the `haxelib` tool as usual.
68 Alternatively, the "github" method can be used.
78 As usual, the installed library can be updated using `haxelib upgrade`
83 downloads and more information can be found at http://thrift.apache.org
92 This version requires Haxe 4 and cannot be used with earlier versions.
100 client side, plus a new ```_service``` interface to be used for server
134 - to allow thrift server to read/write HTTP request/response, it should be pointed out to php strea…
[all …]
|
| /thrift-3.4.0/lib/go/ |
| D | README.md | 60 We must be able to distinguish between optional fields that are set to their
107 The context object passed into the server handler function will be canceled when
124 If that is unacceptable, it can be disabled by having this line early in your
129 Please be advised that due to a
139 …e/thrift/lib/go/thrift#TSimpleServer.Stop) will wait for all client connections to be closed after
140 the last received request to be handled, as the time spent by Stop
141 may sometimes be too long:
142 * When socket timeout is not set, server might be hanged before all active
153 If it's set to <=0, the feature will be disabled (by default), and server
154 will wait for all the client connections to be closed gracefully with
[all …]
|
| /thrift-3.4.0/lib/cpp/src/thrift/transport/ |
| D | TTransport.h | 53 * Generic interface for a method of transporting data. A TTransport may be
126 * @return How many bytes read, which must be equal to size
139 * This can be over-ridden to perform a transport-specific action
153 * and available to be read back in the future. Destroying a TTransport
155 * TTransport object with written but unflushed data, that data may be
171 * This can be over-ridden to perform a transport-specific action
182 * Flushes any pending data to be written. Typically used with buffered
198 * will fail occasionally, so protocols must be prepared to use read if
201 * @oaram buf A buffer where the data can be stored if needed.
203 * buf after the call are undefined. This parameter may be
[all …]
|
| D | TSSLSocket.h | 52 * equivalent function to initialize OpenSSL, must be called before
59 * Cleanup OpenSSL library. This function should be called to clean
127 * Constructor, create an instance of TSSLSocket given an existing socket that can be interrupted.
189 * SSL socket factory. SSL sockets should be created via SSL factory.
196 * longer be responsible for openssl initialization and teardown.
203 * however, since it would be up to the consuming application instead.
237 * @param host Remote host to be connected to
238 * @param port Remote port to be connected to
244 * @param host Remote host to be connected to
245 * @param port Remote port to be connected to
[all …]
|
| /thrift-3.4.0/test/erl/src/ |
| D | thrift_test.app.src | 33 % All of the registered names the application uses. This can be ignored.
36 % Applications that are to be started prior to this one. This can be ignored
42 % this can be ignored as well. To load but not start an application it
47 % on the command line. can be fetched with gas:get_env
|
| /thrift-3.4.0/lib/go/test/tests/ |
| D | validate_test.go | 50 t.Errorf("Error cannot be unwrapped into *ValidationError: %v", err)
64 t.Errorf("Error cannot be unwrapped into *ValidationError: %v", err)
78 t.Errorf("Error cannot be unwrapped into *ValidationError: %v", err)
92 t.Errorf("Error cannot be unwrapped into *ValidationError: %v", err)
106 t.Errorf("Error cannot be unwrapped into *ValidationError: %v", err)
123 t.Errorf("Error cannot be unwrapped into *ValidationError: %v", err)
136 t.Errorf("Error cannot be unwrapped into *ValidationError: %v", err)
149 t.Errorf("Error cannot be unwrapped into *ValidationError: %v", err)
165 t.Errorf("Error cannot be unwrapped into *ValidationError: %v", err)
178 t.Errorf("Error cannot be unwrapped into *ValidationError: %v", err)
[all …]
|
| /thrift-3.4.0/doc/licenses/ |
| D | lgpl-2.1.txt | 56 author's reputation will not be affected by problems that might be
63 any patent license obtained for a version of the library must be
89 For example, on rare occasions, there may be a special need to
91 a de-facto standard. To achieve this, non-free programs must be
113 be combined with the library in order to run.
120 other authorized party saying it may be distributed under the terms of
125 prepared so as to be conveniently linked with application programs
167 a) The modified work must itself be a software library.
172 c) You must cause the whole of the work to be licensed at no
176 table of data to be supplied by an application program that uses
[all …]
|
| /thrift-3.4.0/lib/c_glib/test/ |
| D | testapplicationexception.c | 30 /* A ThriftApplicationException can be created... */ in test_create_and_destroy()
50 be initialized at object creation */ in test_initialize()
59 /* A ThriftApplicationException's properties can be retrieved */ in test_initialize()
87 /* The "type" property can be set to any valid Thrift exception type */ in test_properties_test()
107 /* The "type" property cannot be set to a value too low (less than zero) */ in test_properties_test()
120 /* The "type" property cannot be set to a value too high (greater than the in test_properties_test()
147 /* The "message" property can be set to NULL */ in test_properties_message()
152 /* The "message" property can be set to a valid string */ in test_properties_message()
|
| /thrift-3.4.0/lib/erl/src/ |
| D | thrift.app.src | 53 % All of the registered names the application uses. This can be ignored.
56 % Applications that are to be started prior to this one. This can be ignored
62 % this can be ignored as well. To load but not start an application it
67 % on the command line. can be fetched with gas:get_env
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/server/ |
| D | TExtensibleServlet.java | 43 * TProtocolFactory} to be supplied after the {@link #init()} method has finished. <br>
45 * TProtocolFactory. Those methods are guaranteed to be called exactly once, and that {@link
58 * Returns the appropriate {@link TProcessor}. This will be called <b>once</b> just after the
66 * Returns the appropriate in {@link TProtocolFactory}. This will be called <b>once</b> just after
74 * Returns the appropriate out {@link TProtocolFactory}. This will be called <b>once</b> just
90 throw new ServletException("processor must be set"); in init()
93 throw new ServletException("inFactory must be set"); in init()
96 throw new ServletException("outFactory must be set"); in init()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/protocol/ |
| D | TProtocolUtil.java | 50 * @param type the next value will be interpreted as this TType value.
60 * @param type the next value will be interpreted as this TType value.
148 * can be done, in that case we return the fallback TProtocolFactory. To be certain to correctly
152 * @param fallback The TProtocol to return if no guess can be made.
153 * @return a Class implementing TProtocolFactory which can be used to create a deserializer.
159 // It could not be a TCompactBinary encoding for a field of type 0xb (Map) in guessProtocolFactory()
168 // If the last byte is not 0, then it cannot be TCompactProtocol, it must be in guessProtocolFactory()
187 // It cannot possibly be TCompactProtocol since a value of 0 would imply a field id in guessProtocolFactory()
|
| /thrift-3.4.0/lib/cpp/ |
| D | README.md | 130 This SSL only supports blocking mode socket I/O. It can only be used with
144 An example of certificate validation can be found in TestServer.cpp.
159 Decisions can be one of ALLOW, DENY, and SKIP. ALLOW and DENY means the
160 conversation should be continued or disconnected, respectively. ALLOW and
177 should be the remote host name. Keep in mind, if TSocket::getPeerHost()
181 be checked. It is sent to application through (c), where "sa" is the remote
186 verification process would be stopped.
188 If any of the above "verify" methods returned SKIP, that decision would be
194 to be used by many SSL sockets.
225 keys/server.crt has to be replaced with that host name.
[all …]
|
