pipe_spec.rb

require'libuv'


describeLibuv::Pipedo
before:eachdo
@log=[]
@general_failure=[]

@reactor=Libuv::Reactor.new
@server=@reactor.pipe
@client=@reactor.pipe
@timeout=@reactor.timerdo
@reactor.stop
@general_failure << "test timed out"
end
@timeout.start(5000)

@pipefile="/tmp/test-pipes.pipe"

@reactor.all(@server,@client,@timeout).catchdo |reason|
@general_failure << reason.inspect
@general_failure << "Failed with: #{reason.message}\n#{reason.backtrace}\n"
end

@reactor.notifierdo |error,context|
begin
@general_failure << "Log called: #{context}\n#{error.message}\n#{error.backtrace.join("\n")iferror.backtrace}\n"
rescueException=>e
@general_failure << "error in logger #{e.inspect}"
end
end

begin
File.unlink(@pipefile)
rescue
end
end

after:eachdo
begin
File.unlink(@pipefile)
rescue
end
end

describe'bidirectional inter process communication'do

it"should send a ping and return a pong"do
@reactor.run{ |reactor|
@server.bind(@pipefile)do |client|
client.progressdo |data|
@log << data
client.write('pong')
end
client.start_read
end

# catch server errors
@server.catchdo |reason|
@general_failure << reason.inspect
@reactor.stop

@general_failure << "Failed with: #{reason.message}\n#{reason.backtrace}\n"
end

# start listening
@server.listen(1024)



# connect client to server
@client.connect(@pipefile)do |client|
@client.progressdo |data|
@log << data

@client.close
end

@client.start_read
@client.write('ping')
end

@client.catchdo |reason|
@general_failure << reason.inspect
@reactor.stop

@general_failure << "Failed with: #{reason.message}\n#{reason.backtrace}\n"
end

# Stop the reactor once the client handle is closed
@client.finallydo
@server.close
@reactor.stop
end
}

expect(@general_failure).toeq([])
expect(@log).toeq(['ping','pong'])
end
end

# This test won't pass on windows as pipes don't work like this on windows
describe'unidirectional pipeline',:unix_only=>truedo
before:eachdo
system"/usr/bin/mkfifo",@pipefile
end

it"should send work to a consumer"do
@reactor.run{ |reactor|
heartbeat=@reactor.timer
@file1=@reactor.file(@pipefile,File::RDWR|File::NONBLOCK)do
@server.open(@file1.fileno)do |server|
heartbeat.progressdo
@server.write('workload').catchdo |err|
@general_failure << err
end
end
heartbeat.start(0,200)
end
end
@file1.catchdo |e|
@general_failure << "Log called: #{e.inspect} - #{e.message}\n"
end

@file2=@reactor.file(@pipefile,File::RDWR|File::NONBLOCK)do
# connect client to server
@client.open(@file2.fileno)do |consumer|
consumer.progressdo |data|
@log=data
end

consumer.start_read
end
end


timeout=@reactor.timerdo
@server.close
@client.close
timeout.close
heartbeat.close
@reactor.stop
end
timeout.start(1000)
}

expect(@general_failure).toeq([])
expect(@log).toeq('workload')
end
end
end