在文本文件上写入Twitter流时出现分割错误

Question

我有一个C程序，从Twitter API打开tweet流。这个程序的目的是打开一个流，并将该流写入文本文件。这个程序是成功的，当它只是在终端打印流，但当我改变代码写入一个文件，现在有一个"分割错误"的错误，大约40秒进入执行。size_t writefunc(void *ptr, size_t size, size_t nmemb, struct string *s)是回调函数，它将流写入文件，特别是在

fp=fopen("istream.txt", "a");
fprintf(fp, "%s", s->ptr);
fclose(fp);

为什么有"分割错误"错误?我该如何解决这个问题?我想我使用文件指针的方式不对。

==================================

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <curl/curl.h>
struct string {
  char *ptr;
  size_t len;
};
void init_string(struct string *s) {
  s->len = 0;
  s->ptr = malloc(s->len+1);
  if (s->ptr == NULL) {
    fprintf(stderr, "malloc() failedn");
    exit(EXIT_FAILURE);
  }
  s->ptr[0] = '';
}
size_t writefunc(void *ptr, size_t size, size_t nmemb, struct string *s)
{
  size_t new_len = s->len + size*nmemb;
  size_t max_buffer = 10240;
  FILE *fp;
  fp=fopen("istream.txt", "a"); // <------------- the ERROR! Remove this.
  s->ptr = realloc(s->ptr, new_len+1);
  if (s->ptr == NULL) {
    fprintf(stderr, "realloc() failedn");
    exit(EXIT_FAILURE);
  }
  memcpy(s->ptr+s->len, ptr, size*nmemb);
  s->ptr[new_len] = '';
  s->len = new_len;
  if( s->len >= max_buffer )
  {
    fp=fopen("istream.txt", "a");
    fprintf(fp, "%s", s->ptr);
    fclose(fp);
    fflush( stdout );
    free(s->ptr);
    init_string( s );
  }
  return size*nmemb;
}
int main(void)
{
  CURL *curl;
  CURLcode res;

  curl = curl_easy_init();
  if(curl) {
    struct string s;
    init_string(&s);
    curl_easy_setopt(curl, CURLOPT_URL, "https://stream.twitter.com/1/statuses/sample.json");
    //curl_easy_setopt(curl, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
    curl_easy_setopt(curl, CURLOPT_USERPWD, "neilmarion:password");
    curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, writefunc);
    curl_easy_setopt(curl, CURLOPT_WRITEDATA, &s);
    res = curl_easy_perform(curl);
    //printf("%sn", s.ptr);
    free(s.ptr);
    /* always cleanup */
    curl_easy_cleanup(curl);
  }
  return 0;
}

Answer 1

程序中的大部分内容看起来都是正确的。

如果fp=fopen("istream.txt", "a");无法打开文件，很可能是连续行中的段错误。

尝试在stderr中打印字符串以查看。如果工作，那么问题确实是在fp。

其他评论:
由于是以追加模式打开文件，因此收集缓冲区中的数据并不断重新分配缓冲区实际上是没有意义的。您可以立即追加该文件。

Answer 2

每次进入writefunc就打开istream.txt:

FILE *fp;
fp=fopen("istream.txt", "a");

但是你从来没有在fp上调用fclose。你有这个:

fp=fopen("istreaam.txt", "a");
fprintf(fp, "%s", s->ptr);
fclose(fp);

之后，但是第二个fopen意味着您不再有对第一个fopen返回的内容的引用。

最终，您将耗尽打开的文件，并且进一步的fopen调用将失败。显然这只需要40秒。所以去掉第一个fopen，然后再试一次。