diff options
author | Wim <wim@42.be> | 2021-10-17 00:47:22 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-10-17 00:47:22 +0200 |
commit | 4dd8bae5c91fa4aef09d865d8fef1acd84f90925 (patch) | |
tree | ffad9b242daccaf8c86d1c1fbd59032302bd3be9 /vendor/github.com/gopackage/ddp/ddp.go | |
parent | 7ae45c42e712bd0e66c101f3f714c05aa1dc2104 (diff) | |
download | matterbridge-msglm-4dd8bae5c91fa4aef09d865d8fef1acd84f90925.tar.gz matterbridge-msglm-4dd8bae5c91fa4aef09d865d8fef1acd84f90925.tar.bz2 matterbridge-msglm-4dd8bae5c91fa4aef09d865d8fef1acd84f90925.zip |
Update dependencies (#1610)
* Update dependencies
* Update module to go 1.17
Diffstat (limited to 'vendor/github.com/gopackage/ddp/ddp.go')
-rw-r--r-- | vendor/github.com/gopackage/ddp/ddp.go | 79 |
1 files changed, 0 insertions, 79 deletions
diff --git a/vendor/github.com/gopackage/ddp/ddp.go b/vendor/github.com/gopackage/ddp/ddp.go deleted file mode 100644 index 910adafd..00000000 --- a/vendor/github.com/gopackage/ddp/ddp.go +++ /dev/null @@ -1,79 +0,0 @@ -// Package ddp implements the MeteorJS DDP protocol over websockets. Fallback -// to longpolling is NOT supported (and is not planned on ever being supported -// by this library). We will try to model the library after `net/http` - right -// now the library is barebones and doesn't provide the pluggability of http. -// However, that's the goal for the package eventually. -package ddp - -import ( - "fmt" - "log" - "sync" - "time" -) - -// debugLog is true if we should log debugging information about the connection -var debugLog = true - -// The main file contains common utility types. - -// ------------------------------------------------------------------- - -// idManager provides simple incrementing IDs for ddp messages. -type idManager struct { - // nextID is the next ID for API calls - nextID uint64 - // idMutex is a mutex to protect ID updates - idMutex *sync.Mutex -} - -// newidManager creates a new instance and sets up resources. -func newidManager() *idManager { - return &idManager{idMutex: new(sync.Mutex)} -} - -// newID issues a new ID for use in calls. -func (id *idManager) newID() string { - id.idMutex.Lock() - next := id.nextID - id.nextID++ - id.idMutex.Unlock() - return fmt.Sprintf("%x", next) -} - -// ------------------------------------------------------------------- - -// pingTracker tracks in-flight pings. -type pingTracker struct { - handler func(error) - timeout time.Duration - timer *time.Timer -} - -// ------------------------------------------------------------------- - -// Call represents an active RPC call. -type Call struct { - ID string // The uuid for this method call - ServiceMethod string // The name of the service and method to call. - Args interface{} // The argument to the function (*struct). - Reply interface{} // The reply from the function (*struct). - Error error // After completion, the error status. - Done chan *Call // Strobes when call is complete. - Owner *Client // Client that owns the method call -} - -// done removes the call from any owners and strobes the done channel with itself. -func (call *Call) done() { - delete(call.Owner.calls, call.ID) - select { - case call.Done <- call: - // ok - default: - // We don't want to block here. It is the caller's responsibility to make - // sure the channel has enough buffer space. See comment in Go(). - if debugLog { - log.Println("rpc: discarding Call reply due to insufficient Done chan capacity") - } - } -} |