Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ The package exposes a server and a client module to interact with SRT streams.
```elixir
def deps do
[
{:ex_libsrt, "~> 0.1.1"}
{:ex_libsrt, "~> 0.1.2"}
]
end
```
Expand Down
4 changes: 4 additions & 0 deletions c_src/ex_libsrt/server/server.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -80,6 +80,10 @@ void Server::CloseConnection(int connection_id) {
}

void Server::RunEpoll() {
// Setting this one prevents spamming with "no sockets to check, this would deadlock" logs during closing
// of the system, when there are no sockets in the epoll anymore
srt_epoll_set(epoll, SRT_EPOLL_ENABLE_EMPTY);

int sockets_len = 100;
SrtSocket sockets[sockets_len];

Expand Down
2 changes: 1 addition & 1 deletion c_src/ex_libsrt/srt_nif.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -145,7 +145,7 @@ UNIFEX_TERM start_server(UnifexEnv* env, char* address, int port, char* password
state->server->SetOnSocketData(
[=](Server::SrtSocket socket, const char* data, int len) {
UnifexPayload* payload =
(UnifexPayload*)unifex_alloc(sizeof(UnifexPayload*));
(UnifexPayload*)unifex_alloc(sizeof(UnifexPayload));

unifex_payload_alloc(state->env, UNIFEX_PAYLOAD_BINARY, len, payload);

Expand Down
2 changes: 1 addition & 1 deletion mix.exs
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
defmodule ExLibSRT.MixProject do
use Mix.Project

@version "0.1.1"
@version "0.1.2"
@github_url "https://github.com/membraneframework/ex_libsrt"

def project do
Expand Down