/freebsd-11-stable/contrib/serf/buckets/ |
H A D | request_buckets.c | 58 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 D | barrier_buckets.c | 44 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 D | aggregate_buckets.c | 27 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 D | bwtp_buckets.c | 137 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 D | response_body_buckets.c | 51 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 D | limit_buckets.c | 45 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 D | chunk_buckets.c | 59 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 D | response_buckets.c | 95 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 D | file_buckets.c | 86 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 D | socket_buckets.c | 84 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 D | iovec_buckets.c | 61 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 D | allocator.c | 50 * 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 D | mmap_buckets.c | 52 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 D | simple_buckets.c | 96 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 D | symtab.c | 10 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 D | eagain_bucket.c | 2 * 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 D | stream_bucket.c | 2 * 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 D | archive_entry_link_resolver.c | 265 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 D | archive_write_disk_set_standard_lookup.c | 53 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 D | serf_bucket_util.h | 27 * 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 D | tree-phinodes.c | 134 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 D | malloc.c | 82 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 D | cvmx-tim.c | 73 * @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 D | ratelim-internal.h | 35 /** 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 D | ckh.c | 4 * 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...] |