]>
git.proxmox.com Git - ceph.git/blob - ceph/src/jaegertracing/thrift/lib/rb/spec/unix_socket_spec.rb
2 # Licensed to the Apache Software Foundation (ASF) under one
3 # or more contributor license agreements. See the NOTICE file
4 # distributed with this work for additional information
5 # regarding copyright ownership. The ASF licenses this file
6 # to you under the Apache License, Version 2.0 (the
7 # "License"); you may not use this file except in compliance
8 # with the License. You may obtain a copy of the License at
10 # http://www.apache.org/licenses/LICENSE-2.0
12 # Unless required by applicable law or agreed to in writing,
13 # software distributed under the License is distributed on an
14 # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15 # KIND, either express or implied. See the License for the
16 # specific language governing permissions and limitations
21 require File
.expand_path("#{File.dirname(__FILE__)}/socket_spec_shared")
23 describe
'UNIXSocket' do
25 describe Thrift
::UNIXSocket do
27 @path = '/tmp/thrift_spec_socket'
28 @socket = Thrift
::UNIXSocket.new(@path)
29 @handle = double("Handle", :closed? => false)
30 allow(@handle).to
receive(:close)
31 allow(::UNIXSocket).to
receive(:new).and_return(@handle)
34 it_should_behave_like
"a socket"
36 it
"should raise a TransportException when it cannot open a socket" do
37 expect(::UNIXSocket).to
receive(:new).and_raise(StandardError
)
38 expect
{ @socket.open
}.to
raise_error(Thrift
::TransportException) { |e
| expect(e
.type
).to
eq(Thrift
::TransportException::NOT_OPEN) }
41 it
"should accept an optional timeout" do
42 allow(::UNIXSocket).to
receive(:new)
43 expect(Thrift
::UNIXSocket.new(@path, 5).timeout
).to
eq(5)
46 it
"should provide a reasonable to_s" do
47 allow(::UNIXSocket).to
receive(:new)
48 expect(Thrift
::UNIXSocket.new(@path).to_s
).to
eq("domain(#{@path})")
52 describe Thrift
::UNIXServerSocket do
54 @path = '/tmp/thrift_spec_socket'
55 @socket = Thrift
::UNIXServerSocket.new(@path)
58 it
"should create a handle when calling listen" do
59 expect(UNIXServer
).to
receive(:new).with(@path)
63 it
"should create a Thrift::UNIXSocket to wrap accepted sockets" do
64 handle
= double("UNIXServer")
65 expect(UNIXServer
).to
receive(:new).with(@path).and_return(handle
)
68 expect(handle
).to
receive(:accept).and_return(sock
)
69 trans
= double("UNIXSocket")
70 expect(Thrift
::UNIXSocket).to
receive(:new).and_return(trans
)
71 expect(trans
).to
receive(:handle=).with(sock
)
72 expect(@socket.accept
).to
eq(trans
)
75 it
"should close the handle when closed" do
76 handle
= double("UNIXServer", :closed? => false)
77 expect(UNIXServer
).to
receive(:new).with(@path).and_return(handle
)
79 expect(handle
).to
receive(:close)
80 allow(File
).to
receive(:delete)
84 it
"should delete the socket when closed" do
85 handle
= double("UNIXServer", :closed? => false)
86 expect(UNIXServer
).to
receive(:new).with(@path).and_return(handle
)
88 allow(handle
).to
receive(:close)
89 expect(File
).to
receive(:delete).with(@path)
93 it
"should return nil when accepting if there is no handle" do
94 expect(@socket.accept
).to be_nil
97 it
"should return true for closed? when appropriate" do
98 handle
= double("UNIXServer", :closed? => false)
99 allow(UNIXServer
).to
receive(:new).and_return(handle
)
100 allow(File
).to
receive(:delete)
102 expect(@socket).not_to be_closed
103 allow(handle
).to
receive(:close)
105 expect(@socket).to be_closed
107 expect(@socket).not_to be_closed
108 allow(handle
).to
receive(:closed?).and_return(true)
109 expect(@socket).to be_closed
112 it
"should provide a reasonable to_s" do
113 expect(@socket.to_s
).to
eq("domain(#{@path})")