CamelStore *parent_store;
CamelDataCache *nntp_cache;
CamelNNTPStore *nntp_store;
- CamelNNTPStream *nntp_stream;
+ CamelNNTPStream *nntp_stream = NULL;
CamelStream *stream = NULL;
gint ret;
gchar *line;
nntp_store = CAMEL_NNTP_STORE (parent_store);
nntp_cache = camel_nntp_store_ref_cache (nntp_store);
- nntp_stream = camel_nntp_store_ref_stream (nntp_store);
ret = camel_nntp_command (
nntp_store, cancellable, error,
if (ret == 220) {
GIOStream *base_stream;
+ nntp_stream = camel_nntp_store_ref_stream (nntp_store);
+
base_stream = camel_data_cache_add (
nntp_cache, "cache", msgid, NULL);
if (base_stream != NULL) {
{
CamelStore *parent_store;
CamelNNTPStore *nntp_store;
- CamelNNTPStream *nntp_stream;
+ CamelNNTPStream *nntp_stream = NULL;
CamelStream *filtered_stream;
CamelMimeFilter *crlffilter;
gint ret;
parent_store = camel_folder_get_parent_store (folder);
nntp_store = CAMEL_NNTP_STORE (parent_store);
- nntp_stream = camel_nntp_store_ref_stream (nntp_store);
/* send 'POST' command */
ret = camel_nntp_command (
/* the 'Newsgroups: ' header */
group = g_strdup_printf ("Newsgroups: %s\r\n", full_name);
- /* setup stream filtering */
- filtered_stream = camel_stream_filter_new (CAMEL_STREAM (nntp_stream));
- crlffilter = camel_mime_filter_crlf_new (
- CAMEL_MIME_FILTER_CRLF_ENCODE,
- CAMEL_MIME_FILTER_CRLF_MODE_CRLF_DOTS);
- camel_stream_filter_add (
- CAMEL_STREAM_FILTER (filtered_stream), crlffilter);
- g_object_unref (crlffilter);
-
/* remove mail 'To', 'CC', and 'BCC' headers */
savedhdrs = NULL;
tail = (struct _camel_header_raw *) &savedhdrs;
n = header->next;
}
+ nntp_stream = camel_nntp_store_ref_stream (nntp_store);
+
+ /* setup stream filtering */
+ filtered_stream = camel_stream_filter_new (CAMEL_STREAM (nntp_stream));
+ crlffilter = camel_mime_filter_crlf_new (
+ CAMEL_MIME_FILTER_CRLF_ENCODE,
+ CAMEL_MIME_FILTER_CRLF_MODE_CRLF_DOTS);
+ camel_stream_filter_add (
+ CAMEL_STREAM_FILTER (filtered_stream), crlffilter);
+ g_object_unref (crlffilter);
+
/* write the message */
if (local_error == NULL)
camel_stream_write (