class method

Socket.udp_server_recv

(::Array[::UDPSocket] sockets) { (::String, ::Socket::UDPSource) -> void } -> void

Socket.udp_server_recv(sockets) {|msg, msg_src| ... }

ext/socket/lib/socket.rb View on GitHub ↗

# File tmp/rubies/ruby-4.0.0/ext/socket/lib/socket.rb, line 1430
def self.udp_server_recv(sockets)
  sockets.each {|r|
    msg, sender_addrinfo, _, *controls = r.recvmsg_nonblock(exception: false)
    next if msg == :wait_readable
    ai = r.local_address
    if ai.ipv6? and pktinfo = controls.find {|c| c.cmsg_is?(:IPV6, :PKTINFO) }
      ai = Addrinfo.udp(pktinfo.ipv6_pktinfo_addr.ip_address, ai.ip_port)
      yield msg, UDPSource.new(sender_addrinfo, ai) {|reply_msg|
        r.sendmsg reply_msg, 0, sender_addrinfo, pktinfo
      }
    else
      yield msg, UDPSource.new(sender_addrinfo, ai) {|reply_msg|
        r.send reply_msg, 0, sender_addrinfo
      }
    end
  }
end

Receive UDP/IP packets from the given sockets. For each packet received, the block is called.

The block receives msg and msg_src. msg is a string which is the payload of the received packet. msg_src is a Socket::UDPSource object which is used for reply.

Socket.udp_server_loop can be implemented using this method as follows.

udp_server_sockets(host, port) {|sockets|
  loop {
    readable, _, _ = IO.select(sockets)
    udp_server_recv(readable) {|msg, msg_src| ... }
  }
}

See also .udp_server_loop_on .udp_server_sockets .udp_server_loop .unix also in 4.1 · 3.4 · 3.3 · 3.2 · 3.1 · 3.0

‹ prev.udp_server_loop_on next ›.udp_server_sockets