Show
Ignore:
Timestamp:
10/19/09 01:22:39 (9 years ago)
Author:
Theo Schlossnagle <jesus@omniti.com>
git-committer:
Theo Schlossnagle <jesus@omniti.com> 1255915359 +0000
git-parent:

[08e498f88b47f53edf390c85d08577fa1d7686ab]

git-author:
Theo Schlossnagle <jesus@omniti.com> 1255915359 +0000
Message:

hefty patch. First part of stratcond support for horizontal partitioning of storage. refs #150

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved
  • src/stratcon_iep.c

    r0335d9d r5360a1e  
    142142  } 
    143143  noitL(noit_error, "submitting statement: %s\n", line); 
    144   stratcon_iep_line_processor(DS_OP_INSERT, NULL, line); 
     144  stratcon_iep_line_processor(DS_OP_INSERT, NULL, NULL, line, NULL); 
    145145  stmt->marked = 1; 
    146146} 
     
    163163  /* Phase 1: sweep in all the statements */ 
    164164  for(i=0; i<cnt; i++) { 
    165     char id[UUID_STR_LEN]; 
     165    char id[UUID_STR_LEN+1]; 
    166166    char provides[256]; 
    167167    char *statement; 
     
    202202  /* Phase 2: load the requires graph */ 
    203203  for(i=0; i<cnt; i++) { 
    204     char id[UUID_STR_LEN]; 
     204    char id[UUID_STR_LEN+1]; 
    205205    int rcnt, j; 
    206206    char *requires; 
     
    280280  noitL(noit_debug, "Found %d %s stanzas\n", cnt, path); 
    281281  for(i=0; i<cnt; i++) { 
    282     char id[UUID_STR_LEN]; 
     282    char id[UUID_STR_LEN+1]; 
    283283    char topic[256]; 
    284284    char *query; 
     
    314314      query++; 
    315315    } 
    316     stratcon_iep_line_processor(DS_OP_INSERT, NULL, line); 
     316    stratcon_iep_line_processor(DS_OP_INSERT, NULL, NULL, line, NULL); 
    317317  } 
    318318  free(query_configs); 
     
    419419setup_iep_connection_callback(eventer_t e, int mask, void *closure, 
    420420                              struct timeval *now) { 
    421   stratcon_iep_line_processor(DS_OP_INSERT, NULL, NULL); 
     421  stratcon_iep_line_processor(DS_OP_INSERT, NULL, NULL, NULL, NULL); 
    422422  return 0; 
    423423} 
     
    526526void 
    527527stratcon_iep_line_processor(stratcon_datastore_op_t op, 
    528                             struct sockaddr *remote, void *operand) { 
     528                            struct sockaddr *remote, const char *remote_cn, 
     529                            void *operand, eventer_t completion) { 
    529530  int len; 
    530531  char remote_str[128];