Skip to content

Commit

Permalink
Update README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
Azer0s committed Jan 12, 2021
1 parent a472797 commit 4bfc879
Show file tree
Hide file tree
Showing 3 changed files with 19 additions and 14 deletions.
3 changes: 3 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,9 @@ rootCtx.Send(pid, EmptyMessage{})

### Getting started

To get started, you'll need an installation of qpmd (see: [qpmd](https://github.com/Azer0s/qpmd)).
The quacktor port mapper daemon is responsible for keeping track of all running systems and quacktor instances on your local machine and acts as a "DNS server" for remote machines that want to connect to a local system.

```go
import . "github.com/Azer0s/quacktors"

Expand Down
2 changes: 1 addition & 1 deletion component/component_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -182,4 +182,4 @@ func TestLink(t *testing.T) {

wg.Wait()
quacktors.Wait()
}
}
28 changes: 15 additions & 13 deletions context.go
Original file line number Diff line number Diff line change
Expand Up @@ -137,23 +137,25 @@ func (c *Context) Monitor(pid *Pid) Abortable {
"machine_id", pid.MachineId)

errorChan <- true
} else {
defer func() {
if r := recover(); r != nil {
//This happens if we write to the monitorChan while the actor is being closed
errorChan <- true
}
}()

if pid.monitorChan == nil {

return
}

defer func() {
if r := recover(); r != nil {
//This happens if we write to the monitorChan while the actor is being closed
errorChan <- true
return
}
}()

pid.monitorChan <- c.self

okChan <- true
if pid.monitorChan == nil {
errorChan <- true
return
}

pid.monitorChan <- c.self

okChan <- true
}()

select {
Expand Down

0 comments on commit 4bfc879

Please sign in to comment.