versions/v1_4_0/mynewt-newtmgr/nmxact/nmble/ble_sesn.go

/**
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *  http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

package nmble

import (
	"github.com/runtimeco/go-coap"

	. "mynewt.apache.org/newtmgr/nmxact/bledefs"
	"mynewt.apache.org/newtmgr/nmxact/nmcoap"
	"mynewt.apache.org/newtmgr/nmxact/nmp"
	"mynewt.apache.org/newtmgr/nmxact/sesn"
)

type BleSesn struct {
	cfg sesn.SesnCfg
	bx  *BleXport
	Ns  *NakedSesn
}

func NewBleSesn(bx *BleXport, cfg sesn.SesnCfg) (
	*BleSesn, error) {

	Ns, err := NewNakedSesn(bx, cfg)
	if err != nil {
		return nil, err
	}

	s := &BleSesn{
		cfg: cfg,
		bx:  bx,
		Ns:  Ns,
	}

	return s, nil
}

func (s *BleSesn) AbortRx(seq uint8) error {
	return s.Ns.AbortRx(seq)
}

func (s *BleSesn) Open() error {
	if err := s.bx.AcquireMasterPrimary(s); err != nil {
		return err
	}
	defer s.bx.ReleaseMaster()

	return s.Ns.Open()
}

func (s *BleSesn) OpenConnected(
	connHandle uint16, eventListener *Listener) error {

	return s.Ns.OpenConnected(connHandle, eventListener)
}

func (s *BleSesn) Close() error {
	return s.Ns.Close()
}

func (s *BleSesn) IsOpen() bool {
	return s.Ns.IsOpen()
}

func (s *BleSesn) MtuIn() int {
	return s.Ns.MtuIn()
}

func (s *BleSesn) MtuOut() int {
	return s.Ns.MtuOut()
}

func (s *BleSesn) CoapIsTcp() bool {
	return s.Ns.CoapIsTcp()
}

func (s *BleSesn) MgmtProto() sesn.MgmtProto {
	return s.Ns.MgmtProto()
}

func (s *BleSesn) ConnInfo() (BleConnDesc, error) {
	return s.Ns.ConnInfo()
}

func (s *BleSesn) SetOobKey(key []byte) {
	s.Ns.SetOobKey(key)
}

func (s *BleSesn) TxNmpOnce(req *nmp.NmpMsg, opt sesn.TxOptions) (
	nmp.NmpRsp, error) {

	return s.Ns.TxNmpOnce(req, opt)
}

func (s *BleSesn) TxCoapOnce(m coap.Message,
	resType sesn.ResourceType,
	opt sesn.TxOptions) (coap.COAPCode, []byte, error) {

	return s.Ns.TxCoapOnce(m, resType, opt)
}

func (s *BleSesn) TxCoapObserve(m coap.Message,
	resType sesn.ResourceType,
	opt sesn.TxOptions, NotifCb sesn.GetNotifyCb, stopsignal chan int) (coap.COAPCode, []byte, []byte, error) {

	return s.Ns.TxCoapObserve(m, resType, opt, NotifCb, stopsignal)
}

func (s *BleSesn) RxAccept() (sesn.Sesn, *sesn.SesnCfg, error) {
	return s.Ns.RxAccept()
}

func (s *BleSesn) RxCoap(opt sesn.TxOptions) (coap.Message, error) {
	return s.Ns.RxCoap(opt)
}

func (s *BleSesn) Filters() (nmcoap.MsgFilter, nmcoap.MsgFilter) {
	return s.Ns.Filters()
}