Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
haskell-gargantext
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
145
Issues
145
List
Board
Labels
Milestones
Merge Requests
6
Merge Requests
6
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
gargantext
haskell-gargantext
Commits
7574fc93
Commit
7574fc93
authored
Mar 20, 2025
by
Alfredo Di Napoli
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Address PR feedback
parent
2ffd7ada
Pipeline
#7489
canceled with stages
Changes
2
Pipelines
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
5 additions
and
5 deletions
+5
-5
gargantext-settings.toml_toModify
gargantext-settings.toml_toModify
+2
-2
CentralExchange.hs
src/Gargantext/Core/Notifications/CentralExchange.hs
+3
-3
No files found.
gargantext-settings.toml_toModify
View file @
7574fc93
...
...
@@ -124,8 +124,8 @@ smtp_host = "localhost"
[notifications]
central-exchange = { bind = "tcp://*:5560", connect = "tcp://
localhost
:5560" }
dispatcher = { bind = "tcp://*:5561", connect = "tcp://
localhost
:5561" }
central-exchange = { bind = "tcp://*:5560", connect = "tcp://
127.0.0.1
:5560" }
dispatcher = { bind = "tcp://*:5561", connect = "tcp://
127.0.0.1
:5561" }
[nlp]
...
...
src/Gargantext/Core/Notifications/CentralExchange.hs
View file @
7574fc93
...
...
@@ -109,14 +109,14 @@ gServer cfg = do
$
(
logLoc
)
ioLogger
ERROR
$
"[central_exchange] cannot decode message: "
<>
show
r
-- | A static send timeout in microseconds.
send_timeout_
n
s
::
Int
send_timeout_
n
s
=
50
_000
send_timeout_
u
s
::
Int
send_timeout_
u
s
=
50
_000
-- | Sends the given payload ensure the send doesn't take more than the static
-- 'send_timeout_ns', logging a message if the timeouts kicks in.
sendTimeout
::
Sender
a
=>
Logger
IO
->
Socket
a
->
ByteString
->
IO
()
sendTimeout
ioLogger
sock
payload
=
withFrozenCallStack
$
do
timeoutKickedIn
<-
timeout
send_timeout_
n
s
$
send
sock
$
payload
timeoutKickedIn
<-
timeout
send_timeout_
u
s
$
send
sock
$
payload
case
timeoutKickedIn
of
Nothing
->
$
(
logLoc
)
ioLogger
ERROR
$
"[central_exchange] couldn't send msg in timely fashion."
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment