aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorPablo Neira Ayuso <pablo@gnumonks.org>2011-06-21 19:50:04 +0200
committerPablo Neira Ayuso <pablo@gnumonks.org>2011-06-21 19:50:04 +0200
commitc07a8e7cf73e6218f12a0612fd05e529e6a4f9b4 (patch)
treebb63f2d73893609b05dff3e86679bd0cb64b4fdf
parent591ddadbe8bc056dd0f619f10fd23306cecad4a8 (diff)
ipa: rename `struct ipa_link' by `struct ipa_client_link'
And IPA_LINK_STATE_* by IPA_CLIENT_LINK_STATE_* to prepare the addition of the ipa_server_link abstraction.
-rw-r--r--include/osmocom/abis/ipa.h36
-rw-r--r--src/input/hsl.c4
-rw-r--r--src/input/ipa.c38
-rw-r--r--src/input/ipaccess.c4
4 files changed, 41 insertions, 41 deletions
diff --git a/include/osmocom/abis/ipa.h b/include/osmocom/abis/ipa.h
index 69888f5..bba7e8f 100644
--- a/include/osmocom/abis/ipa.h
+++ b/include/osmocom/abis/ipa.h
@@ -5,29 +5,29 @@
#include <osmocom/core/linuxlist.h>
#include <osmocom/core/timer.h>
-enum ipa_link_state {
- IPA_LINK_STATE_NONE = 0,
- IPA_LINK_STATE_CONNECTING = 1,
- IPA_LINK_STATE_CONNECTED = 2,
- IPA_LINK_STATE_MAX
+enum ipa_client_link_state {
+ IPA_CLIENT_LINK_STATE_NONE = 0,
+ IPA_CLIENT_LINK_STATE_CONNECTING = 1,
+ IPA_CLIENT_LINK_STATE_CONNECTED = 2,
+ IPA_CLIENT_LINK_STATE_MAX
};
-struct ipa_link {
- struct e1inp_line *line;
- struct osmo_fd ofd;
- struct llist_head tx_queue;
- struct osmo_timer_list timer;
- enum ipa_link_state state;
- const char *addr;
- uint16_t port;
- int (*cb)(struct ipa_link *link, struct msgb *msg);
+struct ipa_client_link {
+ struct e1inp_line *line;
+ struct osmo_fd ofd;
+ struct llist_head tx_queue;
+ struct osmo_timer_list timer;
+ enum ipa_client_link_state state;
+ const char *addr;
+ uint16_t port;
+ int (*cb)(struct ipa_client_link *link, struct msgb *msg);
};
-struct ipa_link *ipa_client_link_create(void *ctx, struct e1inp_line *line, const char *addr, uint16_t port, int (*cb)(struct ipa_link *link, struct msgb *msgb));
-void ipa_client_link_destroy(struct ipa_link *link);
+struct ipa_client_link *ipa_client_link_create(void *ctx, struct e1inp_line *line, const char *addr, uint16_t port, int (*cb)(struct ipa_client_link *link, struct msgb *msgb));
+void ipa_client_link_destroy(struct ipa_client_link *link);
-int ipa_client_link_open(struct ipa_link *link);
-void ipa_client_link_close(struct ipa_link *link);
+int ipa_client_link_open(struct ipa_client_link *link);
+void ipa_client_link_close(struct ipa_client_link *link);
int ipa_msg_recv(int fd, struct msgb **rmsg);
diff --git a/src/input/hsl.c b/src/input/hsl.c
index f8c009e..bc8fdb0 100644
--- a/src/input/hsl.c
+++ b/src/input/hsl.c
@@ -302,7 +302,7 @@ static int listen_fd_cb(struct osmo_fd *listen_bfd, unsigned int what)
return ret;
}
-static int hsl_bts_process(struct ipa_link *link, struct msgb *msg)
+static int hsl_bts_process(struct ipa_client_link *link, struct msgb *msg)
{
/* XXX: not implemented yet. */
return 0;
@@ -333,7 +333,7 @@ static int hsl_line_update(struct e1inp_line *line,
}
break;
case E1INP_LINE_R_BTS: {
- struct ipa_link *link;
+ struct ipa_client_link *link;
LOGP(DINP, LOGL_NOTICE, "enabling hsl BTS mode\n");
diff --git a/src/input/ipa.c b/src/input/ipa.c
index 536490e..7c84559 100644
--- a/src/input/ipa.c
+++ b/src/input/ipa.c
@@ -74,24 +74,24 @@ int ipa_msg_recv(int fd, struct msgb **rmsg)
return ret;
}
-void ipa_client_link_close(struct ipa_link *link);
+void ipa_client_link_close(struct ipa_client_link *link);
-static void ipa_client_retry(struct ipa_link *link)
+static void ipa_client_retry(struct ipa_client_link *link)
{
LOGP(DINP, LOGL_NOTICE, "connection closed\n");
ipa_client_link_close(link);
LOGP(DINP, LOGL_NOTICE, "retrying in 5 seconds...\n");
osmo_timer_schedule(&link->timer, 5, 0);
- link->state = IPA_LINK_STATE_CONNECTING;
+ link->state = IPA_CLIENT_LINK_STATE_CONNECTING;
}
-void ipa_client_link_close(struct ipa_link *link)
+void ipa_client_link_close(struct ipa_client_link *link)
{
osmo_fd_unregister(&link->ofd);
close(link->ofd.fd);
}
-static void ipa_client_read(struct ipa_link *link)
+static void ipa_client_read(struct ipa_client_link *link)
{
struct osmo_fd *ofd = &link->ofd;
struct msgb *msg;
@@ -117,7 +117,7 @@ static void ipa_client_read(struct ipa_link *link)
link->cb(link, msg);
}
-static void ipa_client_write(struct ipa_link *link)
+static void ipa_client_write(struct ipa_client_link *link)
{
struct osmo_fd *ofd = &link->ofd;
struct msgb *msg;
@@ -146,12 +146,12 @@ static void ipa_client_write(struct ipa_link *link)
int ipa_client_fd_cb(struct osmo_fd *ofd, unsigned int what)
{
- struct ipa_link *link = ofd->data;
+ struct ipa_client_link *link = ofd->data;
int error, ret;
size_t len = sizeof(error);
switch(link->state) {
- case IPA_LINK_STATE_CONNECTING:
+ case IPA_CLIENT_LINK_STATE_CONNECTING:
ret = getsockopt(ofd->fd, SOL_SOCKET, SO_ERROR, &error, &len);
if (ret >= 0 && error > 0) {
ipa_client_retry(link);
@@ -159,9 +159,9 @@ int ipa_client_fd_cb(struct osmo_fd *ofd, unsigned int what)
}
ofd->when &= ~BSC_FD_WRITE;
LOGP(DINP, LOGL_NOTICE, "connection done.\n");
- link->state = IPA_LINK_STATE_CONNECTED;
+ link->state = IPA_CLIENT_LINK_STATE_CONNECTED;
break;
- case IPA_LINK_STATE_CONNECTED:
+ case IPA_CLIENT_LINK_STATE_CONNECTED:
LOGP(DINP, LOGL_NOTICE, "connected read/write\n");
if (what & BSC_FD_READ)
ipa_client_read(link);
@@ -176,21 +176,21 @@ int ipa_client_fd_cb(struct osmo_fd *ofd, unsigned int what)
static void ipa_link_timer_cb(void *data);
-struct ipa_link *
+struct ipa_client_link *
ipa_client_link_create(void *ctx, struct e1inp_line *line,
const char *addr, uint16_t port,
- int (*cb)(struct ipa_link *link, struct msgb *msgb))
+ int (*cb)(struct ipa_client_link *link, struct msgb *msgb))
{
- struct ipa_link *ipa_link;
+ struct ipa_client_link *ipa_link;
- ipa_link = talloc_zero(ctx, struct ipa_link);
+ ipa_link = talloc_zero(ctx, struct ipa_client_link);
if (!ipa_link)
return NULL;
ipa_link->ofd.when |= BSC_FD_READ | BSC_FD_WRITE;
ipa_link->ofd.cb = ipa_client_fd_cb;
ipa_link->ofd.data = ipa_link;
- ipa_link->state = IPA_LINK_STATE_CONNECTING;
+ ipa_link->state = IPA_CLIENT_LINK_STATE_CONNECTING;
ipa_link->timer.cb = ipa_link_timer_cb;
ipa_link->timer.data = ipa_link;
ipa_link->addr = talloc_strdup(ipa_link, addr);
@@ -201,12 +201,12 @@ ipa_client_link_create(void *ctx, struct e1inp_line *line,
return ipa_link;
}
-void ipa_client_link_destroy(struct ipa_link *link)
+void ipa_client_link_destroy(struct ipa_client_link *link)
{
talloc_free(link);
}
-int ipa_client_link_open(struct ipa_link *link)
+int ipa_client_link_open(struct ipa_client_link *link)
{
int ret;
@@ -227,12 +227,12 @@ int ipa_client_link_open(struct ipa_link *link)
static void ipa_link_timer_cb(void *data)
{
- struct ipa_link *link = data;
+ struct ipa_client_link *link = data;
LOGP(DINP, LOGL_NOTICE, "reconnecting.\n");
switch(link->state) {
- case IPA_LINK_STATE_CONNECTING:
+ case IPA_CLIENT_LINK_STATE_CONNECTING:
ipa_client_link_open(link);
break;
default:
diff --git a/src/input/ipaccess.c b/src/input/ipaccess.c
index 19e5a53..60e7109 100644
--- a/src/input/ipaccess.c
+++ b/src/input/ipaccess.c
@@ -428,7 +428,7 @@ static int rsl_listen_fd_cb(struct osmo_fd *listen_bfd, unsigned int what)
return 0;
}
-static int ipaccess_bts_cb(struct ipa_link *link, struct msgb *msg)
+static int ipaccess_bts_cb(struct ipa_client_link *link, struct msgb *msg)
{
struct ipaccess_head *hh = (struct ipaccess_head *) msg->data;
struct e1inp_ts *e1i_ts = NULL;
@@ -519,7 +519,7 @@ static int ipaccess_line_update(struct e1inp_line *line,
}
break;
case E1INP_LINE_R_BTS: {
- struct ipa_link *link, *rsl_link;
+ struct ipa_client_link *link, *rsl_link;
LOGP(DINP, LOGL_NOTICE, "enabling ipaccess BTS mode\n");