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
155
Issues
155
List
Board
Labels
Milestones
Merge Requests
9
Merge Requests
9
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
6d124f0a
Commit
6d124f0a
authored
1 month ago
by
Alfredo Di Napoli
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Address PR feedback
parent
5fc3f967
Pipeline
#7466
passed with stages
in 46 minutes
Changes
2
Pipelines
1
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 @
6d124f0a
...
...
@@ -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]
...
...
This diff is collapsed.
Click to expand it.
src/Gargantext/Core/Notifications/CentralExchange.hs
View file @
6d124f0a
...
...
@@ -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."
...
...
This diff is collapsed.
Click to expand it.
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