Lines Matching defs:sobj

56  *   entity name (sobj->name) [length is in cache_socache_info_t->name_len]
358 cache_socache_object_t *sobj;
422 obj->vobj = sobj = apr_pcalloc(r->pool, sizeof(*sobj));
425 sobj->key = obj->key;
426 sobj->name = obj->key;
444 cache_socache_object_t *sobj;
456 sobj = apr_pcalloc(r->pool, sizeof(cache_socache_object_t));
464 apr_pool_create(&sobj->pool, r->pool);
466 sobj->buffer = apr_palloc(sobj->pool, dconf->max + 1);
467 sobj->buffer_len = dconf->max + 1;
475 apr_pool_destroy(sobj->pool);
476 sobj->pool = NULL;
480 buffer_len = sobj->buffer_len;
483 strlen(key), sobj->buffer, &buffer_len, r->pool);
489 apr_pool_destroy(sobj->pool);
490 sobj->pool = NULL;
497 apr_pool_destroy(sobj->pool);
498 sobj->pool = NULL;
501 if (buffer_len >= sobj->buffer_len) {
504 apr_pool_destroy(sobj->pool);
505 sobj->pool = NULL;
510 memcpy(&format, sobj->buffer, sizeof(format));
517 memcpy(&expire, sobj->buffer + slider, sizeof(expire));
521 rc = read_array(r, varray, sobj->buffer, buffer_len, &slider);
525 apr_pool_destroy(sobj->pool);
526 sobj->pool = NULL;
538 apr_pool_destroy(sobj->pool);
539 sobj->pool = NULL;
543 buffer_len = sobj->buffer_len;
546 (unsigned char *) nkey, strlen(nkey), sobj->buffer,
553 apr_pool_destroy(sobj->pool);
554 sobj->pool = NULL;
561 apr_pool_destroy(sobj->pool);
562 sobj->pool = NULL;
565 if (buffer_len >= sobj->buffer_len) {
583 sobj->key = nkey;
584 sobj->name = key;
587 memcpy(&sobj->socache_info, sobj->buffer, sizeof(cache_socache_info_t));
597 info->status = sobj->socache_info.status;
598 info->date = sobj->socache_info.date;
599 info->expire = sobj->socache_info.expire;
600 info->request_time = sobj->socache_info.request_time;
601 info->response_time = sobj->socache_info.response_time;
603 memcpy(&info->control, &sobj->socache_info.control, sizeof(cache_control_t));
605 if (sobj->socache_info.name_len <= buffer_len - slider) {
606 if (strncmp((const char *) sobj->buffer + slider, sobj->name,
607 sobj->socache_info.name_len)) {
610 apr_pool_destroy(sobj->pool);
611 sobj->pool = NULL;
614 slider += sobj->socache_info.name_len;
623 if (sobj->socache_info.header_only && !r->header_only) {
626 sobj->key);
627 apr_pool_destroy(sobj->pool);
628 sobj->pool = NULL;
636 if (APR_SUCCESS != read_table(h, r, h->resp_hdrs, sobj->buffer, buffer_len,
642 if (APR_SUCCESS != read_table(h, r, h->req_hdrs, sobj->buffer, buffer_len,
650 sobj->body = apr_brigade_create(r->pool, r->connection->bucket_alloc);
665 e = apr_bucket_immortal_create((const char *) sobj->buffer + slider,
668 APR_BRIGADE_INSERT_TAIL(sobj->body, e);
673 apr_brigade_write(sobj->body, NULL, NULL, (const char *) sobj->buffer
677 apr_pool_destroy(sobj->pool);
678 sobj->pool = NULL;
683 obj->vobj = sobj;
693 apr_pool_destroy(sobj->pool);
694 sobj->pool = NULL;
708 apr_pool_destroy(sobj->pool);
709 sobj->pool = NULL;
724 cache_socache_object_t *sobj;
726 sobj = (cache_socache_object_t *) h->cache_obj->vobj;
727 if (!sobj) {
736 "could not acquire lock, ignoring: %s", sobj->key);
737 apr_pool_destroy(sobj->pool);
738 sobj->pool = NULL;
743 r->server, (unsigned char *) sobj->key, strlen(sobj->key), r->pool);
748 "could not release lock, ignoring: %s", sobj->key);
749 apr_pool_destroy(sobj->pool);
750 sobj->pool = NULL;
767 cache_socache_object_t *sobj = (cache_socache_object_t*) h->cache_obj->vobj;
770 e = APR_BRIGADE_FIRST(sobj->body);
772 if (e != APR_BRIGADE_SENTINEL(sobj->body)) {
790 cache_socache_object_t *sobj = (cache_socache_object_t*) obj->vobj;
796 sobj->headers_out = ap_cache_cacheable_headers_out(r);
800 sobj->headers_in = ap_cache_cacheable_headers_in(r);
803 sobj->expire
808 apr_pool_create(&sobj->pool, r->pool);
810 sobj->buffer = apr_palloc(sobj->pool, dconf->max);
811 sobj->buffer_len = dconf->max;
812 socache_info = (cache_socache_info_t *) sobj->buffer;
814 if (sobj->headers_out) {
817 vary = apr_table_get(sobj->headers_out, "Vary");
823 memcpy(sobj->buffer, &format, sizeof(format));
826 memcpy(sobj->buffer + slider, &obj->info.expire,
833 if (APR_SUCCESS != (rv = store_array(varray, sobj->buffer,
834 sobj->buffer_len, &slider))) {
838 apr_pool_destroy(sobj->pool);
839 sobj->pool = NULL;
847 apr_pool_destroy(sobj->pool);
848 sobj->pool = NULL;
854 (unsigned char *) obj->key, strlen(obj->key), sobj->expire,
855 (unsigned char *) sobj->buffer, (unsigned int) slider,
856 sobj->pool);
867 apr_pool_destroy(sobj->pool);
868 sobj->pool = NULL;
872 obj->key = sobj->key = regen_key(r->pool, sobj->headers_in, varray,
873 sobj->name);
880 socache_info->entity_version = sobj->socache_info.entity_version++;
889 socache_info->header_only = sobj->socache_info.header_only;
892 socache_info->name_len = strlen(sobj->name);
897 if (slider + socache_info->name_len >= sobj->buffer_len) {
900 sobj->name);
901 apr_pool_destroy(sobj->pool);
902 sobj->pool = NULL;
905 memcpy(sobj->buffer + slider, sobj->name, socache_info->name_len);
908 if (sobj->headers_out) {
909 if (APR_SUCCESS != store_table(sobj->headers_out, sobj->buffer,
910 sobj->buffer_len, &slider)) {
912 "out-headers didn't fit in buffer: %s", sobj->name);
913 apr_pool_destroy(sobj->pool);
914 sobj->pool = NULL;
921 if (sobj->headers_in) {
922 if (APR_SUCCESS != store_table(sobj->headers_in, sobj->buffer,
923 sobj->buffer_len, &slider)) {
926 sobj->key);
927 apr_pool_destroy(sobj->pool);
928 sobj->pool = NULL;
933 sobj->body_offset = slider;
943 cache_socache_object_t *sobj =
949 if (!sobj->offset) {
950 sobj->offset = dconf->readsize;
952 if (!sobj->timeout && dconf->readtime) {
953 sobj->timeout = apr_time_now() + dconf->readtime;
956 if (!sobj->newbody) {
957 if (sobj->body) {
958 apr_brigade_cleanup(sobj->body);
961 sobj->body = apr_brigade_create(r->pool,
964 sobj->newbody = 1;
966 if (sobj->offset) {
967 apr_brigade_partition(in, sobj->offset, &e);
977 if (sobj->done || !sobj->pool) {
986 sobj->done = 1;
1015 apr_pool_destroy(sobj->pool);
1016 sobj->pool = NULL;
1025 sobj->file_size += length;
1026 if (sobj->file_size >= sobj->buffer_len - sobj->body_offset) {
1030 h->cache_obj->key, sobj->file_size, sobj->buffer_len - sobj->body_offset);
1031 apr_pool_destroy(sobj->pool);
1032 sobj->pool = NULL;
1041 apr_pool_destroy(sobj->pool);
1042 sobj->pool = NULL;
1045 APR_BRIGADE_INSERT_TAIL(sobj->body, e);
1052 sobj->offset -= length;
1053 if (sobj->offset <= 0) {
1054 sobj->offset = 0;
1057 if ((dconf->readtime && apr_time_now() > sobj->timeout)) {
1058 sobj->timeout = 0;
1074 apr_pool_destroy(sobj->pool);
1075 sobj->pool = NULL;
1080 if ((errno == 0) && (sobj->file_size != cl)) {
1084 apr_pool_destroy(sobj->pool);
1085 sobj->pool = NULL;
1102 cache_socache_object_t *sobj = (cache_socache_object_t *) obj->vobj;
1107 len = sobj->buffer_len - sobj->body_offset;
1108 rv = apr_brigade_flatten(sobj->body, (char *) sobj->buffer
1109 + sobj->body_offset, &len);
1113 sobj->key);
1116 if (len >= sobj->buffer_len - sobj->body_offset) {
1128 apr_pool_destroy(sobj->pool);
1129 sobj->pool = NULL;
1135 (unsigned char *) sobj->key, strlen(sobj->key), sobj->expire,
1136 sobj->buffer, (unsigned int) sobj->body_offset + len, sobj->pool);
1142 apr_pool_destroy(sobj->pool);
1143 sobj->pool = NULL;
1149 "could not write to cache, ignoring: %s", sobj->key);
1155 sobj->name, (apr_uint32_t)apr_time_sec(sobj->expire - r->request_time));
1157 apr_pool_destroy(sobj->pool);
1158 sobj->pool = NULL;
1171 apr_pool_destroy(sobj->pool);
1172 sobj->pool = NULL;
1177 r->server, (unsigned char *) sobj->key, strlen(sobj->key), r->pool);
1186 apr_pool_destroy(sobj->pool);
1187 sobj->pool = NULL;