ganmacs

require 'socket'

HOST = 'localost'
N1 = 2
N2 = 10
MSG = "testtesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttest\n"

def run
  @stop = false

ganmacs

# frozen_string_literal: true

source "https://rubygems.org"

git_source(:github) {|repo_name| "https://github.com/#{repo_name}" }

gem "benchmark-memory"

ganmacs

class FIFO
  def initialize(from_encoding, encoding)
    @from_encoding = from_encoding
    @encoding = encoding
    @need_enc = from_encoding != encoding
    @buffer = ''.force_encoding(from_encoding)
    @eol = "\n".encode(from_encoding).freeze
  end

  attr_reader :from_encoding, :encoding, :buffer

ganmacs

require 'socket'

class Server
  def call
    File.unlink('socket1')
    File.unlink('socket2')
    server1 = UNIXServer.new('socket1')

    server2 = UNIXServer.new('socket2')
    v = Queue.new

ganmacs

require 'logger'
require 'grpc'
require 'grpc/health/checker'

module RubyLogger
  def logger
    Logger.new(STDOUT, level: :debug)
  end
end
GRPC.extend(RubyLogger)

ganmacs

require 'logger'
require 'grpc'
require 'grpc/health/checker'

module RubyLogger
  def logger
    Logger.new(STDOUT, level: :debug)
  end
end
GRPC.extend(RubyLogger)

ganmacs

$ bundle exec rspec
/Users/ganmacs/src/github.com/grpc/grpc/src/ruby/spec/channel_credentials_spec.rb:19: warning: already initialized constant CallCredentials
/Users/ganmacs/src/github.com/grpc/grpc/src/ruby/spec/call_credentials_spec.rb:18: warning: previous definition of CallCredentials was here
/Users/ganmacs/src/github.com/grpc/grpc/src/ruby/spec/generic/rpc_server_spec.rb:161: warning: already initialized constant RpcServer
/Users/ganmacs/src/github.com/grpc/grpc/src/ruby/spec/client_auth_spec.rb:81: warning: previous definition of RpcServer was here
/Users/ganmacs/src/github.com/grpc/grpc/src/ruby/spec/generic/rpc_server_spec.rb:162: warning: already initialized constant StatusCodes
/Users/ganmacs/src/github.com/grpc/grpc/src/ruby/spec/error_sanity_spec.rb:17: warning: previous definition of StatusCodes was here
/opt/brew/bin/grpc_ruby_plugin
/opt/brew/bin/protoc
/opt/brew/bin/grpc_ruby_plugin

ganmacs

require 'logger'
require 'grpc'
require_relative 'helloworld_services_pb'

module RubyLogger
  def logger
    Logger.new(STDOUT, level: :debug)
  end
end
GRPC.extend(RubyLogger)

ganmacs

$ be ruby client.rb                                                                                                                                                          
D, [2018-08-28T16:08:20.263617 #48268] DEBUG -- : calling 127.0.0.1:8000:/grpc.health.v1.Health/Check
D, [2018-08-28T16:08:20.264355 #48268] DEBUG -- : Failing with status #<struct Struct::Status code=4, details="Deadline Exceeded", metadata={}>
#<GRPC::DeadlineExceeded: 4:Deadline Exceeded>
D, [2018-08-28T16:08:20.264596 #48268] DEBUG -- : calling 127.0.0.1:8000:/grpc.health.v1.Health/Check
D, [2018-08-28T16:08:20.265544 #48268] DEBUG -- : Failing with status #<struct Struct::Status code=4, details="Deadline Exceeded", metadata={}>
#<GRPC::DeadlineExceeded: 4:Deadline Exceeded>
D, [2018-08-28T16:08:20.265779 #48268] DEBUG -- : calling 127.0.0.1:8000:/grpc.health.v1.Health/Check
D, [2018-08-28T16:08:20.266243 #48268] DEBUG -- : Failing with status #<struct Struct::Status code=4, details="Deadline Exceeded", metadata={}>
#<GRPC::DeadlineEx

ganmacs

require 'partiarelic/grpc/partiarelic_services_pb.rb'

stub = Partiarelic::V1::App::Stub.new('127.0.0.1:3000', :this_channel_is_insecure)
p stub.manual_start(Partiarelic::V1::ManualStartRequest.new)