gistfile1.txt

func (t *Transaction) Wait(database, table string, timeout *int, where []ovsdb.Condition, columns []string, until string, rows []ovsdb.Row) ovsdb.OperationResult {
	start := time.Now()

	if until != "!=" || until != "==" {
		e := ovsdb.NotSupported{}
		return ovsdb.OperationResult{Error: e.Error()}
	}

	dbModel := t.Model

	Loop:
	for {
		var filteredRows []ovsdb.Row
		foundRows, err := t.rowsFromTransactionCacheAndDatabase(table, where)
		if err != nil {
			panic(err)
		}

		m := dbModel.Mapper
		for _, row := range foundRows {
			info, err := dbModel.NewModelInfo(row)
			if err != nil {
				panic(err)
			}

			foundMatch := true
			for _, column := range columns {
				for _, r := range rows {
					i, err := dbModel.NewModelInfo(r)
					if err != nil {
						panic(err)
					}
					x, err := i.FieldByColumn(column)
					if err != nil {
						continue
					}
					y, err := info.FieldByColumn(column)
					if err != nil {
						continue
					}
					if !reflect.DeepEqual(x, y) {
						foundMatch = false
					}
				}
			}

			if foundMatch {
				resultRow, err := m.NewRow(info)
				if err != nil {
					panic(err)
				}
				filteredRows = append(filteredRows, resultRow)
			}

		}

		if until == "==" && len(filteredRows) > 0 {
			return ovsdb.OperationResult{
				Rows: filteredRows,
			}
		} else if until == "!=" && len(filteredRows) == 0 {
			return ovsdb.OperationResult{}
		}

		if timeout != nil {
			if time.Since(start) > time.Duration(*timeout) * time.Second {
				break Loop
			}
		}
		time.Sleep(200 * time.Millisecond)
	}

	e := ovsdb.TimedOut{}
	return ovsdb.OperationResult{Error: e.Error()}
}