Packages

mariaex

0.2.2
0.9.1 0.9.0 0.9.0-rc.0 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.9 0.7.8 0.7.7 0.7.6 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.0 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.2 0.3.1 0.3.0 0.2.2 0.2.1 0.2.0 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Pure elixir database driver for MariaDB / MySQL.

HexDocs

Current section

Files

Jump to
Readme
44 Versions
1 Dependency
Dependants
Files
Activity
mariaex lib mariaex connection tcp.ex
Raw

lib/mariaex/connection/tcp.ex 

defmodule Mariaex.Connection.Tcp do

  def connect(host, port, socket_options, timeout) do

    sock_opts = [{:packet, :raw}, :binary] ++ socket_options

    case :gen_tcp.connect(host, port, sock_opts, timeout) do

      {:ok, sock} = ok ->

        # A suitable :buffer is only set if :recbuf is included in

        # :socket_options.

        {:ok, [sndbuf: sndbuf, recbuf: recbuf, buffer: buffer]} =

          :inet.getopts(sock, [:sndbuf, :recbuf, :buffer])

        buffer = buffer

          |> max(sndbuf)

          |> max(recbuf)

        :ok = :inet.setopts(sock, [buffer: buffer, active: :once])

        ok

      {:error, _} = error ->

        error

    end

  end



  def receive(_sock, {:tcp, _, blob}), do: blob



  def next(sock), do: :inet.setopts(sock, active: :once)



  def send(sock, data), do: :gen_tcp.send(sock, data)

end