Multiple E2T instance feature - Introduced APIs Delete E2T Instance and associate...

[ric-plt/rtmgr.git] / pkg / sbi / nngpush_test.go

diff --git a/pkg/sbi/nngpush_test.go b/pkg/sbi/nngpush_test.go
index 422a036..b17b2ca 100644 (file)
--- a/pkg/sbi/nngpush_test.go
+++ b/pkg/sbi/nngpush_test.go
@@ -14,6 +14,10 @@
    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.
    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).
+

 ==================================================================================
 */
 /*
 ==================================================================================
 */
 /*


@@ -27,6 +31,9 @@ import (
        "errors"
        "routing-manager/pkg/rtmgr"
        "routing-manager/pkg/stub"
        "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"
 )
 
        "testing"
 )
 


@@ -222,3 +229,28 @@ func TestNngPushDeleteEndpointWithSocketCloseError(t *testing.T) {
                t.Errorf("nngpush.DeleteEndpoint() was incorrect, got: %v, want: %v.", nil, "error")
        }
 }
                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)
+}
+*/