Changeset 5972 for pjproject/trunk/pjsip/src/pjsua2/call.cpp

Timestamp:

Apr 23, 2019 10:49:56 AM (6 years ago)

Author:

nanang

Message:

Re #2181: Implemented video conference APIs for PJSUA2.

File:

• pjproject/trunk/pjsip/src/pjsua2/call.cpp (modified) (6 diffs)

pjproject/trunk/pjsip/src/pjsua2/call.cpp

@@ -152 +152 @@
 //////////////////////////////////////////////////////////////////////////////
 
-/* Call Audio Media. */
-class CallAudioMedia : public AudioMedia
-{
-public:
-    /*
-     * Set the conference port identification associated with the
-     * call audio media.
-     */
-    void setPortId(int id);
-
-    /**
-     * Destructor
-     */
-    virtual ~CallAudioMedia();
-};
-
-
-void CallAudioMedia::setPortId(int pid)
-{
-    this->id = pid;
-}
-
-CallAudioMedia::~CallAudioMedia()
-{
-    id = PJSUA_INVALID_ID;
-}
-
 CallOpParam::CallOpParam(bool useDefaultCallSetting)
 : statusCode(pjsip_status_code(0)), reason(""), options(0)
@@ -271 +244 @@
 
 CallMediaInfo::CallMediaInfo()
-: videoWindow(PJSUA_INVALID_ID)
+: audioConfSlot(PJSUA_INVALID_ID),
+  videoWindow(PJSUA_INVALID_ID),
+  videoIncomingWindowId(PJSUA_INVALID_ID),
+  videoCapDev(PJMEDIA_VID_INVALID_DEV)
 {
 }
@@ -522 +498 @@
 }
 
-AudioMedia Call::getAudioMedia(unsigned med_idx) const throw(Error)
-{
-    CallAudioMedia cam;
-    CallInfo ci = getInfo();
-
-    if (med_idx < ci.media.size() &&
-        ci.media[med_idx].type == PJMEDIA_TYPE_AUDIO)
-    {
-        cam.setPortId(ci.media[med_idx].audioConfSlot);
-    }
-    return cam;
+AudioMedia Call::getAudioMedia(int med_idx) const throw(Error)
+{
+    pjsua_call_info pj_ci;
+    pjsua_call_get_info(id, &pj_ci);
+    
+    if (med_idx < 0) {
+        for (unsigned i = 0; i < pj_ci.media_cnt; ++i) {
+            if (pj_ci.media[med_idx].type == PJMEDIA_TYPE_AUDIO &&
+                pj_ci.media[med_idx].stream.aud.conf_slot != PJSUA_INVALID_ID)
+            {
+                med_idx = i;
+                break;
+            }
+        }
+        if (med_idx < 0) {
+            PJSUA2_RAISE_ERROR3(PJ_ENOTFOUND, "getAudioMedia()",
+                                "no active audio media");
+        }
+    }
+
+    if (med_idx >= (int)pj_ci.media_cnt) {
+        PJSUA2_RAISE_ERROR3(PJ_EINVAL, "getAudioMedia()",
+                            "invalid media index");
+    }
+    if (pj_ci.media[med_idx].type != PJMEDIA_TYPE_AUDIO) {
+        PJSUA2_RAISE_ERROR3(PJ_EINVAL, "getAudioMedia()",
+                            "media is not audio");
+    }
+    if (pj_ci.media[med_idx].stream.aud.conf_slot == PJSUA_INVALID_ID) {
+        PJSUA2_RAISE_ERROR3(PJ_EINVAL, "getAudioMedia()",
+                            "no audio slot (inactive?)");
+    }
+
+    AudioMediaHelper am;
+    am.setPortId(pj_ci.media[med_idx].stream.aud.conf_slot);
+    return am;
+}
+
+VideoMedia Call::getEncodingVideoMedia(int med_idx) const throw(Error)
+{
+    pjsua_call_info pj_ci;
+    pjsua_call_get_info(id, &pj_ci);
+
+    if (med_idx < 0) {
+        for (unsigned i = 0; i < pj_ci.media_cnt; ++i) {
+            if (pj_ci.media[med_idx].type == PJMEDIA_TYPE_VIDEO &&
+                pj_ci.media[med_idx].stream.vid.enc_slot != PJSUA_INVALID_ID)
+            {
+                med_idx = i;
+                break;
+            }
+        }
+        if (med_idx < 0) {
+            PJSUA2_RAISE_ERROR3(PJ_ENOTFOUND, "getEncodingVideoMedia()",
+                                "no active encoding video media");
+        }
+    }
+
+    if (med_idx >= (int)pj_ci.media_cnt) {
+        PJSUA2_RAISE_ERROR3(PJ_EINVAL, "getEncodingVideoMedia()",
+                            "invalid media index");
+    }
+    if (pj_ci.media[med_idx].type != PJMEDIA_TYPE_VIDEO) {
+        PJSUA2_RAISE_ERROR3(PJ_EINVAL, "getEncodingVideoMedia()",
+                            "media is not video");
+    }
+    if (pj_ci.media[med_idx].stream.vid.enc_slot == PJSUA_INVALID_ID) {
+        PJSUA2_RAISE_ERROR3(PJ_EINVAL, "getEncodingVideoMedia()",
+                            "no encoding slot (recvonly?)");
+    }
+
+    VideoMediaHelper vm;
+    vm.setPortId(pj_ci.media[med_idx].stream.vid.enc_slot);
+    return vm;
+}
+
+VideoMedia Call::getDecodingVideoMedia(int med_idx) const throw(Error)
+{
+    pjsua_call_info pj_ci;
+    pjsua_call_get_info(id, &pj_ci);
+
+    if (med_idx < 0) {
+        for (unsigned i = 0; i < pj_ci.media_cnt; ++i) {
+            if (pj_ci.media[med_idx].type == PJMEDIA_TYPE_VIDEO &&
+                pj_ci.media[med_idx].stream.vid.dec_slot != PJSUA_INVALID_ID)
+            {
+                med_idx = i;
+                break;
+            }
+        }
+        if (med_idx < 0) {
+            PJSUA2_RAISE_ERROR3(PJ_ENOTFOUND, "getDecodingVideoMedia()",
+                                "no active decoding video media");
+        }
+    }
+
+    if (med_idx >= (int)pj_ci.media_cnt) {
+        PJSUA2_RAISE_ERROR3(PJ_EINVAL, "getDecodingVideoMedia()",
+                            "invalid media index");
+    }
+    if (pj_ci.media[med_idx].type != PJMEDIA_TYPE_VIDEO) {
+        PJSUA2_RAISE_ERROR3(PJ_EINVAL, "getDecodingVideoMedia()",
+                            "media is not video");
+    }
+    if (pj_ci.media[med_idx].stream.vid.dec_slot == PJSUA_INVALID_ID) {
+        PJSUA2_RAISE_ERROR3(PJ_EINVAL, "getDecodingVideoMedia()",
+                            "no decoding slot (sendonly?)");
+    }
+
+    VideoMediaHelper vm;
+    vm.setPortId(pj_ci.media[med_idx].stream.vid.dec_slot);
+    return vm;
 }
 
@@ -791 +868 @@
             if (mi >= medias.size()) {
                 if (pj_ci.media[mi].type == PJMEDIA_TYPE_AUDIO) {
-                    medias.push_back(new CallAudioMedia);
+                    medias.push_back(new AudioMediaHelper);
                 } else {
                     medias.push_back(NULL);
@@ -798 +875 @@
             
             if (pj_ci.media[mi].type == PJMEDIA_TYPE_AUDIO) {
-                CallAudioMedia *aud_med = (CallAudioMedia *)medias[mi];
-                
+                AudioMediaHelper *aud_med = (AudioMediaHelper*)medias[mi];
                 aud_med->setPortId(pj_ci.media[mi].stream.aud.conf_slot);
-                /* Add media if the conference slot ID is valid. */
+
+                /* Add media if the conference slot ID is valid. */
                 if (pj_ci.media[mi].stream.aud.conf_slot != PJSUA_INVALID_ID)
                 {
@@ -808 +885 @@
                     Endpoint::instance().mediaRemove((AudioMedia &)*aud_med);
                 }
-            }
+            }
         }
     }