More new memory wrapper work.
[asterisk/asterisk.git] / apps / app_milliwatt.c
1 /*
2  * Asterisk -- An open source telephony toolkit.
3  *
4  * Copyright (C) 1999 - 2005, Digium, Inc.
5  *
6  * Mark Spencer <markster@digium.com>
7  *
8  * See http://www.asterisk.org for more information about
9  * the Asterisk project. Please do not directly contact
10  * any of the maintainers of this project for assistance;
11  * the project provides a web site, mailing lists and IRC
12  * channels for your use.
13  *
14  * This program is free software, distributed under the terms of
15  * the GNU General Public License Version 2. See the LICENSE file
16  * at the top of the source tree.
17  */
18
19 /*! \file
20  *
21  * \brief Digital Milliwatt Test
22  *
23  * \author Mark Spencer <markster@digium.com>
24  * 
25  * \ingroup applications
26  */
27
28 #include <stdlib.h>
29 #include <stdio.h>
30 #include <string.h>
31 #include <unistd.h>
32 #include <errno.h>
33
34 #include "asterisk.h"
35
36 ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
37
38 #include "asterisk/lock.h"
39 #include "asterisk/file.h"
40 #include "asterisk/logger.h"
41 #include "asterisk/channel.h"
42 #include "asterisk/pbx.h"
43 #include "asterisk/module.h"
44
45 static char *tdesc = "Digital Milliwatt (mu-law) Test Application";
46
47 static char *app = "Milliwatt";
48
49 static char *synopsis = "Generate a Constant 1000Hz tone at 0dbm (mu-law)";
50
51 static char *descrip = 
52 "Milliwatt(): Generate a Constant 1000Hz tone at 0dbm (mu-law)\n";
53
54 STANDARD_LOCAL_USER;
55
56 LOCAL_USER_DECL;
57
58 static char digital_milliwatt[] = {0x1e,0x0b,0x0b,0x1e,0x9e,0x8b,0x8b,0x9e} ;
59
60 static void *milliwatt_alloc(struct ast_channel *chan, void *params)
61 {
62 int     *indexp;
63         indexp = ast_malloc(sizeof(*indexp));
64         if (indexp == NULL) return(NULL);
65         *indexp = 0;
66         return(indexp);
67 }
68
69 static void milliwatt_release(struct ast_channel *chan, void *data)
70 {
71         free(data);
72         return;
73 }
74
75 static int milliwatt_generate(struct ast_channel *chan, void *data, int len, int samples)
76 {
77         struct ast_frame wf;
78         unsigned char waste[AST_FRIENDLY_OFFSET];
79         unsigned char buf[640];
80         int i,*indexp = (int *) data;
81
82         if (len > sizeof(buf))
83         {
84                 ast_log(LOG_WARNING,"Only doing %d bytes (%d bytes requested)\n",(int)sizeof(buf),len);
85                 len = sizeof(buf);
86         }
87         waste[0] = 0; /* make compiler happy */
88         wf.frametype = AST_FRAME_VOICE;
89         wf.subclass = AST_FORMAT_ULAW;
90         wf.offset = AST_FRIENDLY_OFFSET;
91         wf.mallocd = 0;
92         wf.data = buf;
93         wf.datalen = len;
94         wf.samples = wf.datalen;
95         wf.src = "app_milliwatt";
96         wf.delivery.tv_sec = 0;
97         wf.delivery.tv_usec = 0;
98         /* create a buffer containing the digital milliwatt pattern */
99         for(i = 0; i < len; i++)
100         {
101                 buf[i] = digital_milliwatt[(*indexp)++];
102                 *indexp &= 7;
103         }
104         if (ast_write(chan,&wf) < 0)
105         {
106                 ast_log(LOG_WARNING,"Failed to write frame to '%s': %s\n",chan->name,strerror(errno));
107                 return -1;
108         }
109         return 0;
110 }
111
112 static struct ast_generator milliwattgen = 
113 {
114         alloc: milliwatt_alloc,
115         release: milliwatt_release,
116         generate: milliwatt_generate,
117 } ;
118
119 static int milliwatt_exec(struct ast_channel *chan, void *data)
120 {
121
122         struct localuser *u;
123         LOCAL_USER_ADD(u);
124         ast_set_write_format(chan, AST_FORMAT_ULAW);
125         ast_set_read_format(chan, AST_FORMAT_ULAW);
126         if (chan->_state != AST_STATE_UP)
127         {
128                 ast_answer(chan);
129         }
130         if (ast_activate_generator(chan,&milliwattgen,"milliwatt") < 0)
131         {
132                 ast_log(LOG_WARNING,"Failed to activate generator on '%s'\n",chan->name);
133                 LOCAL_USER_REMOVE(u);
134                 return -1;
135         }
136         while(!ast_safe_sleep(chan, 10000));
137         ast_deactivate_generator(chan);
138         LOCAL_USER_REMOVE(u);
139         return -1;
140 }
141
142 int unload_module(void)
143 {
144         int res;
145
146         res = ast_unregister_application(app);
147
148         STANDARD_HANGUP_LOCALUSERS;
149
150         return res;
151 }
152
153 int load_module(void)
154 {
155         return ast_register_application(app, milliwatt_exec, synopsis, descrip);
156 }
157
158 char *description(void)
159 {
160         return tdesc;
161 }
162
163 int usecount(void)
164 {
165         int res;
166         STANDARD_USECOUNT(res);
167         return res;
168 }
169
170 char *key()
171 {
172         return ASTERISK_GPL_KEY;
173 }