Merged revisions 61961 via svnmerge from
[asterisk/asterisk.git] / res / res_adsi.c
old mode 100755 (executable)
new mode 100644 (file)
index e464c01..a384ac9
@@ -1,34 +1,58 @@
 /*
 /*
- * Asterisk -- A telephony toolkit for Linux.
+ * Asterisk -- An open source telephony toolkit.
  *
  *
- * ADSI support 
- * 
- * Copyright (C) 2001, Linux Support Services, Inc.
+ * Copyright (C) 1999 - 2005, Digium, Inc.
  *
  *
- * Mark Spencer <markster@linux-support.net>
+ * Mark Spencer <markster@digium.com>
+ *
+ * Includes code and algorithms from the Zapata library.
+ *
+ * See http://www.asterisk.org for more information about
+ * the Asterisk project. Please do not directly contact
+ * any of the maintainers of this project for assistance;
+ * the project provides a web site, mailing lists and IRC
+ * channels for your use.
  *
  * This program is free software, distributed under the terms of
  *
  * This program is free software, distributed under the terms of
- * the GNU General Public License.
+ * the GNU General Public License Version 2. See the LICENSE file
+ * at the top of the source tree.
+ */
+
+/*! \file
  *
  *
- * Includes code and algorithms from the Zapata library.
+ * \brief ADSI support 
+ *
+ * \author Mark Spencer <markster@digium.com> 
  *
  *
+ * \note this module is required by app_voicemail and app_getcpeid
+ * \todo Move app_getcpeid into this module
+ * \todo Create a core layer so that app_voicemail does not require
+ *     res_adsi to load
  */
 
  */
 
+#include "asterisk.h"
+
+ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
+
 #include <time.h>
 #include <string.h>
 #include <stdio.h>
 #include <stdlib.h>
 #include <unistd.h>
 #include <math.h>
 #include <time.h>
 #include <string.h>
 #include <stdio.h>
 #include <stdlib.h>
 #include <unistd.h>
 #include <math.h>
-#include <asterisk/ulaw.h>
-#include <asterisk/callerid.h>
-#include <asterisk/logger.h>
-#include <asterisk/fskmodem.h>
-#include <asterisk/channel.h>
-#include <asterisk/adsi.h>
-#include <asterisk/module.h>
-#include <asterisk/config.h>
-#include <asterisk/file.h>
+#include <errno.h>
+
+#include "asterisk/ulaw.h"
+#include "asterisk/alaw.h"
+#include "asterisk/callerid.h"
+#include "asterisk/logger.h"
+#include "asterisk/fskmodem.h"
+#include "asterisk/channel.h"
+#include "asterisk/adsi.h"
+#include "asterisk/module.h"
+#include "asterisk/config.h"
+#include "asterisk/file.h"
+#include "asterisk/options.h"
 
 #define DEFAULT_ADSI_MAX_RETRIES 3
 
 
 #define DEFAULT_ADSI_MAX_RETRIES 3
 
@@ -49,7 +73,7 @@ static char speeddial[ADSI_MAX_SPEED_DIAL][3][20];
 
 static int alignment = 0;
 
 
 static int alignment = 0;
 
-static int adsi_generate(unsigned char *buf, int msgtype, char *msg, int msglen, int msgnum, int last)
+static int adsi_generate(unsigned char *buf, int msgtype, unsigned char *msg, int msglen, int msgnum, int last, int codec)
 {
        int sum;
        int x;  
 {
        int sum;
        int x;  
@@ -99,27 +123,6 @@ static int adsi_generate(unsigned char *buf, int msgtype, char *msg, int msglen,
 
 }
 
 
 }
 
-#if 0
-static int adsi_careful_send(struct ast_channel *chan, unsigned char *buf, int len, int *remainder)
-{
-       int res;
-       fd_set fds;
-       while(len) {
-               FD_ZERO(&fds);
-               FD_SET(chan->fds[0], &fds);
-               select(chan->fds[0] + 1, NULL, &fds, NULL, NULL);
-               res = write(chan->fds[0], buf, len);
-               if (res < 1) {
-                       ast_log(LOG_WARNING, "Failed to write: %s\n", strerror(errno));
-                       return -1;
-               }
-               buf += res;
-               len -= res;
-       }
-       return 0;
-}
-
-#else
 static int adsi_careful_send(struct ast_channel *chan, unsigned char *buf, int len, int *remainder)
 {
        /* Sends carefully on a full duplex channel by using reading for
 static int adsi_careful_send(struct ast_channel *chan, unsigned char *buf, int len, int *remainder)
 {
        /* Sends carefully on a full duplex channel by using reading for
@@ -142,7 +145,7 @@ static int adsi_careful_send(struct ast_channel *chan, unsigned char *buf, int l
                outf.subclass = AST_FORMAT_ULAW;
                outf.data = buf;
                outf.datalen = amt;
                outf.subclass = AST_FORMAT_ULAW;
                outf.data = buf;
                outf.datalen = amt;
-               outf.timelen = amt * 8;
+               outf.samples = amt;
                if (ast_write(chan, &outf)) {
                        ast_log(LOG_WARNING, "Failed to carefully write frame\n");
                        return -1;
                if (ast_write(chan, &outf)) {
                        ast_log(LOG_WARNING, "Failed to carefully write frame\n");
                        return -1;
@@ -177,7 +180,7 @@ static int adsi_careful_send(struct ast_channel *chan, unsigned char *buf, int l
                        outf.subclass = AST_FORMAT_ULAW;
                        outf.data = buf;
                        outf.datalen = amt;
                        outf.subclass = AST_FORMAT_ULAW;
                        outf.data = buf;
                        outf.datalen = amt;
-                       outf.timelen = amt * 8;
+                       outf.samples = amt;
                        if (ast_write(chan, &outf)) {
                                ast_log(LOG_WARNING, "Failed to carefully write frame\n");
                                return -1;
                        if (ast_write(chan, &outf)) {
                                ast_log(LOG_WARNING, "Failed to carefully write frame\n");
                                return -1;
@@ -190,7 +193,6 @@ static int adsi_careful_send(struct ast_channel *chan, unsigned char *buf, int l
        }
        return 0;
 }
        }
        return 0;
 }
-#endif
 
 static int __adsi_transmit_messages(struct ast_channel *chan, unsigned char **msg, int *msglen, int *msgtype)
 {
 
 static int __adsi_transmit_messages(struct ast_channel *chan, unsigned char **msg, int *msglen, int *msgtype)
 {
@@ -218,7 +220,7 @@ static int __adsi_transmit_messages(struct ast_channel *chan, unsigned char **ms
        while(retries < maxretries) {
                if (!(chan->adsicpe & ADSI_FLAG_DATAMODE)) {
                        /* Generate CAS (no SAS) */
        while(retries < maxretries) {
                if (!(chan->adsicpe & ADSI_FLAG_DATAMODE)) {
                        /* Generate CAS (no SAS) */
-                       ast_gen_cas(buf, 0, 680);
+                       ast_gen_cas(buf, 0, 680, AST_FORMAT_ULAW);
                
                        /* Send CAS */
                        if (adsi_careful_send(chan, buf, 680, NULL)) {
                
                        /* Send CAS */
                        if (adsi_careful_send(chan, buf, 680, NULL)) {
@@ -229,7 +231,8 @@ static int __adsi_transmit_messages(struct ast_channel *chan, unsigned char **ms
                        for(;;) {
                                if (((res = ast_waitfor(chan, waittime)) < 1)) {
                                        /* Didn't get back DTMF A in time */
                        for(;;) {
                                if (((res = ast_waitfor(chan, waittime)) < 1)) {
                                        /* Didn't get back DTMF A in time */
-                                       ast_log(LOG_DEBUG, "No ADSI CPE detected (%d)\n", res);
+                                       if (option_debug)
+                                               ast_log(LOG_DEBUG, "No ADSI CPE detected (%d)\n", res);
                                        if (!chan->adsicpe)
                                                chan->adsicpe = AST_ADSI_UNAVAILABLE;
                                        errno = ENOSYS;
                                        if (!chan->adsicpe)
                                                chan->adsicpe = AST_ADSI_UNAVAILABLE;
                                        errno = ENOSYS;
@@ -238,7 +241,8 @@ static int __adsi_transmit_messages(struct ast_channel *chan, unsigned char **ms
                                waittime = res;
                                f = ast_read(chan);
                                if (!f) {
                                waittime = res;
                                f = ast_read(chan);
                                if (!f) {
-                                       ast_log(LOG_DEBUG, "Hangup in ADSI\n");
+                                       if (option_debug)
+                                               ast_log(LOG_DEBUG, "Hangup in ADSI\n");
                                        return -1;
                                }
                                if (f->frametype == AST_FRAME_DTMF) {
                                        return -1;
                                }
                                if (f->frametype == AST_FRAME_DTMF) {
@@ -249,7 +253,8 @@ static int __adsi_transmit_messages(struct ast_channel *chan, unsigned char **ms
                                                break;
                                        } else {
                                                if (f->subclass == 'D')  {
                                                break;
                                        } else {
                                                if (f->subclass == 'D')  {
-                                                       ast_log(LOG_DEBUG, "Off-hook capable CPE only, not ADSI\n");
+                                                       if (option_debug)
+                                                               ast_log(LOG_DEBUG, "Off-hook capable CPE only, not ADSI\n");
                                                } else
                                                        ast_log(LOG_WARNING, "Unknown ADSI response '%c'\n", f->subclass);
                                                if (!chan->adsicpe)
                                                } else
                                                        ast_log(LOG_WARNING, "Unknown ADSI response '%c'\n", f->subclass);
                                                if (!chan->adsicpe)
@@ -261,9 +266,12 @@ static int __adsi_transmit_messages(struct ast_channel *chan, unsigned char **ms
                                ast_frfree(f);
                        }
 
                                ast_frfree(f);
                        }
 
-                       ast_log(LOG_DEBUG, "ADSI Compatible CPE Detected\n");
-               } else
-                       ast_log(LOG_DEBUG, "Already in data mode\n");
+                       if (option_debug)
+                               ast_log(LOG_DEBUG, "ADSI Compatible CPE Detected\n");
+               } else {
+                       if (option_debug)
+                               ast_log(LOG_DEBUG, "Already in data mode\n");
+               }
 
                x = 0;
                pos = 0;
 
                x = 0;
                pos = 0;
@@ -271,13 +279,14 @@ static int __adsi_transmit_messages(struct ast_channel *chan, unsigned char **ms
                def= ast_channel_defer_dtmf(chan);
 #endif
                while((x < 6) && msg[x]) {
                def= ast_channel_defer_dtmf(chan);
 #endif
                while((x < 6) && msg[x]) {
-                       res = adsi_generate(buf + pos, msgtype[x], msg[x], msglen[x], x+1 - start, (x == 5) || !msg[x+1]);
+                       res = adsi_generate(buf + pos, msgtype[x], msg[x], msglen[x], x+1 - start, (x == 5) || !msg[x+1], AST_FORMAT_ULAW);
                        if (res < 0) {
                                ast_log(LOG_WARNING, "Failed to generate ADSI message %d on channel %s\n", x + 1, chan->name);
                                return -1;
                        }
                        if (res < 0) {
                                ast_log(LOG_WARNING, "Failed to generate ADSI message %d on channel %s\n", x + 1, chan->name);
                                return -1;
                        }
-                       ast_log(LOG_DEBUG, "Message %d, of %d input bytes, %d output bytes\n", 
-                                       x + 1, msglen[x], res);
+                       if (option_debug)
+                               ast_log(LOG_DEBUG, "Message %d, of %d input bytes, %d output bytes\n", 
+                                               x + 1, msglen[x], res);
                        pos += res; 
                        x++;
                }
                        pos += res; 
                        x++;
                }
@@ -290,7 +299,8 @@ static int __adsi_transmit_messages(struct ast_channel *chan, unsigned char **ms
                if (res)
                        return -1;
 
                if (res)
                        return -1;
 
-               ast_log(LOG_DEBUG, "Sent total spill of %d bytes\n", pos);
+               if (option_debug)
+                       ast_log(LOG_DEBUG, "Sent total spill of %d bytes\n", pos);
 
                memset(ack, 0, sizeof(ack));
                /* Get real result */
 
                memset(ack, 0, sizeof(ack));
                /* Get real result */
@@ -299,13 +309,15 @@ static int __adsi_transmit_messages(struct ast_channel *chan, unsigned char **ms
                if (res < 0)
                        return -1;
                if (ack[0] == 'D') {
                if (res < 0)
                        return -1;
                if (ack[0] == 'D') {
-                       ast_log(LOG_DEBUG, "Acked up to message %d\n", atoi(ack + 1));
+                       if (option_debug)
+                               ast_log(LOG_DEBUG, "Acked up to message %d\n", atoi(ack + 1));
                        start += atoi(ack + 1);
                        if (start >= x)
                                break;
                        else {
                                retries++;
                        start += atoi(ack + 1);
                        if (start >= x)
                                break;
                        else {
                                retries++;
-                               ast_log(LOG_DEBUG, "Retransmitting (%d), from %d\n", start + 1);
+                               if (option_debug)
+                                       ast_log(LOG_DEBUG, "Retransmitting (%d), from %d\n", retries, start + 1);
                        }
                } else {
                        retries++;
                        }
                } else {
                        retries++;
@@ -321,39 +333,40 @@ static int __adsi_transmit_messages(struct ast_channel *chan, unsigned char **ms
        
 }
 
        
 }
 
-int adsi_begin_download(struct ast_channel *chan, char *service, char *fdn, char *sec, int version)
+int ast_adsi_begin_download(struct ast_channel *chan, char *service, unsigned char *fdn, unsigned char *sec, int version)
 {
        int bytes;
        unsigned char buf[256];
        char ack[2];
 {
        int bytes;
        unsigned char buf[256];
        char ack[2];
-        bytes = 0;
-        /* Setup the resident soft key stuff, a piece at a time */
-        /* Upload what scripts we can for voicemail ahead of time */
-        bytes += adsi_download_connect(buf + bytes, service, fdn, sec, version);
-        if (adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DOWNLOAD))
+       bytes = 0;
+       /* Setup the resident soft key stuff, a piece at a time */
+       /* Upload what scripts we can for voicemail ahead of time */
+       bytes += ast_adsi_download_connect(buf + bytes, service, fdn, sec, version);
+       if (ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DOWNLOAD, 0))
                return -1;
        if (ast_readstring(chan, ack, 1, 10000, 10000, ""))
                return -1;
        if (ack[0] == 'B')
                return 0;
                return -1;
        if (ast_readstring(chan, ack, 1, 10000, 10000, ""))
                return -1;
        if (ack[0] == 'B')
                return 0;
-       ast_log(LOG_DEBUG, "Download was denied by CPE\n");
+       if (option_debug)
+               ast_log(LOG_DEBUG, "Download was denied by CPE\n");
        return -1;
 }
 
        return -1;
 }
 
-int adsi_end_download(struct ast_channel *chan)
+int ast_adsi_end_download(struct ast_channel *chan)
 {
        int bytes;
        unsigned char buf[256];
         bytes = 0;
         /* Setup the resident soft key stuff, a piece at a time */
         /* Upload what scripts we can for voicemail ahead of time */
 {
        int bytes;
        unsigned char buf[256];
         bytes = 0;
         /* Setup the resident soft key stuff, a piece at a time */
         /* Upload what scripts we can for voicemail ahead of time */
-        bytes += adsi_download_disconnect(buf + bytes);
-        if (adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DOWNLOAD))
+        bytes += ast_adsi_download_disconnect(buf + bytes);
+       if (ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DOWNLOAD, 0))
                return -1;
        return 0;
 }
 
                return -1;
        return 0;
 }
 
-int adsi_transmit_message(struct ast_channel *chan, unsigned char *msg, int msglen, int msgtype)
+int ast_adsi_transmit_message_full(struct ast_channel *chan, unsigned char *msg, int msglen, int msgtype, int dowait)
 {
        unsigned char *msgs[5] = { NULL, NULL, NULL, NULL, NULL };
        int msglens[5];
 {
        unsigned char *msgs[5] = { NULL, NULL, NULL, NULL, NULL };
        int msglens[5];
@@ -362,6 +375,7 @@ int adsi_transmit_message(struct ast_channel *chan, unsigned char *msg, int msgl
        int res;
        int x;
        int writeformat, readformat;
        int res;
        int x;
        int writeformat, readformat;
+       int waitforswitch = 0;
 
        writeformat = chan->writeformat;
        readformat = chan->readformat;
 
        writeformat = chan->writeformat;
        readformat = chan->readformat;
@@ -369,11 +383,19 @@ int adsi_transmit_message(struct ast_channel *chan, unsigned char *msg, int msgl
        newdatamode = chan->adsicpe & ADSI_FLAG_DATAMODE;
 
        for (x=0;x<msglen;x+=(msg[x+1]+2)) {
        newdatamode = chan->adsicpe & ADSI_FLAG_DATAMODE;
 
        for (x=0;x<msglen;x+=(msg[x+1]+2)) {
-               if (msg[x] == ADSI_SWITCH_TO_DATA) 
+               if (msg[x] == ADSI_SWITCH_TO_DATA) {
+                       if (option_debug)
+                               ast_log(LOG_DEBUG, "Switch to data is sent!\n");
+                       waitforswitch++;
                        newdatamode = ADSI_FLAG_DATAMODE;
                        newdatamode = ADSI_FLAG_DATAMODE;
+               }
                
                
-               if (msg[x] == ADSI_SWITCH_TO_VOICE)
+               if (msg[x] == ADSI_SWITCH_TO_VOICE) {
+                       if (option_debug)
+                               ast_log(LOG_DEBUG, "Switch to voice is sent!\n");
+                       waitforswitch++;
                        newdatamode = 0;
                        newdatamode = 0;
+               }
        }
        msgs[0] = msg;
 
        }
        msgs[0] = msg;
 
@@ -401,6 +423,17 @@ int adsi_transmit_message(struct ast_channel *chan, unsigned char *msg, int msgl
                return -1;
        }
        res = __adsi_transmit_messages(chan, msgs, msglens, msgtypes);
                return -1;
        }
        res = __adsi_transmit_messages(chan, msgs, msglens, msgtypes);
+
+       if (dowait) {
+               if (option_debug)
+                       ast_log(LOG_DEBUG, "Wait for switch is '%d'\n", waitforswitch);
+               while (waitforswitch-- && ((res = ast_waitfordigit(chan, 1000)) > 0)) { 
+                       res = 0; 
+                       if (option_debug)
+                               ast_log(LOG_DEBUG, "Waiting for 'B'...\n");
+               }
+       }
+       
        if (!res)
                chan->adsicpe = (chan->adsicpe & ~ADSI_FLAG_DATAMODE) | newdatamode;
 
        if (!res)
                chan->adsicpe = (chan->adsicpe & ~ADSI_FLAG_DATAMODE) | newdatamode;
 
@@ -409,10 +442,17 @@ int adsi_transmit_message(struct ast_channel *chan, unsigned char *msg, int msgl
        if (readformat)
                ast_set_read_format(chan, readformat);
 
        if (readformat)
                ast_set_read_format(chan, readformat);
 
+       if (!res)
+               res = ast_safe_sleep(chan, 100 );
        return res;
 }
 
        return res;
 }
 
-static inline int ccopy(unsigned char *dst, unsigned char *src, int max)
+int ast_adsi_transmit_message(struct ast_channel *chan, unsigned char *msg, int msglen, int msgtype)
+{
+       return ast_adsi_transmit_message_full(chan, msg, msglen, msgtype, 1);
+}
+
+static inline int ccopy(unsigned char *dst, const unsigned char *src, int max)
 {
        int x=0;
        /* Carefully copy the requested data */
 {
        int x=0;
        /* Carefully copy the requested data */
@@ -423,7 +463,7 @@ static inline int ccopy(unsigned char *dst, unsigned char *src, int max)
        return x;
 }
 
        return x;
 }
 
-int adsi_load_soft_key(unsigned char *buf, int key, unsigned char *llabel, unsigned char *slabel, unsigned char *ret, int data)
+int ast_adsi_load_soft_key(unsigned char *buf, int key, const char *llabel, const char *slabel, const char *ret, int data)
 {
        int bytes=0;
 
 {
        int bytes=0;
 
@@ -437,13 +477,13 @@ int adsi_load_soft_key(unsigned char *buf, int key, unsigned char *llabel, unsig
        buf[bytes++] = key;
 
        /* Carefully copy long label */
        buf[bytes++] = key;
 
        /* Carefully copy long label */
-       bytes += ccopy(buf + bytes, llabel, 18);
+       bytes += ccopy(buf + bytes, (const unsigned char *)llabel, 18);
 
        /* Place delimiter */
        buf[bytes++] = 0xff;
 
        /* Short label */
 
        /* Place delimiter */
        buf[bytes++] = 0xff;
 
        /* Short label */
-       bytes += ccopy(buf + bytes, slabel, 7);
+       bytes += ccopy(buf + bytes, (const unsigned char *)slabel, 7);
 
 
        /* If specified, copy return string */
 
 
        /* If specified, copy return string */
@@ -453,7 +493,7 @@ int adsi_load_soft_key(unsigned char *buf, int key, unsigned char *llabel, unsig
                if (data)
                        buf[bytes++] = ADSI_SWITCH_TO_DATA2;
                /* Carefully copy return string */
                if (data)
                        buf[bytes++] = ADSI_SWITCH_TO_DATA2;
                /* Carefully copy return string */
-               bytes += ccopy(buf + bytes, ret, 20);
+               bytes += ccopy(buf + bytes, (const unsigned char *)ret, 20);
 
        }
        /* Replace parameter length */
 
        }
        /* Replace parameter length */
@@ -462,7 +502,7 @@ int adsi_load_soft_key(unsigned char *buf, int key, unsigned char *llabel, unsig
        
 }
 
        
 }
 
-int adsi_connect_session(unsigned char *buf, unsigned char *fdn, int ver)
+int ast_adsi_connect_session(unsigned char *buf, unsigned char *fdn, int ver)
 {
        int bytes=0;
        int x;
 {
        int bytes=0;
        int x;
@@ -485,7 +525,7 @@ int adsi_connect_session(unsigned char *buf, unsigned char *fdn, int ver)
 
 }
 
 
 }
 
-int adsi_download_connect(unsigned char *buf, unsigned char *service,  unsigned char *fdn, unsigned char *sec, int ver)
+int ast_adsi_download_connect(unsigned char *buf, char *service,  unsigned char *fdn, unsigned char *sec, int ver)
 {
        int bytes=0;
        int x;
 {
        int bytes=0;
        int x;
@@ -497,24 +537,25 @@ int adsi_download_connect(unsigned char *buf, unsigned char *service,  unsigned
        bytes++;
 
        /* Primary column */
        bytes++;
 
        /* Primary column */
-       bytes+= ccopy(buf + bytes, service, 18);
+       bytes+= ccopy(buf + bytes, (unsigned char *)service, 18);
 
        /* Delimiter */
        buf[bytes++] = 0xff;
        
 
        /* Delimiter */
        buf[bytes++] = 0xff;
        
-       for (x=0;x<4;x++)
+       for (x=0;x<4;x++) {
                buf[bytes++] = fdn[x];
                buf[bytes++] = fdn[x];
+       }
        for (x=0;x<4;x++)
                buf[bytes++] = sec[x];
        for (x=0;x<4;x++)
                buf[bytes++] = sec[x];
-       if (ver > -1)
-               buf[bytes++] = ver & 0xff;
+       buf[bytes++] = ver & 0xff;
 
        buf[1] = bytes - 2;
 
        buf[1] = bytes - 2;
+
        return bytes;
 
 }
 
        return bytes;
 
 }
 
-int adsi_disconnect_session(unsigned char *buf)
+int ast_adsi_disconnect_session(unsigned char *buf)
 {
        int bytes=0;
 
 {
        int bytes=0;
 
@@ -529,7 +570,159 @@ int adsi_disconnect_session(unsigned char *buf)
 
 }
 
 
 }
 
-int adsi_data_mode(unsigned char *buf)
+int ast_adsi_query_cpeid(unsigned char *buf)
+{
+       int bytes = 0;
+       buf[bytes++] = ADSI_QUERY_CPEID;
+       /* Reserve space for length */
+       bytes++;
+       buf[1] = bytes - 2;
+       return bytes;
+}
+
+int ast_adsi_query_cpeinfo(unsigned char *buf)
+{
+       int bytes = 0;
+       buf[bytes++] = ADSI_QUERY_CONFIG;
+       /* Reserve space for length */
+       bytes++;
+       buf[1] = bytes - 2;
+       return bytes;
+}
+
+int ast_adsi_read_encoded_dtmf(struct ast_channel *chan, unsigned char *buf, int maxlen)
+{
+       int bytes = 0;
+       int res;
+       unsigned char current = 0;
+       int gotstar = 0;
+       int pos = 0;
+       memset(buf, 0, sizeof(buf));
+       while(bytes <= maxlen) {
+               /* Wait up to a second for a digit */
+               res = ast_waitfordigit(chan, 1000);
+               if (!res)
+                       break;
+               if (res == '*') {
+                       gotstar = 1;    
+                       continue;
+               }
+               /* Ignore anything other than a digit */
+               if ((res < '0') || (res > '9'))
+                       continue;
+               res -= '0';
+               if (gotstar)
+                       res += 9;
+               if (pos)  {
+                       pos = 0;
+                       buf[bytes++] = (res << 4) | current;
+               } else {
+                       pos = 1;
+                       current = res;
+               }
+               gotstar = 0;
+       }
+       return bytes;
+}
+
+int ast_adsi_get_cpeid(struct ast_channel *chan, unsigned char *cpeid, int voice)
+{
+       unsigned char buf[256];
+       int bytes = 0;
+       int res;
+       bytes += ast_adsi_data_mode(buf);
+       ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0);
+
+       bytes = 0;
+       bytes += ast_adsi_query_cpeid(buf);
+       ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0);
+
+       /* Get response */
+       memset(buf, 0, sizeof(buf));
+       res = ast_adsi_read_encoded_dtmf(chan, cpeid, 4);
+       if (res != 4) {
+               ast_log(LOG_WARNING, "Got %d bytes back of encoded DTMF, expecting 4\n", res);
+               res = 0;
+       } else {
+               res = 1;
+       }
+
+       if (voice) {
+               bytes = 0;
+               bytes += ast_adsi_voice_mode(buf, 0);
+               ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0);
+               /* Ignore the resulting DTMF B announcing it's in voice mode */
+               ast_waitfordigit(chan, 1000);
+       }
+       return res;
+}
+
+int ast_adsi_get_cpeinfo(struct ast_channel *chan, int *width, int *height, int *buttons, int voice)
+{
+       unsigned char buf[256];
+       int bytes = 0;
+       int res;
+       bytes += ast_adsi_data_mode(buf);
+       ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0);
+
+       bytes = 0;
+       bytes += ast_adsi_query_cpeinfo(buf);
+       ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0);
+
+       /* Get width */
+       memset(buf, 0, sizeof(buf));
+       res = ast_readstring(chan, (char *)buf, 2, 1000, 500, "");
+       if (res < 0)
+               return res;
+       if (strlen((char *)buf) != 2) {
+               ast_log(LOG_WARNING, "Got %d bytes of width, expecting 2\n", res);
+               res = 0;
+       } else {
+               res = 1;
+       }
+       if (width)
+               *width = atoi((char *)buf);
+       /* Get height */
+       memset(buf, 0, sizeof(buf));
+       if (res) {
+               res = ast_readstring(chan, (char *)buf, 2, 1000, 500, "");
+               if (res < 0)
+                       return res;
+               if (strlen((char *)buf) != 2) {
+                       ast_log(LOG_WARNING, "Got %d bytes of height, expecting 2\n", res);
+                       res = 0;
+               } else {
+                       res = 1;
+               }       
+               if (height)
+                       *height= atoi((char *)buf);
+       }
+       /* Get buttons */
+       memset(buf, 0, sizeof(buf));
+       if (res) {
+               res = ast_readstring(chan, (char *)buf, 1, 1000, 500, "");
+               if (res < 0)
+                       return res;
+               if (strlen((char *)buf) != 1) {
+                       ast_log(LOG_WARNING, "Got %d bytes of buttons, expecting 1\n", res);
+                       res = 0;
+               } else {
+                       res = 1;
+               }       
+               if (buttons)
+                       *buttons = atoi((char *)buf);
+       }
+       if (voice) {
+               bytes = 0;
+               bytes += ast_adsi_voice_mode(buf, 0);
+               ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0);
+               /* Ignore the resulting DTMF B announcing it's in voice mode */
+               ast_waitfordigit(chan, 1000);
+       }
+       return res;
+}
+
+int ast_adsi_data_mode(unsigned char *buf)
 {
        int bytes=0;
 
 {
        int bytes=0;
 
@@ -544,7 +737,37 @@ int adsi_data_mode(unsigned char *buf)
 
 }
 
 
 }
 
-int adsi_voice_mode(unsigned char *buf, int when)
+int ast_adsi_clear_soft_keys(unsigned char *buf)
+{
+       int bytes=0;
+
+       /* Message type */
+       buf[bytes++] = ADSI_CLEAR_SOFTKEY;
+
+       /* Reserve space for length */
+       bytes++;
+
+       buf[1] = bytes - 2;
+       return bytes;
+
+}
+
+int ast_adsi_clear_screen(unsigned char *buf)
+{
+       int bytes=0;
+
+       /* Message type */
+       buf[bytes++] = ADSI_CLEAR_SCREEN;
+
+       /* Reserve space for length */
+       bytes++;
+
+       buf[1] = bytes - 2;
+       return bytes;
+
+}
+
+int ast_adsi_voice_mode(unsigned char *buf, int when)
 {
        int bytes=0;
 
 {
        int bytes=0;
 
@@ -561,7 +784,7 @@ int adsi_voice_mode(unsigned char *buf, int when)
 
 }
 
 
 }
 
-int adsi_available(struct ast_channel *chan)
+int ast_adsi_available(struct ast_channel *chan)
 {
        int cpe = chan->adsicpe & 0xff;
        if ((cpe == AST_ADSI_AVAILABLE) ||
 {
        int cpe = chan->adsicpe & 0xff;
        if ((cpe == AST_ADSI_AVAILABLE) ||
@@ -570,7 +793,7 @@ int adsi_available(struct ast_channel *chan)
        return 0;
 }
 
        return 0;
 }
 
-int adsi_download_disconnect(unsigned char *buf)
+int ast_adsi_download_disconnect(unsigned char *buf)
 {
        int bytes=0;
 
 {
        int bytes=0;
 
@@ -585,8 +808,8 @@ int adsi_download_disconnect(unsigned char *buf)
 
 }
 
 
 }
 
-int adsi_display(unsigned char *buf, int page, int line, int just, int wrap, 
-                unsigned char *col1, unsigned char *col2)
+int ast_adsi_display(unsigned char *buf, int page, int line, int just, int wrap, 
+                    char *col1, char *col2)
 {
        int bytes=0;
 
 {
        int bytes=0;
 
@@ -616,13 +839,13 @@ int adsi_display(unsigned char *buf, int page, int line, int just, int wrap,
        buf[bytes++] = 0xff;
 
        /* Primary column */
        buf[bytes++] = 0xff;
 
        /* Primary column */
-       bytes+= ccopy(buf + bytes, col1, 20);
+       bytes+= ccopy(buf + bytes, (unsigned char *)col1, 20);
 
        /* Delimiter */
        buf[bytes++] = 0xff;
        
        /* Secondary column */
 
        /* Delimiter */
        buf[bytes++] = 0xff;
        
        /* Secondary column */
-       bytes += ccopy(buf + bytes, col2, 20);
+       bytes += ccopy(buf + bytes, (unsigned char *)col2, 20);
 
        /* Update length */
        buf[1] = bytes - 2;
 
        /* Update length */
        buf[1] = bytes - 2;
@@ -631,11 +854,11 @@ int adsi_display(unsigned char *buf, int page, int line, int just, int wrap,
 
 }
 
 
 }
 
-int adsi_input_control(unsigned char *buf, int page, int line, int display, int format, int just)
+int ast_adsi_input_control(unsigned char *buf, int page, int line, int display, int format, int just)
 {
        int bytes=0;
 
 {
        int bytes=0;
 
-       if (page) {
+       if (page) {
                if (line > 4) return -1;
        } else {
                if (line > 33) return -1;
                if (line > 4) return -1;
        } else {
                if (line > 33) return -1;
@@ -654,26 +877,26 @@ int adsi_input_control(unsigned char *buf, int page, int line, int display, int
 
 }
 
 
 }
 
-int adsi_input_format(unsigned char *buf, int num, int dir, int wrap, unsigned char *format1, unsigned char *format2)
+int ast_adsi_input_format(unsigned char *buf, int num, int dir, int wrap, char *format1, char *format2)
 {
        int bytes = 0;
 
 {
        int bytes = 0;
 
-       if (!strlen(format1))
+       if (!strlen((char *)format1))
                return -1;
 
        buf[bytes++] = ADSI_INPUT_FORMAT;
        bytes++;
        buf[bytes++] = ((dir & 1) << 7) | ((wrap & 1) << 6) | (num & 0x7);
                return -1;
 
        buf[bytes++] = ADSI_INPUT_FORMAT;
        bytes++;
        buf[bytes++] = ((dir & 1) << 7) | ((wrap & 1) << 6) | (num & 0x7);
-       bytes += ccopy(buf + bytes, format1, 20);
+       bytes += ccopy(buf + bytes, (unsigned char *)format1, 20);
        buf[bytes++] = 0xff;
        buf[bytes++] = 0xff;
-       if (format2 && strlen(format2)) {
-               bytes += ccopy(buf + bytes, format2, 20);
+       if (format2 && strlen((char *)format2)) {
+               bytes += ccopy(buf + bytes, (unsigned char *)format2, 20);
        }
        buf[1] = bytes - 2;
        return bytes;
 }
 
        }
        buf[1] = bytes - 2;
        return bytes;
 }
 
-int adsi_set_keys(unsigned char *buf, unsigned char *keys)
+int ast_adsi_set_keys(unsigned char *buf, unsigned char *keys)
 {
        int bytes=0;
        int x;
 {
        int bytes=0;
        int x;
@@ -688,13 +911,13 @@ int adsi_set_keys(unsigned char *buf, unsigned char *keys)
        return bytes;
 }
 
        return bytes;
 }
 
-int adsi_set_line(unsigned char *buf, int page, int line)
+int ast_adsi_set_line(unsigned char *buf, int page, int line)
 {
        int bytes=0;
 
        /* Sanity check line number */
 
 {
        int bytes=0;
 
        /* Sanity check line number */
 
-       if (page) {
+       if (page) {
                if (line > 4) return -1;
        } else {
                if (line > 33) return -1;
                if (line > 4) return -1;
        } else {
                if (line > 33) return -1;
@@ -719,55 +942,9 @@ int adsi_set_line(unsigned char *buf, int page, int line)
 static int total = 0;
 static int speeds = 0;
 
 static int total = 0;
 static int speeds = 0;
 
-#if 0
-int adsi_channel_init(struct ast_channel *chan)
-{
-       char dsp[256];
-       char keys[256];
-       int bytes;
-       int x;
-       unsigned char *msgs[3];
-       unsigned char keyd[6];
-       int lens[3];
-       int types[3];
-       memset(dsp, 0, sizeof(dsp));
-       memset(keys, 0, sizeof(keys));
-       memset(msgs, 0, sizeof(msgs));
-
-       /* Start with initial display setup */
-       bytes = 0;
-       bytes += adsi_connect_session(dsp, NULL, -1);
-       for (x=0;x<total;x++) {
-               bytes += adsi_display(dsp + bytes, ADSI_INFO_PAGE, x + 1, aligns[x], 0,
-                       strlen(intro[x]) ? intro[x] : " ", "");
-       }
-       bytes += adsi_set_line(dsp + bytes, ADSI_INFO_PAGE, 1);
-       msgs[0] = dsp;
-       lens[0] = bytes;
-       types[0] = ADSI_MSG_DISPLAY;
-
-       /* Prepare key setup messages */
-
-       if (speeds) {
-               bytes = 0;
-               memset(keyd, 0, sizeof(keyd));
-               for (x=0;x<speeds;x++) {
-                       bytes += adsi_load_soft_key(keys + bytes, ADSI_SPEED_DIAL + x,
-                                       speeddial[x][1], speeddial[x][2], speeddial[x][0]);
-                       keyd[x] = ADSI_SPEED_DIAL + x;
-               }
-               bytes += adsi_set_keys(keys + bytes, keyd);
-               msgs[1] = keys;
-               lens[1] = bytes;
-               types[1] = ADSI_MSG_DISPLAY;
-       }
-       adsi_transmit_messages(chan, msgs, lens, types);
-       return 0;
-}
-#else
-int adsi_channel_init(struct ast_channel *chan)
+int ast_adsi_channel_restore(struct ast_channel *chan)
 {
 {
-       char dsp[256];
+       unsigned char dsp[256];
        int bytes;
        int x;
        unsigned char keyd[6];
        int bytes;
        int x;
        unsigned char keyd[6];
@@ -776,59 +953,45 @@ int adsi_channel_init(struct ast_channel *chan)
 
        /* Start with initial display setup */
        bytes = 0;
 
        /* Start with initial display setup */
        bytes = 0;
-       bytes += adsi_connect_session(dsp, NULL, -1);
-       for (x=0;x<total;x++) {
-               bytes += adsi_display(dsp + bytes, ADSI_INFO_PAGE, x + 1, aligns[x], 0,
-                       strlen(intro[x]) ? intro[x] : " ", "");
-       }
-       bytes += adsi_set_line(dsp + bytes, ADSI_INFO_PAGE, 1);
+       bytes += ast_adsi_set_line(dsp + bytes, ADSI_INFO_PAGE, 1);
 
        /* Prepare key setup messages */
 
        if (speeds) {
                memset(keyd, 0, sizeof(keyd));
                for (x=0;x<speeds;x++) {
 
        /* Prepare key setup messages */
 
        if (speeds) {
                memset(keyd, 0, sizeof(keyd));
                for (x=0;x<speeds;x++) {
-                       bytes += adsi_load_soft_key(dsp + bytes, ADSI_SPEED_DIAL + x,
-                                       speeddial[x][1], speeddial[x][2], speeddial[x][0], 0);
                        keyd[x] = ADSI_SPEED_DIAL + x;
                }
                        keyd[x] = ADSI_SPEED_DIAL + x;
                }
-               bytes += adsi_set_keys(dsp + bytes, keyd);
+               bytes += ast_adsi_set_keys(dsp + bytes, keyd);
        }
        }
-       adsi_transmit_message(chan, dsp, bytes, ADSI_MSG_DISPLAY);
+       ast_adsi_transmit_message_full(chan, dsp, bytes, ADSI_MSG_DISPLAY, 0);
        return 0;
        return 0;
+
 }
 }
-#endif
 
 
-int adsi_channel_restore(struct ast_channel *chan)
+int ast_adsi_print(struct ast_channel *chan, char **lines, int *aligns, int voice)
 {
 {
-       char dsp[256];
-       int bytes;
+       unsigned char buf[4096];
+       int bytes=0;
+       int res;
        int x;
        int x;
-       unsigned char keyd[6];
-
-       memset(dsp, 0, sizeof(dsp));
-
-       /* Start with initial display setup */
-       bytes = 0;
-       bytes += adsi_set_line(dsp + bytes, ADSI_INFO_PAGE, 1);
-
-       /* Prepare key setup messages */
-
-       if (speeds) {
-               memset(keyd, 0, sizeof(keyd));
-               for (x=0;x<speeds;x++) {
-                       keyd[x] = ADSI_SPEED_DIAL + x;
-               }
-               bytes += adsi_set_keys(dsp + bytes, keyd);
+       for(x=0;lines[x];x++) 
+               bytes += ast_adsi_display(buf + bytes, ADSI_INFO_PAGE, x+1, aligns[x], 0, lines[x], "");
+       bytes += ast_adsi_set_line(buf + bytes, ADSI_INFO_PAGE, 1);
+       if (voice) {
+               bytes += ast_adsi_voice_mode(buf + bytes, 0);
        }
        }
-       adsi_transmit_message(chan, dsp, bytes, ADSI_MSG_DISPLAY);
-       return 0;
-
+       res = ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0);
+       if (voice) {
+               /* Ignore the resulting DTMF B announcing it's in voice mode */
+               ast_waitfordigit(chan, 1000);
+       }
+       return res;
 }
 
 }
 
-int adsi_load_session(struct ast_channel *chan, unsigned char *app, int ver, int data)
+int ast_adsi_load_session(struct ast_channel *chan, unsigned char *app, int ver, int data)
 {
 {
-       char dsp[256];
+       unsigned char dsp[256];
        int bytes;
        int res;
        char resp[2];
        int bytes;
        int res;
        char resp[2];
@@ -837,47 +1000,53 @@ int adsi_load_session(struct ast_channel *chan, unsigned char *app, int ver, int
 
        /* Connect to session */
        bytes = 0;
 
        /* Connect to session */
        bytes = 0;
-       bytes += adsi_connect_session(dsp + bytes, app,ver);
+       bytes += ast_adsi_connect_session(dsp + bytes, app, ver);
 
        if (data)
 
        if (data)
-               bytes += adsi_data_mode(dsp + bytes);
+               bytes += ast_adsi_data_mode(dsp + bytes);
 
        /* Prepare key setup messages */
 
        /* Prepare key setup messages */
-       if (adsi_transmit_message(chan, dsp, bytes, ADSI_MSG_DISPLAY))
-               return -1;
-       res = ast_readstring(chan, resp, 1, 1200, 1200, "");
-       if (res < 0)
+       if (ast_adsi_transmit_message_full(chan, dsp, bytes, ADSI_MSG_DISPLAY, 0))
                return -1;
                return -1;
-       if (res) {
-               ast_log(LOG_DEBUG, "No response from CPE about version.  Assuming not there.\n");
-               return 0;
-       }
-       if (!strcmp(resp, "B")) {
-               ast_log(LOG_DEBUG, "CPE has script '%s' version %d already loaded\n", app, ver);
+       if (app) {
+               res = ast_readstring(chan, resp, 1, 1200, 1200, "");
+               if (res < 0)
+                       return -1;
+               if (res) {
+                       if (option_debug)
+                               ast_log(LOG_DEBUG, "No response from CPE about version.  Assuming not there.\n");
+                       return 0;
+               }
+               if (!strcmp(resp, "B")) {
+                       if (option_debug)
+                               ast_log(LOG_DEBUG, "CPE has script '%s' version %d already loaded\n", app, ver);
+                       return 1;
+               } else if (!strcmp(resp, "A")) {
+                       if (option_debug)
+                               ast_log(LOG_DEBUG, "CPE hasn't script '%s' version %d already loaded\n", app, ver);
+               } else {
+                       ast_log(LOG_WARNING, "Unexpected CPE response to script query: %s\n", resp);
+               }
+       } else
                return 1;
                return 1;
-       } else if (!strcmp(resp, "A")) {
-               ast_log(LOG_DEBUG, "CPE hasn't script '%s' version %d already loaded\n", app, ver);
-       } else {
-               ast_log(LOG_WARNING, "Unexpected CPE response to script query: %s\n", resp);
-       }
        return 0;
 
 }
 
        return 0;
 
 }
 
-int adsi_unload_session(struct ast_channel *chan)
+int ast_adsi_unload_session(struct ast_channel *chan)
 {
 {
-       char dsp[256];
+       unsigned char dsp[256];
        int bytes;
 
        memset(dsp, 0, sizeof(dsp));
 
        /* Connect to session */
        bytes = 0;
        int bytes;
 
        memset(dsp, 0, sizeof(dsp));
 
        /* Connect to session */
        bytes = 0;
-       bytes += adsi_disconnect_session(dsp + bytes);
-       bytes += adsi_voice_mode(dsp + bytes, 0);
+       bytes += ast_adsi_disconnect_session(dsp + bytes);
+       bytes += ast_adsi_voice_mode(dsp + bytes, 0);
 
        /* Prepare key setup messages */
 
        /* Prepare key setup messages */
-       if (adsi_transmit_message(chan, dsp, bytes, ADSI_MSG_DISPLAY))
+       if (ast_adsi_transmit_message_full(chan, dsp, bytes, ADSI_MSG_DISPLAY, 0))
                return -1;
        return 0;
 }
                return -1;
        return 0;
 }
@@ -900,13 +1069,13 @@ static void init_state(void)
 
        for (x=0;x<ADSI_MAX_INTRO;x++)
                aligns[x] = ADSI_JUST_CENT;
 
        for (x=0;x<ADSI_MAX_INTRO;x++)
                aligns[x] = ADSI_JUST_CENT;
-       strcpy(intro[0], "Welcome to the");
-       strcpy(intro[1], "Asterisk");
-       strcpy(intro[2], "Open Source PBX");
+       ast_copy_string(intro[0], "Welcome to the", sizeof(intro[0]));
+       ast_copy_string(intro[1], "Asterisk", sizeof(intro[1]));
+       ast_copy_string(intro[2], "Open Source PBX", sizeof(intro[2]));
        total = 3;
        speeds = 0;
        for (x=3;x<ADSI_MAX_INTRO;x++)
        total = 3;
        speeds = 0;
        for (x=3;x<ADSI_MAX_INTRO;x++)
-               strcpy(intro[x], "");
+               intro[x][0] = '\0';
        memset(speeddial, 0, sizeof(speeddial));
        alignment = ADSI_JUST_CENT;
 }
        memset(speeddial, 0, sizeof(speeddial));
        alignment = ADSI_JUST_CENT;
 }
@@ -918,80 +1087,65 @@ static void adsi_load(void)
        struct ast_variable *v;
        char *name, *sname;
        init_state();
        struct ast_variable *v;
        char *name, *sname;
        init_state();
-       conf = ast_load("adsi.conf");
+       conf = ast_config_load("adsi.conf");
        if (conf) {
                x=0;
        if (conf) {
                x=0;
-               v = ast_variable_browse(conf, "intro");
-               while(v) {
+               for (v = ast_variable_browse(conf, "intro"); v; v = v->next) {
                        if (!strcasecmp(v->name, "alignment"))
                                alignment = str2align(v->value);
                        else if (!strcasecmp(v->name, "greeting")) {
                                if (x < ADSI_MAX_INTRO) {
                                        aligns[x] = alignment;
                        if (!strcasecmp(v->name, "alignment"))
                                alignment = str2align(v->value);
                        else if (!strcasecmp(v->name, "greeting")) {
                                if (x < ADSI_MAX_INTRO) {
                                        aligns[x] = alignment;
-                                       strncpy(intro[x], v->value, 20);
+                                       ast_copy_string(intro[x], v->value, sizeof(intro[x]));
                                        x++;
                                }
                        } else if (!strcasecmp(v->name, "maxretries")) {
                                if (atoi(v->value) > 0)
                                        maxretries = atoi(v->value);
                        }
                                        x++;
                                }
                        } else if (!strcasecmp(v->name, "maxretries")) {
                                if (atoi(v->value) > 0)
                                        maxretries = atoi(v->value);
                        }
-                       v = v->next;
                }
                }
-               v = ast_variable_browse(conf, "speeddial");
                if (x)
                        total = x;
                x = 0;
                if (x)
                        total = x;
                x = 0;
-               while(v) {
-                       name = strtok(v->value, ",");
-                       sname = strtok(NULL, ",");
+               for (v = ast_variable_browse(conf, "speeddial"); v; v = v->next) {
+                       char *stringp = v->value;
+                       name = strsep(&stringp, ",");
+                       sname = strsep(&stringp, ",");
                        if (!sname) 
                                sname = name;
                        if (x < ADSI_MAX_SPEED_DIAL) {
                        if (!sname) 
                                sname = name;
                        if (x < ADSI_MAX_SPEED_DIAL) {
-                               /* Up to 20 digits */
-                               strncpy(speeddial[x][0], v->name, 20);
-                               strncpy(speeddial[x][1], name, 18);
-                               strncpy(speeddial[x][2], sname, 7);
+                               ast_copy_string(speeddial[x][0], v->name, sizeof(speeddial[x][0]));
+                               ast_copy_string(speeddial[x][1], name, 18);
+                               ast_copy_string(speeddial[x][2], sname, 7);
                                x++;
                        }
                                x++;
                        }
-                       v = v->next;
-                               
                }
                if (x)
                        speeds = x;
                }
                if (x)
                        speeds = x;
-               ast_destroy(conf);
+               ast_config_destroy(conf);
        }
 }
 
        }
 }
 
-int reload(void)
+static int reload(void)
 {
        adsi_load();
        return 0;
 }
 
 {
        adsi_load();
        return 0;
 }
 
-int load_module(void)
+static int load_module(void)
 {
        adsi_load();
        return 0;
 }
 
 {
        adsi_load();
        return 0;
 }
 
-int unload_module(void)
+static int unload_module(void)
 {
        /* Can't unload this once we're loaded */
        return -1;
 }
 
 {
        /* Can't unload this once we're loaded */
        return -1;
 }
 
-char *description(void)
-{
-       return "Call Parking Resource";
-}
-
-int usecount(void)
-{
-       /* We should never be unloaded */
-       return 1;
-}
-
-char *key()
-{
-       return ASTERISK_GPL_KEY;
-}
+AST_MODULE_INFO(ASTERISK_GPL_KEY, AST_MODFLAG_GLOBAL_SYMBOLS, "ADSI Resource",
+               .load = load_module,
+               .unload = unload_module,
+               .reload = reload,
+              );