本文整理汇总了C++中rt_sem_init函数的典型用法代码示例。如果您正苦于以下问题：C++ rt_sem_init函数的具体用法？C++ rt_sem_init怎么用？C++ rt_sem_init使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了rt_sem_init函数的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的C++代码示例。
示例1: init_module
int init_module(void)
{
rt_sem_init(¬Empty, 0);
rt_sem_init(¬Full, 1);
Clockstatus = stopped;
return 0;
}
开发者ID:ArcEye，项目名称:RTAI，代码行数:7，代码来源:cmdclk.c
示例2: init_cmdclk
int init_cmdclk(void)
{
notEmpty = rt_sem_init(nam2num("NOTECL"), 0);
notFull = rt_sem_init(nam2num("NOTFCL"), 1);
Clockstatus = stopped;
return 0;
}
开发者ID:ArcEye，项目名称:RTAI，代码行数:7，代码来源:cmdclk.c
示例3: demo_init
int demo_init(void)
{
int i;
rt_thread_t tid;
rt_err_t result;
/* 初始化信号量 */
result = rt_sem_init(&sem_lock , "lock", 1, RT_IPC_FLAG_FIFO);
if (result != RT_EOK)
goto _error;
for (i=0; i<5; i++)
{
result = rt_sem_init(&sem[i] , "sem", 0, RT_IPC_FLAG_FIFO);
if (result != RT_EOK)
goto _error;
}
for (i=0; i<5; i++)
{
tid = rt_thread_create(
"phd",
phd_thread_entry,
(void *)i,
THREAD_STACK_SIZE, 10, RT_TICK_PER_SECOND*3);
if(tid != RT_NULL)
rt_thread_startup(tid);
}
return 0;
_error:
rt_kprintf("init semaphore failed.\n");
return -1;
}
开发者ID:003900107，项目名称:realboard-lpc4088，代码行数:34，代码来源:demo.c
示例4: init_cmdcrn
int init_cmdcrn(void)
{
notEmpty = rt_sem_init(nam2num("NOTECR"), 0);
notFull = rt_sem_init(nam2num("NOTFCR"), 1);
Chronostatus = stoppedInitial;
buffered = FALSE;
fiveSeconds = nano2count(FIVE_SECONDS);
return 0;
}
开发者ID:sensysnetworks，项目名称:stromboli-24.1，代码行数:9，代码来源:cmdcrn.c
示例5: init_module
int init_module(void)
{
rt_sem_init(¬Empty, 0);
rt_sem_init(¬Full, 1);
Chronostatus = stoppedInitial;
buffered = FALSE;
fiveSeconds = nano2count(FIVE_SECONDS);
return 0;
}
开发者ID:sensysnetworks，项目名称:stromboli-24.1，代码行数:9，代码来源:cmdcrn.c
示例6: ipcs_init
////////////////////////////////////////////////////////////////////////
// Init all ipc objects.
static void ipcs_init(void)
{
unsigned short dummy,max_interval;
getFrameSplit(&max_interval,&dummy);
rt_mutex_init(&setup_data_buf_mutex,"musb",RT_IPC_FLAG_FIFO);
rt_sem_init(&rx_sem,"semrx",0,RT_IPC_FLAG_FIFO);
rt_sem_init(&tx1_sem,"semtx0",1,RT_IPC_FLAG_FIFO);
rt_sem_init(&tx2_sem,"semtx1",1,RT_IPC_FLAG_FIFO);
rt_timer_init(&max_interval_timer,"rx_tmr",rx_interval_timeout,
RT_NULL,max_interval/1000*RT_TICK_PER_SECOND,RT_TIMER_FLAG_ONE_SHOT);
}
开发者ID:visitor83，项目名称:fighting_stm32，代码行数:13，代码来源:apptasks.c
示例7: start_task_code
/*
* initialization task
*/
static void start_task_code(int notused)
{
int i;
char buf[9];
buf[8] = 0;
/* create the sync semaphore */
rt_sem_init(&sync_sem, 0);
/* create the priority-test semaphore */
rt_sem_init(&prio_sem, 0);
/* pass the semaphore to the first task */
rt_sem_signal(&sems[0]);
/* wait for each task to send the sync semaphore */
for (i = 0; i < NUM_TASKS; ++i) {
rt_sem_wait(&sync_sem);
}
rt_printk(sync_str);
/* post the priority-test semaphore -- the tasks should then run */
/* in priority order */
for (i = 0; i < NUM_TASKS; ++i) {
rt_sem_signal(&prio_sem);
}
rt_printk("\n");
for (i = 0; i < NUM_TASKS; ++i) {
rt_sem_wait(&sync_sem);
}
rt_printk(sync_str);
/* now, test message queues */
TAKE_PRINT;
rt_printk("testing message queues\n");
GIVE_PRINT;
for (i = 0; i < NUM_TASKS; ++i) {
if (rt_mbx_send(&mbx_in, strs[i], 8)) {
rt_printk("rt_mbx_send() failed\n");
}
}
for (i = 0; i < NUM_TASKS; ++i) {
rt_mbx_receive(&mbx_out, buf, 8);
TAKE_PRINT;
rt_printk("\nreceived from mbx_out: %s", buf);
GIVE_PRINT;
}
rt_printk("\n");
for (i = 0; i < NUM_TASKS; ++i) {
rt_sem_signal(&sync_sem);
}
TAKE_PRINT;
rt_printk("\ninit task complete\n");
GIVE_PRINT;
/* nothing more for this task to do */
}
开发者ID:sensysnetworks，项目名称:stromboli-24.1，代码行数:55，代码来源:rt_process.c
示例8: rt_application_init
int rt_application_init()
{
rt_thread_t thread_h;
rt_err_t result;
/* init system data cfg table */
init_syscfgdata_tbl();
rt_sem_init(&print_sem, "prtsem", 1, RT_IPC_FLAG_PRIO);
#if RT_USING_FILESYSTEM
rt_sem_init(&spiflash_sem, "sfsem", 1, RT_IPC_FLAG_PRIO);
#endif
#if (ADE7880_SPIFLASH_SHARE_SPI || ADE7880_SI4432_SHARE_SPI)
rt_sem_init(&spi_sem_share_by_ade7880, "spi3sem", 1, RT_IPC_FLAG_PRIO);
#endif
#if RT_USING_ADE7880 || RT_USING_SI4432_MAC
rt_event_init(& isr_event_set, "isr_eve", RT_IPC_FLAG_PRIO);
#endif
#if (RT_USING_RS485_BUS && !TEST_485)
init_sys_485();
#endif
RT_APPS_INIT_DEBUG(("func:%s(), will init rt_sys_misc_entry\n", __FUNCTION__));
/* init led thread */
result = rt_thread_init(&misc_thread, "misc", rt_sys_misc_entry,
RT_NULL, (rt_uint8_t*)&misc_stack[0], sizeof(misc_stack), 0x19, 5);
if (result == RT_EOK)
rt_thread_startup(&misc_thread);
#if RT_USING_ADE7880 || RT_USING_SI4432_MAC
thread_h = rt_thread_create("isr_e", rt_isr_event_entry, RT_NULL, 512, ISR_EVENT_THREAD_PRIORITY, 10);
if (thread_h != RT_NULL)
rt_thread_startup(thread_h);
#endif
#if (RT_THREAD_PRIORITY_MAX == 32)
thread_h = rt_thread_create("init", rt_init_thread_entry, RT_NULL, 2048, 8, 20);
#else
thread_h = rt_thread_create("init", rt_init_thread_entry, RT_NULL, 2048, 80, 20);
#endif
if (thread_h != RT_NULL)
rt_thread_startup(thread_h);
RT_APPS_INIT_DEBUG(("func:%s(), base thread initial over\n", __FUNCTION__));
return 0;
}
开发者ID:malooei，项目名称:yeejoin-workspace，代码行数:49，代码来源:application.c
示例9: rt_application_init
int rt_application_init()
{
int i;
rt_thread_t tid;
rt_thread_t init_thread;
rt_err_t result;
/* 初始化信号量 */
result = rt_sem_init(&sem_lock , "lock", 1, RT_IPC_FLAG_FIFO);
if (result != RT_EOK)
goto _error;
for (i=0; i<5; i++)
{
result = rt_sem_init(&sem[i] , "sem", 0, RT_IPC_FLAG_FIFO);
if (result != RT_EOK)
goto _error;
}
#if (RT_THREAD_PRIORITY_MAX == 32)
init_thread = rt_thread_create("init",
rt_init_thread_entry, RT_NULL,
2048, 8, 20);
#else
init_thread = rt_thread_create("init",
rt_init_thread_entry, RT_NULL,
2048, 80, 20);
#endif
if (init_thread != RT_NULL)
rt_thread_startup(init_thread);
for (i=0; i<5; i++)
{
tid = rt_thread_create(
"phd",
phd_thread_entry,
(void *)i,
THREAD_STACK_SIZE, 10, RT_TICK_PER_SECOND*3);
if(tid != RT_NULL)
rt_thread_startup(tid);
}
return 0;
_error:
rt_kprintf("init semaphore failed.\n");
return -1;
}
开发者ID:15863118785，项目名称:realtouch-stm32f4，代码行数:48，代码来源:application.c
示例10: lpc_emac_hw_init
int lpc_emac_hw_init(void)
{
rt_event_init(&tx_event, "tx_event", RT_IPC_FLAG_FIFO);
rt_sem_init(&sem_lock, "eth_lock", 1, RT_IPC_FLAG_FIFO);
/* set autonegotiation mode */
lpc_emac_device.phy_mode = EMAC_PHY_AUTO;
// OUI 00-60-37 NXP Semiconductors
lpc_emac_device.dev_addr[0] = 0x00;
lpc_emac_device.dev_addr[1] = 0x60;
lpc_emac_device.dev_addr[2] = 0x37;
/* set mac address: (only for test) */
lpc_emac_device.dev_addr[3] = 0x12;
lpc_emac_device.dev_addr[4] = 0x34;
lpc_emac_device.dev_addr[5] = 0x56;
lpc_emac_device.parent.parent.init = lpc_emac_init;
lpc_emac_device.parent.parent.open = lpc_emac_open;
lpc_emac_device.parent.parent.close = lpc_emac_close;
lpc_emac_device.parent.parent.read = lpc_emac_read;
lpc_emac_device.parent.parent.write = lpc_emac_write;
lpc_emac_device.parent.parent.control = lpc_emac_control;
lpc_emac_device.parent.parent.user_data = RT_NULL;
lpc_emac_device.parent.eth_rx = lpc_emac_rx;
lpc_emac_device.parent.eth_tx = lpc_emac_tx;
eth_device_init(&(lpc_emac_device.parent), "e0");
return 0;
}
开发者ID:firetechmlf，项目名称:RealBoard4088，代码行数:31，代码来源:drv_emac.c
示例11: pthread_cond_init
int pthread_cond_init(pthread_cond_t *cond, const pthread_condattr_t *attr)
{
rt_err_t result;
char cond_name[RT_NAME_MAX];
static rt_uint16_t cond_num = 0;
/* parameter check */
if (cond == RT_NULL)
return EINVAL;
if ((attr != RT_NULL) && (*attr != PTHREAD_PROCESS_PRIVATE))
return EINVAL;
rt_snprintf(cond_name, sizeof(cond_name), "cond%02d", cond_num++);
if (attr == RT_NULL) /* use default value */
cond->attr = PTHREAD_PROCESS_PRIVATE;
else
cond->attr = *attr;
result = rt_sem_init(&cond->sem, cond_name, 0, RT_IPC_FLAG_FIFO);
if (result != RT_EOK)
return EINVAL;
/* detach the object from system object container */
rt_object_detach(&(cond->sem.parent.parent));
return 0;
}
开发者ID:cedar-renjun，项目名称:air-conditioning-assistant，代码行数:28，代码来源:pthread_cond.c
示例12: main
int main(void)
{
RT_TASK *task;
RTIME now;
int cnt=0;
// make main thread LXRT soft realtime
task = rt_task_init_schmod(nam2num("MYTASK"), 9, 0, 0, SCHED_FIFO, 0xF);
mlockall(MCL_CURRENT | MCL_FUTURE);
// start realtime timer and scheduler
//rt_set_oneshot_mode();
rt_set_periodic_mode();
start_rt_timer(0);
now = rt_get_time() + 10*PERIOD;
rt_task_make_periodic(task, now, PERIOD);
printf("Init mutex and cond.\n");
mutex = rt_sem_init(nam2num("MUTEX"), 1);
if (mutex==0)
printf("Error init mutex\n");
cond = rt_cond_init(nam2num("CONDITION"));
if (cond==0)
printf("Error init cond\n");
thread0 = rt_thread_create(fun0, NULL, 10000);
//thread1 = rt_thread_create(fun1, NULL, 20000);
//rt_sleep(PERIOD);
while (cnt < THRESHOLD) {
rt_task_wait_period();
rt_printk("main: Hello World %d!\n",cnt);
rt_sem_wait(mutex); //now the mutex should have value 0
if (instance_cnt==0) {
rt_sem_signal(mutex); //now the mutex should have vaule 1
rt_printk("worker thread busy!\n");
} else {
instance_cnt++;
rt_cond_signal(cond);
rt_sem_signal(mutex); //now the mutex should have vaule 1
rt_printk("signaling worker thread to start!\n");
}
cnt++;
}
// wait for end of program
printf("TYPE <ENTER> TO TERMINATE\n");
getchar();
// cleanup
stop_rt_timer();
return 0;
}
开发者ID:debashish216，项目名称:lte-testbed-news，代码行数:60，代码来源:condtest.c
示例13: pcap_netif_hw_init
void pcap_netif_hw_init(void)
{
rt_sem_init(&sem_lock, "eth_lock", 1, RT_IPC_FLAG_FIFO);
pcap_netif_device.dev_addr[0] = 0x00;
pcap_netif_device.dev_addr[1] = 0x60;
pcap_netif_device.dev_addr[2] = 0x37;
/* set mac address: (only for test) */
pcap_netif_device.dev_addr[3] = 0x12;
pcap_netif_device.dev_addr[4] = 0x34;
pcap_netif_device.dev_addr[5] = 0x56;
pcap_netif_device.parent.parent.init = pcap_netif_init;
pcap_netif_device.parent.parent.open = pcap_netif_open;
pcap_netif_device.parent.parent.close = pcap_netif_close;
pcap_netif_device.parent.parent.read = pcap_netif_read;
pcap_netif_device.parent.parent.write = pcap_netif_write;
pcap_netif_device.parent.parent.control = pcap_netif_control;
pcap_netif_device.parent.parent.user_data = RT_NULL;
pcap_netif_device.parent.eth_rx = pcap_netif_rx;
pcap_netif_device.parent.eth_tx = pcap_netif_tx;
eth_device_init(&(pcap_netif_device.parent), "e0");
}
开发者ID:bright-pan，项目名称:smart-lock，代码行数:25，代码来源:pcap_netif.c
示例14: rtos_sem_init
int rtos_sem_init(rt_sem_t* m, int value )
{
CHK_LXRT_CALL();
// store the pointer in m->opaque...
m->sem = rt_sem_init( rt_get_name(0) , value);
return m->sem == 0 ? -1 : 0;
}
开发者ID:jsreng，项目名称:orocos-rtt，代码行数:7，代码来源:fosi.c
示例15: finsh_lua
void finsh_lua(struct para *parameters)
{
rt_err_t (*rx_indicate)(rt_device_t dev, rt_size_t size);
rt_sem_init(&(dev4lua.sem), "luasem", 0, 0);
/* save old rx_indicate */
rx_indicate = dev4lua.device->rx_indicate;
/* set new rx_indicate */
rt_device_set_rx_indicate(dev4lua.device, lua_rx_ind);
{
int argc = parameters->argc;
char **argv = parameters->argv;
/*
rt_kprintf("argc =%d, argv[1] =%d\n", argc, argv[1]);
while(1);
*/
/* run lua interpreter */
lua_main(argc, argv);
}
if (parameters->argc > 1)
rt_free(parameters->argv[1]);
rt_free(parameters);
/* recover old rx_indicate */
rt_device_set_rx_indicate(dev4lua.device, rx_indicate);
}
开发者ID:bbw2008good，项目名称:rt-thread，代码行数:29，代码来源:lua_in_finsh.c
示例16: davinci_i2c_init
int davinci_i2c_init(char *bus_name)
{
struct rt_i2c_bus_device *bus;
struct davinci_i2c_dev *dev;
int r;
bus = rt_malloc(sizeof(struct rt_i2c_bus_device));
if (bus == RT_NULL)
{
rt_kprintf("rt_malloc failed\n");
return -RT_ENOMEM;
}
rt_memset((void *)bus, 0, sizeof(struct rt_i2c_bus_device));
bus->ops = &bus_ops;
bus->timeout = DAVINCI_I2C_TIMEOUT;
dev = rt_malloc(sizeof(struct davinci_i2c_dev));
if (!dev)
{
r = -RT_ENOMEM;
goto err;
}
rt_memset((void *)dev, 0, sizeof(struct davinci_i2c_dev));
rt_sem_init(&dev->completion, "i2c_ack", 0, RT_IPC_FLAG_FIFO);
dev->irq = IRQ_I2C;
dev->clk = clk_get("I2CCLK");
if (dev->clk == RT_NULL) {
r = -RT_ERROR;
goto err1;
}
psc_change_state(DAVINCI_DM365_LPSC_I2C, 3);
dev->base = DAVINCI_I2C_BASE;
dev->bus_freq = 100;
dev->bus_delay = 0;
bus->priv = dev;
i2c_davinci_init(dev);
rt_hw_interrupt_install(dev->irq, i2c_davinci_isr, (void *)dev, "I2C");
rt_hw_interrupt_umask(dev->irq);
return rt_i2c_bus_device_register(bus, bus_name);
err1:
rt_free(dev);
err:
rt_free(bus);
return r;
}
开发者ID:dongjw777，项目名称:dm365-voip，代码行数:60，代码来源:i2c-davinci.c
示例17: init_module
int init_module(void)
{
int i;
rt_sem_init(&barrier, NTASKS + 1);
smbx = rt_msgget(nam2num("SMSG"), 0x666 | IPC_CREAT);
for (i = 0; i < NTASKS; i++) {
char mname[6] = "RMBX";
mname[4] = i + '0';
mname[5] = 0;
rmbx[i] = rt_msgget(nam2num(mname), 0x666 | IPC_CREAT);
}
rt_set_oneshot_mode();
start_rt_timer(0);
rt_kthread_init(&bthread, bfun, 0, 0x8000, 1, 1, 0);
rt_task_resume(&bthread);
for (i = 0; i < NTASKS; i++) {
rt_kthread_init(&mthread[i], mfun, i, 0x8000, i + 2, 1, 0);
rt_task_resume(&mthread[i]);
}
return 0;
}
开发者ID:cjecho，项目名称:RTAI，代码行数:26，代码来源:ktestmsg.c
示例18: main
int main(void)
{
RT_TASK *Main_Task;
long msg;
if (!(Main_Task = rt_thread_init(nam2num("MNTSK"), 10, 0, SCHED_FIFO, 0xF))) {
printf("CANNOT INIT MAIN TASK\n");
exit(1);
}
if (!(hard_timer_running = rt_is_hard_timer_running())) {
start_rt_timer(0);
}
barrier = rt_sem_init(nam2num("PREMS"), 4);
latency_thread = rt_thread_create(latency_fun, NULL, 0);
fast_thread = rt_thread_create(fast_fun, NULL, 0);
slow_thread = rt_thread_create(slow_fun, NULL, 0);
start = rt_get_time() + nano2count(200000000);
rt_sem_wait_barrier(barrier);
rt_receive(0, &msg);
end = 1;
rt_sem_wait_barrier(barrier);
rt_thread_join(latency_thread);
rt_thread_join(fast_thread);
rt_thread_join(slow_thread);
if (!hard_timer_running) {
stop_rt_timer();
}
rt_sem_delete(barrier);
rt_thread_delete(Main_Task);
return 0;
}
开发者ID:ArcEye，项目名称:3.4.55-rtai，代码行数:32，代码来源:preempt.c
示例19: rs485_system_init
int rs485_system_init(void)
{
rt_err_t result;
rt_thread_t init_thread;
rs485_send_mut = rt_mutex_create("rs485mut",RT_IPC_FLAG_FIFO);
rs485_data_init();
uart1_dev_my = (struct _uart_dev_my*)rt_malloc(sizeof(struct _uart_dev_my));
if (uart1_dev_my == RT_NULL)
{
rt_kprintf("no memory for shell\n");
return -1;
}
memset(uart1_dev_my, 0, sizeof(struct _uart_dev_my));
rt_sem_init(&(uart1_dev_my->rx_sem), "rs485rx", 0, 0);
uart1_dev_my->device = RT_NULL;
uart1_rs485_set_device();
uart1_sem = rt_sem_create("uart1_sem",0, RT_IPC_FLAG_FIFO);
init_thread = rt_thread_create("rs485",rt_rs485_thread_entry, RT_NULL,
4092, 8, 21);
if (init_thread != RT_NULL)
rt_thread_startup(init_thread);
return 0;
}
开发者ID:pigeon0411，项目名称:aclean_ct，代码行数:35，代码来源:rs485_decode.c
示例20: susb_init
/**
* This function will initialize susb host controller device.
*
* @param dev the host controller device to be initalize.
*
* @return the error code, RT_EOK on successfully.
*/
static rt_err_t susb_init(rt_device_t dev)
{
rt_sem_init(&sem_lock, "s_lock", 1, RT_IPC_FLAG_FIFO);
/* roothub initilizition */
root_hub.num_ports = 1;
root_hub.is_roothub = RT_TRUE;
root_hub.self = RT_NULL;
root_hub.hcd = &susb_hcd;
/* Hardware Init */
USB_OTG_BSP_Init(&USB_OTG_Core);
/* configure GPIO pin used for switching VBUS power */
USB_OTG_BSP_ConfigVBUS(0);
/* Host de-initializations */
USBH_DeInit(&USB_OTG_Core, &USB_Host);
/* Start the USB OTG core */
HCD_Init(&USB_OTG_Core , USB_OTG_FS_CORE_ID);
USBH_DeAllocate_AllChannel(&USB_OTG_Core);
/* Enable Interrupts */
USB_OTG_BSP_EnableInterrupt(&USB_OTG_Core);
return RT_EOK;
}
开发者ID:aozima，项目名称:realtouch-stm32f4，代码行数:36，代码来源:stm32f4xx_hcd.c
注：本文中的rt_sem_init函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论