external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-02-13 03:41:55 +00:00
Code Issues Releases Wiki Activity

research st: refine public

Browse source
This commit is contained in:
winlin 2014-11-05 17:16:15 +08:00
parent bba2d3dd98
commit 315707d726
1 changed files with 165 additions and 182 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

347
trunk/research/st/public.h Executable file → Normal file
View file

@ -1,182 +1,165 @@
/* /*
* The contents of this file are subject to the Mozilla Public * The contents of this file are subject to the Mozilla Public
* License Version 1.1 (the "License"); you may not use this file * License Version 1.1 (the "License"); you may not use this file
* except in compliance with the License. You may obtain a copy of * except in compliance with the License. You may obtain a copy of
* the License at http://www.mozilla.org/MPL/ * the License at http://www.mozilla.org/MPL/
* *
* Software distributed under the License is distributed on an "AS * Software distributed under the License is distributed on an "AS
* IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or * IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
* implied. See the License for the specific language governing * implied. See the License for the specific language governing
* rights and limitations under the License. * rights and limitations under the License.
* *
* The Original Code is the Netscape Portable Runtime library. * The Original Code is the Netscape Portable Runtime library.
* *
* The Initial Developer of the Original Code is Netscape * The Initial Developer of the Original Code is Netscape
* Communications Corporation. Portions created by Netscape are * Communications Corporation. Portions created by Netscape are
* Copyright (C) 1994-2000 Netscape Communications Corporation. All * Copyright (C) 1994-2000 Netscape Communications Corporation. All
* Rights Reserved. * Rights Reserved.
* *
* Contributor(s): Silicon Graphics, Inc. * Contributor(s): Silicon Graphics, Inc.
* *
* Portions created by SGI are Copyright (C) 2000-2001 Silicon * Portions created by SGI are Copyright (C) 2000-2001 Silicon
* Graphics, Inc. All Rights Reserved. * Graphics, Inc. All Rights Reserved.
* *
* Alternatively, the contents of this file may be used under the * Alternatively, the contents of this file may be used under the
* terms of the GNU General Public License Version 2 or later (the * terms of the GNU General Public License Version 2 or later (the
* "GPL"), in which case the provisions of the GPL are applicable * "GPL"), in which case the provisions of the GPL are applicable
* instead of those above. If you wish to allow use of your * instead of those above. If you wish to allow use of your
* version of this file only under the terms of the GPL and not to * version of this file only under the terms of the GPL and not to
* allow others to use your version of this file under the MPL, * allow others to use your version of this file under the MPL,
* indicate your decision by deleting the provisions above and * indicate your decision by deleting the provisions above and
* replace them with the notice and other provisions required by * replace them with the notice and other provisions required by
* the GPL. If you do not delete the provisions above, a recipient * the GPL. If you do not delete the provisions above, a recipient
* may use your version of this file under either the MPL or the * may use your version of this file under either the MPL or the
* GPL. * GPL.
*/ */
#ifndef __ST_THREAD_H__ #ifndef __ST_THREAD_H__
#define __ST_THREAD_H__ #define __ST_THREAD_H__
#include <unistd.h> #include <unistd.h>
#include <sys/types.h> #include <sys/types.h>
#include <sys/socket.h> #include <sys/socket.h>
#include <sys/uio.h> #include <sys/uio.h>
#include <time.h> #include <time.h>
#include <errno.h> #include <errno.h>
#include <poll.h> #include <poll.h>
#define ST_VERSION "1.9" #define ST_VERSION "1.9"
#define ST_VERSION_MAJOR 1 #define ST_VERSION_MAJOR 1
#define ST_VERSION_MINOR 9 #define ST_VERSION_MINOR 9
/* Undefine this to remove the context switch callback feature. */ /* Undefine this to remove the context switch callback feature. */
#define ST_SWITCH_CB #define ST_SWITCH_CB
#ifndef ETIME #ifndef ETIME
#define ETIME ETIMEDOUT #define ETIME ETIMEDOUT
#endif #endif
#ifndef ST_UTIME_NO_TIMEOUT #ifndef ST_UTIME_NO_TIMEOUT
#define ST_UTIME_NO_TIMEOUT ((st_utime_t) -1LL) #define ST_UTIME_NO_TIMEOUT ((st_utime_t) -1LL)
#endif #endif
#ifndef ST_UTIME_NO_WAIT #ifndef ST_UTIME_NO_WAIT
#define ST_UTIME_NO_WAIT 0 #define ST_UTIME_NO_WAIT 0
#endif #endif
#define ST_EVENTSYS_DEFAULT 0 #define ST_EVENTSYS_DEFAULT 0
#define ST_EVENTSYS_SELECT 1 #define ST_EVENTSYS_SELECT 1
#define ST_EVENTSYS_POLL 2 #define ST_EVENTSYS_POLL 2
#define ST_EVENTSYS_ALT 3 #define ST_EVENTSYS_ALT 3
#ifdef __cplusplus #ifdef __cplusplus
extern "C" { extern "C" {
#endif #endif
typedef unsigned long long st_utime_t; typedef unsigned long long st_utime_t;
typedef struct _st_thread * st_thread_t; typedef struct _st_thread * st_thread_t;
typedef struct _st_cond * st_cond_t; typedef struct _st_cond * st_cond_t;
typedef struct _st_mutex * st_mutex_t; typedef struct _st_mutex * st_mutex_t;
typedef struct _st_netfd * st_netfd_t; typedef struct _st_netfd * st_netfd_t;
#ifdef ST_SWITCH_CB #ifdef ST_SWITCH_CB
typedef void (*st_switch_cb_t)(void); typedef void (*st_switch_cb_t)(void);
#endif #endif
extern int st_init(void); extern int st_init(void);
extern int st_getfdlimit(void); extern int st_getfdlimit(void);
extern int st_set_eventsys(int eventsys); extern int st_set_eventsys(int eventsys);
extern int st_get_eventsys(void); extern int st_get_eventsys(void);
extern const char *st_get_eventsys_name(void); extern const char *st_get_eventsys_name(void);
#ifdef ST_SWITCH_CB #ifdef ST_SWITCH_CB
extern st_switch_cb_t st_set_switch_in_cb(st_switch_cb_t cb); extern st_switch_cb_t st_set_switch_in_cb(st_switch_cb_t cb);
extern st_switch_cb_t st_set_switch_out_cb(st_switch_cb_t cb); extern st_switch_cb_t st_set_switch_out_cb(st_switch_cb_t cb);
#endif #endif
extern st_thread_t st_thread_self(void); extern st_thread_t st_thread_self(void);
extern void st_thread_exit(void *retval); extern void st_thread_exit(void *retval);
extern int st_thread_join(st_thread_t thread, void **retvalp); extern int st_thread_join(st_thread_t thread, void **retvalp);
extern void st_thread_interrupt(st_thread_t thread); extern void st_thread_interrupt(st_thread_t thread);
extern st_thread_t st_thread_create(void *(*start)(void *arg), void *arg, extern st_thread_t st_thread_create(void *(*start)(void *arg), void *arg, int joinable, int stack_size);
int joinable, int stack_size); extern int st_randomize_stacks(int on);
extern int st_randomize_stacks(int on); extern int st_set_utime_function(st_utime_t (*func)(void));
extern int st_set_utime_function(st_utime_t (*func)(void));
extern st_utime_t st_utime(void);
extern st_utime_t st_utime(void); extern st_utime_t st_utime_last_clock(void);
extern st_utime_t st_utime_last_clock(void); extern int st_timecache_set(int on);
extern int st_timecache_set(int on); extern time_t st_time(void);
extern time_t st_time(void); extern int st_usleep(st_utime_t usecs);
extern int st_usleep(st_utime_t usecs); extern int st_sleep(int secs);
extern int st_sleep(int secs); extern st_cond_t st_cond_new(void);
extern st_cond_t st_cond_new(void); extern int st_cond_destroy(st_cond_t cvar);
extern int st_cond_destroy(st_cond_t cvar); extern int st_cond_timedwait(st_cond_t cvar, st_utime_t timeout);
extern int st_cond_timedwait(st_cond_t cvar, st_utime_t timeout); extern int st_cond_wait(st_cond_t cvar);
extern int st_cond_wait(st_cond_t cvar); extern int st_cond_signal(st_cond_t cvar);
extern int st_cond_signal(st_cond_t cvar); extern int st_cond_broadcast(st_cond_t cvar);
extern int st_cond_broadcast(st_cond_t cvar); extern st_mutex_t st_mutex_new(void);
extern st_mutex_t st_mutex_new(void); extern int st_mutex_destroy(st_mutex_t lock);
extern int st_mutex_destroy(st_mutex_t lock); extern int st_mutex_lock(st_mutex_t lock);
extern int st_mutex_lock(st_mutex_t lock); extern int st_mutex_unlock(st_mutex_t lock);
extern int st_mutex_unlock(st_mutex_t lock); extern int st_mutex_trylock(st_mutex_t lock);
extern int st_mutex_trylock(st_mutex_t lock);
extern int st_key_create(int *keyp, void (*destructor)(void *));
extern int st_key_create(int *keyp, void (*destructor)(void *)); extern int st_key_getlimit(void);
extern int st_key_getlimit(void); extern int st_thread_setspecific(int key, void *value);
extern int st_thread_setspecific(int key, void *value); extern void *st_thread_getspecific(int key);
extern void *st_thread_getspecific(int key);
extern st_netfd_t st_netfd_open(int osfd);
extern st_netfd_t st_netfd_open(int osfd); extern st_netfd_t st_netfd_open_socket(int osfd);
extern st_netfd_t st_netfd_open_socket(int osfd); extern void st_netfd_free(st_netfd_t fd);
extern void st_netfd_free(st_netfd_t fd); extern int st_netfd_close(st_netfd_t fd);
extern int st_netfd_close(st_netfd_t fd); extern int st_netfd_fileno(st_netfd_t fd);
extern int st_netfd_fileno(st_netfd_t fd); extern void st_netfd_setspecific(st_netfd_t fd, void *value,
extern void st_netfd_setspecific(st_netfd_t fd, void *value, void (*destructor)(void *));
void (*destructor)(void *)); extern void *st_netfd_getspecific(st_netfd_t fd);
extern void *st_netfd_getspecific(st_netfd_t fd); extern int st_netfd_serialize_accept(st_netfd_t fd);
extern int st_netfd_serialize_accept(st_netfd_t fd); extern int st_netfd_poll(st_netfd_t fd, int how, st_utime_t timeout);
extern int st_netfd_poll(st_netfd_t fd, int how, st_utime_t timeout);
extern int st_poll(struct pollfd *pds, int npds, st_utime_t timeout);
extern int st_poll(struct pollfd *pds, int npds, st_utime_t timeout); extern st_netfd_t st_accept(st_netfd_t fd, struct sockaddr *addr, int *addrlen, st_utime_t timeout);
extern st_netfd_t st_accept(st_netfd_t fd, struct sockaddr *addr, int *addrlen, extern int st_connect(st_netfd_t fd, const struct sockaddr *addr, int addrlen, st_utime_t timeout);
st_utime_t timeout); extern ssize_t st_read(st_netfd_t fd, void *buf, size_t nbyte, st_utime_t timeout);
extern int st_connect(st_netfd_t fd, const struct sockaddr *addr, int addrlen, extern ssize_t st_read_fully(st_netfd_t fd, void *buf, size_t nbyte, st_utime_t timeout);
st_utime_t timeout); extern int st_read_resid(st_netfd_t fd, void *buf, size_t *resid, st_utime_t timeout);
extern ssize_t st_read(st_netfd_t fd, void *buf, size_t nbyte, extern ssize_t st_readv(st_netfd_t fd, const struct iovec *iov, int iov_size, st_utime_t timeout);
st_utime_t timeout); extern int st_readv_resid(st_netfd_t fd, struct iovec **iov, int *iov_size, st_utime_t timeout);
extern ssize_t st_read_fully(st_netfd_t fd, void *buf, size_t nbyte, extern ssize_t st_write(st_netfd_t fd, const void *buf, size_t nbyte, st_utime_t timeout);
st_utime_t timeout); extern int st_write_resid(st_netfd_t fd, const void *buf, size_t *resid, st_utime_t timeout);
extern int st_read_resid(st_netfd_t fd, void *buf, size_t *resid, extern ssize_t st_writev(st_netfd_t fd, const struct iovec *iov, int iov_size, st_utime_t timeout);
st_utime_t timeout); extern int st_writev_resid(st_netfd_t fd, struct iovec **iov, int *iov_size, st_utime_t timeout);
extern ssize_t st_readv(st_netfd_t fd, const struct iovec *iov, int iov_size, extern int st_recvfrom(st_netfd_t fd, void *buf, int len, struct sockaddr *from, int *fromlen, st_utime_t timeout);
st_utime_t timeout); extern int st_sendto(st_netfd_t fd, const void *msg, int len, const struct sockaddr *to, int tolen, st_utime_t timeout);
extern int st_readv_resid(st_netfd_t fd, struct iovec **iov, int *iov_size, extern int st_recvmsg(st_netfd_t fd, struct msghdr *msg, int flags, st_utime_t timeout);
st_utime_t timeout); extern int st_sendmsg(st_netfd_t fd, const struct msghdr *msg, int flags, st_utime_t timeout);
extern ssize_t st_write(st_netfd_t fd, const void *buf, size_t nbyte, extern st_netfd_t st_open(const char *path, int oflags, mode_t mode);
st_utime_t timeout);
extern int st_write_resid(st_netfd_t fd, const void *buf, size_t *resid, #ifdef DEBUG
st_utime_t timeout); extern void _st_show_thread_stack(st_thread_t thread, const char *messg);
extern ssize_t st_writev(st_netfd_t fd, const struct iovec *iov, int iov_size, extern void _st_iterate_threads(void);
st_utime_t timeout); #endif
extern int st_writev_resid(st_netfd_t fd, struct iovec **iov, int *iov_size, #ifdef __cplusplus
st_utime_t timeout); }
extern int st_recvfrom(st_netfd_t fd, void *buf, int len, #endif
struct sockaddr *from, int *fromlen,
st_utime_t timeout); #endif /* !__ST_THREAD_H__ */
extern int st_sendto(st_netfd_t fd, const void *msg, int len,
const struct sockaddr *to, int tolen, st_utime_t timeout);
extern int st_recvmsg(st_netfd_t fd, struct msghdr *msg, int flags,
st_utime_t timeout);
extern int st_sendmsg(st_netfd_t fd, const struct msghdr *msg, int flags,
st_utime_t timeout);
extern st_netfd_t st_open(const char *path, int oflags, mode_t mode);
#ifdef DEBUG
extern void _st_show_thread_stack(st_thread_t thread, const char *messg);
extern void _st_iterate_threads(void);
#endif
#ifdef __cplusplus
}
#endif
#endif /* !__ST_THREAD_H__ */