Browse Source

Set the pool idle and switch pool, if need

djm34
elbandi 11 years ago committed by Jan Berdajs
parent
commit
98676763b9
  1. 1
      miner.h
  2. 10
      sgminer.c
  3. 4
      util.c

1
miner.h

@ -1418,6 +1418,7 @@ extern bool log_curses_only(int prio, const char *datetime, const char *str);
extern void clear_logwin(void); extern void clear_logwin(void);
extern void logwin_update(void); extern void logwin_update(void);
extern bool pool_tclear(struct pool *pool, bool *var); extern bool pool_tclear(struct pool *pool, bool *var);
extern void pool_failed(struct pool *pool);
extern struct thread_q *tq_new(void); extern struct thread_q *tq_new(void);
extern void tq_free(struct thread_q *tq); extern void tq_free(struct thread_q *tq);
extern bool tq_push(struct thread_q *tq, void *data); extern bool tq_push(struct thread_q *tq, void *data);

10
sgminer.c

@ -3605,6 +3605,16 @@ struct work *copy_work_noffset(struct work *base_work, int noffset)
return work; return work;
} }
void pool_failed(struct pool *pool)
{
if (!pool_tset(pool, &pool->idle)) {
cgtime(&pool->tv_idle);
if (pool == current_pool()) {
switch_pools(NULL);
}
}
}
static void pool_died(struct pool *pool) static void pool_died(struct pool *pool)
{ {
if (!pool_tset(pool, &pool->idle)) { if (!pool_tset(pool, &pool->idle)) {

4
util.c

@ -1712,8 +1712,10 @@ static bool parse_reconnect(struct pool *pool, json_t *val)
free(tmp); free(tmp);
mutex_unlock(&pool->stratum_lock); mutex_unlock(&pool->stratum_lock);
if (!restart_stratum(pool)) if (!restart_stratum(pool)) {
pool_failed(pool);
return false; return false;
}
return true; return true;
} }

Loading…
Cancel
Save