diff --git a/bfg.c b/bfg.c
index a3a1dad..a19fcfa 100644
--- a/bfg.c
+++ b/bfg.c
@@ -52,6 +52,7 @@ static int32_t add_single_char(char ch, char flags, int32_t* crs_len) {
 // note that we check for -x .:.:ab but not for -x .:.:ba
 //
 int32_t bf_init(char *arg) {
+  bf_options.rain = 0;
   int32_t i = 0;
   int32_t crs_len = 0;
   char flags = 0;
@@ -189,8 +190,17 @@ uint64_t bf_get_pcount() {
   return foo;
 }
 
+int accu(int value)
+{
+	int sum = 0;
+	for(int i=1; i<=value; ++i)
+	{
+		sum+=i;
+	}
+	return sum;
+}
 
-char *bf_next() {
+char *bf_next(_Bool rainy) {
   int32_t i, pos = bf_options.current - 1;
 
   if (bf_options.current > bf_options.to)
@@ -200,9 +210,25 @@ char *bf_next() {
     fprintf(stderr, "Error: Can not allocate memory for -x data!\n");
     return NULL;
   }
+  
+  if(rainy)
+  {
+	for (i = 0; i < bf_options.current; i++){
+	  bf_options.ptr[i] = bf_options.crs[(bf_options.state[i]+bf_options.rain)%bf_options.crs_len];
+	  bf_options.rain += i+1;
+	}
+    if(bf_options.crs_len%10 == 0)
+	  bf_options.rain-=accu(bf_options.current)-2;
+    else if(bf_options.crs_len%2 == 0)
+	  bf_options.rain-=accu(bf_options.current)-4;
+    else if(bf_options.crs_len%2)
+	  bf_options.rain-=accu(bf_options.current)-1;
 
-  for (i = 0; i < bf_options.current; i++)
-    bf_options.ptr[i] = bf_options.crs[bf_options.state[i]];
+  }
+  else
+    for (i = 0; i < bf_options.current; i++)
+	  bf_options.ptr[i] = bf_options.crs[bf_options.state[i]];
+		
   bf_options.ptr[bf_options.current] = 0;
 
   if (debug) {
diff --git a/bfg.h b/bfg.h
index 2ac5f49..132571b 100644
--- a/bfg.h
+++ b/bfg.h
@@ -41,6 +41,7 @@ typedef struct {
   char *crs;                    /* internal representation of charset */
   char *ptr;                    /* ptr to the last generated password */
   uint32_t disable_symbols;
+  unsigned long rain;
 } bf_option;
 
 extern bf_option bf_options;
@@ -48,7 +49,7 @@ extern bf_option bf_options;
 #ifdef HAVE_MATH_H
 extern uint64_t bf_get_pcount();
 extern int32_t bf_init(char *arg);
-extern char *bf_next();
+extern char *bf_next(_Bool rainy);
 #endif
 
 #endif
diff --git a/hydra.c b/hydra.c
index d3f7430..6f2b497 100644
--- a/hydra.c
+++ b/hydra.c
@@ -337,6 +337,7 @@ char *sck = NULL;
 int32_t prefer_ipv6 = 0, conwait = 0, loop_cnt = 0, fck = 0, options = 0, killed = 0;
 int32_t child_head_no = -1, child_socket;
 int32_t total_redo_count = 0;
+bool rainy = false;
 
 // moved for restore feature
 int32_t process_restore = 0, dont_unlink;
@@ -482,6 +483,7 @@ void help(int32_t ext) {
                     "[service://server[:PORT][/OPT]]\n");
   PRINT_NORMAL(ext, "\nOptions:\n");
   PRINT_EXTEND(ext, "  -R        restore a previous aborted/crashed session\n"
+  					"  -r		 in conjonction with -x, use rain algorythm\n"
                     "  -I        ignore an existing restore file (don't wait 10 seconds)\n"
 #ifdef LIBOPENSSL
                     "  -S        perform an SSL connect\n"
@@ -1745,7 +1747,7 @@ int32_t hydra_send_next_pair(int32_t target_no, int32_t head_no) {
 #ifndef HAVE_MATH_H
                   sleep(1);
 #else
-                  hydra_targets[target_no]->pass_ptr = bf_next();
+                  hydra_targets[target_no]->pass_ptr = bf_next(hydra_options.rainy);
                   if (debug)
                     printf("[DEBUG] bfg new password for next child: %s\n", hydra_targets[target_no]->pass_ptr);
 #endif
@@ -2229,7 +2231,7 @@ int main(int argc, char *argv[]) {
     help(1);
   if (argc < 2)
     help(0);
-  while ((i = getopt(argc, argv, "hIq64Rde:vVl:fFg:L:p:OP:o:b:M:C:t:T:m:w:W:s:SUux:yc:K")) >= 0) {
+  while ((i = getopt(argc, argv, "hIq64Rrde:vVl:fFg:L:p:OP:o:b:M:C:t:T:m:w:W:s:SUux:yc:K")) >= 0) {
     switch (i) {
     case 'h':
       help(1);
@@ -2256,6 +2258,9 @@ int main(int argc, char *argv[]) {
       hydra_options.restore = 1;
       hydra_restore_read();
       break;
+    case 'r':
+      hydra_options.rainy = true;
+      break;
     case 'I':
       ignore_restore = 1; // this is not to be saved in hydra_options!
       break;
@@ -3267,7 +3272,7 @@ int main(int argc, char *argv[]) {
 #ifdef HAVE_MATH_H
             if (bf_init(bf_options.arg))
               exit(-1);         // error description is handled by bf_init
-            pass_ptr = bf_next();
+            pass_ptr = bf_next(hydra_options.rainy);
             hydra_brains.countpass += bf_get_pcount();
             hydra_brains.sizepass += BF_BUFLEN;
 #else
diff --git a/hydra.h b/hydra.h
index 0d47f0f..1aa04a2 100644
--- a/hydra.h
+++ b/hydra.h
@@ -221,6 +221,7 @@ typedef struct {
   char *service;
   char bfg;
   int32_t skip_redo;
+  _Bool rainy;
 } hydra_option;
 
 #define _HYDRA_H