aboutsummaryrefslogtreecommitdiff
path: root/src/conversation
diff options
context:
space:
mode:
Diffstat (limited to 'src/conversation')
-rw-r--r--src/conversation/Makefile.am2
-rw-r--r--src/conversation/gnunet-conversation.c21
-rw-r--r--src/conversation/gnunet-helper-audio-playback.c15
-rw-r--r--src/conversation/gnunet-service-conversation.c7
-rw-r--r--src/conversation/microphone.c2
5 files changed, 26 insertions, 21 deletions
diff --git a/src/conversation/Makefile.am b/src/conversation/Makefile.am
index 83313e7f8..cc2938144 100644
--- a/src/conversation/Makefile.am
+++ b/src/conversation/Makefile.am
@@ -180,7 +180,7 @@ gnunet_service_conversation_LDADD = \
180 libgnunetconversation.la \ 180 libgnunetconversation.la \
181 libgnunetspeaker.la \ 181 libgnunetspeaker.la \
182 libgnunetmicrophone.la \ 182 libgnunetmicrophone.la \
183 $(top_builddir)/src/cadet/libgnunetcadetnew.la \ 183 $(top_builddir)/src/cadet/libgnunetcadet.la \
184 $(top_builddir)/src/util/libgnunetutil.la \ 184 $(top_builddir)/src/util/libgnunetutil.la \
185 $(INTLLIBS) 185 $(INTLLIBS)
186gnunet_service_conversation_LDFLAGS = \ 186gnunet_service_conversation_LDFLAGS = \
diff --git a/src/conversation/gnunet-conversation.c b/src/conversation/gnunet-conversation.c
index 925db4665..c5275c0de 100644
--- a/src/conversation/gnunet-conversation.c
+++ b/src/conversation/gnunet-conversation.c
@@ -1265,13 +1265,20 @@ run (void *cls,
1265int 1265int
1266main (int argc, char *const *argv) 1266main (int argc, char *const *argv)
1267{ 1267{
1268 static const struct GNUNET_GETOPT_CommandLineOption options[] = { 1268 struct GNUNET_GETOPT_CommandLineOption options[] = {
1269 {'e', "ego", "NAME", 1269
1270 gettext_noop ("sets the NAME of the ego to use for the phone (and name resolution)"), 1270 GNUNET_GETOPT_OPTION_STRING ('e',
1271 1, &GNUNET_GETOPT_set_string, &ego_name}, 1271 "ego",
1272 {'p', "phone", "LINE", 1272 "NAME",
1273 gettext_noop ("sets the LINE to use for the phone"), 1273 gettext_noop ("sets the NAME of the ego to use for the phone (and name resolution)"),
1274 1, &GNUNET_GETOPT_set_string, &line}, 1274 &ego_name),
1275
1276 GNUNET_GETOPT_OPTION_STRING ('p',
1277 "phone",
1278 "LINE",
1279 gettext_noop ("sets the LINE to use for the phone"),
1280 &line),
1281
1275 GNUNET_GETOPT_OPTION_END 1282 GNUNET_GETOPT_OPTION_END
1276 }; 1283 };
1277 int ret; 1284 int ret;
diff --git a/src/conversation/gnunet-helper-audio-playback.c b/src/conversation/gnunet-helper-audio-playback.c
index e965cb2aa..4344e1d41 100644
--- a/src/conversation/gnunet-helper-audio-playback.c
+++ b/src/conversation/gnunet-helper-audio-playback.c
@@ -549,7 +549,6 @@ ogg_demux_and_decode ()
549 */ 549 */
550static int 550static int
551stdin_receiver (void *cls, 551stdin_receiver (void *cls,
552 void *client,
553 const struct GNUNET_MessageHeader *msg) 552 const struct GNUNET_MessageHeader *msg)
554{ 553{
555 struct AudioMessage *audio; 554 struct AudioMessage *audio;
@@ -727,12 +726,14 @@ ogg_init ()
727 ogg_sync_init (&oy); 726 ogg_sync_init (&oy);
728} 727}
729 728
729
730static void 730static void
731drain_callback (pa_stream*s, int success, void *userdata) 731drain_callback (pa_stream*s, int success, void *userdata)
732{ 732{
733 pa_threaded_mainloop_signal (m, 0); 733 pa_threaded_mainloop_signal (m, 0);
734} 734}
735 735
736
736/** 737/**
737 * The main function for the playback helper. 738 * The main function for the playback helper.
738 * 739 *
@@ -746,7 +747,7 @@ main (int argc, char *argv[])
746 static unsigned long long toff; 747 static unsigned long long toff;
747 748
748 char readbuf[MAXLINE]; 749 char readbuf[MAXLINE];
749 struct GNUNET_SERVER_MessageStreamTokenizer *stdin_mst; 750 struct GNUNET_MessageStreamTokenizer *stdin_mst;
750 char c; 751 char c;
751 ssize_t ret; 752 ssize_t ret;
752#ifdef DEBUG_READ_PURE_OGG 753#ifdef DEBUG_READ_PURE_OGG
@@ -762,7 +763,7 @@ main (int argc, char *argv[])
762 GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, "pipe"); 763 GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, "pipe");
763 return 1; 764 return 1;
764 } 765 }
765 stdin_mst = GNUNET_SERVER_mst_create (&stdin_receiver, NULL); 766 stdin_mst = GNUNET_MST_create (&stdin_receiver, NULL);
766 ogg_init (); 767 ogg_init ();
767 pa_init (); 768 pa_init ();
768 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 769 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
@@ -802,11 +803,11 @@ main (int argc, char *argv[])
802 } 803 }
803 else 804 else
804#endif 805#endif
805 GNUNET_SERVER_mst_receive (stdin_mst, NULL, 806 GNUNET_MST_from_buffer (stdin_mst,
806 readbuf, ret, 807 readbuf, ret,
807 GNUNET_NO, GNUNET_NO); 808 GNUNET_NO, GNUNET_NO);
808 } 809 }
809 GNUNET_SERVER_mst_destroy (stdin_mst); 810 GNUNET_MST_destroy (stdin_mst);
810 if (stream_out) 811 if (stream_out)
811 { 812 {
812 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 813 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
diff --git a/src/conversation/gnunet-service-conversation.c b/src/conversation/gnunet-service-conversation.c
index f80cc1d11..5f43bfe80 100644
--- a/src/conversation/gnunet-service-conversation.c
+++ b/src/conversation/gnunet-service-conversation.c
@@ -779,7 +779,6 @@ handle_cadet_hangup_message (void *cls,
779 { 779 {
780 case CS_CALLEE_INIT: 780 case CS_CALLEE_INIT:
781 GNUNET_break_op (0); 781 GNUNET_break_op (0);
782 destroy_line_cadet_channels (ch);
783 return; 782 return;
784 case CS_CALLEE_RINGING: 783 case CS_CALLEE_RINGING:
785 case CS_CALLEE_CONNECTED: 784 case CS_CALLEE_CONNECTED:
@@ -1110,7 +1109,7 @@ handle_client_call_message (void *cls,
1110 line->channel_tail, 1109 line->channel_tail,
1111 ch); 1110 ch);
1112 ch->status = CS_CALLER_CALLING; 1111 ch->status = CS_CALLER_CALLING;
1113 ch->channel = GNUNET_CADET_channel_creatE (cadet, 1112 ch->channel = GNUNET_CADET_channel_create (cadet,
1114 ch, 1113 ch,
1115 &msg->target, 1114 &msg->target,
1116 &msg->line_port, 1115 &msg->line_port,
@@ -1264,7 +1263,7 @@ handle_client_register_message (void *cls,
1264 }; 1263 };
1265 1264
1266 line->line_port = msg->line_port; 1265 line->line_port = msg->line_port;
1267 line->port = GNUNET_CADET_open_porT (cadet, 1266 line->port = GNUNET_CADET_open_port (cadet,
1268 &msg->line_port, 1267 &msg->line_port,
1269 &inbound_channel, 1268 &inbound_channel,
1270 line, 1269 line,
@@ -1307,7 +1306,7 @@ run (void *cls,
1307 GNUNET_assert (GNUNET_OK == 1306 GNUNET_assert (GNUNET_OK ==
1308 GNUNET_CRYPTO_get_peer_identity (cfg, 1307 GNUNET_CRYPTO_get_peer_identity (cfg,
1309 &my_identity)); 1308 &my_identity));
1310 cadet = GNUNET_CADET_connecT (cfg); 1309 cadet = GNUNET_CADET_connect (cfg);
1311 if (NULL == cadet) 1310 if (NULL == cadet)
1312 { 1311 {
1313 GNUNET_break (0); 1312 GNUNET_break (0);
diff --git a/src/conversation/microphone.c b/src/conversation/microphone.c
index 94f52f8dc..7871433a3 100644
--- a/src/conversation/microphone.c
+++ b/src/conversation/microphone.c
@@ -64,13 +64,11 @@ struct Microphone
64 * Function to process the audio from the record helper 64 * Function to process the audio from the record helper
65 * 65 *
66 * @param cls clsoure with our `struct Microphone` 66 * @param cls clsoure with our `struct Microphone`
67 * @param client NULL
68 * @param msg the message from the helper 67 * @param msg the message from the helper
69 * @return #GNUNET_OK on success, #GNUNET_SYSERR on error 68 * @return #GNUNET_OK on success, #GNUNET_SYSERR on error
70 */ 69 */
71static int 70static int
72process_record_messages (void *cls, 71process_record_messages (void *cls,
73 void *client,
74 const struct GNUNET_MessageHeader *msg) 72 const struct GNUNET_MessageHeader *msg)
75{ 73{
76 struct Microphone *mic = cls; 74 struct Microphone *mic = cls;