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.
+
+ This source code is part of the near-RT RIC (RAN Intelligent Controller)
+ platform project (RICP).
+
==================================================================================
*/
/*
"errors"
"routing-manager/pkg/rtmgr"
"routing-manager/pkg/stub"
+ //"nanomsg.org/go/mangos/v2"
+ //_ "nanomsg.org/go/mangos/v2/transport/all"
+ //"nanomsg.org/go/mangos/v2/protocol/push"
"testing"
)
}
/*
-nngpush.UpdateEndpoints() is testd against stub.ValidXapps dataset
+nngpush.UpdateEndpoints() is testd against stub.ValidXApps dataset
*/
func TestNngPushUpdateEndpoints(t *testing.T) {
var nngpush = NngPush{}
t.Errorf("nngpush.DeleteEndpoint() was incorrect, got: %v, want: %v.", nil, "error")
}
}
+
+/*
+Initialize and send policies
+*/
+func TestNngPushInitializeandsendPolicies(t *testing.T) {
+ var nngpush = NngPush{}
+ _,_ = createNewPushSocket()
+ policies := []string{"hello","welcome"}
+ nngpush.send(rtmgr.Eps["10.1.1.1:0"],&policies)
+}
+
+/*
+func TestPipeEventHandler(t *testing.T) {
+ var sock mangos.Socket
+ var event mangos.PipeEvent
+ var pipe mangos.Pipe
+
+ var err error
+ sock, err = push.NewSocket()
+ sock.Dial("tcp://127.0.0.1:4555")
+ sock.SetPipeEventHook(pipeEventHandler)
+ pipeEventHandler(event,pipe)
+ t.Log(err)
+}
+*/