[Freeswitch-svn] [commit] r11499 - freeswitch/trunk/src/mod/event_handlers/mod_erlang_event

[FreeSWITCH SVN]

Author: andrew
Date: Mon Jan 26 19:13:59 2009
New Revision: 11499

Log:
Support sending a message to a registered process to request a pid (when spawning won't cut it)


Modified:
   freeswitch/trunk/src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c

Modified: freeswitch/trunk/src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c
==============================================================================
--- freeswitch/trunk/src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c	(original)
+++ freeswitch/trunk/src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c	Mon Jan 26 19:13:59 2009
@@ -899,6 +899,7 @@
 	return 0;
 }
 
+
 static listener_t* new_listener(struct ei_cnode_s *ec, int clientfd)
 {
 	switch_memory_pool_t *listener_pool = NULL;
@@ -950,6 +951,7 @@
 	return listener;
 }
 
+
 session_elem_t* attach_call_to_registered_process(listener_t* listener, char* reg_name, switch_core_session_t *session)
 {
 	/* create a session list element */
@@ -976,6 +978,7 @@
 	return session_element;
 }
 
+
 session_elem_t* attach_call_to_spawned_process(listener_t* listener, char *module, char *function, switch_core_session_t *session)
 {
 	/* create a session list element */
@@ -993,8 +996,26 @@
 			session_element->session = session;
 			erlang_pid *pid;
 			erlang_ref ref;
-			
-			ei_spawn(listener->ec, listener->sockfd, &ref, module, function, 0, argv);
+
+			if (!strcmp(function, "!")) {
+				/* send a message to request a pid */
+				ei_x_buff rbuf;
+				ei_x_new_with_version(&rbuf);
+
+				ei_init_ref(listener->ec, &ref);
+				ei_x_encode_tuple_header(&rbuf, 3);
+				ei_x_encode_atom(&rbuf, "new_pid");
+				ei_x_encode_ref(&rbuf, &ref);
+				ei_x_encode_pid(&rbuf, ei_self(listener->ec));
+				ei_reg_send(listener->ec, listener->sockfd, module, rbuf.buff, rbuf.index);
+#ifdef EI_DEBUG
+				ei_x_print_reg_msg(&rbuf, module, 1);
+#endif
+				ei_x_free(&rbuf);
+			} else {
+				ei_spawn(listener->ec, listener->sockfd, &ref, module, function, 0, argv);
+			}
+
 			ei_hash_ref(&ref, hash);
 
 			while (!(pid = (erlang_pid *) switch_core_hash_find(listener->spawn_pid_hash, hash))) {