putsubs.c

Go to the documentation of this file.

#include <unistd.h>
#include "getln.h"
#include "error.h"
#include "logmsg.h"
#include "readwrite.h"
#include "str.h"
#include "fmt.h"
#include "stralloc.h"
#include "open.h"
#include "buffer.h"
#include "case.h"
#include "errtxt.h"
#include "subscribe.h"
#include "qmail.h"
#include "idx.h"
 
#define WHO "putsubs"

 
static buffer bi;
static char inbuf[512];
char strnum[FMT_ULONG];
static stralloc line = {0};
static stralloc fn = {0};
 
static void die_nomem() { logmsg(WHO,111,FATAL,ERR_NOMEM); }
static void die_write(void) { logmsg(WHO,111,FATAL,B(ERR_WRITE,"stdout")); }

 
unsigned long putsubs(const char *dbname,unsigned long hash_lo,unsigned long hash_hi,int subwrite(),int flagsql)
{
 
  unsigned int i;
  int fd;
  unsigned long no = 0L;
  int match;
  unsigned int hashpos;
 
    if (!stralloc_copys(&fn,dbname)) die_nomem();
    if (!stralloc_catb(&fn,"/subscribers/?",15)) die_nomem();   /* NOTE: Also copies terminal '\0' */
    hashpos = fn.len - 2;
    if (hash_lo > 52) hash_lo = 52;
    if (hash_hi > 52) hash_hi = 52;
    if (hash_hi < hash_lo) hash_hi = hash_lo;
 
    for (i = hash_lo; i <= hash_hi; ++i) {
      fn.s[hashpos] = 64 + i;                                   /* hash range 0-52 */
      fd = open_read(fn.s);
      if (fd == -1) {
        if (errno != error_noent)
          logmsg(WHO,111,FATAL,B(ERR_READ,fn.s));
      } else {
        buffer_init(&bi,buffer_unixread,fd,inbuf,sizeof(inbuf));
 
        for (;;) {
          if (getln(&bi,&line,&match,'\0') == -1)
            logmsg(WHO,111,FATAL,B(ERR_READ,fn.s));
          if (!match)
            break;
          if (subwrite(line.s + 1,line.len - 2) == -1) die_write();
          no++;
        }
        close(fd);
      }
    }
 
    return no;
}