libs/rt-thread-official
libs/rt-thread-official
4
0
Fork 0
mirror of https://github.com/RT-Thread/rt-thread.git synced 2025-02-07 01:54:33 +08:00
Code Issues Releases Wiki Activity

Merge pull request #4531 from whj4674672/pipe

Browse Source 
pipe name depend on RT_NAME_MAX
This commit is contained in:
Bernard Xiong 2021-03-27 14:51:15 +08:00 committed by GitHub
commit 9cf0720b68
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
components/drivers/src/pipe.c
View File

@ -320,7 +320,7 @@ static const struct dfs_file_ops pipe_fops =
}; };
#endif /* end of RT_USING_POSIX */ #endif /* end of RT_USING_POSIX */
rt_err_t rt_pipe_open (rt_device_t device, rt_uint16_t oflag) rt_err_t rt_pipe_open(rt_device_t device, rt_uint16_t oflag)
{ {
rt_pipe_t *pipe = (rt_pipe_t *)device; rt_pipe_t *pipe = (rt_pipe_t *)device;
rt_err_t ret = RT_EOK; rt_err_t ret = RT_EOK;
@ -348,7 +348,7 @@ __exit:
return ret; return ret;
} }
rt_err_t rt_pipe_close (rt_device_t device) rt_err_t rt_pipe_close(rt_device_t device)
{ {
rt_pipe_t *pipe = (rt_pipe_t *)device; rt_pipe_t *pipe = (rt_pipe_t *)device;
@ -366,7 +366,7 @@ rt_err_t rt_pipe_close (rt_device_t device)
return RT_EOK; return RT_EOK;
} }
rt_size_t rt_pipe_read (rt_device_t device, rt_off_t pos, void *buffer, rt_size_t count) rt_size_t rt_pipe_read(rt_device_t device, rt_off_t pos, void *buffer, rt_size_t count)
{ {
uint8_t *pbuf; uint8_t *pbuf;
rt_size_t read_bytes = 0; rt_size_t read_bytes = 0;
@ -394,7 +394,7 @@ rt_size_t rt_pipe_read (rt_device_t device, rt_off_t pos, void *buffer, rt_siz
return read_bytes; return read_bytes;
} }
rt_size_t rt_pipe_write (rt_device_t device, rt_off_t pos, const void *buffer, rt_size_t count) rt_size_t rt_pipe_write(rt_device_t device, rt_off_t pos, const void *buffer, rt_size_t count)
{ {
uint8_t *pbuf; uint8_t *pbuf;
rt_size_t write_bytes = 0; rt_size_t write_bytes = 0;
@ -531,8 +531,8 @@ int rt_pipe_delete(const char *name)
int pipe(int fildes[2]) int pipe(int fildes[2])
{ {
rt_pipe_t *pipe; rt_pipe_t *pipe;
char dname[8]; char dname[RT_NAME_MAX];
char dev_name[32]; char dev_name[RT_NAME_MAX * 4];
static int pipeno = 0; static int pipeno = 0;
rt_snprintf(dname, sizeof(dname), "pipe%d", pipeno++); rt_snprintf(dname, sizeof(dname), "pipe%d", pipeno++);