Home
last modified time | relevance | path

Searched full:to (Results 1 – 25 of 2348) sorted by relevance

12345678910>>...94

/thrift-3.4.0/lib/rb/spec/
Djson_protocol_spec.rb3 # Licensed to the Apache Software Foundation (ASF) under one
7 # to you under the Apache License, Version 2.0 (the
13 # Unless required by applicable law or agreed to in writing,
33 expect(@trans.read(@trans.available)).to eq('\u000a')
36 expect(@trans.read(@trans.available)).to eq('\u0020')
41 expect(@trans.read(@trans.available)).to eq('\\n')
44 expect(@trans.read(@trans.available)).to eq(' ')
47 expect(@trans.read(@trans.available)).to eq("\\\\")
50 expect(@trans.read(@trans.available)).to eq('@')
55 expect(@trans.read(@trans.available)).to eq("\"this is a \\\\ json\\nstring\"")
[all …]
Dbase_transport_spec.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
27 expect(exc.type).to eq(Thrift::TransportException::ALREADY_OPEN)
28 expect(exc.message).to eq("msg")
35 expect(transport).to receive(:read).with(40).ordered.and_return("10 letters")
36 expect(transport).to receive(:read).with(30).ordered.and_return("fifteen letters")
37 expect(transport).to receive(:read).with(15).ordered.and_return("more characters")
38 expect(transport.read_all(40)).to eq("10 lettersfifteen lettersmore characters")
44 expect(Thrift::BaseTransport.method_defined?(sym)).to be_truthy
[all …]
Dstruct_spec.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
28 expect(fields).to eq(SpecNamespace::Foo::FIELDS)
31 it "should initialize all fields to defaults" do
35 it "should initialize all fields to defaults and accept a block argument" do
42 expect(object.simple).to eq(53)
43 expect(object.words).to eq("words")
44 expect(object.hello).to eq(SpecNamespace::Hello.new(:greeting => 'hello, world!'))
45 expect(object.ints).to eq([1, 2, 2, 3])
[all …]
Dexception_spec.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
27 expect(e.message).to eq("test message")
33 expect(Thrift::ApplicationException.superclass).to eq(Thrift::Exception)
38 expect(e.type).to eq(Thrift::ApplicationException::UNKNOWN)
39 expect(e.message).to be_nil
41 expect(e.type).to eq(Thrift::ApplicationException::UNKNOWN_METHOD)
42 expect(e.message).to eq("test message")
47 expect(prot).to receive(:read_struct_begin).ordered
[all …]
Dbytes_spec.rb3 # Licensed to the Apache Software Foundation (ASF) under one
7 # to you under the Apache License, Version 2.0 (the
13 # Unless required by applicable law or agreed to in writing,
28 expect(b.length).to eq(0)
29 expect(b.encoding).to eq(Encoding::BINARY)
34 expect(b.length).to eq(2)
35 expect(b.getbyte(0)).to eq(0)
36 expect(b.getbyte(1)).to eq(0)
37 expect(b.encoding).to eq(Encoding::BINARY)
46 expect(a.encoding).to eq(Encoding::BINARY)
[all …]
Dhttp_client_spec.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
26 @client = Thrift::HTTPClientTransport.new("http://my.domain.com/path/to/service?param=value")
30 @client.to_s == "http://my.domain.com/path/to/service?param=value"
34 expect(@client).to be_open
36 expect(@client).to be_open
42 expect(Net::HTTP).to receive(:new).with("my.domain.com", 80) do
44 expect(http).to receive(:use_ssl=).with(false)
45 …expect(http).to receive(:post).with("/path/to/service?param=value", "a test frame", {"Content-Type…
[all …]
Dbase_protocol_spec.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
33 expect(@trans).to receive(:to_s).once.and_return("trans")
34 expect(@prot.to_s).to eq("trans")
38 expect(@prot.trans).to eql(@trans)
42 expect(@prot).to receive(:write_field_begin).with('field', 'type', 'fid').ordered
43 … expect(@prot).to receive(:write_type).with({:name => 'field', :type => 'type'}, 'value').ordered
44 expect(@prot).to receive(:write_field_end).ordered
49 expect(@prot).to receive(:write_field_begin).with('field', 'type', 'fid').ordered
[all …]
Dserver_spec.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
32 it "should default to BaseTransportFactory and BinaryProtocolFactory when not specified" do
34 …expect(@server.instance_variable_get(:'@transport_factory')).to be_an_instance_of(Thrift::BaseTran…
35 …expect(@server.instance_variable_get(:'@protocol_factory')).to be_an_instance_of(Thrift::BinaryPro…
39 expect { @server.serve()}.to raise_error(NotImplementedError)
43 expect(@serverTrans).to receive(:to_s).once.and_return("serverTrans")
44 expect(@trans).to receive(:to_s).once.and_return("trans")
45 expect(@prot).to receive(:to_s).once.and_return("prot")
[all …]
Dunix_socket_spec.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
30 allow(@handle).to receive(:close)
31 allow(::UNIXSocket).to receive(:new).and_return(@handle)
37 expect(::UNIXSocket).to receive(:new).and_raise(StandardError)
38 …expect { @socket.open }.to raise_error(Thrift::TransportException) { |e| expect(e.type).to eq(Thri…
42 allow(::UNIXSocket).to receive(:new)
43 expect(Thrift::UNIXSocket.new(@path, 5).timeout).to eq(5)
47 allow(::UNIXSocket).to receive(:new)
[all …]
Dsocket_spec_shared.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
24 expect(@socket.open).to eq(@handle)
30 expect(@socket).to be_open
38 it "should write data to the handle" do
40 expect(@handle).to receive(:write).with("foobar")
42 expect(@handle).to receive(:write).with("fail").and_raise(StandardError)
43 …expect { @socket.write("fail") }.to raise_error(Thrift::TransportException) { |e| expect(e.type).t…
48 expect(@handle).to receive(:readpartial).with(17).and_raise(StandardError)
[all …]
Dprocessor_spec.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
35 expect(obj).to receive(:trans).ordered do
37 expect(trans).to receive(:flush).ordered
43 …expect(@prot).to receive(:read_message_begin).ordered.and_return ['testMessage', Thrift::MessageTy…
44 expect(@processor).to receive(:process_testMessage).with(17, @prot, @prot).ordered
45 expect(@processor.process(@prot, @prot)).to eq(true)
49 …expect(@prot).to receive(:read_message_begin).ordered.and_return ['testMessage', Thrift::MessageTy…
50 expect(@prot).to receive(:skip).with(Thrift::Types::STRUCT).ordered
[all …]
Dssl_socket_spec.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
30 allow(@simple_socket_handle).to receive(:close)
31 allow(@simple_socket_handle).to receive(:connect_nonblock)
32 allow(@simple_socket_handle).to receive(:setsockopt)
35 allow(@handle).to receive(:connect_nonblock)
36 allow(@handle).to receive(:close)
37 allow(@handle).to receive(:post_connection_check)
39 allow(::Socket).to receive(:new).and_return(@simple_socket_handle)
[all …]
Dserver_socket_spec.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
31 expect(TCPServer).to receive(:new).with(nil, 1234)
37 expect(TCPServer).to receive(:new).with('localhost', 1234)
42 it "should create a Thrift::Socket to wrap accepted sockets" do
44 expect(TCPServer).to receive(:new).with(nil, 1234).and_return(handle)
47 expect(handle).to receive(:accept).and_return(sock)
49 expect(Thrift::Socket).to receive(:new).and_return(trans)
50 expect(trans).to receive(:handle=).with(sock)
[all …]
Dserializer_spec.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
25 it "should serialize structs to binary by default" do
28 expect(data).to eq("\x0B\x00\x01\x00\x00\x00\x0E'Ello guv'nor!\x00")
31 it "should serialize structs to the given protocol" do
33 expect(protocol).to receive(:write_struct_begin).with("SpecNamespace::Hello")
34 expect(protocol).to receive(:write_field_begin).with("greeting", Thrift::Types::STRING, 1)
35 expect(protocol).to receive(:write_string).with("Good day")
36 expect(protocol).to receive(:write_field_end)
[all …]
Dunion_spec.rb2 # Licensed to the Apache Software Foundation (ASF) under one
6 # to you under the Apache License, Version 2.0 (the
12 # Unless required by applicable law or agreed to in writing,
27 expect(union.get_set_field).to eq(nil)
28 expect(union.get_value).to eq(nil)
34 expect(union.get_set_field).to eq(:integer32)
35 expect(union.get_value).to eq(25)
36 expect(union.integer32).to eq(25)
41 expect(union.get_set_field).to eq(:integer32)
42 expect(union.integer32).to eq(5)
[all …]
/thrift-3.4.0/doc/licenses/
Dlgpl-2.1.txt6 Everyone is permitted to copy and distribute verbatim copies
15 The licenses for most software are designed to take away your
16 freedom to share and change it. By contrast, the GNU General Public
17 Licenses are intended to guarantee your freedom to share and change
18 free software--to make sure the software is free for all its users.
20 This license, the Lesser General Public License, applies to some
22 Free Software Foundation and other authors who decide to use it. You
25 strategy to use in any particular case, based on the explanations below.
27 When we speak of free software, we are referring to freedom of use,
28 not price. Our General Public Licenses are designed to make sure that
[all …]
/thrift-3.4.0/build/cmake/
Dconfig.h.in2 * Licensed to the Apache Software Foundation (ASF) under one
6 * to you under the Apache License, Version 2.0 (the
12 * Unless required by applicable law or agreed to in writing,
29 /* Define to the address where bug reports for this package should be sent. */
32 /* Define to the full name of this package. */
35 /* Define to the one symbol short name of this package. */
38 /* Define to the home page for this package. */
41 /* Define to the version of this package. */
44 /* Define to the full name and version of this package. */
53 /* TODO: This is just set to 1 for the moment
[all …]
/thrift-3.4.0/.github/
Dstale.yml7 # Set to false to disable. If disabled, issues still need to be closed manually, but will remain ma…
10 # Issues or Pull Requests with these labels will never be considered stale. Set to `[]` to disable
18 # Set to true to ignore issues in a project (defaults to false)
21 # Set to true to ignore issues in a milestone (defaults to false)
24 # Label to use when marking as stale
27 # Comment to post when marking as stale. Set to `false` to disable
33 # Comment to post when removing the stale label.
38 # Comment to post when closing a stale Issue or Pull Request.
40 This issue has been automatically closed due to inactivity.
46 # Limit to only `issues` or `pulls`
[all …]
/thrift-3.4.0/doc/specs/
Dthrift.tex11 % You will need a copy of sigplanconf.cls to format this document.
28 % \copyrightdata{[to be supplied]}
44 Facebook to expedite development and implementation of efficient and scalable
45 backend services. Its primary goal is to enable efficient and reliable
47 language that tend to require the most customization into a common library
48 that is implemented in each language. Specifically, Thrift allows developers to
50 and generate all the necessary code to build RPC clients and servers.
54 intended to be taken as research, but rather it is an exposition on what we did
71 these services, various programming languages have been selected to
88 Choosing static code generation over a dynamic system allows us to create
[all …]
/thrift-3.4.0/
DCONTRIBUTING.md1 # How to Contribute #
3 …to the Apache Thrift project! Information on why and how to contribute is available on the Apache…
12 it activates the continuous integration (CI) build systems at Appveyor and Travis to build your cha…
18 1. All pull requests should contain a single commit per issue, or we will ask you to squash it.
31 1. Clone the fork to your development system.
33 1. Modify the source to include the improvement/bugfix, and:
35 * Remember to provide *tests* for all submitted changes!
38 …to [Travis CI](http://docs.travis-ci.com/user/getting-started/#Step-one%3A-Sign-in) and [AppVeyor]…
40 1. Squash your changes to a single commit. This maintains clean change history.
41 …1. Commit and push changes to your branch (please use issue name and description as commit title, …
[all …]
/thrift-3.4.0/lib/java/
DREADME.md6 Licensed to the Apache Software Foundation (ASF) under one
10 to you under the Apache License, Version 2.0 (the
16 Unless required by applicable law or agreed to in writing,
27 easiest way to build and install is this simple command line:
31 It is important to use the install/fast option to eliminate
33 the build tooling is designed to work with cached files in the
36 install code to copy to the target destination.
42 the Gradle build system, which tends to be predominant amongst Java
45 Currently we use gradle 7.5.1 to build the Thrift Java source. The usual way to setup gradle
46 project is to include the gradle-wrapper.jar in the project and then run the gradle wrapper to
[all …]
/thrift-3.4.0/contrib/zeromq/
DREADME.md1 This directory contains some glue code to allow Thrift RPCs to be sent over
8 hidden from developers, but one cannot be: oneway methods have to be handled
9 differently from normal ones. ZeroMQ requires the messaging pattern to be
11 message-by-message basis whether to send a reply. Therefore, this
12 implementation makes it the client's responsibility to ensure that ZMQ_REQ
15 have to expose two servers (on two ports), but the TZmqMultiServer makes it
16 easy to run the two together in the same thread.
20 To build, simply install Thrift and ZeroMQ, then run "make". If you install
21 in a non-standard location, make sure to set THRIFT to the location of the
22 Thrift code generator on the make command line and PKG_CONFIG_PATH to a path
[all …]
/thrift-3.4.0/lib/cpp/src/thrift/transport/
DTTransport.h2 * Licensed to the Apache Software Foundation (ASF) under one
6 * to you under the Apache License, Version 2.0 (the
12 * Unless required by applicable law or agreed to in writing,
34 * Helper template to hoist readAll implementation out of TTransport
44 throw TTransportException(TTransportException::END_OF_FILE, "No more data to read."); in readAll()
79 * Tests whether there is more data to read or if the remote side is
81 * but implementations should add logic to test for this condition where
83 * This is used by a server to check if it should listen for another
106 * Attempt to read up to the specified number of bytes into the string.
108 * @param buf Reference to the location to write the data
[all …]
/thrift-3.4.0/lib/d/src/thrift/async/
Dbase.d2 * Licensed to the Apache Software Foundation (ASF) under one
6 * to you under the Apache License, Version 2.0 (the
12 * Unless required by applicable law or agreed to in writing,
41 * // the async manager to execute another task in the meantime, because
45 * // Do something with s, e.g. set a TPromise result to it.
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
64 * used. Each work item is run in its own fiber and is expected to yield() away
67 * The second important purpose of TAsyncManager is to serialize access to
69 * RPC calls over the same connection in rapid succession would likely lead to
[all …]
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/
DTSimpleFileTransport.java2 * Licensed to the Apache Software Foundation (ASF) under one
6 * to you under the Apache License, Version 2.0 (the
12 * Unless required by applicable law or agreed to in writing,
36 * @param path the path to the file to open/create
37 * @param read true to support read operations
38 * @param write true to support write operations
39 * @param openFile true to open the file on construction
51 * @param path the path to the file to open/create
52 * @param read true to support read operations
53 * @param write true to support write operations
[all …]

12345678910>>...94