Class: Ignis::Collective::Transport::RIOFunctionTableWrapper

Inherits:
Object
  • Object
show all
Defined in:
lib/nvruby/collective/transport/rio_transport.rb

Overview

RIO Function Table Wrapper Wraps RIO function calls

Instance Method Summary collapse

Instance Method Details

#close_completion_queue(cq) ⇒ Object 



368
369
370
 
# File 'lib/nvruby/collective/transport/rio_transport.rb', line 368

def close_completion_queue(cq)
  true
end

#create_completion_queue(size) ⇒ Object 



333
334
335
336
 
# File 'lib/nvruby/collective/transport/rio_transport.rb', line 333

def create_completion_queue(size)
  # Returns a completion queue handle
  { handle: SecureRandom.uuid, size: size }
end

#create_request_queue(socket:, max_outstanding_receive:, max_receive_data_buffers:, max_outstanding_send:, max_send_data_buffers:, recv_cq:, send_cq:) ⇒ Object 



338
339
340
341
342
 
# File 'lib/nvruby/collective/transport/rio_transport.rb', line 338

def create_request_queue(socket:, max_outstanding_receive:, max_receive_data_buffers:,
                          max_outstanding_send:, max_send_data_buffers:,
                          recv_cq:, send_cq:)
  { handle: SecureRandom.uuid }
end

#dequeue_completion(cq, count) ⇒ Object 



364
365
366
 
# File 'lib/nvruby/collective/transport/rio_transport.rb', line 364

def dequeue_completion(cq, count)
  [{ status: :ok, bytes_transferred: 0 }]
end

#deregister_buffer(buffer_id) ⇒ Object 



348
349
350
 
# File 'lib/nvruby/collective/transport/rio_transport.rb', line 348

def deregister_buffer(buffer_id)
  true
end

#notify(cq) ⇒ Object 



360
361
362
 
# File 'lib/nvruby/collective/transport/rio_transport.rb', line 360

def notify(cq)
  true
end

#receive(request_queue:, buffer_id:, offset:, length:, flags:) ⇒ Object 



356
357
358
 
# File 'lib/nvruby/collective/transport/rio_transport.rb', line 356

def receive(request_queue:, buffer_id:, offset:, length:, flags:)
  true
end

#register_buffer(buffer, size) ⇒ Object 



344
345
346
 
# File 'lib/nvruby/collective/transport/rio_transport.rb', line 344

def register_buffer(buffer, size)
  SecureRandom.uuid
end

#send(request_queue:, buffer_id:, offset:, length:, flags:) ⇒ Object 



352
353
354
 
# File 'lib/nvruby/collective/transport/rio_transport.rb', line 352

def send(request_queue:, buffer_id:, offset:, length:, flags:)
  true
end