This commit is contained in:
@@ -40,6 +40,9 @@ func NewRemoteGrain(id CartId, address string) *RemoteGrain {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (g *RemoteGrain) Connect() error {
|
func (g *RemoteGrain) Connect() error {
|
||||||
|
if g == nil {
|
||||||
|
return fmt.Errorf("grain is deleted")
|
||||||
|
}
|
||||||
if g.connection == nil {
|
if g.connection == nil {
|
||||||
addr := g.Address
|
addr := g.Address
|
||||||
if !strings.Contains(addr, ":") {
|
if !strings.Contains(addr, ":") {
|
||||||
|
|||||||
Reference in New Issue
Block a user