mirrors/linphone-iphone
1
0
Fork 1
mirror of https://gitlab.linphone.org/BC/public/linphone-iphone.git synced 2026-01-28 08:39:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Applied snapshot taken callback changes from master

Browse source
This commit is contained in:
Sylvain Berfini 2018-04-30 12:52:53 +02:00
parent 9570ab8a39
commit d67eeda873
12 changed files with 141 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
coreapi/private_functions.h
View file

@ -49,6 +49,7 @@ void linphone_call_notify_stats_updated(LinphoneCall *call, const LinphoneCallSt
void linphone_call_notify_info_message_received(LinphoneCall *call, const LinphoneInfoMessage *msg);
void linphone_call_notify_ack_processing(LinphoneCall *call, LinphoneHeaders *msg, bool_t is_received);
void linphone_call_notify_tmmbr_received(LinphoneCall *call, int stream_index, int tmmbr);
void linphone_call_notify_snapshot_taken(LinphoneCall *call, const char *file_path);
LinphoneCall * linphone_call_new_outgoing(struct _LinphoneCore *lc, const LinphoneAddress *from, const LinphoneAddress *to, const LinphoneCallParams *params, LinphoneProxyConfig *cfg);
LinphoneCall * linphone_call_new_incoming(struct _LinphoneCore *lc, const LinphoneAddress *from, const LinphoneAddress *to, LinphonePrivate::SalCallOp *op);

14
include/linphone/api/c-call-cbs.h
View file

@ -173,6 +173,20 @@ LINPHONE_PUBLIC LinphoneCallCbsTmmbrReceivedCb linphone_call_cbs_get_tmmbr_recei
*/
LINPHONE_PUBLIC void linphone_call_cbs_set_tmmbr_received(LinphoneCallCbs *cbs, LinphoneCallCbsTmmbrReceivedCb cb);
/**
* Get the snapshot taken callback.
* @param[in] cbs LinphoneCallCbs object.
* @return The current snapshot taken callback.
*/
LINPHONE_PUBLIC LinphoneCallCbsSnapshotTakenCb linphone_call_cbs_get_snapshot_taken(LinphoneCallCbs *cbs);
/**
* Set the snapshot taken callback.
* @param[in] cbs LinphoneCallCbs object.
* @param[in] cb The snapshot taken callback to be used.
*/
LINPHONE_PUBLIC void linphone_call_cbs_set_snapshot_taken(LinphoneCallCbs *cbs, LinphoneCallCbsSnapshotTakenCb cb);
/**
* @}
*/

7
include/linphone/api/c-callbacks.h
View file

@ -95,6 +95,13 @@ typedef void (*LinphoneCallCbsAckProcessingCb)(LinphoneCall *call, LinphoneHeade
*/
typedef void (*LinphoneCallCbsTmmbrReceivedCb)(LinphoneCall *call, int stream_index, int tmmbr);
/**
* Callback for notifying a snapshot taken.
* @param call LinphoneCall for which the snapshot was taken
* @param filepath the name of the saved file
*/
typedef void (*LinphoneCallCbsSnapshotTakenCb)(LinphoneCall *call, const char *filepath);
/**
* @}
**/

9
src/c-wrapper/api/c-call-cbs.cpp
View file

@ -34,6 +34,7 @@ struct _LinphoneCallCbs {
LinphoneCallCbsTransferStateChangedCb transferStateChangedCb;
LinphoneCallCbsAckProcessingCb ackProcessing;
LinphoneCallCbsTmmbrReceivedCb tmmbrReceivedCb;
LinphoneCallCbsSnapshotTakenCb snapshotTakenCb;
};
BELLE_SIP_DECLARE_VPTR_NO_EXPORT(LinphoneCallCbs);
@ -133,3 +134,11 @@ LinphoneCallCbsTmmbrReceivedCb linphone_call_cbs_get_tmmbr_received (LinphoneCal
void linphone_call_cbs_set_tmmbr_received (LinphoneCallCbs *cbs, LinphoneCallCbsTmmbrReceivedCb cb) {
cbs->tmmbrReceivedCb = cb;
}
LinphoneCallCbsSnapshotTakenCb linphone_call_cbs_get_snapshot_taken(LinphoneCallCbs *cbs) {
return cbs->snapshotTakenCb;
}
void linphone_call_cbs_set_snapshot_taken(LinphoneCallCbs *cbs, LinphoneCallCbsSnapshotTakenCb cb) {
cbs->snapshotTakenCb = cb;
}

3
src/c-wrapper/api/c-call.cpp
View file

@ -184,6 +184,9 @@ void linphone_call_notify_tmmbr_received (LinphoneCall *call, int stream_index,
NOTIFY_IF_EXIST(TmmbrReceived, tmmbr_received, call, stream_index, tmmbr)
}
void linphone_call_notify_snapshot_taken(LinphoneCall *call, const char *file_path) {
NOTIFY_IF_EXIST(SnapshotTaken, snapshot_taken, call, file_path)
}
// =============================================================================
// Public functions.

1
src/call/call-p.h
View file

@ -111,6 +111,7 @@ private:
bool isPlayingRingbackTone (const std::shared_ptr<CallSession> &session) override;
void onRealTimeTextCharacterReceived (const std::shared_ptr<CallSession> &session, RealtimeTextReceivedCharacter *character) override;
void onTmmbrReceived(const std::shared_ptr<CallSession> &session, int streamIndex, int tmmbr) override;
void onSnapshotTaken(const std::shared_ptr<CallSession> &session, const char *file_path) override;
mutable LinphonePlayer *player = nullptr;

5
src/call/call.cpp
View file

@ -496,6 +496,11 @@ void CallPrivate::onTmmbrReceived (const shared_ptr<CallSession> &session, int s
linphone_call_notify_tmmbr_received(L_GET_C_BACK_PTR(q), streamIndex, tmmbr);
}
void CallPrivate::onSnapshotTaken(const shared_ptr<CallSession> &session, const char *file_path) {
L_Q();
linphone_call_notify_snapshot_taken(L_GET_C_BACK_PTR(q), file_path);
}
// =============================================================================
Call::Call (CallPrivate &p, shared_ptr<Core> core) : Object(p), CoreAccessor(core) {

2
src/conference/session/call-session-listener.h
View file

@ -55,6 +55,7 @@ public:
virtual void onInfoReceived (const std::shared_ptr<CallSession> &session, const LinphoneInfoMessage *im) {}
virtual void onNoMediaTimeoutCheck (const std::shared_ptr<CallSession> &session, bool oneSecondElapsed) {}
virtual void onTmmbrReceived (const std::shared_ptr<CallSession> &session, int streamIndex, int tmmbr) {}
virtual void onSnapshotTaken(const std::shared_ptr<CallSession> &session, const char *file_path) {}
virtual void onEncryptionChanged (const std::shared_ptr<CallSession> &session, bool activated, const std::string &authToken) {}
@ -80,6 +81,7 @@ public:
virtual bool isPlayingRingbackTone (const std::shared_ptr<CallSession> &session) { return false; }
virtual void onRealTimeTextCharacterReceived (const std::shared_ptr<CallSession> &session, RealtimeTextReceivedCharacter *data) {}
};
LINPHONE_END_NAMESPACE

3
src/conference/session/media-session-p.h
View file

@ -106,6 +106,9 @@ public:
// CoreListener
void onNetworkReachable (bool sipNetworkReachable, bool mediaNetworkReachable) override;
// Call listener
void snapshotTakenCb(void *userdata, struct _MSFilter *f, unsigned int id, void *arg);
private:
static OrtpJitterBufferAlgorithm jitterBufferNameToAlgo (const std::string &name);

21
src/conference/session/media-session.cpp
View file

@ -4364,11 +4364,30 @@ void MediaSession::resetFirstVideoFrameDecoded () {
ms_filter_call_method_noarg(d->videoStream->ms.decoder, MS_VIDEO_DECODER_RESET_FIRST_IMAGE_NOTIFICATION);
}
void MediaSessionPrivate::snapshotTakenCb(void *userdata, struct _MSFilter *f, unsigned int id, void *arg) {
#ifdef VIDEO_ENABLED
L_Q();
if (id == MS_JPEG_WRITER_SNAPSHOT_TAKEN) {
const char *filepath = (const char *) arg;
listener->onSnapshotTaken(q->getSharedFromThis(), filepath);
}
#endif
}
#ifdef VIDEO_ENABLED
static void snapshot_taken(void *userdata, struct _MSFilter *f, unsigned int id, void *arg) {
MediaSessionPrivate *d = (MediaSessionPrivate *)userdata;
d->snapshotTakenCb(userdata, f, id, arg);
}
#endif
LinphoneStatus MediaSession::takePreviewSnapshot (const string& file) {
#ifdef VIDEO_ENABLED
L_D();
if (d->videoStream && d->videoStream->local_jpegwriter) {
ms_filter_clear_notify_callback(d->videoStream->jpegwriter);
const char *filepath = file.empty() ? nullptr : file.c_str();
ms_filter_add_notify_callback(d->videoStream->local_jpegwriter, snapshot_taken, d, TRUE);
return ms_filter_call_method(d->videoStream->local_jpegwriter, MS_JPEG_WRITER_TAKE_SNAPSHOT, (void *)filepath);
}
lWarning() << "Cannot take local snapshot: no currently running video stream on this call";
@ -4380,7 +4399,9 @@ LinphoneStatus MediaSession::takeVideoSnapshot (const string& file) {
#ifdef VIDEO_ENABLED
L_D();
if (d->videoStream && d->videoStream->jpegwriter) {
ms_filter_clear_notify_callback(d->videoStream->jpegwriter);
const char *filepath = file.empty() ? nullptr : file.c_str();
ms_filter_add_notify_callback(d->videoStream->jpegwriter, snapshot_taken, d, TRUE);
return ms_filter_call_method(d->videoStream->jpegwriter, MS_JPEG_WRITER_TAKE_SNAPSHOT, (void *)filepath);
}
lWarning() << "Cannot take snapshot: no currently running video stream on this call";

76
tester/call_video_tester.c
View file

@ -1693,6 +1693,15 @@ static void video_call_recording_vp8_test(void) {
record_call("recording", TRUE, "VP8");
}
static void snapshot_taken(LinphoneCall *call, const char *filepath) {
char *filename = bc_tester_file("snapshot.jpeg");
LinphoneCore *lc = linphone_call_get_core(call);
stats *callstats = get_stats(lc);
BC_ASSERT_STRING_EQUAL(filepath, filename);
callstats->number_of_snapshot_taken++;
ms_free(filename);
}
static void video_call_snapshot(void) {
LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc");
LinphoneCoreManager* pauline = linphone_core_manager_new(transport_supported(LinphoneTransportTls) ? "pauline_rc" : "pauline_tcp_rc");
@ -1700,7 +1709,6 @@ static void video_call_snapshot(void) {
LinphoneCallParams *paulineParams = linphone_core_create_call_params(pauline->lc, NULL);
LinphoneCall *callInst = NULL;
char *filename = bc_tester_file("snapshot.jpeg");
int dummy = 0;
bool_t call_succeeded = FALSE;
linphone_core_enable_video_capture(marie->lc, TRUE);
@ -1712,12 +1720,73 @@ static void video_call_snapshot(void) {
BC_ASSERT_TRUE(call_succeeded = call_with_params(marie, pauline, marieParams, paulineParams));
BC_ASSERT_PTR_NOT_NULL(callInst = linphone_core_get_current_call(marie->lc));
if((call_succeeded == TRUE) && (callInst != NULL)) {
if (call_succeeded == TRUE && callInst != NULL) {
LinphoneCall *marie_call = linphone_core_get_current_call(marie->lc);
LinphoneCallCbs *marie_call_cbs = linphone_factory_create_call_cbs(linphone_factory_get());
BC_ASSERT_PTR_NOT_NULL(marie_call);
linphone_call_cbs_set_snapshot_taken(marie_call_cbs, snapshot_taken);
linphone_call_add_callbacks(marie_call, marie_call_cbs);
linphone_call_cbs_unref(marie_call_cbs);
int jpeg_support = linphone_call_take_video_snapshot(callInst, filename);
if (jpeg_support < 0) {
ms_warning("No jpegwriter support!");
} else {
wait_for_until(marie->lc, pauline->lc, &dummy, 1, 5000);
BC_ASSERT_TRUE(wait_for(marie->lc,pauline->lc,&marie->stat.number_of_snapshot_taken,1));
BC_ASSERT_EQUAL(ortp_file_exist(filename), 0, int, "%d");
remove(filename);
}
end_call(marie, pauline);
}
ms_free(filename);
linphone_call_params_unref(marieParams);
linphone_call_params_unref(paulineParams);
linphone_core_manager_destroy(marie);
linphone_core_manager_destroy(pauline);
}
static void video_call_snapshots(void) {
LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc");
LinphoneCoreManager* pauline = linphone_core_manager_new(transport_supported(LinphoneTransportTls) ? "pauline_rc" : "pauline_tcp_rc");
LinphoneCallParams *marieParams = linphone_core_create_call_params(marie->lc, NULL);
LinphoneCallParams *paulineParams = linphone_core_create_call_params(pauline->lc, NULL);
LinphoneCall *callInst = NULL;
char *filename = bc_tester_file("snapshot.jpeg");
bool_t call_succeeded = FALSE;
int dummy = 0;
linphone_core_enable_video_capture(marie->lc, TRUE);
linphone_core_enable_video_display(marie->lc, TRUE);
linphone_core_enable_video_capture(pauline->lc, TRUE);
linphone_core_enable_video_display(pauline->lc, FALSE);
linphone_call_params_enable_video(marieParams, TRUE);
linphone_call_params_enable_video(paulineParams, TRUE);
BC_ASSERT_TRUE(call_succeeded = call_with_params(marie, pauline, marieParams, paulineParams));
BC_ASSERT_PTR_NOT_NULL(callInst = linphone_core_get_current_call(marie->lc));
if (call_succeeded == TRUE && callInst != NULL) {
LinphoneCall *marie_call = linphone_core_get_current_call(marie->lc);
LinphoneCallCbs *marie_call_cbs = linphone_factory_create_call_cbs(linphone_factory_get());
BC_ASSERT_PTR_NOT_NULL(marie_call);
linphone_call_cbs_set_snapshot_taken(marie_call_cbs, snapshot_taken);
linphone_call_add_callbacks(marie_call, marie_call_cbs);
linphone_call_cbs_unref(marie_call_cbs);
int jpeg_support = linphone_call_take_video_snapshot(callInst, filename);
if (jpeg_support < 0) {
ms_warning("No jpegwriter support!");
} else {
BC_ASSERT_TRUE(wait_for(marie->lc,pauline->lc,&marie->stat.number_of_snapshot_taken,1));
BC_ASSERT_EQUAL(ortp_file_exist(filename), 0, int, "%d");
remove(filename);
wait_for_until(marie->lc, pauline->lc, &dummy, 1, 1000);
linphone_call_take_video_snapshot(callInst, filename);
BC_ASSERT_TRUE(wait_for(marie->lc,pauline->lc,&marie->stat.number_of_snapshot_taken,2));
BC_ASSERT_EQUAL(ortp_file_exist(filename), 0, int, "%d");
remove(filename);
wait_for_until(marie->lc, pauline->lc, &dummy, 1, 1000);
linphone_call_take_video_snapshot(callInst, filename);
BC_ASSERT_TRUE(wait_for(marie->lc,pauline->lc,&marie->stat.number_of_snapshot_taken,3));
BC_ASSERT_EQUAL(ortp_file_exist(filename), 0, int, "%d");
remove(filename);
}
@ -2214,6 +2283,7 @@ test_t call_video_tests[] = {
TEST_NO_TAG("Video call recording (H264)", video_call_recording_h264_test),
TEST_NO_TAG("Video call recording (VP8)", video_call_recording_vp8_test),
TEST_NO_TAG("Snapshot", video_call_snapshot),
TEST_NO_TAG("Snapshots", video_call_snapshots),
TEST_NO_TAG("Video call with early media and no matching audio codecs", video_call_with_early_media_no_matching_audio_codecs),
TEST_NO_TAG("DTLS SRTP video call", dtls_srtp_video_call),
TEST_ONE_TAG("DTLS SRTP ice video call", dtls_srtp_ice_video_call, "ICE"),

2
tester/liblinphone_tester.h
View file

@ -291,6 +291,8 @@ typedef struct _stats {
int number_of_participants_removed;
int number_of_subject_changed;
int number_of_participant_devices_added;
int number_of_snapshot_taken;
}stats;