Searched refs:bucket (Results 1 - 25 of 94) sorted by relevance

1234

/freebsd-10.0-release/sys/mips/rmi/
H A Dmsgring_xls.cfg46 * across all sending agents should not exceed the bucket size.
60 * The bucket size of a bucket should be aligned to the bucket's starting index in that
62 * are 32 and 32, bucket2's size has to be 64. bucket size 0 is valid.
64 * The format of the file is pretty straight forward. Each bucket definition has the size
65 * and the list of sending agents to that bucket with the number of credits to send.
67 * Undefined buckets have a size of 0 and Tx stations have 0 credits to send to that bucket.
69 * Following are the currently supported bucket names
141 bucket "cpu_0_
[all...]
H A Dmsgring.cfg44 * across all sending agents should not exceed the bucket size.
69 * The bucket size of a bucket should be aligned to the bucket's starting index in that
71 * are 32 and 32, bucket2's size has to be 64. bucket size 0 is valid.
73 * The format of the file is pretty straight forward. Each bucket definition has the size
74 * and the list of sending agents to that bucket with the number of credits to send.
76 * Undefined buckets have a size of 0 and Tx stations have 0 credits to send to that bucket.
78 * Following are the currently supported bucket names
233 bucket "cpu_0_
[all...]
/freebsd-10.0-release/contrib/serf/buckets/
H A Drequest_buckets.c53 serf_bucket_t *bucket,
56 request_context_t *ctx = (request_context_t *)bucket->data;
62 serf_bucket_t *bucket)
64 return ((request_context_t *)bucket->data)->headers;
68 serf_bucket_t *bucket,
71 request_context_t *ctx = (request_context_t *)bucket->data;
82 apr_pstrcat(serf_bucket_allocator_get_pool(bucket->allocator),
88 static void serialize_data(serf_bucket_t *bucket) argument
90 request_context_t *ctx = bucket->data;
97 * and wrap a bucket aroun
52 serf_bucket_request_set_CL( serf_bucket_t *bucket, apr_int64_t len) argument
61 serf_bucket_request_get_headers( serf_bucket_t *bucket) argument
67 serf_bucket_request_set_root( serf_bucket_t *bucket, const char *root_url) argument
146 serf_request_read(serf_bucket_t *bucket, apr_size_t requested, const char **data, apr_size_t *len) argument
157 serf_request_readline(serf_bucket_t *bucket, int acceptable, int *found, const char **data, apr_size_t *len) argument
168 serf_request_read_iovec(serf_bucket_t *bucket, apr_size_t requested, int vecs_size, struct iovec *vecs, int *vecs_used) argument
182 serf_request_peek(serf_bucket_t *bucket, const char **data, apr_size_t *len) argument
193 serf_bucket_request_become( serf_bucket_t *bucket, const char *method, const char *uri, serf_bucket_t *body) argument
[all...]
H A Dbarrier_buckets.c39 static apr_status_t serf_barrier_read(serf_bucket_t *bucket, argument
43 barrier_context_t *ctx = bucket->data;
48 static apr_status_t serf_barrier_read_iovec(serf_bucket_t *bucket, argument
53 barrier_context_t *ctx = bucket->data;
59 static apr_status_t serf_barrier_readline(serf_bucket_t *bucket, argument
63 barrier_context_t *ctx = bucket->data;
68 static apr_status_t serf_barrier_peek(serf_bucket_t *bucket, argument
72 barrier_context_t *ctx = bucket->data;
77 static void serf_barrier_destroy(serf_bucket_t *bucket) argument
79 /* The intent of this bucket i
[all...]
H A Daggregate_buckets.c22 serf_bucket_t *bucket; member in struct:bucket_list
28 bucket_list_t *last; /* last bucket of the list */
34 /* Does this bucket own its children? !0 if yes, 0 if not. */
44 /* If we finished reading a bucket during the previous read, then
45 * we can now toss that bucket.
51 serf_bucket_destroy(ctx->done->bucket);
60 serf_bucket_t *bucket, serf_bucket_alloc_t *allocator)
62 aggregate_context_t *ctx = bucket->data;
98 serf_bucket_t *bucket = serf_bucket_aggregate_create(allocator); local
99 aggregate_context_t *ctx = bucket
59 serf_bucket_aggregate_cleanup( serf_bucket_t *bucket, serf_bucket_alloc_t *allocator) argument
109 serf_aggregate_destroy_and_data(serf_bucket_t *bucket) argument
127 serf_bucket_aggregate_become(serf_bucket_t *bucket) argument
224 read_aggregate(serf_bucket_t *bucket, apr_size_t requested, int vecs_size, struct iovec *vecs, int *vecs_used) argument
315 serf_aggregate_read(serf_bucket_t *bucket, apr_size_t requested, const char **data, apr_size_t *len) argument
339 serf_aggregate_read_iovec(serf_bucket_t *bucket, apr_size_t requested, int vecs_size, struct iovec *vecs, int *vecs_used) argument
352 serf_aggregate_readline(serf_bucket_t *bucket, int acceptable, int *found, const char **data, apr_size_t *len) argument
412 serf_aggregate_peek(serf_bucket_t *bucket, const char **data, apr_size_t *len) argument
456 serf_aggregate_read_bucket( serf_bucket_t *bucket, const serf_bucket_type_t *type) argument
[all...]
H A Dbwtp_buckets.c132 serf_bucket_t *bucket)
134 if (SERF_BUCKET_IS_BWTP_FRAME(bucket)) {
135 frame_context_t *ctx = bucket->data;
139 else if (SERF_BUCKET_IS_BWTP_INCOMING_FRAME(bucket)) {
140 incoming_context_t *ctx = bucket->data;
149 serf_bucket_t *bucket)
151 if (SERF_BUCKET_IS_BWTP_FRAME(bucket)) {
152 frame_context_t *ctx = bucket->data;
156 else if (SERF_BUCKET_IS_BWTP_INCOMING_FRAME(bucket)) {
157 incoming_context_t *ctx = bucket
131 serf_bucket_bwtp_frame_get_channel( serf_bucket_t *bucket) argument
148 serf_bucket_bwtp_frame_get_type( serf_bucket_t *bucket) argument
165 serf_bucket_bwtp_frame_get_phrase( serf_bucket_t *bucket) argument
182 serf_bucket_bwtp_frame_get_headers( serf_bucket_t *bucket) argument
219 serialize_data(serf_bucket_t *bucket) argument
254 serf_bwtp_frame_read(serf_bucket_t *bucket, apr_size_t requested, const char **data, apr_size_t *len) argument
265 serf_bwtp_frame_readline(serf_bucket_t *bucket, int acceptable, int *found, const char **data, apr_size_t *len) argument
276 serf_bwtp_frame_read_iovec(serf_bucket_t *bucket, apr_size_t requested, int vecs_size, struct iovec *vecs, int *vecs_used) argument
290 serf_bwtp_frame_peek(serf_bucket_t *bucket, const char **data, apr_size_t *len) argument
333 bwtp_incoming_destroy_and_data(serf_bucket_t *bucket) argument
537 serf_bucket_bwtp_incoming_frame_wait_for_headers( serf_bucket_t *bucket) argument
545 bwtp_incoming_read(serf_bucket_t *bucket, apr_size_t requested, const char **data, apr_size_t *len) argument
568 bwtp_incoming_readline(serf_bucket_t *bucket, int acceptable, int *found, const char **data, apr_size_t *len) argument
[all...]
H A Dlimit_buckets.c40 static apr_status_t serf_limit_read(serf_bucket_t *bucket, argument
44 limit_context_t *ctx = bucket->data;
74 static apr_status_t serf_limit_readline(serf_bucket_t *bucket, argument
78 limit_context_t *ctx = bucket->data;
100 static apr_status_t serf_limit_peek(serf_bucket_t *bucket, argument
104 limit_context_t *ctx = bucket->data;
109 static void serf_limit_destroy(serf_bucket_t *bucket) argument
111 limit_context_t *ctx = bucket->data;
115 serf_default_destroy_and_data(bucket);
H A Dresponse_body_buckets.c46 static apr_status_t serf_response_body_read(serf_bucket_t *bucket, argument
51 body_context_t *ctx = bucket->data;
81 static apr_status_t serf_response_body_readline(serf_bucket_t *bucket, argument
86 body_context_t *ctx = bucket->data;
108 static apr_status_t serf_response_body_peek(serf_bucket_t *bucket, argument
112 body_context_t *ctx = bucket->data;
117 static void serf_response_body_destroy(serf_bucket_t *bucket) argument
119 body_context_t *ctx = bucket->data;
123 serf_default_destroy_and_data(bucket);
H A Dchunk_buckets.c54 static apr_status_t create_chunk(serf_bucket_t *bucket) argument
56 chunk_context_t *ctx = bucket->data;
100 bucket->allocator);
126 static apr_status_t serf_chunk_read(serf_bucket_t *bucket, argument
130 chunk_context_t *ctx = bucket->data;
135 status = create_chunk(bucket);
143 /* Mask EOF from aggregate bucket. */
152 static apr_status_t serf_chunk_readline(serf_bucket_t *bucket, argument
156 chunk_context_t *ctx = bucket->data;
161 /* Mask EOF from aggregate bucket
170 serf_chunk_read_iovec(serf_bucket_t *bucket, apr_size_t requested, int vecs_size, struct iovec *vecs, int *vecs_used) argument
199 serf_chunk_peek(serf_bucket_t *bucket, const char **data, apr_size_t *len) argument
216 serf_chunk_destroy(serf_bucket_t *bucket) argument
[all...]
H A Dresponse_buckets.c67 serf_bucket_t *bucket)
69 response_context_t *ctx = bucket->data;
75 serf_bucket_t *bucket)
77 return ((response_context_t *)bucket->data)->headers;
81 static void serf_response_destroy_and_data(serf_bucket_t *bucket) argument
83 response_context_t *ctx = bucket->data;
86 serf_bucket_mem_free(bucket->allocator, (void*)ctx->sl.reason);
94 serf_default_destroy_and_data(bucket);
333 serf_bucket_t *bucket)
335 response_context_t *ctx = bucket
66 serf_bucket_response_set_head( serf_bucket_t *bucket) argument
74 serf_bucket_response_get_headers( serf_bucket_t *bucket) argument
332 serf_bucket_response_wait_for_headers( serf_bucket_t *bucket) argument
371 serf_response_read(serf_bucket_t *bucket, apr_size_t requested, const char **data, apr_size_t *len) argument
403 serf_response_readline(serf_bucket_t *bucket, int acceptable, int *found, const char **data, apr_size_t *len) argument
419 serf_response_full_become_aggregate(serf_bucket_t *bucket) argument
[all...]
H A Dfile_buckets.c81 static apr_status_t serf_file_read(serf_bucket_t *bucket, argument
85 file_context_t *ctx = bucket->data;
90 static apr_status_t serf_file_readline(serf_bucket_t *bucket, argument
94 file_context_t *ctx = bucket->data;
99 static apr_status_t serf_file_peek(serf_bucket_t *bucket, argument
103 file_context_t *ctx = bucket->data;
H A Dsocket_buckets.c79 serf_bucket_t *bucket,
83 socket_context_t *ctx = bucket->data;
89 static apr_status_t serf_socket_read(serf_bucket_t *bucket, argument
93 socket_context_t *ctx = bucket->data;
98 static apr_status_t serf_socket_readline(serf_bucket_t *bucket, argument
102 socket_context_t *ctx = bucket->data;
107 static apr_status_t serf_socket_peek(serf_bucket_t *bucket, argument
111 socket_context_t *ctx = bucket->data;
78 serf_bucket_socket_set_read_progress_cb( serf_bucket_t *bucket, const serf_progress_t progress_func, void *progress_baton) argument
H A Diovec_buckets.c56 static apr_status_t serf_iovec_readline(serf_bucket_t *bucket, argument
63 static apr_status_t serf_iovec_read_iovec(serf_bucket_t *bucket, argument
69 iovec_context_t *ctx = bucket->data;
109 static apr_status_t serf_iovec_read(serf_bucket_t *bucket, argument
117 status = serf_iovec_read_iovec(bucket, requested, 1, vec, &vecs_used);
129 static apr_status_t serf_iovec_peek(serf_bucket_t *bucket, argument
133 iovec_context_t *ctx = bucket->data;
151 static void serf_iovec_destroy(serf_bucket_t *bucket) argument
153 iovec_context_t *ctx = bucket->data;
155 serf_bucket_mem_free(bucket
[all...]
H A Dallocator.c45 * apr_allocator associated with the bucket allocator. The apr_allocator
69 const serf_bucket_t *bucket; member in struct:__anon4131
76 int next_index; /* info[] is a ring. next bucket goes at this idx. */
284 const serf_bucket_t *bucket,
293 /* Search backwards. In all likelihood, the bucket which just got
301 if ((rs = &track->info[idx])->bucket == bucket) {
317 rs->bucket = bucket;
330 const serf_bucket_t *bucket,
282 find_read_status( track_state_t *track, const serf_bucket_t *bucket, int create_rs) argument
329 serf_debug__record_read( const serf_bucket_t *bucket, apr_status_t status) argument
389 serf_debug__bucket_destroy(const serf_bucket_t *bucket) argument
[all...]
H A Dmmap_buckets.c47 static apr_status_t serf_mmap_read(serf_bucket_t *bucket, argument
51 mmap_context_t *ctx = bucket->data;
73 static apr_status_t serf_mmap_readline(serf_bucket_t *bucket, argument
77 mmap_context_t *ctx = bucket->data;
102 static apr_status_t serf_mmap_peek(serf_bucket_t *bucket, argument
H A Dsimple_buckets.c91 static apr_status_t serf_simple_read(serf_bucket_t *bucket, argument
95 simple_context_t *ctx = bucket->data;
109 static apr_status_t serf_simple_readline(serf_bucket_t *bucket, argument
113 simple_context_t *ctx = bucket->data;
125 static apr_status_t serf_simple_peek(serf_bucket_t *bucket, argument
129 simple_context_t *ctx = bucket->data;
135 /* we returned everything this bucket will ever hold */
139 static void serf_simple_destroy(serf_bucket_t *bucket) argument
141 simple_context_t *ctx = bucket->data;
146 serf_default_destroy_and_data(bucket);
[all...]
H A Ddechunk_buckets.c55 static void serf_dechunk_destroy_and_data(serf_bucket_t *bucket) argument
57 dechunk_context_t *ctx = bucket->data;
61 serf_default_destroy_and_data(bucket);
64 static apr_status_t serf_dechunk_read(serf_bucket_t *bucket, argument
68 dechunk_context_t *ctx = bucket->data;
124 /* Delegate to the stream bucket to do the read. */
147 /* Delegate to the stream bucket to do the read. */
/freebsd-10.0-release/contrib/byacc/
H A Dsymtab.c10 static bucket **symbol_table = 0;
11 bucket *first_symbol;
12 bucket *last_symbol;
29 bucket *
32 bucket *bp;
36 bp = TMALLOC(bucket, 1);
56 bucket *
59 bucket *bp, **bpp;
83 bucket *bp;
85 symbol_table = TMALLOC(bucket *, TABLE_SIZ
[all...]
/freebsd-10.0-release/contrib/libarchive/libarchive/
H A Darchive_entry_link_resolver.c265 size_t hash, bucket; local
282 bucket = hash & (res->number_buckets - 1);
283 for (le = res->buckets[bucket]; le != NULL; le = le->next) {
296 /* Remove it from this hash bucket. */
301 if (res->buckets[bucket] == le)
302 res->buckets[bucket] = le->next;
316 size_t bucket; local
326 /* Look for next non-empty bucket in the links cache. */
327 for (bucket = 0; bucket < re
356 size_t hash, bucket; local
388 size_t i, bucket; local
[all...]
H A Darchive_write_disk_set_standard_lookup.c53 struct bucket { struct
80 * but has a bad pathology in which it thrashes a single bucket. Even
87 struct bucket *ucache = malloc(cache_size * sizeof(struct bucket));
88 struct bucket *gcache = malloc(cache_size * sizeof(struct bucket));
89 memset(ucache, 0, cache_size * sizeof(struct bucket));
90 memset(gcache, 0, cache_size * sizeof(struct bucket));
100 struct bucket *b;
101 struct bucket *gcach
[all...]
/freebsd-10.0-release/contrib/serf/
H A Dserf_bucket_util.h22 * for implementing buckets. It is not needed by users of the bucket
34 * Basic bucket creation function.
36 * This function will create a bucket of @a type, allocating the necessary
37 * memory from @a allocator. The @a data bucket-private information will
38 * be stored into the bucket.
52 serf_bucket_t *bucket,
65 serf_bucket_t *bucket,
76 * of bucket cannot be found within @a bucket.
79 serf_bucket_t *bucket,
[all...]
/freebsd-10.0-release/contrib/gcc/
H A Dtree-phinodes.c134 int bucket = NUM_BUCKETS - 2; local
139 for (bucket = len - 2; bucket < NUM_BUCKETS - 2; bucket++)
140 if (free_phinodes[bucket])
144 if (bucket < NUM_BUCKETS - 2
145 && PHI_ARG_CAPACITY (free_phinodes[bucket]) >= len)
148 phi = free_phinodes[bucket];
149 free_phinodes[bucket] = PHI_CHAIN (free_phinodes[bucket]);
244 int bucket; local
[all...]
/freebsd-10.0-release/libexec/rtld-elf/
H A Dmalloc.c87 u_char ovu_index; /* bucket # */
117 static int pagebucket; /* page size bucket */
171 register int bucket; local
190 bucket = 0;
194 bucket++;
196 pagebucket = bucket;
205 amt = 8; /* size of first bucket */
206 bucket = 0;
208 amt = 16; /* size of first bucket */
209 bucket
[all...]
/freebsd-10.0-release/sys/contrib/octeon-sdk/
H A Dcvmx-tim.c73 * @param tick Time between each bucket in microseconds. This must not be
111 * to fetch the bucket data, Resulting in timer ring error interrupt
165 cvmx_tim.bucket = cvmx_bootmem_alloc(CVMX_TIM_NUM_TIMERS * cvmx_tim.num_buckets
167 if (cvmx_tim.bucket == NULL)
172 memset(cvmx_tim.bucket, 0, CVMX_TIM_NUM_TIMERS * cvmx_tim.num_buckets * sizeof(cvmx_tim_bucket_entry_t));
180 cvmx_tim_bucket_entry_t *bucket = cvmx_tim.bucket + timer_id * cvmx_tim.num_buckets; local
188 /* Tell the hardware where about the bucket array */
191 ring_ctl2.s.base = cvmx_ptr_to_phys(bucket) >> 5;
214 /* Tell the hardware where about the bucket arra
273 uint32_t bucket; local
[all...]
/freebsd-10.0-release/contrib/jemalloc/src/
H A Dckh.c4 * hash bucket contains 2^n cells, for n >= 1, and 2 indicates that two hash
24 * | #cells/bucket |
32 * The number of cells per bucket is chosen such that a bucket fits in one cache
49 * Search bucket for key and return the cell number if found; SIZE_T_MAX
53 ckh_bucket_search(ckh_t *ckh, size_t bucket, const void *key) argument
59 cell = &ckh->tab[(bucket << LG_CKH_BUCKET_CELLS) + i];
61 return ((bucket << LG_CKH_BUCKET_CELLS) + i);
73 size_t hashes[2], bucket, cell; local
79 /* Search primary bucket
92 ckh_try_bucket_insert(ckh_t *ckh, size_t bucket, const void *key, const void *data) argument
129 size_t hashes[2], bucket, tbucket; local
196 size_t hashes[2], bucket; local
[all...]

Completed in 273 milliseconds

1234