| @@ -32,6 +32,7 @@ · 31 unmodified lines |
| 32 | 32 | enum MatrixMode { |
| 33 | 33 | MATRIX_SQUARE, |
| 34 | 34 | MATRIX_ROW, |
| 35 | + MATRIX_COLUMN, |
| 35 | 36 | MATRIX_NBMODES, |
| 36 | 37 | }; |
| 37 | 38 | |
| @@ -60,9 +61,10 @@ typedef struct ConvolutionContext { · 22 unmodified lines |
| 60 | 61 | |
| 61 | 62 | void (*setup[4])(int radius, const uint8_t *c[], const uint8_t *src, int stride, |
| 62 | 63 | int x, int width, int y, int height, int bpc); |
| 63 | | − void (*filter[4])(uint8_t *dst, const uint8_t *src, int width, |
| 64 | + void (*filter[4])(uint8_t *dst, int width, |
| 64 | 65 | float rdiv, float bias, const int *const matrix, |
| 65 | | − const uint8_t *c[], int peak, int radius); |
| 66 | + const uint8_t *c[], int peak, int radius, |
| 67 | + int dstride, int stride); |
| 66 | 68 | } ConvolutionContext; |
| 67 | 69 | |
| 68 | 70 | #define OFFSET(x) offsetof(ConvolutionContext, x) |
| @@ -87,6 +89,7 @@ static const AVOption convolution_options[] = { · 18 unmodified lines |
| 87 | 89 | { "3mode", "set matrix mode for 4th plane", OFFSET(mode[3]), AV_OPT_TYPE_INT, {.i64=MATRIX_SQUARE}, 0, MATRIX_NBMODES-1, FLAGS, "mode" }, |
| 88 | 90 | { "square", "square matrix", 0, AV_OPT_TYPE_CONST, {.i64=MATRIX_SQUARE}, 0, 0, FLAGS, "mode" }, |
| 89 | 91 | { "row", "single row matrix", 0, AV_OPT_TYPE_CONST, {.i64=MATRIX_ROW} , 0, 0, FLAGS, "mode" }, |
| 92 | + { "column", "single column matrix", 0, AV_OPT_TYPE_CONST, {.i64=MATRIX_COLUMN}, 0, 0, FLAGS, "mode" }, |
| 90 | 93 | { NULL } |
| 91 | 94 | }; |
| 92 | 95 | |
| @@ -140,9 +143,10 @@ typedef struct ThreadData { · 47 unmodified lines |
| 140 | 143 | AVFrame *in, *out; |
| 141 | 144 | } ThreadData; |
| 142 | 145 | |
| 143 | | −static void filter16_prewitt(uint8_t *dstp, const uint8_t *src, int width, |
| 146 | +static void filter16_prewitt(uint8_t *dstp, int width, |
| 144 | 147 | float scale, float delta, const int *const matrix, |
| 145 | | − const uint8_t *c[], int peak, int radius) |
| 148 | + const uint8_t *c[], int peak, int radius, |
| 149 | + int dstride, int stride) |
| 146 | 150 | { |
| 147 | 151 | uint16_t *dst = (uint16_t *)dstp; |
| 148 | 152 | int x; |
| @@ -157,9 +161,10 @@ static void filter16_prewitt(uint8_t *dstp, const uint8_t *src, int width, · 8 unmodified lines |
| 157 | 161 | } |
| 158 | 162 | } |
| 159 | 163 | |
| 160 | | −static void filter16_roberts(uint8_t *dstp, const uint8_t *src, int width, |
| 164 | +static void filter16_roberts(uint8_t *dstp, int width, |
| 161 | 165 | float scale, float delta, const int *const matrix, |
| 162 | | − const uint8_t *c[], int peak, int radius) |
| 166 | + const uint8_t *c[], int peak, int radius, |
| 167 | + int dstride, int stride) |
| 163 | 168 | { |
| 164 | 169 | uint16_t *dst = (uint16_t *)dstp; |
| 165 | 170 | int x; |
| @@ -172,9 +177,10 @@ static void filter16_roberts(uint8_t *dstp, const uint8_t *src, int width, · 6 unmodified lines |
| 172 | 177 | } |
| 173 | 178 | } |
| 174 | 179 | |
| 175 | | −static void filter16_sobel(uint8_t *dstp, const uint8_t *src, int width, |
| 180 | +static void filter16_sobel(uint8_t *dstp, int width, |
| 176 | 181 | float scale, float delta, const int *const matrix, |
| 177 | | − const uint8_t *c[], int peak, int radius) |
| 182 | + const uint8_t *c[], int peak, int radius, |
| 183 | + int dstride, int stride) |
| 178 | 184 | { |
| 179 | 185 | uint16_t *dst = (uint16_t *)dstp; |
| 180 | 186 | int x; |
| @@ -189,9 +195,10 @@ static void filter16_sobel(uint8_t *dstp, const uint8_t *src, int width, · 8 unmodified lines |
| 189 | 195 | } |
| 190 | 196 | } |
| 191 | 197 | |
| 192 | | −static void filter_prewitt(uint8_t *dst, const uint8_t *src, int width, |
| 198 | +static void filter_prewitt(uint8_t *dst, int width, |
| 193 | 199 | float scale, float delta, const int *const matrix, |
| 194 | | − const uint8_t *c[], int peak, int radius) |
| 200 | + const uint8_t *c[], int peak, int radius, |
| 201 | + int dstride, int stride) |
| 195 | 202 | { |
| 196 | 203 | const uint8_t *c0 = c[0], *c1 = c[1], *c2 = c[2]; |
| 197 | 204 | const uint8_t *c3 = c[3], *c5 = c[5]; |
| @@ -208,9 +215,10 @@ static void filter_prewitt(uint8_t *dst, const uint8_t *src, int width, · 10 unmodified lines |
| 208 | 215 | } |
| 209 | 216 | } |
| 210 | 217 | |
| 211 | | −static void filter_roberts(uint8_t *dst, const uint8_t *src, int width, |
| 218 | +static void filter_roberts(uint8_t *dst, int width, |
| 212 | 219 | float scale, float delta, const int *const matrix, |
| 213 | | − const uint8_t *c[], int peak, int radius) |
| 220 | + const uint8_t *c[], int peak, int radius, |
| 221 | + int dstride, int stride) |
| 214 | 222 | { |
| 215 | 223 | int x; |
| 216 | 224 | |
| @@ -222,9 +230,10 @@ static void filter_roberts(uint8_t *dst, const uint8_t *src, int width, · 5 unmodified lines |
| 222 | 230 | } |
| 223 | 231 | } |
| 224 | 232 | |
| 225 | | −static void filter_sobel(uint8_t *dst, const uint8_t *src, int width, |
| 233 | +static void filter_sobel(uint8_t *dst, int width, |
| 226 | 234 | float scale, float delta, const int *const matrix, |
| 227 | | − const uint8_t *c[], int peak, int radius) |
| 235 | + const uint8_t *c[], int peak, int radius, |
| 236 | + int dstride, int stride) |
| 228 | 237 | { |
| 229 | 238 | const uint8_t *c0 = c[0], *c1 = c[1], *c2 = c[2]; |
| 230 | 239 | const uint8_t *c3 = c[3], *c5 = c[5]; |
| @@ -241,9 +250,10 @@ static void filter_sobel(uint8_t *dst, const uint8_t *src, int width, · 10 unmodified lines |
| 241 | 250 | } |
| 242 | 251 | } |
| 243 | 252 | |
| 244 | | −static void filter16_3x3(uint8_t *dstp, const uint8_t *src, int width, |
| 253 | +static void filter16_3x3(uint8_t *dstp, int width, |
| 245 | 254 | float rdiv, float bias, const int *const matrix, |
| 246 | | − const uint8_t *c[], int peak, int radius) |
| 255 | + const uint8_t *c[], int peak, int radius, |
| 256 | + int dstride, int stride) |
| 247 | 257 | { |
| 248 | 258 | uint16_t *dst = (uint16_t *)dstp; |
| 249 | 259 | int x; |
| @@ -263,9 +273,10 @@ static void filter16_3x3(uint8_t *dstp, const uint8_t *src, int width, · 13 unmodified lines |
| 263 | 273 | } |
| 264 | 274 | } |
| 265 | 275 | |
| 266 | | −static void filter16_5x5(uint8_t *dstp, const uint8_t *src, int width, |
| 276 | +static void filter16_5x5(uint8_t *dstp, int width, |
| 267 | 277 | float rdiv, float bias, const int *const matrix, |
| 268 | | − const uint8_t *c[], int peak, int radius) |
| 278 | + const uint8_t *c[], int peak, int radius, |
| 279 | + int dstride, int stride) |
| 269 | 280 | { |
| 270 | 281 | uint16_t *dst = (uint16_t *)dstp; |
| 271 | 282 | int x; |
| @@ -281,9 +292,10 @@ static void filter16_5x5(uint8_t *dstp, const uint8_t *src, int width, · 9 unmodified lines |
| 281 | 292 | } |
| 282 | 293 | } |
| 283 | 294 | |
| 284 | | −static void filter16_7x7(uint8_t *dstp, const uint8_t *src, int width, |
| 295 | +static void filter16_7x7(uint8_t *dstp, int width, |
| 285 | 296 | float rdiv, float bias, const int *const matrix, |
| 286 | | − const uint8_t *c[], int peak, int radius) |
| 297 | + const uint8_t *c[], int peak, int radius, |
| 298 | + int dstride, int stride) |
| 287 | 299 | { |
| 288 | 300 | uint16_t *dst = (uint16_t *)dstp; |
| 289 | 301 | int x; |
| @@ -299,9 +311,10 @@ static void filter16_7x7(uint8_t *dstp, const uint8_t *src, int width, · 9 unmodified lines |
| 299 | 311 | } |
| 300 | 312 | } |
| 301 | 313 | |
| 302 | | −static void filter16_row(uint8_t *dstp, const uint8_t *src, int width, |
| 314 | +static void filter16_row(uint8_t *dstp, int width, |
| 303 | 315 | float rdiv, float bias, const int *const matrix, |
| 304 | | − const uint8_t *c[], int peak, int radius) |
| 316 | + const uint8_t *c[], int peak, int radius, |
| 317 | + int dstride, int stride) |
| 305 | 318 | { |
| 306 | 319 | uint16_t *dst = (uint16_t *)dstp; |
| 307 | 320 | int x; |
| @@ -317,9 +330,30 @@ static void filter16_row(uint8_t *dstp, const uint8_t *src, int width, · 9 unmodified lines |
| 317 | 330 | } |
| 318 | 331 | } |
| 319 | 332 | |
| 320 | | −static void filter_7x7(uint8_t *dst, const uint8_t *src, int width, |
| 333 | +static void filter16_column(uint8_t *dstp, int height, |
| 334 | + float rdiv, float bias, const int *const matrix, |
| 335 | + const uint8_t *c[], int peak, int radius, |
| 336 | + int dstride, int stride) |
| 337 | +{ |
| 338 | + uint16_t *dst = (uint16_t *)dstp; |
| 339 | + int y; |
| 340 | + |
| 341 | + for (y = 0; y < height; y++) { |
| 342 | + int i, sum = 0; |
| 343 | + |
| 344 | + for (i = 0; i < 2 * radius + 1; i++) |
| 345 | + sum += AV_RN16A(&c[i][0 + y * stride]) * matrix[i]; |
| 346 | + |
| 347 | + sum = (int)(sum * rdiv + bias + 0.5f); |
| 348 | + dst[0] = av_clip(sum, 0, peak); |
| 349 | + dst += dstride / 2; |
| 350 | + } |
| 351 | +} |
| 352 | + |
| 353 | +static void filter_7x7(uint8_t *dst, int width, |
| 321 | 354 | float rdiv, float bias, const int *const matrix, |
| 322 | | − const uint8_t *c[], int peak, int radius) |
| 355 | + const uint8_t *c[], int peak, int radius, |
| 356 | + int dstride, int stride) |
| 323 | 357 | { |
| 324 | 358 | int x; |
| 325 | 359 | |
| @@ -334,9 +368,10 @@ static void filter_7x7(uint8_t *dst, const uint8_t *src, int width, · 8 unmodified lines |
| 334 | 368 | } |
| 335 | 369 | } |
| 336 | 370 | |
| 337 | | −static void filter_5x5(uint8_t *dst, const uint8_t *src, int width, |
| 371 | +static void filter_5x5(uint8_t *dst, int width, |
| 338 | 372 | float rdiv, float bias, const int *const matrix, |
| 339 | | − const uint8_t *c[], int peak, int radius) |
| 373 | + const uint8_t *c[], int peak, int radius, |
| 374 | + int dstride, int stride) |
| 340 | 375 | { |
| 341 | 376 | int x; |
| 342 | 377 | |
| @@ -351,9 +386,10 @@ static void filter_5x5(uint8_t *dst, const uint8_t *src, int width, · 8 unmodified lines |
| 351 | 386 | } |
| 352 | 387 | } |
| 353 | 388 | |
| 354 | | −static void filter_3x3(uint8_t *dst, const uint8_t *src, int width, |
| 389 | +static void filter_3x3(uint8_t *dst, int width, |
| 355 | 390 | float rdiv, float bias, const int *const matrix, |
| 356 | | − const uint8_t *c[], int peak, int radius) |
| 391 | + const uint8_t *c[], int peak, int radius, |
| 392 | + int dstride, int stride) |
| 357 | 393 | { |
| 358 | 394 | const uint8_t *c0 = c[0], *c1 = c[1], *c2 = c[2]; |
| 359 | 395 | const uint8_t *c3 = c[3], *c4 = c[4], *c5 = c[5]; |
| @@ -369,9 +405,10 @@ static void filter_3x3(uint8_t *dst, const uint8_t *src, int width, · 9 unmodified lines |
| 369 | 405 | } |
| 370 | 406 | } |
| 371 | 407 | |
| 372 | | −static void filter_row(uint8_t *dst, const uint8_t *src, int width, |
| 408 | +static void filter_row(uint8_t *dst, int width, |
| 373 | 409 | float rdiv, float bias, const int *const matrix, |
| 374 | | − const uint8_t *c[], int peak, int radius) |
| 410 | + const uint8_t *c[], int peak, int radius, |
| 411 | + int dstride, int stride) |
| 375 | 412 | { |
| 376 | 413 | int x; |
| 377 | 414 | |
| @@ -386,6 +423,25 @@ static void filter_row(uint8_t *dst, const uint8_t *src, int width, · 8 unmodified lines |
| 386 | 423 | } |
| 387 | 424 | } |
| 388 | 425 | |
| 426 | +static void filter_column(uint8_t *dst, int height, |
| 427 | + float rdiv, float bias, const int *const matrix, |
| 428 | + const uint8_t *c[], int peak, int radius, |
| 429 | + int dstride, int stride) |
| 430 | +{ |
| 431 | + int y; |
| 432 | + |
| 433 | + for (y = 0; y < height; y++) { |
| 434 | + int i, sum = 0; |
| 435 | + |
| 436 | + for (i = 0; i < 2 * radius + 1; i++) |
| 437 | + sum += c[i][0 + y * stride] * matrix[i]; |
| 438 | + |
| 439 | + sum = (int)(sum * rdiv + bias + 0.5f); |
| 440 | + dst[0] = av_clip_uint8(sum); |
| 441 | + dst += dstride; |
| 442 | + } |
| 443 | +} |
| 444 | + |
| 389 | 445 | static void setup_3x3(int radius, const uint8_t *c[], const uint8_t *src, int stride, |
| 390 | 446 | int x, int w, int y, int h, int bpc) |
| 391 | 447 | { |
| @@ -448,6 +504,20 @@ static void setup_row(int radius, const uint8_t *c[], const uint8_t *src, int st · 56 unmodified lines |
| 448 | 504 | } |
| 449 | 505 | } |
| 450 | 506 | |
| 507 | +static void setup_column(int radius, const uint8_t *c[], const uint8_t *src, int stride, |
| 508 | + int x, int w, int y, int h, int bpc) |
| 509 | +{ |
| 510 | + int i; |
| 511 | + |
| 512 | + for (i = 0; i < radius * 2 + 1; i++) { |
| 513 | + int xoff = FFABS(x + i - radius); |
| 514 | + |
| 515 | + xoff = xoff >= h ? 2 * h - 1 - xoff : xoff; |
| 516 | + |
| 517 | + c[i] = src + y * bpc + xoff * stride; |
| 518 | + } |
| 519 | +} |
| 520 | + |
| 451 | 521 | static int filter_slice(AVFilterContext *ctx, void *arg, int jobnr, int nb_jobs) |
| 452 | 522 | { |
| 453 | 523 | ConvolutionContext *s = ctx->priv; |
| @@ -457,43 +527,64 @@ static int filter_slice(AVFilterContext *ctx, void *arg, int jobnr, int nb_jobs) · 3 unmodified lines |
| 457 | 527 | int plane; |
| 458 | 528 | |
| 459 | 529 | for (plane = 0; plane < s->nb_planes; plane++) { |
| 530 | + const int mode = s->mode[plane]; |
| 531 | + const int bpc = s->bpc; |
| 460 | 532 | const int radius = s->size[plane] / 2; |
| 461 | 533 | const int height = s->planeheight[plane]; |
| 462 | 534 | const int width = s->planewidth[plane]; |
| 463 | 535 | const int stride = in->linesize[plane]; |
| 464 | 536 | const int dstride = out->linesize[plane]; |
| 465 | | − const int slice_start = (height * jobnr) / nb_jobs; |
| 466 | | − const int slice_end = (height * (jobnr+1)) / nb_jobs; |
| 537 | + const int sizeh = mode == MATRIX_COLUMN ? width : height; |
| 538 | + const int sizew = mode == MATRIX_COLUMN ? height : width; |
| 539 | + const int slice_start = (sizeh * jobnr) / nb_jobs; |
| 540 | + const int slice_end = (sizeh * (jobnr+1)) / nb_jobs; |
| 467 | 541 | const float rdiv = s->rdiv[plane]; |
| 468 | 542 | const float bias = s->bias[plane]; |
| 469 | 543 | const uint8_t *src = in->data[plane]; |
| 470 | | − uint8_t *dst = out->data[plane] + slice_start * out->linesize[plane]; |
| 544 | + const int dst_pos = slice_start * (mode == MATRIX_COLUMN ? bpc : out->linesize[plane]); |
| 545 | + uint8_t *dst = out->data[plane] + dst_pos; |
| 471 | 546 | const int *matrix = s->matrix[plane]; |
| 472 | | − const int bpc = s->bpc; |
| 473 | 547 | const uint8_t *c[49]; |
| 474 | 548 | int y, x; |
| 475 | 549 | |
| 476 | 550 | if (s->copy[plane]) { |
| 477 | | − av_image_copy_plane(dst, dstride, src + slice_start * stride, stride, |
| 478 | | − width * bpc, slice_end - slice_start); |
| 551 | + if (mode == MATRIX_COLUMN) |
| 552 | + av_image_copy_plane(dst, dstride, src + slice_start * bpc, stride, |
| 553 | + (slice_end - slice_start) * bpc, height); |
| 554 | + else |
| 555 | + av_image_copy_plane(dst, dstride, src + slice_start * stride, stride, |
| 556 | + width * bpc, slice_end - slice_start); |
| 479 | 557 | continue; |
| 480 | 558 | } |
| 481 | 559 | |
| 482 | 560 | for (y = slice_start; y < slice_end; y++) { |
| 561 | + const int xoff = mode == MATRIX_COLUMN ? (y - slice_start) * bpc : radius * bpc; |
| 562 | + const int yoff = mode == MATRIX_COLUMN ? radius * stride : 0; |
| 563 | + |
| 483 | 564 | for (x = 0; x < radius; x++) { |
| 565 | + const int xoff = mode == MATRIX_COLUMN ? (y - slice_start) * bpc : x * bpc; |
| 566 | + const int yoff = mode == MATRIX_COLUMN ? x * stride : 0; |
| 567 | + |
| 484 | 568 | s->setup[plane](radius, c, src, stride, x, width, y, height, bpc); |
| 485 | | − s->filter[plane](dst + x * bpc, src, 1, rdiv, |
| 486 | | − bias, matrix, c, s->max, radius); |
| 569 | + s->filter[plane](dst + yoff + xoff, 1, rdiv, |
| 570 | + bias, matrix, c, s->max, radius, |
| 571 | + dstride, stride); |
| 487 | 572 | } |
| 488 | 573 | s->setup[plane](radius, c, src, stride, radius, width, y, height, bpc); |
| 489 | | − s->filter[plane](dst + radius * bpc, src, width - 2 * radius, |
| 490 | | − rdiv, bias, matrix, c, s->max, radius); |
| 491 | | − for (x = width - radius; x < width; x++) { |
| 574 | + s->filter[plane](dst + yoff + xoff, sizew - 2 * radius, |
| 575 | + rdiv, bias, matrix, c, s->max, radius, |
| 576 | + dstride, stride); |
| 577 | + for (x = sizew - radius; x < sizew; x++) { |
| 578 | + const int xoff = mode == MATRIX_COLUMN ? (y - slice_start) * bpc : x * bpc; |
| 579 | + const int yoff = mode == MATRIX_COLUMN ? x * stride : 0; |
| 580 | + |
| 492 | 581 | s->setup[plane](radius, c, src, stride, x, width, y, height, bpc); |
| 493 | | − s->filter[plane](dst + x * bpc, src, 1, rdiv, |
| 494 | | − bias, matrix, c, s->max, radius); |
| 582 | + s->filter[plane](dst + yoff + xoff, 1, rdiv, |
| 583 | + bias, matrix, c, s->max, radius, |
| 584 | + dstride, stride); |
| 495 | 585 | } |
| 496 | | − dst += dstride; |
| 586 | + if (mode != MATRIX_COLUMN) |
| 587 | + dst += dstride; |
| 497 | 588 | } |
| 498 | 589 | } |
| 499 | 590 | |
| @@ -524,6 +615,8 @@ static int config_input(AVFilterLink *inlink) · 24 unmodified lines |
| 524 | 615 | for (p = 0; p < s->nb_planes; p++) { |
| 525 | 616 | if (s->mode[p] == MATRIX_ROW) |
| 526 | 617 | s->filter[p] = filter16_row; |
| 618 | + else if (s->mode[p] == MATRIX_COLUMN) |
| 619 | + s->filter[p] = filter16_column; |
| 527 | 620 | else if (s->size[p] == 3) |
| 528 | 621 | s->filter[p] = filter16_3x3; |
| 529 | 622 | else if (s->size[p] == 5) |
| @@ -566,7 +659,7 @@ static int filter_frame(AVFilterLink *inlink, AVFrame *in) · 36 unmodified lines |
| 566 | 659 | |
| 567 | 660 | td.in = in; |
| 568 | 661 | td.out = out; |
| 569 | | − ctx->internal->execute(ctx, filter_slice, &td, NULL, FFMIN(s->planeheight[1], s->nb_threads)); |
| 662 | + ctx->internal->execute(ctx, filter_slice, &td, NULL, FFMIN3(s->planeheight[1], s->planewidth[1], s->nb_threads)); |
| 570 | 663 | |
| 571 | 664 | av_frame_free(&in); |
| 572 | 665 | return ff_filter_frame(outlink, out); |
| @@ -602,6 +695,10 @@ static av_cold int init(AVFilterContext *ctx) · 29 unmodified lines |
| 602 | 695 | s->filter[i] = filter_row; |
| 603 | 696 | s->setup[i] = setup_row; |
| 604 | 697 | s->size[i] = s->matrix_length[i]; |
| 698 | + } else if (s->mode[i] == MATRIX_COLUMN) { |
| 699 | + s->filter[i] = filter_column; |
| 700 | + s->setup[i] = setup_column; |
| 701 | + s->size[i] = s->matrix_length[i]; |
| 605 | 702 | } else if (s->matrix_length[i] == 9) { |
| 606 | 703 | s->size[i] = 3; |
| 607 | 704 | if (!memcmp(matrix, same3x3, sizeof(same3x3))) |