1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
2 * vim:expandtab:shiftwidth=8:tabstop=8:
4 * Copyright (C) 2004 Cluster File Systems, Inc.
5 * Author: Nikita Danilov <nikita@clusterfs.com>
7 * This file is part of Lustre, http://www.lustre.org.
9 * Lustre is free software; you can redistribute it and/or modify it under the
10 * terms of version 2 of the GNU General Public License as published by the
11 * Free Software Foundation.
13 * Lustre is distributed in the hope that it will be useful, but WITHOUT ANY
14 * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
15 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
18 * You should have received a copy of the GNU General Public License along
19 * with Lustre; if not, write to the Free Software Foundation, Inc., 675 Mass
20 * Ave, Cambridge, MA 02139, USA.
22 * Implementation of portable time API for user-level.
26 #ifndef __LIBCFS_USER_PRIM_H__
27 #define __LIBCFS_USER_PRIM_H__
29 #ifndef __LIBCFS_LIBCFS_H__
30 #error Do not #include this file directly. #include <libcfs/libcfs.h> instead
33 /* Implementations of portable APIs for liblustre */
36 * liblustre is single-threaded, so most "synchronization" APIs are trivial.
43 #include <sys/signal.h>
45 #include <libcfs/list.h>
46 #include <libcfs/user-time.h>
53 #define PAGE_SIZE (getpagesize())
54 static __inline__ int getpageshift()
56 int pagesize = getpagesize();
57 #if (__GNUC__ >= 4) || ((__GNUC__ == 3) && (__GNUC_MINOR__ >= 4))
58 /* unsigned int is 32 bits on all our architectures */
59 return (__builtin_clz(pagesize) ^ 31);
61 register int pageshift = -1;
62 while (pagesize) { pagesize >>= 1; pageshift++; }
68 #define PAGE_MASK (~(PAGE_SIZE-1))
70 #define PAGE_SHIFT (getpageshift())
75 * Wait Queue. No-op implementation.
78 typedef struct cfs_waitlink {
79 struct list_head sleeping;
83 typedef struct cfs_waitq {
84 struct list_head sleepers;
87 void cfs_waitq_init(struct cfs_waitq *waitq);
88 void cfs_waitlink_init(struct cfs_waitlink *link);
89 void cfs_waitq_add(struct cfs_waitq *waitq, struct cfs_waitlink *link);
90 void cfs_waitq_add_exclusive(struct cfs_waitq *waitq,
91 struct cfs_waitlink *link);
92 void cfs_waitq_forward(struct cfs_waitlink *link, struct cfs_waitq *waitq);
93 void cfs_waitq_del(struct cfs_waitq *waitq, struct cfs_waitlink *link);
94 int cfs_waitq_active(struct cfs_waitq *waitq);
95 void cfs_waitq_signal(struct cfs_waitq *waitq);
96 void cfs_waitq_signal_nr(struct cfs_waitq *waitq, int nr);
97 void cfs_waitq_broadcast(struct cfs_waitq *waitq, int state);
98 void cfs_waitq_wait(struct cfs_waitlink *link);
99 int64_t cfs_waitq_timedwait(struct cfs_waitlink *link, int state, int64_t timeout);
100 #define cfs_schedule_timeout(s, t) \
103 cfs_waitq_timedwait(&l, s, t); \
106 #define CFS_TASK_INTERRUPTIBLE (0)
107 #define CFS_TASK_UNINT (0)
112 * for this moment, liblusre will not rely OST for non-page-aligned write
114 #define LIBLUSTRE_HANDLE_UNALIGNED_PAGE
119 struct list_head list;
120 unsigned long private;
122 /* internally used by liblustre file i/o */
125 #ifdef LIBLUSTRE_HANDLE_UNALIGNED_PAGE
130 typedef struct page cfs_page_t;
132 #define CFS_PAGE_SIZE PAGE_SIZE
133 #define CFS_PAGE_SHIFT PAGE_SHIFT
134 #define CFS_PAGE_MASK (~((__u64)CFS_PAGE_SIZE-1))
136 cfs_page_t *cfs_alloc_page(unsigned int flags);
137 void cfs_free_page(cfs_page_t *pg);
138 void *cfs_page_address(cfs_page_t *pg);
139 void *cfs_kmap(cfs_page_t *pg);
140 void cfs_kunmap(cfs_page_t *pg);
142 #define cfs_get_page(p) __I_should_not_be_called__(at_all)
143 #define cfs_page_count(p) __I_should_not_be_called__(at_all)
144 #define cfs_page_index(p) ((p)->index)
148 * Inline function, so utils can use them without linking of libcfs
150 #define __ALLOC_ZERO (1 << 2)
151 static inline void *cfs_alloc(size_t nr_bytes, u_int32_t flags)
155 result = malloc(nr_bytes);
156 if (result != NULL && (flags & __ALLOC_ZERO))
157 memset(result, 0, nr_bytes);
161 #define cfs_free(addr) free(addr)
162 #define cfs_alloc_large(nr_bytes) cfs_alloc(nr_bytes, 0)
163 #define cfs_free_large(addr) cfs_free(addr)
165 #define CFS_ALLOC_ATOMIC_TRY (0)
173 #define SLAB_HWCACHE_ALIGN 0
174 #define SLAB_KERNEL 0
178 cfs_mem_cache_create(const char *, size_t, size_t, unsigned long);
179 int cfs_mem_cache_destroy(cfs_mem_cache_t *c);
180 void *cfs_mem_cache_alloc(cfs_mem_cache_t *c, int gfp);
181 void cfs_mem_cache_free(cfs_mem_cache_t *c, void *addr);
183 typedef int (cfs_read_proc_t)(char *page, char **start, off_t off,
184 int count, int *eof, void *data);
186 struct file; /* forward ref */
187 typedef int (cfs_write_proc_t)(struct file *file, const char *buffer,
188 unsigned long count, void *data);
193 typedef sigset_t cfs_sigset_t;
198 #include <sys/time.h>
201 struct list_head tl_list;
202 void (*function)(unsigned long unused);
207 #define cfs_init_timer(t) do {} while(0)
208 #define cfs_jiffies \
210 unsigned long _ret = 0; \
212 if (gettimeofday(&tv, NULL) == 0) \
217 static inline int cfs_timer_init(cfs_timer_t *l, void (* func)(unsigned long), void *arg)
219 CFS_INIT_LIST_HEAD(&l->tl_list);
221 l->data = (unsigned long)arg;
225 static inline int cfs_timer_is_armed(cfs_timer_t *l)
227 if (cfs_time_before(cfs_jiffies, l->expires))
233 static inline void cfs_timer_arm(cfs_timer_t *l, int thetime)
235 l->expires = thetime;
238 static inline void cfs_timer_disarm(cfs_timer_t *l)
242 static inline long cfs_timer_deadline(cfs_timer_t *l)
248 #define cfs_init_timer(t) do {} while(0)
249 void cfs_timer_init(struct cfs_timer *t, void (*func)(unsigned long), void *arg);
250 void cfs_timer_done(struct cfs_timer *t);
251 void cfs_timer_arm(struct cfs_timer *t, cfs_time_t deadline);
252 void cfs_timer_disarm(struct cfs_timer *t);
253 int cfs_timer_is_armed(struct cfs_timer *t);
255 cfs_time_t cfs_timer_deadline(struct cfs_timer *t);
258 #define in_interrupt() (0)
260 static inline void cfs_pause(cfs_duration_t d)
264 cfs_duration_nsec(d, &s);
268 typedef void cfs_psdev_t;
270 static inline int cfs_psdev_register(cfs_psdev_t *foo)
275 static inline int cfs_psdev_deregister(cfs_psdev_t *foo)
281 * portable UNIX device file identification.
284 typedef unsigned int cfs_rdev_t;
285 // typedef unsigned long long kdev_t;
288 #define cfs_lock_kernel() do {} while (0)
289 #define cfs_sigfillset(l) do {} while (0)
290 #define cfs_recalc_sigpending(l) do {} while (0)
291 #define cfs_kernel_thread(l,m,n) LBUG()
293 // static inline void local_irq_save(unsigned long flag) {return;}
294 // static inline void local_irq_restore(unsigned long flag) {return;}
297 CFS_STACK_TRACE_DEPTH = 16
300 struct cfs_stack_trace {
301 void *frame[CFS_STACK_TRACE_DEPTH];
307 #define do_div(a,b) \
309 unsigned long remainder;\
310 remainder = (a) % (b); \
319 /* __LIBCFS_USER_PRIM_H__ */
323 * c-indentation-style: "K&R"