code: func sendMsg(p *Pss, sp *network.Peer, msg *PssMsg) bool {
  	var isPssEnabled bool
  	info := sp.Info()
  	for _, capability := range info.Caps {
  		if capability == p.capstring {
  			isPssEnabled = true
  			break
  		}
  	}
  	if !isPssEnabled {
  		log.Error("peer doesn't have matching pss capabilities, skipping", "peer", info.Name, "caps", info.Caps)
  		return false
  	}
  
  	// get the protocol peer from the forwarding peer cache
  	p.fwdPoolMu.RLock()
  	pp := p.fwdPool[sp.Info().ID]
  	p.fwdPoolMu.RUnlock()
  
  	err := pp.Send(context.TODO(), msg)
  	if err != nil {
  		metrics.GetOrRegisterCounter("pss.pp.send.error", nil).Inc(1)
  		log.Error(err.Error())
  	}
  
  	return err == nil
  }
docs: // tries to send a message, returns true if successful