0,0
};
-static struct bsc_fd gps_bfd;
+static struct osmo_fd gps_bfd;
#ifdef _HAVE_GPSD
static struct gps_data_t* gdata;
-int osmo_gpsd_cb(struct bsc_fd *bfd, unsigned int what)
+int osmo_gpsd_cb(struct osmo_fd *bfd, unsigned int what)
{
struct tm *tm;
unsigned diff = 0;
return -1;
}
- bsc_register_fd(&gps_bfd);
+ osmo_fd_register(&gps_bfd);
return 0;
}
LOGP(DGPS, LOGL_INFO, "Disconnecting from gpsd\n");
- bsc_unregister_fd(&gps_bfd);
+ osmo_fd_unregister(&gps_bfd);
gps_close(gdata);
gps_bfd.fd = -1; /* -1 or 0 indicates: 'close' */
return (strtoul(line+1, NULL, 16) == checksum);
}
-int osmo_serialgps_cb(struct bsc_fd *bfd, unsigned int what)
+int osmo_serialgps_cb(struct osmo_fd *bfd, unsigned int what)
{
char buff[128];
static char line[128];
printf("Failed to set termios for GPS\n");
}
- bsc_register_fd(&gps_bfd);
+ osmo_fd_register(&gps_bfd);
return 0;
}
LOGP(DGPS, LOGL_INFO, "Close GPS device\n");
- bsc_unregister_fd(&gps_bfd);
+ osmo_fd_unregister(&gps_bfd);
if (isatty(gps_bfd.fd))
tcsetattr(gps_bfd.fd, TCSANOW, &gps_old_termios);
#define GSM_L2_LENGTH 256
#define GSM_L2_HEADROOM 32
-static int layer2_read(struct bsc_fd *fd)
+static int layer2_read(struct osmo_fd *fd)
{
struct msgb *msg;
u_int16_t len;
return 0;
}
-static int layer2_write(struct bsc_fd *fd, struct msgb *msg)
+static int layer2_write(struct osmo_fd *fd, struct msgb *msg)
{
int rc;
ms->l2_wq.read_cb = layer2_read;
ms->l2_wq.write_cb = layer2_write;
- rc = bsc_register_fd(&ms->l2_wq.bfd);
+ rc = osmo_fd_register(&ms->l2_wq.bfd);
if (rc != 0) {
fprintf(stderr, "Failed to register fd.\n");
close(ms->l2_wq.bfd.fd);
close(ms->l2_wq.bfd.fd);
ms->l2_wq.bfd.fd = -1;
- bsc_unregister_fd(&ms->l2_wq.bfd);
+ osmo_fd_unregister(&ms->l2_wq.bfd);
return 0;
}
while (!quit) {
if (l23_app_work)
l23_app_work(ms);
- bsc_select_main(0);
+ osmo_select_main(0);
}
return 0;
#define GSM_SAP_LENGTH 300
#define GSM_SAP_HEADROOM 32
-static int sap_read(struct bsc_fd *fd)
+static int sap_read(struct osmo_fd *fd)
{
struct msgb *msg;
u_int16_t len;
return 0;
}
-static int sap_write(struct bsc_fd *fd, struct msgb *msg)
+static int sap_write(struct osmo_fd *fd, struct msgb *msg)
{
int rc;
ms->sap_wq.read_cb = sap_read;
ms->sap_wq.write_cb = sap_write;
- rc = bsc_register_fd(&ms->sap_wq.bfd);
+ rc = osmo_fd_register(&ms->sap_wq.bfd);
if (rc != 0) {
fprintf(stderr, "Failed to register fd.\n");
return rc;
close(ms->sap_wq.bfd.fd);
ms->sap_wq.bfd.fd = -1;
- bsc_unregister_fd(&ms->sap_wq.bfd);
+ osmo_fd_unregister(&ms->sap_wq.bfd);
return 0;
}
l23_app_work(&quit);
if (quit && llist_empty(&ms_list))
break;
- bsc_select_main(0);
+ osmo_select_main(0);
}
l23_app_exit();
struct tool_connection {
struct tool_server *server;
struct llist_head entry;
- struct bsc_fd fd;
+ struct osmo_fd fd;
};
/**
* server for a tool
*/
struct tool_server {
- struct bsc_fd bfd;
+ struct osmo_fd bfd;
uint8_t dlci;
struct llist_head connections;
};
enum romload_state romload_state;
enum mtk_state mtk_state;
enum dnload_mode mode;
- struct bsc_fd serial_fd;
+ struct osmo_fd serial_fd;
char *filename;
char *chainload_filename;
return nbytes;
}
-static int serial_read(struct bsc_fd *fd, unsigned int flags)
+static int serial_read(struct osmo_fd *fd, unsigned int flags)
{
int rc;
if (flags & BSC_FD_READ) {
exit(2);
}
-static int un_tool_read(struct bsc_fd *fd, unsigned int flags)
+static int un_tool_read(struct osmo_fd *fd, unsigned int flags)
{
int rc, c;
uint16_t length = 0xffff;
close:
close(fd->fd);
- bsc_unregister_fd(fd);
+ osmo_fd_unregister(fd);
llist_del(&con->entry);
talloc_free(con);
return -1;
}
/* accept a new connection */
-static int tool_accept(struct bsc_fd *fd, unsigned int flags)
+static int tool_accept(struct osmo_fd *fd, unsigned int flags)
{
struct tool_server *srv = (struct tool_server *)fd->data;
struct tool_connection *con;
con->fd.when = BSC_FD_READ;
con->fd.cb = un_tool_read;
con->fd.data = con;
- if (bsc_register_fd(&con->fd) != 0) {
+ if (osmo_fd_register(&con->fd) != 0) {
fprintf(stderr, "Failed to register the fd.\n");
return -1;
}
const char *path,
uint8_t dlci)
{
- struct bsc_fd *bfd = &ts->bfd;
+ struct osmo_fd *bfd = &ts->bfd;
struct sockaddr_un local;
unsigned int namelen;
int rc;
sercomm_register_rx_cb(dlci, hdlc_tool_cb);
- if (bsc_register_fd(bfd) != 0) {
+ if (osmo_fd_register(bfd) != 0) {
fprintf(stderr, "Failed to register the bfd.\n");
return -1;
}
exit(1);
}
- if (bsc_register_fd(&dnload.serial_fd) != 0) {
+ if (osmo_fd_register(&dnload.serial_fd) != 0) {
fprintf(stderr, "Failed to register the serial.\n");
exit(1);
}
dnload.load_address[3] = tmp_load_address & 0xff;
while (1)
- bsc_select_main(0);
+ osmo_select_main(0);
close(dnload.serial_fd.fd);
#define DEFAULT_SOCKET "/tmp/osmocom_loader"
-static struct bsc_fd connection;
+static struct osmo_fd connection;
enum {
STATE_INIT,
}
static int
-loader_read_cb(struct bsc_fd *fd, unsigned int flags) {
+loader_read_cb(struct osmo_fd *fd, unsigned int flags) {
struct msgb *msg;
u_int16_t len;
int rc;
loader_connect(const char *socket_path) {
int rc;
struct sockaddr_un local;
- struct bsc_fd *conn = &connection;
+ struct osmo_fd *conn = &connection;
local.sun_family = AF_UNIX;
strncpy(local.sun_path, socket_path, sizeof(local.sun_path));
conn->cb = loader_read_cb;
conn->data = NULL;
- if (bsc_register_fd(conn) != 0) {
+ if (osmo_fd_register(conn) != 0) {
fprintf(stderr, "Failed to register fd.\n");
exit(1);
}
loader_command(argv[0], argc - optind, argv + optind);
while(!osmoload.quit) {
- bsc_select_main(0);
+ osmo_select_main(0);
}
if(osmoload.binfile) {