cfc65a13f6
This commit includes updates that affects the build, testing, and
deployment of Tile38.
- The root level build.sh has been broken up into multiple scripts
and placed in the "scripts" directory.
- The vendor directory has been updated to follow the Go modules
rules, thus `make` should work on isolated environments. Also
some vendored packages may have been updated to a later
version, if needed.
- The Makefile has been updated to allow for making single
binaries such as `make tile38-server`. There is some scaffolding
during the build process, so from now on all binaries should be
made using make. For example, to run a development version of
the tile38-cli binary, do this:
make tile38-cli && ./tile38-cli
not this:
go run cmd/tile38-cli/main.go
- Travis.CI docker push script has been updated to address a
change to Docker's JSON repo meta output, which in turn fixes
a bug where new Tile38 versions were not being properly pushed
to Docker
103 lines
2.0 KiB
Go
103 lines
2.0 KiB
Go
/*
|
|
* Copyright (c) 2013 IBM Corp.
|
|
*
|
|
* All rights reserved. This program and the accompanying materials
|
|
* are made available under the terms of the Eclipse Public License v1.0
|
|
* which accompanies this distribution, and is available at
|
|
* http://www.eclipse.org/legal/epl-v10.html
|
|
*
|
|
* Contributors:
|
|
* Seth Hoenig
|
|
* Allan Stockdill-Mander
|
|
* Mike Robertson
|
|
*/
|
|
|
|
package mqtt
|
|
|
|
import (
|
|
"fmt"
|
|
"sync"
|
|
"time"
|
|
)
|
|
|
|
// MId is 16 bit message id as specified by the MQTT spec.
|
|
// In general, these values should not be depended upon by
|
|
// the client application.
|
|
type MId uint16
|
|
|
|
type messageIds struct {
|
|
sync.RWMutex
|
|
index map[uint16]Token
|
|
}
|
|
|
|
const (
|
|
midMin uint16 = 1
|
|
midMax uint16 = 65535
|
|
)
|
|
|
|
func (mids *messageIds) cleanUp() {
|
|
mids.Lock()
|
|
for _, token := range mids.index {
|
|
switch t := token.(type) {
|
|
case *PublishToken:
|
|
t.err = fmt.Errorf("Connection lost before Publish completed")
|
|
case *SubscribeToken:
|
|
t.err = fmt.Errorf("Connection lost before Subscribe completed")
|
|
case *UnsubscribeToken:
|
|
t.err = fmt.Errorf("Connection lost before Unsubscribe completed")
|
|
case nil:
|
|
continue
|
|
}
|
|
token.flowComplete()
|
|
}
|
|
mids.index = make(map[uint16]Token)
|
|
mids.Unlock()
|
|
}
|
|
|
|
func (mids *messageIds) freeID(id uint16) {
|
|
mids.Lock()
|
|
delete(mids.index, id)
|
|
mids.Unlock()
|
|
}
|
|
|
|
func (mids *messageIds) getID(t Token) uint16 {
|
|
mids.Lock()
|
|
defer mids.Unlock()
|
|
for i := midMin; i < midMax; i++ {
|
|
if _, ok := mids.index[i]; !ok {
|
|
mids.index[i] = t
|
|
return i
|
|
}
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (mids *messageIds) getToken(id uint16) Token {
|
|
mids.RLock()
|
|
defer mids.RUnlock()
|
|
if token, ok := mids.index[id]; ok {
|
|
return token
|
|
}
|
|
return &DummyToken{id: id}
|
|
}
|
|
|
|
type DummyToken struct {
|
|
id uint16
|
|
}
|
|
|
|
func (d *DummyToken) Wait() bool {
|
|
return true
|
|
}
|
|
|
|
func (d *DummyToken) WaitTimeout(t time.Duration) bool {
|
|
return true
|
|
}
|
|
|
|
func (d *DummyToken) flowComplete() {
|
|
ERROR.Printf("A lookup for token %d returned nil\n", d.id)
|
|
}
|
|
|
|
func (d *DummyToken) Error() error {
|
|
return nil
|
|
}
|