Packages

efirebirdsql

0.9.3
0.9.14 0.9.13 0.9.12 0.9.11 0.9.10 0.9.9 0.9.8 0.9.7 0.9.6 0.9.5 0.9.4 0.9.3 0.9.2 0.9.1 0.9.0 0.8.5 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.0 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.10 0.5.9 0.5.8 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.0 0.3.0 0.2.3 0.2.2 0.2.1 0.2.0 0.1.4 0.1.3 0.1.2 0.1.1

Firebird Client

HexDocs

Current section

Files

Jump to
Readme
49 Versions
0 Dependencies
Dependants
Files
Activity
efirebirdsql src efirebirdsql_socket.erl
Raw

src/efirebirdsql_socket.erl 

%%% The MIT License (MIT)

%%% Copyright (c) 2016-2021 Hajime Nakagami<nakagami@gmail.com>



-module(efirebirdsql_socket).



-export([send/2, recv/2, recv_align/2, recv_null_bitmap/2]).



-include("efirebirdsql.hrl").



send(Conn, Data) when Conn#conn.write_state =:= undefined ->

    gen_tcp:send(Conn#conn.sock, Data);

send(Conn, Message) ->

    Encrypted = crypto:crypto_update(Conn#conn.write_state, Message),

    gen_tcp:send(Conn#conn.sock, Encrypted).



recv(_Conn, Len) when Len =:= 0 ->

    {ok, []};

recv(Conn, Len) when Conn#conn.read_state =:= undefined ->

    gen_tcp:recv(Conn#conn.sock, Len);

recv(Conn, Len) ->

    {T, Encrypted} = gen_tcp:recv(Conn#conn.sock, Len),

    Message = crypto:crypto_update(Conn#conn.read_state, Encrypted),

    {T, Message}.



recv_align(Conn, Len) ->

    {T, V} = recv(Conn, Len),

    if

        Len rem 4 =/= 0 -> recv(Conn, 4 - (Len rem 4));

        true -> nil

    end,

    {T, V}.



recv_null_bitmap(_Conn, BitLen) when BitLen =:= 0 ->

    <<>>;

recv_null_bitmap(Conn, BitLen) ->

    Div8 = BitLen div 8,

    Len = if

        BitLen rem 8 =:= 0 -> Div8;

        BitLen rem 8 =/= 0 -> Div8 + 1

        end,

    {ok, Buf} = recv_align(Conn, Len),

    <<Bitmap:Len/little-unit:8>> = Buf,

    Bitmap.