forked from aniani/vim
updated for version 7.0001
This commit is contained in:
Bram Moolenaar
206
src/os_beos.c
Normal file
206
src/os_beos.c
Normal file
@@ -0,0 +1,206 @@
|
||||
/* vi:set ts=8 sts=4 sw=4:
|
||||
*
|
||||
* VIM - Vi IMproved by Bram Moolenaar
|
||||
* BeBox port Copyright 1997 by Olaf Seibert.
|
||||
*
|
||||
* Do ":help uganda" in Vim to read copying and usage conditions.
|
||||
* Do ":help credits" in Vim to see a list of people who contributed.
|
||||
* See README.txt for an overview of the Vim source code.
|
||||
*/
|
||||
/*
|
||||
* os_beos.c Additional stuff for BeOS (rest is in os_unix.c)
|
||||
*/
|
||||
|
||||
#include <float.h>
|
||||
#include <termios.h>
|
||||
#include <kernel/OS.h>
|
||||
#include "vim.h"
|
||||
|
||||
#if USE_THREAD_FOR_INPUT_WITH_TIMEOUT
|
||||
|
||||
#ifdef PROTO /* making prototypes on Unix */
|
||||
#define sem_id int
|
||||
#define thread_id int
|
||||
#endif
|
||||
|
||||
char_u charbuf;
|
||||
signed char charcount;
|
||||
sem_id character_present;
|
||||
sem_id character_wanted;
|
||||
thread_id read_thread_id;
|
||||
|
||||
#define TRY_ABORT 0 /* This code does not work so turn it off. */
|
||||
|
||||
#if TRY_ABORT
|
||||
static void
|
||||
mostly_ignore(int sig)
|
||||
{
|
||||
}
|
||||
#endif
|
||||
|
||||
static long
|
||||
read_thread(void *dummy)
|
||||
{
|
||||
signal(SIGINT, SIG_IGN);
|
||||
signal(SIGQUIT, SIG_IGN);
|
||||
#if TRY_ABORT
|
||||
signal(SIGUSR1, mostly_ignore);
|
||||
#endif
|
||||
|
||||
for (;;) {
|
||||
if (acquire_sem(character_wanted) != B_NO_ERROR)
|
||||
break;
|
||||
charcount = read(read_cmd_fd, &charbuf, 1);
|
||||
release_sem(character_present);
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
void
|
||||
beos_cleanup_read_thread(void)
|
||||
{
|
||||
if (character_present > 0)
|
||||
delete_sem(character_present);
|
||||
character_present = 0;
|
||||
if (read_thread_id > 0)
|
||||
kill_thread(read_thread_id);
|
||||
read_thread_id = 0;
|
||||
}
|
||||
|
||||
#endif
|
||||
|
||||
/*
|
||||
* select() emulation. Hopefully, in DR9 there will be something
|
||||
* useful supplied by the system. ... Alas, not. Not in AAPR, nor
|
||||
* in PR or even PR2... R3 then maybe? I don't think so!
|
||||
*/
|
||||
|
||||
int
|
||||
beos_select(int nbits,
|
||||
struct fd_set *rbits,
|
||||
struct fd_set *wbits,
|
||||
struct fd_set *ebits,
|
||||
struct timeval *timeout)
|
||||
{
|
||||
bigtime_t tmo;
|
||||
|
||||
if (nbits == 0) {
|
||||
/* select is purely being used for delay */
|
||||
snooze(timeout->tv_sec * 1e6 + timeout->tv_usec);
|
||||
return 0;
|
||||
}
|
||||
#if 0
|
||||
/*
|
||||
* This does not seem to work either. Reads here are not supposed to
|
||||
* block indefinitely, yet they do. This is most annoying.
|
||||
*/
|
||||
if (FD_ISSET(0, rbits)) {
|
||||
char cbuf[1];
|
||||
int count;
|
||||
struct termios told;
|
||||
struct termios tnew;
|
||||
tcgetattr(0, &told);
|
||||
tnew = told;
|
||||
tnew.c_lflag &= ~ICANON;
|
||||
tnew.c_cc[VMIN] = 0;
|
||||
tnew.c_cc[VTIME] = timeout->tv_sec * 10 + timeout->tv_usec / 100000;
|
||||
tcsetattr(0, TCSANOW, &tnew);
|
||||
|
||||
count = read(0, &cbuf, sizeof(cbuf));
|
||||
tcsetattr(0, TCSANOW, &told);
|
||||
if (count > 0) {
|
||||
add_to_input_buf(&cbuf[0], count);
|
||||
return 1;
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
#endif
|
||||
#if USE_THREAD_FOR_INPUT_WITH_TIMEOUT
|
||||
/*
|
||||
* Check if the operation is really on stdin...
|
||||
*/
|
||||
if (FD_ISSET(read_cmd_fd, rbits))
|
||||
{
|
||||
int acquired;
|
||||
|
||||
/*
|
||||
* Is this the first time through?
|
||||
* Then start up the thread and initialise the semaphores.
|
||||
*/
|
||||
if (character_present == 0) {
|
||||
character_present = create_sem(0, "vim character_present");
|
||||
character_wanted = create_sem(1, "vim character_wanted");
|
||||
read_thread_id = spawn_thread(read_thread, "vim async read",
|
||||
B_NORMAL_PRIORITY, NULL);
|
||||
atexit(beos_cleanup_read_thread);
|
||||
resume_thread(read_thread_id);
|
||||
}
|
||||
|
||||
/* timeout == NULL means "indefinitely" */
|
||||
if (timeout) {
|
||||
tmo = timeout->tv_sec * 1e6 + timeout->tv_usec;
|
||||
/* 0 means "don't wait, which is impossible to do exactly. */
|
||||
if (tmo == 0)
|
||||
tmo = 1.0;
|
||||
}
|
||||
#if TRY_ABORT
|
||||
release_sem(character_wanted);
|
||||
#endif
|
||||
if (timeout)
|
||||
acquired = acquire_sem_etc(character_present, 1, B_TIMEOUT, tmo);
|
||||
else
|
||||
acquired = acquire_sem(character_present);
|
||||
if (acquired == B_NO_ERROR) {
|
||||
if (charcount > 0) {
|
||||
add_to_input_buf(&charbuf, 1);
|
||||
#if !TRY_ABORT
|
||||
release_sem(character_wanted);
|
||||
#endif
|
||||
|
||||
return 1;
|
||||
} else {
|
||||
#if !TRY_ABORT
|
||||
release_sem(character_wanted);
|
||||
#endif
|
||||
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
#if TRY_ABORT
|
||||
else {
|
||||
/*
|
||||
* Timeout occurred. Break the read() call by sending
|
||||
* a signal. Problem: it may be just read()ing it now.
|
||||
* Therefore we still have to finish the handshake with
|
||||
* the thread and maybe remember the character.
|
||||
*/
|
||||
kill(read_thread_id, SIGUSR1);
|
||||
/*
|
||||
* If some other error occurred, don't hang now.
|
||||
* (We will most likely hang later anyway...)
|
||||
*/
|
||||
if (acquired == B_TIMED_OUT)
|
||||
acquire_sem(character_present);
|
||||
if (charcount > 0) {
|
||||
add_to_input_buf(&charbuf, 1);
|
||||
return 1;
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
#endif
|
||||
}
|
||||
#endif
|
||||
|
||||
#if FEAT_GUI_BEOS
|
||||
/*
|
||||
* If not reading from terminal, pretend there is input.
|
||||
* This makes the pty reading (for the GUI) "work" for
|
||||
* :!ls but not for :r !ls ... weird.
|
||||
*/
|
||||
if (gui.in_use && State == EXTERNCMD)
|
||||
return 1;
|
||||
#endif
|
||||
return 0;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user