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

12345

/freebsd-11-stable/contrib/serf/buckets/
H A Drequest_buckets.c58 serf_bucket_t *bucket,
61 request_context_t *ctx = (request_context_t *)bucket->data;
67 serf_bucket_t *bucket)
69 return ((request_context_t *)bucket->data)->headers;
73 serf_bucket_t *bucket,
76 request_context_t *ctx = (request_context_t *)bucket->data;
87 apr_pstrcat(serf_bucket_allocator_get_pool(bucket->allocator),
93 static void serialize_data(serf_bucket_t *bucket) argument
95 request_context_t *ctx = bucket->data;
102 * and wrap a bucket aroun
57 serf_bucket_request_set_CL( serf_bucket_t *bucket, apr_int64_t len) argument
66 serf_bucket_request_get_headers( serf_bucket_t *bucket) argument
72 serf_bucket_request_set_root( serf_bucket_t *bucket, const char *root_url) argument
151 serf_request_read(serf_bucket_t *bucket, apr_size_t requested, const char **data, apr_size_t *len) argument
162 serf_request_readline(serf_bucket_t *bucket, int acceptable, int *found, const char **data, apr_size_t *len) argument
173 serf_request_read_iovec(serf_bucket_t *bucket, apr_size_t requested, int vecs_size, struct iovec *vecs, int *vecs_used) argument
187 serf_request_peek(serf_bucket_t *bucket, const char **data, apr_size_t *len) argument
200 serf_request_destroy(serf_bucket_t *bucket) argument
212 serf_bucket_request_become( serf_bucket_t *bucket, const char *method, const char *uri, serf_bucket_t *body) argument
[all...]
H A Dbarrier_buckets.c44 static apr_status_t serf_barrier_read(serf_bucket_t *bucket, argument
48 barrier_context_t *ctx = bucket->data;
53 static apr_status_t serf_barrier_read_iovec(serf_bucket_t *bucket, argument
58 barrier_context_t *ctx = bucket->data;
64 static apr_status_t serf_barrier_readline(serf_bucket_t *bucket, argument
68 barrier_context_t *ctx = bucket->data;
73 static apr_status_t serf_barrier_peek(serf_bucket_t *bucket, argument
77 barrier_context_t *ctx = bucket->data;
82 static void serf_barrier_destroy(serf_bucket_t *bucket) argument
84 /* The intent of this bucket i
[all...]
H A Daggregate_buckets.c27 serf_bucket_t *bucket; member in struct:bucket_list
33 bucket_list_t *last; /* last bucket of the list */
39 /* Does this bucket own its children? !0 if yes, 0 if not. */
49 /* If we finished reading a bucket during the previous read, then
50 * we can now toss that bucket.
56 serf_bucket_destroy(ctx->done->bucket);
65 serf_bucket_t *bucket, serf_bucket_alloc_t *allocator)
67 aggregate_context_t *ctx = bucket->data;
103 serf_bucket_t *bucket = serf_bucket_aggregate_create(allocator); local
104 aggregate_context_t *ctx = bucket
64 serf_bucket_aggregate_cleanup( serf_bucket_t *bucket, serf_bucket_alloc_t *allocator) argument
114 serf_aggregate_destroy_and_data(serf_bucket_t *bucket) argument
132 serf_bucket_aggregate_become(serf_bucket_t *bucket) argument
229 read_aggregate(serf_bucket_t *bucket, apr_size_t requested, int vecs_size, struct iovec *vecs, int *vecs_used) argument
320 serf_aggregate_read(serf_bucket_t *bucket, apr_size_t requested, const char **data, apr_size_t *len) argument
344 serf_aggregate_read_iovec(serf_bucket_t *bucket, apr_size_t requested, int vecs_size, struct iovec *vecs, int *vecs_used) argument
357 serf_aggregate_readline(serf_bucket_t *bucket, int acceptable, int *found, const char **data, apr_size_t *len) argument
417 serf_aggregate_peek(serf_bucket_t *bucket, const char **data, apr_size_t *len) argument
461 serf_aggregate_read_bucket( serf_bucket_t *bucket, const serf_bucket_type_t *type) argument
[all...]
H A Dbwtp_buckets.c137 serf_bucket_t *bucket)
139 if (SERF_BUCKET_IS_BWTP_FRAME(bucket)) {
140 frame_context_t *ctx = bucket->data;
144 else if (SERF_BUCKET_IS_BWTP_INCOMING_FRAME(bucket)) {
145 incoming_context_t *ctx = bucket->data;
154 serf_bucket_t *bucket)
156 if (SERF_BUCKET_IS_BWTP_FRAME(bucket)) {
157 frame_context_t *ctx = bucket->data;
161 else if (SERF_BUCKET_IS_BWTP_INCOMING_FRAME(bucket)) {
162 incoming_context_t *ctx = bucket
136 serf_bucket_bwtp_frame_get_channel( serf_bucket_t *bucket) argument
153 serf_bucket_bwtp_frame_get_type( serf_bucket_t *bucket) argument
170 serf_bucket_bwtp_frame_get_phrase( serf_bucket_t *bucket) argument
187 serf_bucket_bwtp_frame_get_headers( serf_bucket_t *bucket) argument
224 serialize_data(serf_bucket_t *bucket) argument
259 serf_bwtp_frame_read(serf_bucket_t *bucket, apr_size_t requested, const char **data, apr_size_t *len) argument
270 serf_bwtp_frame_readline(serf_bucket_t *bucket, int acceptable, int *found, const char **data, apr_size_t *len) argument
281 serf_bwtp_frame_read_iovec(serf_bucket_t *bucket, apr_size_t requested, int vecs_size, struct iovec *vecs, int *vecs_used) argument
295 serf_bwtp_frame_peek(serf_bucket_t *bucket, const char **data, apr_size_t *len) argument
338 bwtp_incoming_destroy_and_data(serf_bucket_t *bucket) argument
542 serf_bucket_bwtp_incoming_frame_wait_for_headers( serf_bucket_t *bucket) argument
550 bwtp_incoming_read(serf_bucket_t *bucket, apr_size_t requested, const char **data, apr_size_t *len) argument
573 bwtp_incoming_readline(serf_bucket_t *bucket, int acceptable, int *found, const char **data, apr_size_t *len) argument
[all...]
H A Dresponse_body_buckets.c51 static apr_status_t serf_response_body_read(serf_bucket_t *bucket, argument
56 body_context_t *ctx = bucket->data;
86 static apr_status_t serf_response_body_readline(serf_bucket_t *bucket, argument
91 body_context_t *ctx = bucket->data;
113 static apr_status_t serf_response_body_peek(serf_bucket_t *bucket, argument
117 body_context_t *ctx = bucket->data;
122 static void serf_response_body_destroy(serf_bucket_t *bucket) argument
124 body_context_t *ctx = bucket->data;
128 serf_default_destroy_and_data(bucket);
H A Dlimit_buckets.c45 static apr_status_t serf_limit_read(serf_bucket_t *bucket, argument
49 limit_context_t *ctx = bucket->data;
79 static apr_status_t serf_limit_readline(serf_bucket_t *bucket, argument
83 limit_context_t *ctx = bucket->data;
105 static apr_status_t serf_limit_peek(serf_bucket_t *bucket, argument
109 limit_context_t *ctx = bucket->data;
114 static void serf_limit_destroy(serf_bucket_t *bucket) argument
116 limit_context_t *ctx = bucket->data;
120 serf_default_destroy_and_data(bucket);
H A Dchunk_buckets.c59 static apr_status_t create_chunk(serf_bucket_t *bucket) argument
61 chunk_context_t *ctx = bucket->data;
105 bucket->allocator);
131 static apr_status_t serf_chunk_read(serf_bucket_t *bucket, argument
135 chunk_context_t *ctx = bucket->data;
140 status = create_chunk(bucket);
148 /* Mask EOF from aggregate bucket. */
157 static apr_status_t serf_chunk_readline(serf_bucket_t *bucket, argument
161 chunk_context_t *ctx = bucket->data;
166 /* Mask EOF from aggregate bucket
175 serf_chunk_read_iovec(serf_bucket_t *bucket, apr_size_t requested, int vecs_size, struct iovec *vecs, int *vecs_used) argument
204 serf_chunk_peek(serf_bucket_t *bucket, const char **data, apr_size_t *len) argument
221 serf_chunk_destroy(serf_bucket_t *bucket) argument
[all...]
H A Dresponse_buckets.c95 serf_bucket_t *bucket)
97 response_context_t *ctx = bucket->data;
103 serf_bucket_t *bucket)
105 return ((response_context_t *)bucket->data)->headers;
109 static void serf_response_destroy_and_data(serf_bucket_t *bucket) argument
111 response_context_t *ctx = bucket->data;
114 serf_bucket_mem_free(bucket->allocator, (void*)ctx->sl.reason);
122 serf_default_destroy_and_data(bucket);
372 serf_bucket_t *bucket)
374 response_context_t *ctx = bucket
94 serf_bucket_response_set_head( serf_bucket_t *bucket) argument
102 serf_bucket_response_get_headers( serf_bucket_t *bucket) argument
371 serf_bucket_response_wait_for_headers( serf_bucket_t *bucket) argument
410 serf_response_read(serf_bucket_t *bucket, apr_size_t requested, const char **data, apr_size_t *len) argument
442 serf_response_readline(serf_bucket_t *bucket, int acceptable, int *found, const char **data, apr_size_t *len) argument
458 serf_response_full_become_aggregate(serf_bucket_t *bucket) argument
[all...]
H A Dfile_buckets.c86 static apr_status_t serf_file_read(serf_bucket_t *bucket, argument
90 file_context_t *ctx = bucket->data;
95 static apr_status_t serf_file_readline(serf_bucket_t *bucket, argument
99 file_context_t *ctx = bucket->data;
104 static apr_status_t serf_file_peek(serf_bucket_t *bucket, argument
108 file_context_t *ctx = bucket->data;
H A Dsocket_buckets.c84 serf_bucket_t *bucket,
88 socket_context_t *ctx = bucket->data;
94 static apr_status_t serf_socket_read(serf_bucket_t *bucket, argument
98 socket_context_t *ctx = bucket->data;
103 static apr_status_t serf_socket_readline(serf_bucket_t *bucket, argument
107 socket_context_t *ctx = bucket->data;
112 static apr_status_t serf_socket_peek(serf_bucket_t *bucket, argument
116 socket_context_t *ctx = bucket->data;
83 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.c61 static apr_status_t serf_iovec_readline(serf_bucket_t *bucket, argument
68 static apr_status_t serf_iovec_read_iovec(serf_bucket_t *bucket, argument
74 iovec_context_t *ctx = bucket->data;
114 static apr_status_t serf_iovec_read(serf_bucket_t *bucket, argument
122 status = serf_iovec_read_iovec(bucket, requested, 1, vec, &vecs_used);
134 static apr_status_t serf_iovec_peek(serf_bucket_t *bucket, argument
138 iovec_context_t *ctx = bucket->data;
156 static void serf_iovec_destroy(serf_bucket_t *bucket) argument
158 iovec_context_t *ctx = bucket->data;
160 serf_bucket_mem_free(bucket
[all...]
H A Dallocator.c50 * apr_allocator associated with the bucket allocator. The apr_allocator
74 const serf_bucket_t *bucket; member in struct:__anon53
81 int next_index; /* info[] is a ring. next bucket goes at this idx. */
289 const serf_bucket_t *bucket,
298 /* Search backwards. In all likelihood, the bucket which just got
306 if ((rs = &track->info[idx])->bucket == bucket) {
322 rs->bucket = bucket;
335 const serf_bucket_t *bucket,
287 find_read_status( track_state_t *track, const serf_bucket_t *bucket, int create_rs) argument
334 serf_debug__record_read( const serf_bucket_t *bucket, apr_status_t status) argument
394 serf_debug__bucket_destroy(const serf_bucket_t *bucket) argument
[all...]
H A Dmmap_buckets.c52 static apr_status_t serf_mmap_read(serf_bucket_t *bucket, argument
56 mmap_context_t *ctx = bucket->data;
78 static apr_status_t serf_mmap_readline(serf_bucket_t *bucket, argument
82 mmap_context_t *ctx = bucket->data;
107 static apr_status_t serf_mmap_peek(serf_bucket_t *bucket, argument
H A Dsimple_buckets.c96 static apr_status_t serf_simple_read(serf_bucket_t *bucket, argument
100 simple_context_t *ctx = bucket->data;
114 static apr_status_t serf_simple_readline(serf_bucket_t *bucket, argument
118 simple_context_t *ctx = bucket->data;
130 static apr_status_t serf_simple_peek(serf_bucket_t *bucket, argument
134 simple_context_t *ctx = bucket->data;
140 /* we returned everything this bucket will ever hold */
144 static void serf_simple_destroy(serf_bucket_t *bucket) argument
146 simple_context_t *ctx = bucket->data;
151 serf_default_destroy_and_data(bucket);
[all...]
/freebsd-11-stable/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);
62 bucket *
65 bucket *bp, **bpp;
89 bucket *bp;
91 symbol_table = TMALLOC(bucket *, TABLE_SIZ
[all...]
/freebsd-11-stable/contrib/subversion/subversion/libsvn_ra_serf/
H A Deagain_bucket.c2 * eagain_bucket.c : a serf bucket that handles slowing down data
39 eagain_bucket_read(serf_bucket_t *bucket, argument
44 eagain_baton_t *eab = bucket->data;
71 eagain_bucket_readline(serf_bucket_t *bucket, argument
86 eagain_bucket_peek(serf_bucket_t *bucket, argument
90 const eagain_baton_t *eab = bucket->data;
H A Dstream_bucket.c2 * stream_bucket.c : a serf bucket that wraps a readable svn_stream_t
67 stream_bucket_read(serf_bucket_t *bucket, apr_size_t requested, argument
70 stream_bucket_ctx_t *ctx = bucket->data;
76 stream_bucket_readline(serf_bucket_t *bucket, int acceptable, argument
79 stream_bucket_ctx_t *ctx = bucket->data;
85 stream_bucket_peek(serf_bucket_t *bucket, const char **data, apr_size_t *len) argument
87 stream_bucket_ctx_t *ctx = bucket->data;
/freebsd-11-stable/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 = calloc(cache_size, sizeof(struct bucket));
88 struct bucket *gcache = calloc(cache_size, sizeof(struct bucket));
103 struct bucket *b;
104 struct bucket *gcache = (struct bucket *)private_data;
172 struct bucket *
[all...]
/freebsd-11-stable/contrib/serf/
H A Dserf_bucket_util.h27 * for implementing buckets. It is not needed by users of the bucket
39 * Basic bucket creation function.
41 * This function will create a bucket of @a type, allocating the necessary
42 * memory from @a allocator. The @a data bucket-private information will
43 * be stored into the bucket.
57 serf_bucket_t *bucket,
70 serf_bucket_t *bucket,
81 * of bucket cannot be found within @a bucket.
84 serf_bucket_t *bucket,
[all...]
/freebsd-11-stable/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-11-stable/libexec/rtld-elf/
H A Dmalloc.c82 u_char ovu_index; /* bucket # */
112 static int pagebucket; /* page size bucket */
155 register int bucket; local
174 bucket = 0;
178 bucket++;
180 pagebucket = bucket;
189 amt = 8; /* size of first bucket */
190 bucket = 0;
192 amt = 16; /* size of first bucket */
193 bucket
[all...]
/freebsd-11-stable/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-11-stable/contrib/ntp/sntp/libevent/
H A Dratelim-internal.h35 /** A token bucket is an internal structure that tracks how many bytes we are
42 /** When was this bucket last updated? Measured in abstract 'ticks'
43 * relative to the token bucket configuration. */
47 /** Configuration info for a token bucket or set of token buckets. */
66 /** The current tick is 'current_tick': add bytes to 'bucket' as specified in
68 int ev_token_bucket_update_(struct ev_token_bucket *bucket,
77 /** Adjust 'bucket' to respect 'cfg', and note that it was last updated in
79 * configuration of 'bucket'; otherwise, we are setting it up for the first
82 int ev_token_bucket_init_(struct ev_token_bucket *bucket,
/freebsd-11-stable/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
197 size_t hashes[2], bucket; local
[all...]

Completed in 137 milliseconds

12345