pjambet

irb(main):138:0> [256].pack('S') > [15].pack('S')
=> false
irb(main):139:0> [256].pack('S>') > [15].pack('S>')
=> true

pjambet

require 'benchmark'
require 'securerandom'

require_relative './dict'

RANDOM_BYTES = SecureRandom.bytes(16)

class MyHash
  def initialize(pairs)
    if pairs.length == 1

pjambet

require 'benchmark'
require 'securerandom'

require_relative './dict'

RANDOM_BYTES = SecureRandom.bytes(16)

def setup_dict(size)
  dict = BYORedis::Dict.new
  size.times { |i| dict[i.to_s] = i.to_s }

pjambet

require 'socket'

socket = TCPSocket.new 'localhost', 2000
socket.write "request"
socket.close

pjambet

require 'socket'

# EPIPE, when the socket is closed by the time we try to read, we can read, but writing fails
# ECONNRESET, when the socket is closed by the time we try to write
def process_events(event)
  p 'in proccess'
  res = event.read_nonblock(1024, exception: false) # => YET THE FUCKING STACKTRACE POINTS HERE WHEN ECONNRESET
  p res
  event.puts "FUCK YOU puts" # => EPIPE
  # p '==--=='

pjambet

Notes

• dbDictType used as argument to dictCreate in server.c (initServer)
• Uses dictSdsHash, dictSdsKeyCompare, dictSdsKeyDestructor, dictObjectDestructor
• dict struct:
  • dictType
  • privdata
  • ht (2 of them)
  • rehashidx
• iterators

pjambet

require 'fiddle'

class BYOArray < BasicObject

  PTR_SIZE = ::Fiddle::SIZEOF_LONG

  def initialize(max_size)
    @max_size = max_size
    @current_size = 0
    @beginning_address = ::Fiddle::Pointer.malloc(PTR_SIZE)

pjambet

object Railway {

  sealed trait TwoTrack[F]

  case class Success[S](data: S) extends TwoTrack[S]

  case class Failure[S](message: String) extends TwoTrack[S]

  def succeed[S](x: S) = Success(x)

pjambet

object Railway {

  sealed trait TwoTrack[F]

  case class Success[S](data: S) extends TwoTrack[S]

  case class Failure[S](message: String) extends TwoTrack[S]

  def succeed[S](x: S) = Success(x)

pjambet

final case class OrderRequest(cardNumber: String)
// ...
val route =
  path("order") {
    post {
      entity(as[OrderRequest]) { orderRequest =>
        onComplete(PurchaseService.createPurchase(orderRequest.cardNumber)) {
          case Success(Right(result)) =>
            complete(StatusCodes.Created, result)
          case Success(Left(error)) =>