hyperestraier/trunk/estnode.c

/*************************************************************************************************
 * Implementation of the node API
 *                                                      Copyright (C) 2004-2005 Mikio Hirabayashi
 * This file is part of Hyper Estraier.
 * Hyper Estraier is free software; you can redistribute it and/or modify it under the terms of
 * the GNU Lesser General Public License as published by the Free Software Foundation; either
 * version 2.1 of the License or any later version.  Hyper Estraier is distributed in the hope
 * that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Lesser General Public
 * License for more details.
 * You should have received a copy of the GNU Lesser General Public License along with Hyper
 * Estraier; if not, write to the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
 * Boston, MA 02111-1307 USA.
 *************************************************************************************************/


#include "estraier.h"
#include "estmtdb.h"
#include "estnode.h"
#include "myconf.h"

#if defined(_SYS_MSVC_) || defined(_SYS_MINGW_)
#define socklen_t       int
#define in_addr_t       int
#elif defined(_SYS_MACOSX_)
#define socklen_t       int
#endif

#define ESTNUMBUFSIZ   32                /* size of a buffer for a number */
#define ESTPATHBUFSIZ  4096              /* size of a buffer for a path */
#define ESTIOBUFSIZ    8192              /* size of a buffer for I/O */
#define ESTMINIBNUM    31                /* bucket number of map for attributes */
#define ESTLISTUNIT    64                /* allocation unit number of a list */
#define ESTDNHOLDSEC   300               /* holding time of domain names */
#define ESTDNHOLDNUM   4096              /* holding number of domain names */

typedef struct {                         /* type of structure for interaction of a URL */
  int alive;                             /* whether to be alive */
  pthread_cond_t *cond;                  /* condition variable */
  const char *url;                       /* URL */
  const char *pxhost;                    /* host name of proxy */
  int pxport;                            /* port number of proxy */
  const char *auth;                      /* authority */
  const CBLIST *reqheads;                /* request headers */
  const char *reqbody;                   /* request body */
  int rbsiz;                             /* size of the request body */
  int *rescodep;                         /* pointer to a variable for status code */
  CBMAP *resheads;                       /* response headers */
  CBDATUM *resbody;                      /* response body */
} TARGSHUTTLE;


/* private function prototypes */
static int est_sock_close(int sock);
static int est_inet_aton(const char *cp, struct in_addr *inp);
static void *est_url_shuttle_impl(void *targ);
static void est_sockpt_down(void *sp);
static int est_node_set_inform(ESTNODE *node);
static void est_parse_search_header(ESTNODERES *nres, const char *str);
static void est_parse_search_body(ESTNODERES *nres, char *str);


/*************************************************************************************************
 * API for the network environment
 *************************************************************************************************/


/* Cache of host addresses */
CBMAP *est_host_addrs = NULL;


/* Initialize the networking environment. */
int est_init_net_env(void){
#if defined(_SYS_MSVC_) || defined(_SYS_MINGW_)
  WSADATA wsaData;
  if(est_host_addrs) return TRUE;
  est_host_addrs = cbmapopenex(ESTDNHOLDNUM + 1);
  return WSAStartup(MAKEWORD(2,0), &wsaData) == 0;
#else
  if(est_host_addrs) return TRUE;
  est_host_addrs = cbmapopenex(ESTDNHOLDNUM + 1);
  return TRUE;
#endif
}


/* Free the networking environment. */
void est_free_net_env(void){
#if defined(_SYS_MSVC_) || defined(_SYS_MINGW_)
  if(!est_host_addrs) return;
  cbmapclose(est_host_addrs);
  WSACleanup();
#else
  if(!est_host_addrs) return;
  cbmapclose(est_host_addrs);
#endif
}


/*************************************************************************************************
 * API for search result of node
 *************************************************************************************************/


/* Delete a node result object. */
void est_noderes_delete(ESTNODERES *nres){
  int i;
  assert(nres);
  cbmapclose(nres->hints);
  for(i = nres->top; i < nres->top + nres->dnum; i++){
    free(nres->docs[i].snippet);
    cbmapclose(nres->docs[i].attrs);
  }
  free(nres->docs);
  free(nres);
}


/* Get a map object for hints of a node result object. */
CBMAP *est_noderes_hints(ESTNODERES *nres){
  assert(nres);
  return nres->hints;
}


/* Get the number of documents in a node result object. */
int est_noderes_doc_num(ESTNODERES *nres){
  assert(nres);
  return nres->dnum;
}


/* Refer a result document object in a node result object. */
ESTRESDOC *est_noderes_get_doc(ESTNODERES *nres, int index){
  assert(nres && index >= 0);
  if(index >= nres->dnum) return NULL;
  return nres->docs + (nres->top + index);
}


/* Get the URI of a result document object. */
const char *est_resdoc_uri(ESTRESDOC *rdoc){
  assert(rdoc);
  return rdoc->uri;
}


/* Get a list of attribute names of a result document object. */
CBLIST *est_resdoc_attr_names(ESTRESDOC *rdoc){
  CBLIST *names;
  assert(rdoc);
  names = cbmapkeys(rdoc->attrs);
  cblistsort(names);
  return names;
}


/* Get the value of an attribute of a result document object. */
const char *est_resdoc_attr(ESTRESDOC *rdoc, const char *name){
  assert(rdoc && name);
  return cbmapget(rdoc->attrs, name, -1, NULL);
}


/* Get the value of an attribute of a result document object. */
const char *est_resdoc_snippet(ESTRESDOC *rdoc){
  assert(rdoc);
  return rdoc->snippet;
}


/*************************************************************************************************
 * API for node
 *************************************************************************************************/


/* Create a node connection object. */
ESTNODE *est_node_new(const char *url){
  ESTNODE *node;
  node = cbmalloc(sizeof(ESTNODE));
  node->url = cbmemdup(url, -1);
  node->pxhost = NULL;
  node->pxport = 0;
  node->timeout = -1;
  node->auth = NULL;
  node->name = NULL;
  node->label = NULL;
  node->dnum = -1;
  node->wnum = -1;
  node->size = -1.0;
  node->status = 0;
  node->heads = cbmapopenex(ESTMINIBNUM);
  return node;
}


/* Destroy a node connection object. */
void est_node_delete(ESTNODE *node){
  assert(node);
  cbmapclose(node->heads);
  free(node->label);
  free(node->name);
  free(node->auth);
  free(node->pxhost);
  free(node->url);
  free(node);
}


/* Get the status code of the last request of a node. */
int est_node_status(ESTNODE *node){
  assert(node);
  return node->status;
}


/* Set the proxy information of a node connection object. */
void est_node_set_proxy(ESTNODE *node, const char *host, int port){
  assert(node && host && port >= 0);
  free(node->pxhost);
  node->pxhost = cbmemdup(host, -1);
  node->pxport = port;
}


/* Set timeout of a connection. */
void est_node_set_timeout(ESTNODE *node, int sec){
  assert(node && sec >= 0);
  node->timeout = sec;
}


/* Set the authoririty information of a node connection object. */
void est_node_set_auth(ESTNODE *node, const char *name, const char *passwd){
  assert(node && name && passwd);
  free(node->auth);
  node->auth = cbsprintf("%s:%s", name, passwd);
}


/* Add a document to a node. */
int est_node_put_doc(ESTNODE *node, ESTDOC *doc){
  CBLIST *reqheads;
  const char *kbuf;
  char url[ESTPATHBUFSIZ], *vbuf, *reqbody;
  int rescode, err, ksiz;
  assert(node && doc);
  err = FALSE;
  sprintf(url, "%s/put_doc", node->url);
  reqheads = cblistopen();
  if(cbmaprnum(node->heads) > 0){
    cbmapiterinit(node->heads);
    while((kbuf = cbmapiternext(node->heads, &ksiz)) != NULL){
      vbuf = cbsprintf("%s: %s", kbuf, cbmapget(node->heads, kbuf, ksiz, NULL));
      cblistpush(reqheads, vbuf, -1);
      free(vbuf);
    }
  }
  cblistpush(reqheads, "Content-Type: " ESTDRAFTTYPE, -1);
  reqbody = est_doc_dump_draft(doc);
  if(!est_url_shuttle(url, node->pxhost, node->pxport, node->timeout, node->auth, reqheads,
                      reqbody, strlen(reqbody), &rescode, NULL, NULL)){
    node->status = -1;
    err = TRUE;
  }
  if(!err){
    node->status = rescode;
    if(rescode != 200) err = TRUE;
  }
  free(reqbody);
  cblistclose(reqheads);
  return err ? FALSE : TRUE;
}


/* Remove a document from a node. */
int est_node_out_doc(ESTNODE *node, int id){
  CBLIST *reqheads;
  CBDATUM *reqbody;
  const char *kbuf;
  char url[ESTPATHBUFSIZ], *vbuf;
  int rescode, err, ksiz;
  assert(node && id > 0);
  err = FALSE;
  sprintf(url, "%s/out_doc", node->url);
  reqheads = cblistopen();
  if(cbmaprnum(node->heads) > 0){
    cbmapiterinit(node->heads);
    while((kbuf = cbmapiternext(node->heads, &ksiz)) != NULL){
      vbuf = cbsprintf("%s: %s", kbuf, cbmapget(node->heads, kbuf, ksiz, NULL));
      cblistpush(reqheads, vbuf, -1);
      free(vbuf);
    }
  }
  cblistpush(reqheads, "Content-Type: " ESTFORMTYPE, -1);
  reqbody = cbdatumopen("", 0);
  est_datum_printf(reqbody, "id=%d", id);
  if(!est_url_shuttle(url, node->pxhost, node->pxport, node->timeout, node->auth, reqheads,
                      cbdatumptr(reqbody), cbdatumsize(reqbody), &rescode, NULL, NULL)){
    node->status = -1;
    err = TRUE;
  }
  if(!err){
    node->status = rescode;
    if(rescode != 200) err = TRUE;
  }
  cbdatumclose(reqbody);
  cblistclose(reqheads);
  return err ? FALSE : TRUE;
}


/* Remove a document specified by URI from a node. */
int est_node_out_doc_by_uri(ESTNODE *node, const char *uri){
  CBLIST *reqheads;
  CBDATUM *reqbody;
  const char *kbuf;
  char url[ESTPATHBUFSIZ], *vbuf;
  int rescode, err, ksiz;
  assert(node && uri);
  err = FALSE;
  sprintf(url, "%s/out_doc", node->url);
  reqheads = cblistopen();
  if(cbmaprnum(node->heads) > 0){
    cbmapiterinit(node->heads);
    while((kbuf = cbmapiternext(node->heads, &ksiz)) != NULL){
      vbuf = cbsprintf("%s: %s", kbuf, cbmapget(node->heads, kbuf, ksiz, NULL));
      cblistpush(reqheads, vbuf, -1);
      free(vbuf);
    }
  }
  cblistpush(reqheads, "Content-Type: " ESTFORMTYPE, -1);
  reqbody = cbdatumopen("", 0);
  est_datum_printf(reqbody, "uri=%?", uri);
  if(!est_url_shuttle(url, node->pxhost, node->pxport, node->timeout, node->auth, reqheads,
                      cbdatumptr(reqbody), cbdatumsize(reqbody), &rescode, NULL, NULL)){
    node->status = -1;
    err = TRUE;
  }
  if(!err){
    node->status = rescode;
    if(rescode != 200) err = TRUE;
  }
  cbdatumclose(reqbody);
  cblistclose(reqheads);
  return err ? FALSE : TRUE;
}


/* Retrieve a document in a node. */
ESTDOC *est_node_get_doc(ESTNODE *node, int id){
  ESTDOC *doc;
  CBLIST *reqheads;
  CBDATUM *reqbody, *resbody;
  const char *kbuf;
  char url[ESTPATHBUFSIZ], *vbuf;
  int rescode, err, ksiz;
  assert(node && id > 0);
  err = FALSE;
  sprintf(url, "%s/get_doc", node->url);
  reqheads = cblistopen();
  if(cbmaprnum(node->heads) > 0){
    cbmapiterinit(node->heads);
    while((kbuf = cbmapiternext(node->heads, &ksiz)) != NULL){
      vbuf = cbsprintf("%s: %s", kbuf, cbmapget(node->heads, kbuf, ksiz, NULL));
      cblistpush(reqheads, vbuf, -1);
      free(vbuf);
    }
  }
  cblistpush(reqheads, "Content-Type: " ESTFORMTYPE, -1);
  reqbody = cbdatumopen("", 0);
  est_datum_printf(reqbody, "id=%d", id);
  resbody = cbdatumopen("", 0);
  if(!est_url_shuttle(url, node->pxhost, node->pxport, node->timeout, node->auth, reqheads,
                      cbdatumptr(reqbody), cbdatumsize(reqbody), &rescode, NULL, resbody)){
    node->status = -1;
    err = TRUE;
  }
  if(!err){
    node->status = rescode;
    if(rescode != 200) err = TRUE;
  }
  doc = err ? NULL : est_doc_new_from_draft(cbdatumptr(resbody));
  cbdatumclose(resbody);
  cbdatumclose(reqbody);
  cblistclose(reqheads);
  return doc;
}


/* Retrieve a document specified by URI in a node. */
ESTDOC *est_node_get_doc_by_uri(ESTNODE *node, const char *uri){
  ESTDOC *doc;
  CBLIST *reqheads;
  CBDATUM *reqbody, *resbody;
  const char *kbuf;
  char url[ESTPATHBUFSIZ], *vbuf;
  int rescode, err, ksiz;
  assert(node && uri);
  err = FALSE;
  sprintf(url, "%s/get_doc", node->url);
  reqheads = cblistopen();
  if(cbmaprnum(node->heads) > 0){
    cbmapiterinit(node->heads);
    while((kbuf = cbmapiternext(node->heads, &ksiz)) != NULL){
      vbuf = cbsprintf("%s: %s", kbuf, cbmapget(node->heads, kbuf, ksiz, NULL));
      cblistpush(reqheads, vbuf, -1);
      free(vbuf);
    }
  }
  cblistpush(reqheads, "Content-Type: " ESTFORMTYPE, -1);
  reqbody = cbdatumopen("", 0);
  est_datum_printf(reqbody, "uri=%?", uri);
  resbody = cbdatumopen("", 0);
  if(!est_url_shuttle(url, node->pxhost, node->pxport, node->timeout, node->auth, reqheads,
                      cbdatumptr(reqbody), cbdatumsize(reqbody), &rescode, NULL, resbody)){
    node->status = -1;
    err = TRUE;
  }
  if(!err){
    node->status = rescode;
    if(rescode != 200) err = TRUE;
  }
  doc = err ? NULL : est_doc_new_from_draft(cbdatumptr(resbody));
  cbdatumclose(resbody);
  cbdatumclose(reqbody);
  cblistclose(reqheads);
  return doc;
}


/* Retrieve the value of an attribute of a document in a node. */
char *est_node_get_doc_attr(ESTNODE *node, int id, const char *name){
  CBLIST *reqheads;
  CBDATUM *reqbody, *resbody;
  const char *kbuf;
  char url[ESTPATHBUFSIZ], *vbuf;
  int rescode, err, ksiz;
  assert(node && id > 0);
  err = FALSE;
  sprintf(url, "%s/get_doc_attr", node->url);
  reqheads = cblistopen();
  if(cbmaprnum(node->heads) > 0){
    cbmapiterinit(node->heads);
    while((kbuf = cbmapiternext(node->heads, &ksiz)) != NULL){
      vbuf = cbsprintf("%s: %s", kbuf, cbmapget(node->heads, kbuf, ksiz, NULL));
      cblistpush(reqheads, vbuf, -1);
      free(vbuf);
    }
  }
  cblistpush(reqheads, "Content-Type: " ESTFORMTYPE, -1);
  reqbody = cbdatumopen("", 0);
  est_datum_printf(reqbody, "id=%d&attr=%?", id, name);
  resbody = cbdatumopen("", 0);
  if(!est_url_shuttle(url, node->pxhost, node->pxport, node->timeout, node->auth, reqheads,
                      cbdatumptr(reqbody), cbdatumsize(reqbody), &rescode, NULL, resbody)){
    node->status = -1;
    err = TRUE;
  }
  if(!err){
    node->status = rescode;
    if(rescode != 200) err = TRUE;
  }
  if(err){
    cbdatumclose(resbody);
    vbuf = NULL;
  } else {
    vbuf = cbdatumtomalloc(resbody, NULL);
    cbstrtrim(vbuf);
  }
  cbdatumclose(reqbody);
  cblistclose(reqheads);
  return vbuf;
}


/* Retrieve the value of an attribute of a document specified by URI in a node. */
char *est_node_get_doc_attr_by_uri(ESTNODE *node, const char *uri, const char *name){
  CBLIST *reqheads;
  CBDATUM *reqbody, *resbody;
  const char *kbuf;
  char url[ESTPATHBUFSIZ], *vbuf;
  int rescode, err, ksiz;
  assert(node && uri);
  err = FALSE;
  sprintf(url, "%s/get_doc_attr", node->url);
  reqheads = cblistopen();
  if(cbmaprnum(node->heads) > 0){
    cbmapiterinit(node->heads);
    while((kbuf = cbmapiternext(node->heads, &ksiz)) != NULL){
      vbuf = cbsprintf("%s: %s", kbuf, cbmapget(node->heads, kbuf, ksiz, NULL));
      cblistpush(reqheads, vbuf, -1);
      free(vbuf);
    }
  }
  cblistpush(reqheads, "Content-Type: " ESTFORMTYPE, -1);
  reqbody = cbdatumopen("", 0);
  est_datum_printf(reqbody, "uri=%?&attr=%?", uri, name);
  resbody = cbdatumopen("", 0);
  if(!est_url_shuttle(url, node->pxhost, node->pxport, node->timeout, node->auth, reqheads,
                      cbdatumptr(reqbody), cbdatumsize(reqbody), &rescode, NULL, resbody)){
    node->status = -1;
    err = TRUE;
  }
  if(!err){
    node->status = rescode;
    if(rescode != 200) err = TRUE;
  }
  if(err){
    cbdatumclose(resbody);
    vbuf = NULL;
  } else {
    vbuf = cbdatumtomalloc(resbody, NULL);
    cbstrtrim(vbuf);
  }
  cbdatumclose(reqbody);
  cblistclose(reqheads);
  return vbuf;
}


/* Get the ID of a document spacified by URI. */
int est_node_uri_to_id(ESTNODE *node, const char *uri){
  CBLIST *reqheads;
  CBDATUM *reqbody, *resbody;
  const char *kbuf;
  char url[ESTPATHBUFSIZ], *vbuf;
  int rescode, err, ksiz, id;
  assert(node && uri);
  err = FALSE;
  sprintf(url, "%s/uri_to_id", node->url);
  reqheads = cblistopen();
  if(cbmaprnum(node->heads) > 0){
    cbmapiterinit(node->heads);
    while((kbuf = cbmapiternext(node->heads, &ksiz)) != NULL){
      vbuf = cbsprintf("%s: %s", kbuf, cbmapget(node->heads, kbuf, ksiz, NULL));
      cblistpush(reqheads, vbuf, -1);
      free(vbuf);
    }
  }
  cblistpush(reqheads, "Content-Type: " ESTFORMTYPE, -1);
  reqbody = cbdatumopen("", 0);
  est_datum_printf(reqbody, "uri=%?", uri);
  resbody = cbdatumopen("", 0);
  if(!est_url_shuttle(url, node->pxhost, node->pxport, node->timeout, node->auth, reqheads,
                      cbdatumptr(reqbody), cbdatumsize(reqbody), &rescode, NULL, resbody)){
    node->status = -1;
    err = TRUE;
  }
  if(!err){
    node->status = rescode;
    if(rescode != 200) err = TRUE;
  }
  id = err ? -1 : atoi(cbdatumptr(resbody));
  cbdatumclose(resbody);
  cbdatumclose(reqbody);
  cblistclose(reqheads);
  return id;
}


/* Get the name of a node. */
const char *est_node_name(ESTNODE *node){
  assert(node);
  if(node->name) return node->name;
  est_node_set_inform(node);
  return node->name;
}


/* Get the label of a node. */
const char *est_node_label(ESTNODE *node){
  assert(node);
  if(node->label) return node->label;
  est_node_set_inform(node);
  return node->label;
}


/* Get the number of documents in a node. */
int est_node_doc_num(ESTNODE *node){
  assert(node);
  if(node->dnum >= 0) return node->dnum;
  est_node_set_inform(node);
  return node->dnum;
}


/* Get the number of words in a node. */
int est_node_word_num(ESTNODE *node){
  assert(node);
  if(node->wnum >= 0) return node->wnum;
  est_node_set_inform(node);
  return node->wnum;
}


/* Get the size of the datbase of a node. */
double est_node_size(ESTNODE *node){
  assert(node);
  if(node->size >= 0.0) return node->size;
  est_node_set_inform(node);
  return node->size;
}


/* Search documents corresponding a condition for a node. */
ESTNODERES *est_node_search(ESTNODE *node, ESTCOND *cond, int depth){
  ESTNODERES *nres;
  const CBLIST *attrs;
  CBLIST *reqheads;
  CBDATUM *reqbody, *resbody;
  const char *kbuf, *phrase, *order;
  char buf[ESTPATHBUFSIZ], *vbuf, *ptr, *pv, *ep;
  int i, rescode, err, ksiz, max, plen, part, end;
  assert(node && cond && depth >= 0);
  err = FALSE;
  sprintf(buf, "%s/search", node->url);
  reqheads = cblistopen();
  if(cbmaprnum(node->heads) > 0){
    cbmapiterinit(node->heads);
    while((kbuf = cbmapiternext(node->heads, &ksiz)) != NULL){
      vbuf = cbsprintf("%s: %s", kbuf, cbmapget(node->heads, kbuf, ksiz, NULL));
      cblistpush(reqheads, vbuf, -1);
      free(vbuf);
    }
  }
  cblistpush(reqheads, "Content-Type: " ESTFORMTYPE, -1);
  reqbody = cbdatumopen("", 0);
  if((phrase = est_cond_phrase(cond)) != NULL) est_datum_printf(reqbody, "phrase=%?", phrase);
  if((attrs = est_cond_attrs(cond)) != NULL){
    for(i = 0; i < cblistnum(attrs); i++){
      if(cbdatumsize(reqbody) > 0) cbdatumcat(reqbody, "&", 1);
      est_datum_printf(reqbody, "attr%d=%?", i + 1, cblistval(attrs, i, NULL));
    }
  }
  if((max = est_cond_max(cond)) >= 0){
    if(cbdatumsize(reqbody) > 0) cbdatumcat(reqbody, "&", 1);
    est_datum_printf(reqbody, "max=%d", max);
  } else {
    if(cbdatumsize(reqbody) > 0) cbdatumcat(reqbody, "&", 1);
    est_datum_printf(reqbody, "max=%d", INT_MAX / 2);
  }
  if((order = est_cond_order(cond)) != NULL){
    if(cbdatumsize(reqbody) > 0) cbdatumcat(reqbody, "&", 1);
    est_datum_printf(reqbody, "order=%?", order);
  }
  if(cbdatumsize(reqbody) > 0) cbdatumcat(reqbody, "&", 1);
  est_datum_printf(reqbody, "depth=%d", depth);
  resbody = cbdatumopen("", 0);
  if(!est_url_shuttle(buf, node->pxhost, node->pxport, node->timeout, node->auth, reqheads,
                      cbdatumptr(reqbody), cbdatumsize(reqbody), &rescode, NULL, resbody)){
    node->status = -1;
    err = TRUE;
  }
  if(!err){
    node->status = rescode;
    if(rescode != 200) err = TRUE;
  }
  if(err){
    cbdatumclose(resbody);
    cbdatumclose(reqbody);
    cblistclose(reqheads);
    return NULL;
  }
  ptr = cbdatumtomalloc(resbody, NULL);
  if(!(pv = strchr(ptr, '\n')) || pv <= ptr + 3){
    free(ptr);
    cbdatumclose(reqbody);
    cblistclose(reqheads);
    return NULL;
  }
  *pv = '\0';
  if(pv[-1] == '\r') pv[-1] = '\0';
  plen = strlen(ptr);
  pv++;
  ep = pv;
  nres = est_noderes_new();
  part = 0;
  end = FALSE;
  while(*ep != '\0'){
    if(*ep == *ptr && cbstrfwmatch(ep, ptr) && ep[-1] == '\n' &&
       (ep[plen] == '\r' || ep[plen] == '\n' || ep[plen] == ':')){
      *ep = '\0';
      if(part == 0){
        est_parse_search_header(nres, pv);
      } else {
        est_parse_search_body(nres, pv);
      }
      ep += plen;
      if(cbstrfwmatch(ep, ":END")){
        end = TRUE;
        break;
      }
      if(*ep == '\r') ep++;
      if(*ep == '\n') ep++;
      pv = ep;
      part++;
    } else {
      ep++;
    }
  }
  free(ptr);
  cbdatumclose(reqbody);
  cblistclose(reqheads);
  if(!end){
    est_noderes_delete(nres);
    return NULL;
  }
  return nres;
}


/* Manage a user account of a node. */
int est_node_set_user(ESTNODE *node, const char *name, int mode){
  CBLIST *reqheads;
  CBDATUM *reqbody, *resbody;
  const char *kbuf;
  char url[ESTPATHBUFSIZ], *vbuf;
  int rescode, err, ksiz;
  assert(node && name);
  err = FALSE;
  sprintf(url, "%s/_set_user", node->url);
  reqheads = cblistopen();
  if(cbmaprnum(node->heads) > 0){
    cbmapiterinit(node->heads);
    while((kbuf = cbmapiternext(node->heads, &ksiz)) != NULL){
      vbuf = cbsprintf("%s: %s", kbuf, cbmapget(node->heads, kbuf, ksiz, NULL));
      cblistpush(reqheads, vbuf, -1);
      free(vbuf);
    }
  }
  cblistpush(reqheads, "Content-Type: " ESTFORMTYPE, -1);
  reqbody = cbdatumopen("", 0);
  est_datum_printf(reqbody, "name=%?&mode=%d", name, mode);
  resbody = cbdatumopen("", 0);
  if(!est_url_shuttle(url, node->pxhost, node->pxport, node->timeout, node->auth, reqheads,
                      cbdatumptr(reqbody), cbdatumsize(reqbody), &rescode, NULL, resbody)){
    node->status = -1;
    err = TRUE;
  }
  if(!err){
    node->status = rescode;
    if(rescode != 200) err = TRUE;
  }
  cbdatumclose(resbody);
  cbdatumclose(reqbody);
  cblistclose(reqheads);
  return err ? FALSE : TRUE;
}


/* Manage a link of a node. */
int est_node_set_link(ESTNODE *node, const char *url, const char *label, int credit){
  CBLIST *reqheads;
  CBDATUM *reqbody, *resbody;
  const char *kbuf;
  char myurl[ESTPATHBUFSIZ], *vbuf;
  int rescode, err, ksiz;
  assert(node && url && label);
  err = FALSE;
  sprintf(myurl, "%s/_set_link", node->url);
  reqheads = cblistopen();
  if(cbmaprnum(node->heads) > 0){
    cbmapiterinit(node->heads);
    while((kbuf = cbmapiternext(node->heads, &ksiz)) != NULL){
      vbuf = cbsprintf("%s: %s", kbuf, cbmapget(node->heads, kbuf, ksiz, NULL));
      cblistpush(reqheads, vbuf, -1);
      free(vbuf);
    }
  }
  cblistpush(reqheads, "Content-Type: " ESTFORMTYPE, -1);
  reqbody = cbdatumopen("", 0);
  if(credit >= 0){
    est_datum_printf(reqbody, "url=%?&label=%?&credit=%d", url, label, credit);
  } else {
    est_datum_printf(reqbody, "url=%?&label=%?", url, label);
  }
  resbody = cbdatumopen("", 0);
  if(!est_url_shuttle(myurl, node->pxhost, node->pxport, node->timeout, node->auth, reqheads,
                      cbdatumptr(reqbody), cbdatumsize(reqbody), &rescode, NULL, resbody)){
    node->status = -1;
    err = TRUE;
  }
  if(!err){
    node->status = rescode;
    if(rescode != 200) err = TRUE;
  }
  cbdatumclose(resbody);
  cbdatumclose(reqbody);
  cblistclose(reqheads);
  return err ? FALSE : TRUE;
}


/*************************************************************************************************
 * features for experts
 *************************************************************************************************/


/* Get the name of this host. */
const char *est_get_host_name(void){
  static char host[ESTPATHBUFSIZ];
  static int first = TRUE;
  if(!est_host_addrs) return "127.0.0.1";
  if(first){
    first = FALSE;
    if(gethostname(host, ESTPATHBUFSIZ - 1) == -1) return "127.0.0.1";
    return host;
  }
  return host;
}


/* Get the address of a host. */
char *est_get_host_addr(const char *name){
  static pthread_mutex_t mymutex = PTHREAD_MUTEX_INITIALIZER;
  struct hostent *info;
  const char *addr;
  char *buf, *pv, vbuf[64];
  int i, ost, nsiz, asiz, vsiz;
  assert(name);
  if(!est_host_addrs) return NULL;
  if(pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &ost) != 0) return NULL;
  if(pthread_mutex_lock(&mymutex) != 0){
    pthread_setcancelstate(ost, NULL);
    return NULL;
  }
  nsiz = strlen(name);
  buf = NULL;
  if((addr = cbmapget(est_host_addrs, name, nsiz, &asiz)) != NULL){
    buf = cbmemdup(addr, asiz);
    if((pv = strchr(buf, '\t')) != NULL){
      *pv = '\0';
      if((int)time(NULL) - atoi(pv + 1) > ESTDNHOLDSEC){
        free(buf);
        buf = NULL;
      }
    }
    cbmapmove(est_host_addrs, name, nsiz, FALSE);
  }
  pthread_mutex_unlock(&mymutex);
  pthread_setcancelstate(ost, NULL);
  if(buf){
    if(buf[0] != '\0') return buf;
    free(buf);
    return NULL;
  }
  if((info = gethostbyname(name)) != NULL && info->h_addr_list[0]){
    addr = inet_ntoa(*(struct in_addr *)info->h_addr_list[0]);
  } else {
    addr = NULL;
  }
  buf = addr ? cbmemdup(addr, -1) : NULL;
  if(pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &ost) == 0){
    if(pthread_mutex_lock(&mymutex) == 0){
      vsiz = sprintf(vbuf, "%s\t%d", addr ? addr : "", (int)time(NULL));
      cbmapput(est_host_addrs, name, nsiz, vbuf, vsiz, TRUE);
      if(cbmaprnum(est_host_addrs) > ESTDNHOLDNUM){
        cbmapiterinit(est_host_addrs);
        for(i = 0; i < ESTDNHOLDNUM / 4 &&
              (addr = cbmapiternext(est_host_addrs, &asiz)) != NULL; i++){
          cbmapout(est_host_addrs, addr, asiz);
        }
      }
      pthread_mutex_unlock(&mymutex);
    }
    pthread_setcancelstate(ost, NULL);
  }
  return buf;
}


/* Get a server socket of an address and a port. */
int est_get_server_sock(const char *addr, int port){
  struct sockaddr_in address;
  struct linger li;
  int ost, sock, optone;
  assert(port > 0);
  if(pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &ost) != 0) return -1;
  memset(&address, 0, sizeof(address));
  address.sin_family = AF_INET;
  if(!est_inet_aton(addr ? addr : "0.0.0.0", &address.sin_addr)){
    pthread_setcancelstate(ost, NULL);
    return -1;
  }
  address.sin_port = htons(port);
  if((sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1){
    pthread_setcancelstate(ost, NULL);
    return -1;
  }
  li.l_onoff = 1;
  li.l_linger = 100;
  optone = 1;
  if(setsockopt(sock, SOL_SOCKET, SO_LINGER, (char *)&li, sizeof(li)) == -1 ||
     setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char *)&optone, sizeof(optone)) == -1){
    est_sock_close(sock);
    pthread_setcancelstate(ost, NULL);
    return -1;
  }
  if(bind(sock, (struct sockaddr *)&address, sizeof(address)) == -1 ||
     listen(sock, SOMAXCONN) == -1){
    est_sock_close(sock);
    pthread_setcancelstate(ost, NULL);
    return -1;
  }
  pthread_setcancelstate(ost, NULL);
  return sock;
}


/* Accept a connection from a client. */
int est_accept_conn(int sock, char *abuf, int *pp){
  struct sockaddr_in address;
  socklen_t socklen;
  int clsock;
  assert(sock >= 0);
  socklen = sizeof(address);
  if((clsock = accept(sock, (struct sockaddr *)&address, &socklen)) >= 0){
    if(abuf) sprintf(abuf, "%s", inet_ntoa(address.sin_addr));
    if(pp) *pp = (int)ntohs(address.sin_port);
    return clsock;
  }
  return (errno == EINTR || errno == EAGAIN) ? 0 : -1;
}


/* Get a client socket to an address and a port. */
int est_get_client_sock(const char *addr, int port){
  struct sockaddr_in address;
  struct linger li;
  int ost, sock;
  assert(addr && port >= 0);
  if(pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &ost) != 0) return -1;
  memset(&address, 0, sizeof(address));
  address.sin_family = AF_INET;
  if(!est_inet_aton(addr, &address.sin_addr)){
    pthread_setcancelstate(ost, NULL);
    return -1;
  }
  address.sin_port = htons(port);
  if((sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1){
    pthread_setcancelstate(ost, NULL);
    return -1;
  }
  li.l_onoff = 1;
  li.l_linger = 100;
  if(setsockopt(sock, SOL_SOCKET, SO_LINGER, (char *)&li, sizeof(li)) == -1){
    est_sock_close(sock);
    pthread_setcancelstate(ost, NULL);
    return -1;
  }
  if(connect(sock, (struct sockaddr *)&address, sizeof(address)) == -1){
    est_sock_close(sock);
    pthread_setcancelstate(ost, NULL);
    return -1;
  }
  pthread_setcancelstate(ost, NULL);
  return sock;
}


/* Shutdown and close a socket. */
void est_sock_down(int sock){
  assert(sock >= 0);
  shutdown(sock, 2);
  est_sock_close(sock);
}


/* Receive all data from a socket. */
char *est_sock_recv_all(int sock, int len){
  char *buf;
  int i, bs;
  assert(sock >= 0 && len >= 0);
  buf = cbmalloc(len + 1);
  for(i = 0; i < len && (bs = recv(sock, buf + i, len - i, 0)) != 0; i += bs){
    if(bs == -1 && errno != EINTR){
      free(buf);
      return NULL;
    }
  }
  buf[i] = '\0';
  return buf;
}


/* Receive a line from a socket. */
int est_sock_recv_line(int sock, char *buf, int max){
  char *wp;
  assert(sock >= 0 && buf && max > 0);
  max--;
  wp = buf;
  while(wp < buf + max){
    switch(recv(sock, wp, 1, 0)){
    case -1:
      if(errno != EINTR){
        *wp = '\0';
        return wp - buf;
      }
      break;
    case 0:
      *wp = '\0';
      return wp - buf;
    default:
      switch(*wp){
      case '\r':
        break;
      case '\n':
        *wp = '\0';
        return wp - buf;
      default:
        wp++;
        break;
      }
      break;
    }
  }
  *wp = '\0';
  return wp - buf;
}


/* Receive void data from a socket. */
void est_sock_recv_void(int sock){
  fd_set rfds;
  struct timeval tv;
  char ibuf[ESTIOBUFSIZ];
  assert(sock >= 0);
  FD_ZERO(&rfds);
  FD_SET(sock, &rfds);
  tv.tv_sec = 0;
  tv.tv_usec = 0;
  if(select(sock + 1, &rfds, NULL, NULL, &tv) > 0 && FD_ISSET(sock, &rfds))
    recv(sock, ibuf, ESTIOBUFSIZ, 0);
}


/* Write all data into a socket. */
void est_sock_send_all(int sock, const char *buf, int len){
  const char *rp;
  int rv, wb;
  assert(sock >= 0 && buf && len >= 0);
  rp = buf;
  rv = 0;
  do {
    wb = send(sock, rp, len, 0);
    switch(wb){
    case -1: if(errno != EINTR) return;
    case 0: break;
    default:
      rp += wb;
      len -= wb;
      rv += wb;
      break;
    }
  } while(len > 0);
}


/* Perform formatted output into a datum object. */
void est_datum_printf(CBDATUM *datum, const char *format, ...){
  va_list ap;
  char *tmp, cbuf[ESTNUMBUFSIZ], tbuf[ESTNUMBUFSIZ*2];
  unsigned char c;
  int cblen, tlen;
  assert(datum && format);
  va_start(ap, format);
  while(*format != '\0'){
    if(*format == '%'){
      cbuf[0] = '%';
      cblen = 1;
      format++;
      while(strchr("0123456789 .+-", *format) && *format != '\0' && cblen < ESTNUMBUFSIZ - 1){
        cbuf[cblen++] = *format;
        format++;
      }
      cbuf[cblen++] = *format;
      cbuf[cblen] = '\0';
      switch(*format){
      case 's':
        tmp = va_arg(ap, char *);
        if(!tmp) tmp = "(null)";
        cbdatumcat(datum, tmp, -1);
        break;
      case 'd':
        tlen = sprintf(tbuf, cbuf, va_arg(ap, int));
        cbdatumcat(datum, tbuf, tlen);
        break;
      case 'o': case 'u': case 'x': case 'X': case 'c':
        tlen = sprintf(tbuf, cbuf, va_arg(ap, unsigned int));
        cbdatumcat(datum, tbuf, tlen);
        break;
      case 'e': case 'E': case 'f': case 'g': case 'G':
        tlen = sprintf(tbuf, cbuf, va_arg(ap, double));
        cbdatumcat(datum, tbuf, tlen);
        break;
      case '@':
        tmp = va_arg(ap, char *);
        if(!tmp) tmp = "(null)";
        while(*tmp){
          switch(*tmp){
          case '&': cbdatumcat(datum, "&amp;", 5); break;
          case '<': cbdatumcat(datum, "&lt;", 4); break;
          case '>': cbdatumcat(datum, "&gt;", 4); break;
          case '"': cbdatumcat(datum, "&quot;", 6); break;
          default:
            if(!((*tmp >= 0 && *tmp <= 0x8) || (*tmp >= 0x0e && *tmp <= 0x1f)))
              cbdatumcat(datum, tmp, 1);
            break;
          }
          tmp++;
        }
        break;
      case '?':
        tmp = va_arg(ap, char *);
        if(!tmp) tmp = "(null)";
        while(*tmp){
          c = *(unsigned char *)tmp;
          if((c >= 'A' && c <= 'Z') || (c >= 'a' && c <= 'z') ||
             (c >= '0' && c <= '9') || (c != '\0' && strchr("_-.", c))){
            cbdatumcat(datum, tmp, 1);
          } else {
            tlen = sprintf(tbuf, "%%%02X", c);
            cbdatumcat(datum, tbuf, tlen);
          }
          tmp++;
        }
        break;
      case '%':
        cbdatumcat(datum, "%", 1);
        break;
      }
    } else {
      cbdatumcat(datum, format, 1);
    }
    format++;
  }
  va_end(ap);
}


/* Perform an interaction of a URL. */
int est_url_shuttle(const char *url, const char *pxhost, int pxport, int outsec,
                    const char *auth, const CBLIST *reqheads, const char *reqbody, int rbsiz,
                    int *rescodep, CBMAP *resheads, CBDATUM *resbody){
  pthread_t th;
  pthread_mutex_t mutex;
  pthread_cond_t cond;
  struct timespec timeout;
  TARGSHUTTLE targ;
  int err, rv;
  void *rvp;
  pthread_mutex_init(&mutex, NULL);
  pthread_cond_init(&cond, NULL);
  targ.alive = TRUE;
  targ.cond = &cond;
  targ.url = url;
  targ.pxhost = pxhost;
  targ.pxport = pxport;
  targ.auth = auth;
  targ.reqheads = reqheads;
  targ.reqbody = reqbody;
  targ.rbsiz = rbsiz;
  targ.rescodep = rescodep;
  targ.resheads = resheads;
  targ.resbody = resbody;
  err = FALSE;
  if(outsec >= 0){
    if(pthread_mutex_lock(&mutex) == 0){
      if(pthread_create(&th, NULL, est_url_shuttle_impl, &targ) == 0){
        timeout.tv_sec = time(NULL) + outsec;
        timeout.tv_nsec = 1000 * 1000 * 500;
        rv = 0;
        while(targ.alive && rv != ETIMEDOUT){
          rv = pthread_cond_timedwait(&cond, &mutex, &timeout);
        }
        if(rv == ETIMEDOUT){
          pthread_cancel(th);
          pthread_join(th, NULL);
          err = TRUE;
        } else if(pthread_join(th, &rvp) != 0 || rvp != NULL){
          err = TRUE;
        }
      } else {
        err = TRUE;
      }
      pthread_mutex_unlock(&mutex);
    } else {
      err = TRUE;
    }
  } else {
    if(est_url_shuttle_impl(&targ) != NULL) err = TRUE;
  }
  if(pthread_mutex_destroy(&mutex) != 0) err = TRUE;
  if(pthread_cond_destroy(&cond) != 0) err = TRUE;
  return err ? FALSE : TRUE;
}


/* Add a header to a node connection object. */
void est_node_add_header(ESTNODE *node, const char *name, const char *value){
  const char *vbuf;
  int len;
  assert(node && name);
  len = strlen(name);
  if(value){
    if((vbuf = cbmapget(node->heads, name, len, NULL)) != NULL){
      cbmapputcat(node->heads, name, len, ", ", 2);
      cbmapputcat(node->heads, name, len, value, -1);
    } else {
      cbmapput(node->heads, name, len, value, -1, FALSE);
    }
  } else {
    cbmapout(node->heads, name, len);
  }
}


/* Create a node result object. */
ESTNODERES *est_noderes_new(void){
  ESTNODERES *nres;
  nres = cbmalloc(sizeof(ESTNODERES));
  nres->top = 0;
  nres->max = ESTLISTUNIT;
  nres->docs = cbmalloc(sizeof(ESTRESDOC) * nres->max);
  nres->dnum = 0;
  nres->hints = cbmapopenex(ESTMINIBNUM);
  return nres;
}


/* Add a document information to a node result object. */
void est_noderes_add_doc(ESTNODERES *nres, CBMAP *attrs, char *snippet){
  const char *uri;
  assert(nres && attrs && snippet);
  if(!(uri = cbmapget(attrs, ESTDATTRURI, -1, NULL))){
    free(snippet);
    cbmapclose(attrs);
    return;
  }
  if(nres->top + nres->dnum >= nres->max){
    nres->max *= 2;
    nres->docs = cbrealloc(nres->docs, nres->max * sizeof(ESTRESDOC));
  }
  nres->docs[nres->top+nres->dnum].uri = uri;
  nres->docs[nres->top+nres->dnum].attrs = attrs;
  nres->docs[nres->top+nres->dnum].snippet = snippet;
  nres->dnum++;
}


/* Remove the top of result document objects in a node result object. */
int est_noderes_shift(ESTNODERES *nres, CBMAP **attrp, char **snippetp){
  assert(nres && attrp && snippetp);
  if(nres->dnum < 1) return FALSE;
  *attrp = nres->docs[nres->top].attrs;
  *snippetp = nres->docs[nres->top].snippet;
  nres->top++;
  nres->dnum--;
  return TRUE;
}


/*************************************************************************************************
 * private objects
 *************************************************************************************************/


/* Close a socket.
   `sock' specifies a socket.
   The return value is 0 if success, else it is -1. */
static int est_sock_close(int sock){
#if defined(_SYS_MSVC_) || defined(_SYS_MINGW_)
  assert(sock >= 0);
  return closesocket(sock);
#else
  assert(sock >= 0);
  return close(sock);
#endif
}


/* Convert a host address to network binary data.
   `cp' specifies a host address.
   `inp' specifies the pointer to an structure into which the result is to be stored.
   The return value is true if success, else it is false. */
static int est_inet_aton(const char *cp, struct in_addr *inp){
#if defined(_SYS_MSVC_) || defined(_SYS_MINGW_)
  in_addr_t in;
  assert(cp && inp);
  if((in = inet_addr(cp)) == INADDR_NONE){
    if(!strcmp(cp, "255.255.255.255")){
      inp->s_addr = in;
      return TRUE;
    }
    return FALSE;
  }
  inp->s_addr = in;
  return TRUE;
#else
  assert(cp && inp);
  return inet_aton(cp, inp);
#endif
}


/* Perform the communication which can be canceled.
   `targ' specifies the pointer to a closure arguments.
   The return value is `NULL' if sucessful or non `NULL' value on error. */
static void *est_url_shuttle_impl(void *targ){
  const CBLIST *reqheads;
  CBMAP *resheads, *elems;
  CBDATUM *resbody, *datum;
  const char *url, *pxhost, *auth, *reqbody, *tmp, *scheme, *host, *path, *query, *rp;
  char *addr, *enc, iobuf[ESTIOBUFSIZ], name[ESTIOBUFSIZ], *pv;
  int i, pxport, rbsiz, *rescodep, port, sock, *sp, size, nsiz;
  assert(targ);
  url = ((TARGSHUTTLE *)targ)->url;
  pxhost = ((TARGSHUTTLE *)targ)->pxhost;
  pxport = ((TARGSHUTTLE *)targ)->pxport;
  auth = ((TARGSHUTTLE *)targ)->auth;
  reqheads = ((TARGSHUTTLE *)targ)->reqheads;
  reqbody = ((TARGSHUTTLE *)targ)->reqbody;
  rbsiz = ((TARGSHUTTLE *)targ)->rbsiz;
  rescodep = ((TARGSHUTTLE *)targ)->rescodep;
  resheads = ((TARGSHUTTLE *)targ)->resheads;
  resbody = ((TARGSHUTTLE *)targ)->resbody;
  elems = cburlbreak(url);
  pthread_cleanup_push((void (*)(void *))cbmapclose, elems);
  scheme = cbmapget(elems, "scheme", -1, NULL);
  host = cbmapget(elems, "host", -1, NULL);
  port = (tmp = cbmapget(elems, "port", -1, NULL)) ? atoi(tmp) : 80;
  if(!auth) auth = cbmapget(elems, "authority", -1, NULL);
  if(!(path = cbmapget(elems, "path", -1, NULL))) path = "/";
  if(!(query = cbmapget(elems, "query", -1, NULL))) query = "";
  if(!scheme || cbstricmp(scheme, "http") || !host || port < 1 ||
     !(addr = est_get_host_addr(pxhost ? pxhost : host))){
    ((TARGSHUTTLE *)targ)->alive = FALSE;
    pthread_cond_signal(((TARGSHUTTLE *)targ)->cond);
    return "error";
  }
  pthread_cleanup_push((void (*)(void *))free, addr);
  if((sock = est_get_client_sock(addr, pxhost ? pxport : port)) == -1){
    ((TARGSHUTTLE *)targ)->alive = FALSE;
    pthread_cond_signal(((TARGSHUTTLE *)targ)->cond);
    return "error";
  }
  sp = cbmalloc(sizeof(int));
  *sp = sock;
  pthread_cleanup_push((void (*)(void *))est_sockpt_down, sp);
  datum = cbdatumopen("", 0);
  pthread_cleanup_push((void (*)(void *))cbdatumclose, datum);
  if(pxhost){
    est_datum_printf(datum, "%s %s HTTP/1.0\r\n", reqbody ? "POST" : "GET", url);
  } else if(reqbody){
    est_datum_printf(datum, "POST %s HTTP/1.0\r\n", path);
  } else if(query[0] != 0){
    est_datum_printf(datum, "GET %s?%s HTTP/1.0\r\n", path, query);
  } else {
    est_datum_printf(datum, "GET %s HTTP/1.0\r\n", path);
  }
  est_datum_printf(datum, "Host: %s:%d\r\n", host, port);
  est_datum_printf(datum, "Connection: close\r\n", path);
  est_datum_printf(datum, "User-Agent: %s/%s\r\n", ESTAGENTNAME, est_version);
  if(auth){
    enc = cbbaseencode(auth, -1);
    est_datum_printf(datum, "Authorization: Basic %s\r\n", enc);
    free(enc);
  }
  if(reqbody) est_datum_printf(datum, "Content-Length: %d\r\n", rbsiz);
  if(reqheads){
    for(i = 0; i < cblistnum(reqheads); i++){
      rp = cblistval(reqheads, i, &size);
      est_datum_printf(datum, rp, size);
      est_datum_printf(datum, "\r\n", 2);
    }
  }
  est_datum_printf(datum, "\r\n");
  est_sock_send_all(sock, cbdatumptr(datum), cbdatumsize(datum));
  if(reqbody) est_sock_send_all(sock, reqbody, rbsiz);
  if((size = est_sock_recv_line(sock, iobuf, ESTIOBUFSIZ - 1)) < 1 ||
     !cbstrfwmatch(iobuf, "HTTP/") || !(rp = strchr(iobuf, ' '))){
    ((TARGSHUTTLE *)targ)->alive = FALSE;
    pthread_cond_signal(((TARGSHUTTLE *)targ)->cond);
    return "error";
  }
  rp++;
  if(rescodep) *rescodep = atoi(rp);
  if(resheads) cbmapput(resheads, "", 0, iobuf, size, TRUE);
  name[0] = '\0';
  nsiz = 0;
  while((size = est_sock_recv_line(sock, iobuf, ESTIOBUFSIZ - 1)) > 0){
    if(resheads){
      if(iobuf[0] == ' ' || iobuf[0] == '\t'){
        if(name[0] != '\0'){
          iobuf[0] = ' ';
          cbmapputcat(resheads, name, nsiz, iobuf, size);
        }
      } else if((rp = strchr(iobuf, ':')) > iobuf){
        nsiz = rp - iobuf;
        memcpy(name, iobuf, nsiz);
        name[nsiz] = '\0';
        for(pv = name; *pv != '\0'; pv++){
          if(*pv >= 'A'&& *pv <= 'Z') *pv = *pv + ('a' - 'A');
        }
        rp++;
        if(*rp == ' ' || *rp == '\t') rp++;
        if(cbmapget(resheads, name, nsiz, NULL)){
          cbmapputcat(resheads, name, nsiz, ", ", 2);
          cbmapputcat(resheads, name, nsiz, pv, -1);
        } else {
          cbmapput(resheads, name, nsiz, rp, -1, TRUE);
        }
      }
    }
  }
  while((size = recv(sock, iobuf, ESTIOBUFSIZ, 0)) > 0){
    if(resbody) cbdatumcat(resbody, iobuf, size);
  }
  pthread_cleanup_pop(1);
  pthread_cleanup_pop(1);
  pthread_cleanup_pop(1);
  pthread_cleanup_pop(1);
  ((TARGSHUTTLE *)targ)->alive = FALSE;
  pthread_cond_signal(((TARGSHUTTLE *)targ)->cond);
  return NULL;
}


/* Release the socket of a pointer.
   `sp' specifies the pointer to a variable of a file descriptor. */
static void est_sockpt_down(void *sp){
  est_sock_down(*(int *)sp);
  free(sp);
}


/* Set meta informations of a node.
   `node' specifies a node connection object.
   The return value is true if success, else it is false. */
static int est_node_set_inform(ESTNODE *node){
  CBLIST *reqheads, *elems;
  CBDATUM *resbody;
  const char *kbuf, *ptr;
  char url[ESTPATHBUFSIZ], *vbuf, *pv;
  int rescode, err, ksiz;
  assert(node);
  err = FALSE;
  sprintf(url, "%s/inform", node->url);
  reqheads = cblistopen();
  if(cbmaprnum(node->heads) > 0){
    cbmapiterinit(node->heads);
    while((kbuf = cbmapiternext(node->heads, &ksiz)) != NULL){
      vbuf = cbsprintf("%s: %s", kbuf, cbmapget(node->heads, kbuf, ksiz, NULL));
      cblistpush(reqheads, vbuf, -1);
      free(vbuf);
    }
  }
  node->dnum = -1;
  node->wnum = -1;
  node->size = -1.0;
  resbody = cbdatumopen("", 0);
  if(!est_url_shuttle(url, node->pxhost, node->pxport, node->timeout, node->auth, reqheads,
                      NULL, -1, &rescode, NULL, resbody)){
    node->status = -1;
    err = TRUE;
  }
  if(!err){
    node->status = rescode;
    if(rescode != 200) err = TRUE;
  }
  if(!err){
    ptr = cbdatumptr(resbody);
    if((pv = strchr(ptr, '\n')) != NULL){
      elems = cbsplit(ptr, pv - ptr, "\t");
      if(cblistnum(elems) == 5){
        if(!node->name) node->name = cbmemdup(cblistval(elems, 0, NULL), -1);
        if(!node->label) node->label = cbmemdup(cblistval(elems, 1, NULL), -1);
        node->dnum = atoi(cblistval(elems, 2, NULL));
        node->wnum = atoi(cblistval(elems, 3, NULL));
        node->size = strtod(cblistval(elems, 4, NULL), NULL);
        if(node->dnum < 0){
          node->dnum = -1;
          err = TRUE;
        }
        if(node->wnum < 0){
          node->wnum = -1;
          err = TRUE;
        }
        if(node->size < 0.0){
          node->size = -1.0;
          err = TRUE;
        }
      } else {
        err = TRUE;
      }
      cblistclose(elems);
    } else {
      err = TRUE;
    }
  }
  cbdatumclose(resbody);
  cblistclose(reqheads);
  return err ? FALSE : TRUE;
}


/* Parse the header of a result data.
   `nres' specifies a node result object.
   `str' specifies the header of a result data. */
static void est_parse_search_header(ESTNODERES *nres, const char *str){
  CBLIST *lines;
  const char *line, *pv;
  int i;
  assert(nres && str);
  lines = cbsplit(str, -1, "\r\n");
  for(i = 0; i < cblistnum(lines); i++){
    line = cblistval(lines, i, NULL);
    if(!(pv = strchr(line, '\t')) || pv == line || pv[1] == '\0') continue;
    cbmapput(nres->hints, line, pv - line, pv + 1, -1, FALSE);
  }
  cblistclose(lines);
}


/* Parse a body part of a result data.
   `nres' specifies a node result object.
   `str' specifies a body part of a result data. */
static void est_parse_search_body(ESTNODERES *nres, char *str){
  CBMAP *attrs;
  char *pv, *ep, *mp;
  pv = str;
  attrs = cbmapopenex(ESTMINIBNUM);
  while(TRUE){
    if(!(ep = strchr(pv, '\n')) || ep == pv) break;
    *ep = '\0';
    cbstrtrim(pv);
    if(*pv == '\0') break;
    if((mp = strchr(pv, '=')) != NULL){
      *mp = '\0';
      cbmapput(attrs, pv, -1, mp + 1, -1, TRUE);
    }
    pv = ep + 1;
  }
  while(*pv == '\r' || *pv == '\n'){
    pv++;
  }
  est_noderes_add_doc(nres, attrs, cbmemdup(pv, -1));
}


/* END OF FILE */